aion_flow

-module(aion@workflow).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/aion/workflow.gleam").
-export([run/1, all/1, race/1, map/2, now/0, random/0, random_int/2, sleep/1, start_timer/2, cancel_timer/1, with_timeout/2, continue_as_new/2, 'receive'/1, timer_id/1, spawn/6, spawn_and_wait/6, timestamp_to_milliseconds/1, define/5, name/1, input_codec/1, output_codec/1, error_codec/1, entry_fn/1]).

-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.

?MODULEDOC(
    " Workflow authoring surface.\n"
    "\n"
    " This module is an aggregator only: it forwards declarations from the\n"
    " workflow submodules and contains no workflow business logic. `run` is the\n"
    " only recorded activity dispatch surface in this brief; deterministic time\n"
    " and random values come from AD through `aion/internal/ffi`.\n"
).

-file("src/aion/workflow.gleam", 35).
-spec run(aion@activity:activity(any(), FJM)) -> {ok, FJM} |
    {error, aion@error:activity_error()}.
run(Activity) ->
    aion@workflow@run:run(Activity).

-file("src/aion/workflow.gleam", 41).
-spec all(list(aion@activity:activity(any(), FJS))) -> {ok, list(FJS)} |
    {error, aion@error:activity_error()}.
all(Activities) ->
    aion@workflow@concurrency:all(Activities).

-file("src/aion/workflow.gleam", 47).
-spec race(list(aion@activity:activity(any(), FKA))) -> {ok, FKA} |
    {error, aion@error:activity_error()}.
race(Activities) ->
    aion@workflow@concurrency:race(Activities).

-file("src/aion/workflow.gleam", 53).
-spec map(list(FKG), fun((FKG) -> aion@activity:activity(any(), FKJ))) -> {ok,
        list(FKJ)} |
    {error, aion@error:activity_error()}.
map(Items, To_activity) ->
    aion@workflow@concurrency:map(Items, To_activity).

-file("src/aion/workflow.gleam", 60).
-spec now() -> {ok, aion@workflow@run:timestamp()} |
    {error, aion@error:engine_error()}.
now() ->
    aion@workflow@run:now().

-file("src/aion/workflow.gleam", 64).
-spec random() -> {ok, float()} | {error, aion@error:engine_error()}.
random() ->
    aion@workflow@run:random().

-file("src/aion/workflow.gleam", 68).
-spec random_int(integer(), integer()) -> {ok, integer()} |
    {error, aion@error:engine_error()}.
random_int(Min, Max) ->
    aion@workflow@run:random_int(Min, Max).

-file("src/aion/workflow.gleam", 72).
-spec sleep(aion@duration:duration()) -> {ok, nil} |
    {error, aion@error:engine_error()}.
sleep(Duration) ->
    aion@workflow@timer:sleep(Duration).

-file("src/aion/workflow.gleam", 76).
-spec start_timer(binary(), aion@duration:duration()) -> {ok,
        aion@workflow@timer:timer_ref()} |
    {error, aion@error:engine_error()}.
start_timer(Name, Duration) ->
    aion@workflow@timer:start_timer(Name, Duration).

-file("src/aion/workflow.gleam", 83).
-spec cancel_timer(aion@workflow@timer:timer_ref()) -> {ok, nil} |
    {error, aion@error:engine_error()}.
cancel_timer(Reference) ->
    aion@workflow@timer:cancel_timer(Reference).

-file("src/aion/workflow.gleam", 87).
-spec with_timeout(
    fun(() -> {ok, FLB} | {error, FLC}),
    aion@duration:duration()
) -> {ok, FLB} | {error, aion@error:timeout_result_error(FLC)}.
with_timeout(Operation, Deadline) ->
    aion@workflow@timer:with_timeout(Operation, Deadline).

-file("src/aion/workflow.gleam", 94).
-spec continue_as_new(FLI, aion@codec:codec(FLI)) -> {ok, nil} |
    {error, aion@error:workflow_error()}.
