Packages

bpe

13.5.22-aleph
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
2 Dependencies
Dependants
Files
Activity
bpe src ext bpe_order.erl
Raw

src/ext/bpe_order.erl 

-module(bpe_order).

-include_lib("bpe/include/bpe.hrl").

-export([def/0, auth/1, action/2]).



auth(_) -> true.



def() ->

    P = #process{

      name = "E-Commerce Order",

      module = ?MODULE,

      flows = [

        #sequenceFlow{id = "->CartActive", source = "CartCreated", target = "CartActive"},

        #sequenceFlow{id = "CartActive->Checkout", source = "CartActive", target = "Checkout"},

        #sequenceFlow{id = "AbandonedRecovery->CartActive", source = "AbandonedRecovery", target = "CartActive"},

        #sequenceFlow{id = "Checkout->Payment", source = "Checkout", target = "Payment"},

        #sequenceFlow{id = "Payment->Fulfilment", source = "Payment", target = "Fulfilment"},

        #sequenceFlow{id = "Fulfilment->PostPurchase", source = "Fulfilment", target = "PostPurchase"},

        #sequenceFlow{id = "PostPurchase->Delivered", source = "PostPurchase", target = "Delivered"}

      ],

      tasks = [

        #beginEvent{id = "CartCreated"},

        #userTask{id = "CartActive"},

        #serviceTask{id = "AbandonedRecovery"},

        #userTask{id = "Checkout"},

        #serviceTask{id = "Payment"},

        #serviceTask{id = "Fulfilment"},

        #serviceTask{id = "PostPurchase"},

        #endEvent{id = "Delivered"}

      ],

      beginEvent = "CartCreated",

      endEvent = "Delivered",

      events = [

        #messageEvent{id = "PaymentReceived"},

        #messageEvent{id = "ShipmentUpdate"},

        #boundaryEvent{id = '*', timeout = #timeout{spec = {0, {1, 0, 0}}}}

      ]

    },

    P#process{tasks = bpe_xml:fillInOut(P#process.tasks, P#process.flows)}.



action({request, "CartCreated", _}, Proc) -> #result{state = Proc};

action({request, "CartActive", _}, Proc) -> #result{state = Proc};

action({request, "AbandonedRecovery", _}, Proc) ->

    #result{

       type = reply,

       reply = "CartActive",

       state = Proc#process{docs = [{abandoned_recovery_sent, true}]}

    };

action({request, "Checkout", _}, Proc) -> #result{state = Proc};

action({request, "Payment", _}, Proc) ->

    case bpe:doc({payment_received}, Proc) of

        [] -> #result{type = reply, reply = "Payment", state = Proc};

        _ -> #result{type = reply, reply = {complete, "Fulfilment"}, state = Proc#process{docs = [{tx, paid}]}}

    end;

action({request, "Fulfilment", _}, Proc) -> #result{state = Proc};

action({request, "PostPurchase", _}, Proc) ->

    #result{state = Proc#process{docs = [{post_purchase_sent, true}]}};

action({request, "Delivered", _}, Proc) -> #result{type = stop, state = Proc}.