Packages

bpe

5.8.4
13.5.22-aleph 11.4.16 11.4.15 11.4.14 11.4.13 9.9.7 9.9.6 8.12.4 8.12.3 8.12.1 8.12.0 retired 8.2.1 8.2.0 8.1.0 7.11.0 7.10.4 7.10.3 7.10.2 7.10.1 7.9.1 7.9.0 7.8.2 7.8.1 7.8.0 7.6.4 7.6.3 7.6.2 7.6.1 7.6.0 7.5.15 7.5.14 7.5.13 7.5.12 7.5.11 7.5.10 7.5.9 7.5.8 7.5.7 7.5.6 7.5.5 7.5.3 7.5.2 7.5.1 7.5.0 7.4.11 7.4.10 7.4.9 7.4.8 7.4.7 7.4.6 7.4.5 7.4.4 7.4.3 7.4.2 7.4.1 7.4.0 7.3.0 7.2.8 7.2.7 7.2.6 7.1.6 7.1.5 7.1.4 7.1.3 7.1.2 6.12.7 6.12.6 6.12.5 6.12.3 6.12.2 6.12.1 6.12.0 6.11.0 6.10.0 6.5.3 6.5.2 6.5.1 6.5.0 6.4.0 6.3.0 5.12.0 5.11.4 5.11.3 5.11.2 5.11.1 5.11.0 5.8.7 5.8.6 5.8.5 5.8.4 5.8.3 5.8.2 5.8.1 5.8.0 5.7.0 5.6.0 5.5.2 5.5.1 5.4.0 5.2.0 5.1.3 5.1.2 5.1.1 4.12.4 4.12.3 4.12.2 4.12.1 4.12.0 4.11.8 4.11.7 4.11.6 4.11.5 4.11.4 4.11.3 4.11.2 4.11.1 4.11.0 4.10.24 4.10.23 4.10.22 4.10.21 4.10.20 4.10.19 4.10.18 4.10.17 4.10.16 4.10.15 4.10.14 4.10.13 4.10.12 4.10.11 4.10.10 4.10.9 4.10.8 4.10.7 4.10.6 4.10.5 4.10.4 4.10.3 4.10.2 4.10.1 4.10.0 4.9.18 4.9.17 4.9.16 4.9.15 4.9.14 4.9.13 4.9.12 4.9.11 4.9.10 4.9.9 4.9.8 4.9.7 4.9.6 4.9.5 4.9.4 4.9.3 4.9.2 4.9.1 4.9.0 4.8.1 4.8.0 4.7.5 4.7.3 4.7.2 4.7.1 4.7.0 4.6.0 2.4.0 0.7.16

ERP/1: RTP GST WebRTC ICE SDP H.264 H.265 MP4 MPEG-2 HLS HEVC

HexDocs

Current section

Files

Jump to
Readme
171 Versions
3 Dependencies
Dependants
Files
Activity
bpe src bpe_proc.erl
Raw

src/bpe_proc.erl 

-module(bpe_proc).

-author('Maxim Sokhatsky').

-include("bpe.hrl").

-include_lib("kvs/include/cursors.hrl").

-behaviour(gen_server).

-export([start_link/1]).

-export([init/1,handle_call/3,handle_cast/2,handle_info/2,terminate/2,code_change/3]).

-compile(export_all).



start_link(Parameters) -> gen_server:start_link(?MODULE, Parameters, []).



debug(Proc,Name,Targets,Target,Status,Reason) ->

    case application:get_env(bpe,debug,true) of

         true -> logger:notice("BPE: ~ts [~ts:~ts] ~p/~p ~p",

                               [erlang:list_to_binary(Proc#process.id),Name,Target,Status,Reason,Targets]);

         false -> skip end.



process_event(Event,Proc) ->

    EventName = element(#messageEvent.id,Event),

    Targets = bpe_task:targets(EventName,Proc),

    Target0 = bpe_task:find_flow(EventName, Targets),

    Target1 = case Target0 of

                [] -> EventName;

                T -> T

              end,

    {Status,{Reason, Target}, ProcState} = bpe_event:handle_event(Event, Target1, Proc),

    bpe:add_trace(ProcState, [], Target),

    kvs:append(ProcState,"/bpe/proc"),

    debug(ProcState,EventName,Targets,Target,Status,Reason),

    fix_reply({Status,{Reason,Target},ProcState}).



process_task(Stage,Proc) -> process_task(Stage,Proc,false).

process_task(Stage,Proc,NoFlow) ->

    {_,Curr} = bpe:current_task(Proc),

    Task = bpe:step(Proc,Curr),

    Targets = case NoFlow of

                   true -> noflow;

                   _ -> bpe_task:targets(Curr,Proc) end,

    {Status,{Reason,Target},ProcState} =

       case {Targets,Curr,Stage} of

         {noflow,_,_} -> {reply,{complete,Curr},Proc};

         {[],[],_}    -> bpe_task:already_finished(Proc);

         {[],Curr,_}  -> bpe_task:handle_task(Task,Curr,Curr,Proc);

         {[],_,_}     -> bpe_task:denied_flow(Curr,Proc);

         {List,_,[]}  -> bpe_task:handle_task(Task,Curr,bpe_task:find_flow(Stage,List),Proc);

         {List,_,_}   -> {reply,{complete,bpe_task:find_flow(Stage,List)},Proc} end,



    case (Status == stop) orelse (NoFlow == true) of

       true -> [];

       _ -> bpe:add_trace(ProcState,[],Target),

            debug(ProcState,Curr,Targets,Target,Status,Reason) end,



    fix_reply({Status,{Reason,Target},ProcState}).



fix_reply({stop,{Reason,Reply},State}) -> {stop,Reason,Reply,State};

fix_reply(P) -> P.



% BPMN 2.0 Инфотех

handle_call({get},               _,Proc) -> { reply, Proc, Proc };

handle_call({set,State},         _,Proc) -> { reply, Proc, State };

handle_call({next},              _,Proc) ->

  try bpe:processFlow(Proc)

  catch _X:_Y:Z -> {reply,{error,'next/1',Z},Proc} end;

handle_call({next,Stage},        _,Proc) ->

  try bpe:processFlow(Stage,Proc)

  catch _X:_Y:Z -> {reply,{error,'next/2',Z},Proc} end;

handle_call({amend,Form},        _,Proc) ->

  try bpe:processFlow(bpe_env:append(env,Proc,Form))

  catch _X:_Y:Z -> {reply,{error,'amend/2',Z},Proc} end;

handle_call({discard,Form},      _,Proc) ->

  try bpe:processFlow(bpe_env:remove(env,Proc,Form))

  catch _X:_Y:Z -> {reply,{error,'discard/2',Z},Proc} end;

handle_call({event,Event},       _,Proc) ->

  try process_event(Event,Proc)

  catch _X:_Y:Z -> {reply,{error,'event/2',Z},Proc} end;



% BPMN 1.0 ПриватБанк



handle_call({complete},          _,Proc) ->

  try process_task([],Proc)

  catch _X:_Y:Z -> {reply,{error,'complete/1',Z},Proc} end;

handle_call({complete,Stage},    _,Proc) ->

  try process_task(Stage,Proc)

  catch _X:_Y:Z -> {reply,{error,'complete/2',Z},Proc} end;

handle_call({modify,Form,append},_,Proc) ->

  try process_task([],bpe_env:append(env,Proc,Form),true)

  catch _X:_Y:Z -> {reply,{error,'append/2',Z},Proc} end;

handle_call({modify,Form,remove},_,Proc) ->

  try process_task([],bpe_env:remove(env,Proc,Form),true)

  catch _X:_Y:Z -> {reply,{error,'remove/2',Z},Proc} end;

handle_call(Command,_,Proc)              -> { reply,{unknown,Command},Proc }.



init(Process) ->

    Proc = bpe:load(Process#process.id,Process),

    logger:notice("BPE: ~ts spawned as ~p",[erlang:list_to_binary(Proc#process.id),self()]),

    Till = bpe:till(calendar:local_time(), application:get_env(bpe,ttl,24*60*60)),

    bpe:cache({process,erlang:list_to_binary(Proc#process.id)},self(),Till),

    [ bpe:reg({messageEvent,element(1,EventRec),Proc#process.id}) || EventRec <- bpe:events(Proc) ],

    {ok, Proc#process{timer=erlang:send_after(rand:uniform(10000),self(),{timer,ping})}}.



handle_cast({mon_link,MID},Proc) -> {noreply, Proc#process{monitor=MID}};

handle_cast(Msg, State) ->

    logger:notice("BPE: Unknown API async: ~p.", [Msg]),

    {stop, {error, {unknown_cast, Msg}}, State}.



handle_info({timer,ping}, State=#process{timer=Timer,id=Id,events=Events,notifications=Pid}) ->

    (application:get_env(bpe,ping_discipline,bpe_ping)):ping(State);



handle_info({'DOWN', _MonitorRef, _Type, _Object, _Info} = Msg, State = #process{id=Id}) ->

    logger:notice("BPE: Connection closed, shutting down session: ~p.", [Msg]),

    bpe:cache({process,erlang:list_to_binary(Id)},undefined),

    {stop, normal, State};



handle_info(Info, State=#process{}) ->

    logger:notice("BPE: Unrecognized info: ~p", [Info]),

    {noreply, State}.



terminate(Reason, #process{id=Id}) ->

    BinId = erlang:list_to_binary(Id),

    logger:notice("BPE: ~ts terminate Reason: ~p", [BinId,Reason]),

    spawn(fun() -> supervisor:delete_child(bpe_otp,BinId) end),

    bpe:cache({process,BinId},undefined),

    ok.



code_change(_OldVsn, State, _Extra) ->

    {ok, State}.