continue_as_new(Input, Input_codec) ->
    aion@workflow@continuation:continue_as_new(Input, Input_codec).

-file("src/aion/workflow.gleam", 101).
-spec 'receive'(aion@signal:signal_ref(FLM)) -> {ok, FLM} |
    {error, aion@error:receive_error()}.
'receive'(Reference) ->
    aion@signal:'receive'(Reference).

-file("src/aion/workflow.gleam", 107).
-spec timer_id(aion@workflow@timer:timer_ref()) -> binary().
timer_id(Reference) ->
    aion@workflow@timer:timer_id(Reference).

-file("src/aion/workflow.gleam", 111).
-spec spawn(
    binary(),
    fun((FLQ) -> {ok, FLR} | {error, FLS}),
    FLQ,
    aion@codec:codec(FLQ),
    aion@codec:codec(FLR),
    aion@codec:codec(FLS)
) -> {ok, aion@child:child_handle(FLR, FLS)} |
    {error, aion@error:engine_error()}.
spawn(Name, Workflow_fn, Input, Input_codec, Output_codec, Error_codec) ->
    aion@child:spawn(
        Name,
        Workflow_fn,
        Input,
        Input_codec,
        Output_codec,
        Error_codec
    ).

-file("src/aion/workflow.gleam", 122).
-spec spawn_and_wait(
    binary(),
    fun((FMC) -> {ok, FMD} | {error, FME}),
    FMC,
    aion@codec:codec(FMC),
    aion@codec:codec(FMD),
    aion@codec:codec(FME)
) -> {ok, FMD} | {error, aion@error:child_error(FME)}.
spawn_and_wait(Name, Workflow_fn, Input, Input_codec, Output_codec, Error_codec) ->
    aion@child:spawn_and_wait(
        Name,
        Workflow_fn,
        Input,
        Input_codec,
        Output_codec,
        Error_codec
    ).

-file("src/aion/workflow.gleam", 140).
-spec timestamp_to_milliseconds(aion@workflow@run:timestamp()) -> integer().
timestamp_to_milliseconds(Timestamp) ->
    aion@workflow@run:timestamp_to_milliseconds(Timestamp).

-file("src/aion/workflow.gleam", 144).
-spec define(
    binary(),
    aion@codec:codec(FMN),
    aion@codec:codec(FMP),
    aion@codec:codec(FMR),
    fun((FMN) -> {ok, FMP} | {error, FMR})
) -> aion@workflow@define:workflow_definition(FMN, FMP, FMR).
define(Name, Input_codec, Output_codec, Error_codec, Entry_fn) ->
    aion@workflow@define:define(
        Name,
        Input_codec,
        Output_codec,
        Error_codec,
        Entry_fn
    ).

-file("src/aion/workflow.gleam", 154).
-spec name(aion@workflow@define:workflow_definition(any(), any(), any())) -> binary().
name(Definition) ->
    aion@workflow@define:name(Definition).

-file("src/aion/workflow.gleam", 160).
-spec input_codec(aion@workflow@define:workflow_definition(FNE, any(), any())) -> aion@codec:codec(FNE).
input_codec(Definition) ->
    aion@workflow@define:input_codec(Definition).

-file("src/aion/workflow.gleam", 166).
-spec output_codec(aion@workflow@define:workflow_definition(any(), FNM, any())) -> aion@codec:codec(FNM).
output_codec(Definition) ->
    aion@workflow@define:output_codec(Definition).

-file("src/aion/workflow.gleam", 172).
-spec error_codec(aion@workflow@define:workflow_definition(any(), any(), FNU)) -> aion@codec:codec(FNU).
error_codec(Definition) ->
    aion@workflow@define:error_codec(Definition).

-file("src/aion/workflow.gleam", 178).
-spec entry_fn(aion@workflow@define:workflow_definition(FNZ, FOA, FOB)) -> fun((FNZ) -> {ok,
        FOA} |
    {error, FOB}).
entry_fn(Definition) ->
    aion@workflow@define:entry_fn(Definition).