5487101041

pending completion

Build # 5487101041

Build Type

push

github

Committed by

DenysGonchar

Commit Message

adding optional CT suite/group/testcase logging at MIM node

Run Details

27764 of 33096 relevant lines covered (83.89%)

36741.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.1

/src/pubsub/node_push.erl

%%%-------------------------------------------------------------------
%%% @author Rafal Slota
%%% @copyright (C) 2017 Erlang Solutions Ltd.
%%% This software is released under the Apache License, Version 2.0
%%% cited in 'LICENSE.txt'.
%%% @end
%%%-------------------------------------------------------------------
%%% @doc
%%% Node implementation that proxies all published items to `push_notification' hook.
%%% @end
%%%-------------------------------------------------------------------
-module(node_push).
-author('rafal.slota@erlang-solutions.com').
-behaviour(gen_pubsub_node).

-include("mongoose.hrl").
-include("jlib.hrl").
-include("pubsub.hrl").

-export([based_on/0, init/3, terminate/2, options/0, features/0,
         publish_item/9, node_to_path/1, should_delete_when_owner_removed/0]).

based_on() ->  node_flat.

init(Host, ServerHost, Opts) ->
    node_flat:init(Host, ServerHost, Opts),
    ok.

terminate(Host, ServerHost) ->
    node_flat:terminate(Host, ServerHost),
    ok.

options() ->
    [{deliver_payloads, true},
     {notify_config, false},
     {notify_delete, false},
     {notify_retract, false},
     {purge_offline, false},
     {persist_items, false},
     {max_items, 1},
     {subscribe, true},
     {access_model, whitelist},
     {roster_groups_allowed, []},
     {publish_model, open},
     {notification_type, headline},
     {max_payload_size, ?MAX_PAYLOAD_SIZE},
     {send_last_published_item, on_sub_and_presence},
     {deliver_notifications, true},
     {presence_based_delivery, true}].

features() ->
    [
        <<"create-nodes">>,
        <<"delete-nodes">>,
        <<"modify-affiliations">>,
        <<"publish">>,
        <<"publish-options">>,
        <<"publish-only-affiliation">>,
        <<"purge-nodes">>,
        <<"retrieve-affiliations">>
    ].

publish_item(ServerHost, Nidx, Publisher, Model, _MaxItems, _ItemId, _ItemPublisher, Payload,
             PublishOptions) ->
    {ok, Affiliation} = mod_pubsub_db_backend:get_affiliation(Nidx, jid:to_lower(Publisher)),
    ElPayload = [El || #xmlel{} = El <- Payload],

    case is_allowed_to_publish(Model, Affiliation) of
        true ->
            do_publish_item(ServerHost, PublishOptions, ElPayload);
        false ->
            {error, mongoose_xmpp_errors:forbidden()}
    end.

do_publish_item(ServerHost, PublishOptions,
                [#xmlel{name = <<"notification">>} | _] = Notifications) ->
    case parse_form(PublishOptions) of
        #{<<"device_id">> := _, <<"service">> := _} = OptionMap ->
            NotificationForms = [parse_form(El) || El <- Notifications],
            Result = mongoose_hooks:push_notifications(ServerHost, ok,
                                                       NotificationForms, OptionMap),
            handle_push_hook_result(Result);
        _ ->
            {error, mod_pubsub:extended_error(mongoose_xmpp_errors:conflict(), <<"precondition-not-met">>)}
    end;
do_publish_item(_ServerHost, _PublishOptions, _Payload) ->
    {error, mongoose_xmpp_errors:bad_request()}.

handle_push_hook_result(ok) ->
    {result, default};
handle_push_hook_result({error, device_not_registered}) ->
    {error, mod_pubsub:extended_error(mongoose_xmpp_errors:not_acceptable_cancel(), <<"device-not-registered">>)};
handle_push_hook_result({error, _}) ->
    {error, mod_pubsub:extended_error(mongoose_xmpp_errors:bad_request(), <<"faild-to-submit-push-notification">>)}.

node_to_path(Node) ->
    node_flat:node_to_path(Node).

should_delete_when_owner_removed() -> true.

%%%
%%% Internal
%%%

is_allowed_to_publish(PublishModel, Affiliation) ->
    (PublishModel == open)
    or (PublishModel == publishers)
        and ((Affiliation == owner)
              or (Affiliation == publisher)
              or (Affiliation == publish_only)).

-spec parse_form(undefined | exml:element()) -> invalid_form | #{binary() => binary()}.
parse_form(undefined) ->
    #{};
parse_form(Parent) ->
    case mongoose_data_forms:find_and_parse_form(Parent) of
        #{type := <<"submit">>, kvs := KVs} ->
            maps:filtermap(fun(_, [V]) -> {true, V};
                              (_, _) -> false
                           end, KVs);
        _ ->
            invalid_form
    end.

1	%%%-------------------------------------------------------------------
2	%%% @author Rafal Slota
3	%%% @copyright (C) 2017 Erlang Solutions Ltd.
4	%%% This software is released under the Apache License, Version 2.0
5	%%% cited in 'LICENSE.txt'.
6	%%% @end
7	%%%-------------------------------------------------------------------
8	%%% @doc
9	%%% Node implementation that proxies all published items to `push_notification' hook.
10	%%% @end
11	%%%-------------------------------------------------------------------
12	-module(node_push).
13	-author('rafal.slota@erlang-solutions.com').
14	-behaviour(gen_pubsub_node).
15
16	-include("mongoose.hrl").
17	-include("jlib.hrl").
18	-include("pubsub.hrl").
19
20	-export([based_on/0, init/3, terminate/2, options/0, features/0,
21	publish_item/9, node_to_path/1, should_delete_when_owner_removed/0]).
22
23	based_on() -> node_flat.	2,142✔
24
25	init(Host, ServerHost, Opts) ->
26	node_flat:init(Host, ServerHost, Opts),	95✔
27	ok.	95✔
28
29	terminate(Host, ServerHost) ->
30	node_flat:terminate(Host, ServerHost),	95✔
31	ok.	95✔
32
33	options() ->
34	[{deliver_payloads, true},	330✔
35	{notify_config, false},
36	{notify_delete, false},
37	{notify_retract, false},
38	{purge_offline, false},
39	{persist_items, false},
40	{max_items, 1},
41	{subscribe, true},
42	{access_model, whitelist},
43	{roster_groups_allowed, []},
44	{publish_model, open},
45	{notification_type, headline},
46	{max_payload_size, ?MAX_PAYLOAD_SIZE},
47	{send_last_published_item, on_sub_and_presence},
48	{deliver_notifications, true},
49	{presence_based_delivery, true}].
50
51	features() ->
52	[	1,622✔
53	<<"create-nodes">>,
54	<<"delete-nodes">>,
55	<<"modify-affiliations">>,
56	<<"publish">>,
57	<<"publish-options">>,
58	<<"publish-only-affiliation">>,
59	<<"purge-nodes">>,
60	<<"retrieve-affiliations">>
61	].
62
63	publish_item(ServerHost, Nidx, Publisher, Model, _MaxItems, _ItemId, _ItemPublisher, Payload,
64	PublishOptions) ->
65	{ok, Affiliation} = mod_pubsub_db_backend:get_affiliation(Nidx, jid:to_lower(Publisher)),	403✔
66	ElPayload = [El \|\| #xmlel{} = El <- Payload],	403✔
67
68	case is_allowed_to_publish(Model, Affiliation) of	403✔
69	true ->
70	do_publish_item(ServerHost, PublishOptions, ElPayload);	396✔
71	false ->
72	{error, mongoose_xmpp_errors:forbidden()}	7✔
73	end.
74
75	do_publish_item(ServerHost, PublishOptions,
76	[#xmlel{name = <<"notification">>} \| _] = Notifications) ->
77	case parse_form(PublishOptions) of	389✔
78	#{<<"device_id">> := _, <<"service">> := _} = OptionMap ->
79	NotificationForms = [parse_form(El) \|\| El <- Notifications],	382✔
80	Result = mongoose_hooks:push_notifications(ServerHost, ok,	382✔
81	NotificationForms, OptionMap),
82	handle_push_hook_result(Result);	382✔
83	_ ->
84	{error, mod_pubsub:extended_error(mongoose_xmpp_errors:conflict(), <<"precondition-not-met">>)}	7✔
85	end;
86	do_publish_item(_ServerHost, _PublishOptions, _Payload) ->
87	{error, mongoose_xmpp_errors:bad_request()}.	7✔
88
89	handle_push_hook_result(ok) ->
90	{result, default};	354✔
91	handle_push_hook_result({error, device_not_registered}) ->
92	{error, mod_pubsub:extended_error(mongoose_xmpp_errors:not_acceptable_cancel(), <<"device-not-registered">>)};	7✔
93	handle_push_hook_result({error, _}) ->
94	{error, mod_pubsub:extended_error(mongoose_xmpp_errors:bad_request(), <<"faild-to-submit-push-notification">>)}.	21✔
95
96	node_to_path(Node) ->
97	node_flat:node_to_path(Node).	330✔
98
99	should_delete_when_owner_removed() -> true.	16✔
100
101	%%%
102	%%% Internal
103	%%%
104
105	is_allowed_to_publish(PublishModel, Affiliation) ->
106	(PublishModel == open)
107	or (PublishModel == publishers)	403✔
108	and ((Affiliation == owner)
109	or (Affiliation == publisher)
110	or (Affiliation == publish_only)).
111
112	-spec parse_form(undefined \| exml:element()) -> invalid_form \| #{binary() => binary()}.
113	parse_form(undefined) ->
114	#{};	7✔
115	parse_form(Parent) ->
116	case mongoose_data_forms:find_and_parse_form(Parent) of	764✔
117	#{type := <<"submit">>, kvs := KVs} ->
118	maps:filtermap(fun(_, [V]) -> {true, V};	764✔
119	(_, _) -> false	×
120	end, KVs);
121	_ ->
122	invalid_form	×
123	end.

esl / MongooseIM / 5487101041

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous