HyperBEAM PoC for workflow execution

gistfile1.txt

% Create a wallet
Wallet = ar_wallet:new().

Module1 = #{ ~"content-type" => ~"application/lua", ~"body" =>
<<"""
function compute(base, req)
    base.result = "Hello HyperBEAM 1"
    return base
end
""">>}.

Module2 = #{ ~"content-type" => ~"application/lua", ~"body" =>
<<"""
function compute(base, req)
    base.result = "Hello HyperBEAM 2"
    return base
end
""">>}.

Workflow = #{
 ~"name" => ~"MyWorkflow",
 ~"steps" => #{
    ~"start" => #{~"description" => ~"First step", ~"execution-device" => ~"[email protected]", ~"module" => Module1},
    ~"step2" => #{~"description" => ~"Second step", ~"execution-device" => ~"[email protected]", ~"module" => Module2}
 },
 ~"transitions" => #{~"start" => #{~"true" => ~"step2"}}
}.

{ok, #{~"workflow-id" := WorkflowId}} = hb_ao:resolve(#{device => ~"[email protected]"}, #{~"path" => ~"create", ~"workflow" => Workflow}, #{~"wallet" => Wallet}).

{ok, #{~"prepared-id" := PreparedId1}} = hb_ao:resolve(#{device => ~"[email protected]"}, #{~"path" => ~"prepare_start", ~"workflow-id" => WorkflowId, ~"body" => #{}}, #{~"wallet" => Wallet}).

{ok, #{~"activity-id" := ActivityId1}} = hb_ao:resolve(#{device => ~"[email protected]"}, #{~"path" => ~"run", ~"workflow-id" => WorkflowId, ~"prepared-id" => PreparedId1}, #{~"wallet" => Wallet}).

{ok, #{~"prepared-id" := PreparedId2}} = hb_ao:resolve(#{device => ~"[email protected]"}, #{~"path" => ~"prepare_next", ~"workflow-id" => WorkflowId, ~"prev-activity-id" => ActivityId1}, #{~"wallet" => Wallet}).

{ok, #{~"activity-id" := ActivityId2}} = hb_ao:resolve(#{device => ~"[email protected]"}, #{~"path" => ~"run", ~"workflow-id" => WorkflowId, ~"prepared-id" => PreparedId2}, #{~"wallet" => Wallet}).