-module(telega@flow@builder). -compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]). -define(FILEPATH, "src/telega/flow/builder.gleam"). -export([new/4, new_with_default_converters/3, add_step/3, add_step_with_middleware/4, add_step_with_hooks/5, add_step_with_hooks_and_middleware/6, add_global_middleware/2, add_conditional/5, add_multi_conditional/4, add_parallel_steps/4, parallel/4, add_subflow/6, build/2, with_inline_subflow/6, with_inline_subflow_mapped/8, inline_next/3, on_complete/2, on_error/2, set_on_flow_enter/2, set_on_flow_leave/2, with_ttl/2, on_timeout/2, set_on_flow_exit/2]). -export_type([flow_builder/4]). -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(" FlowBuilder and all builder functions for constructing flows.\n"). -opaque flow_builder(AXRO, AXRP, AXRQ, AXRR) :: {flow_builder, binary(), gleam@dict:dict(binary(), telega@flow@types:step_config(AXRO, AXRP, AXRQ, AXRR)), fun((AXRO) -> binary()), fun((binary()) -> {ok, AXRO} | {error, nil}), telega@flow@types:flow_storage(AXRQ), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AXRP, AXRQ, AXRR)} | {error, AXRQ})), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance(), gleam@option:option(AXRQ)) -> {ok, telega@bot:context(AXRP, AXRQ, AXRR)} | {error, AXRQ})), list(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance(), fun(() -> {ok, {telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_action(AXRO), telega@flow@types:flow_instance()}} | {error, AXRQ})) -> {ok, {telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_action(AXRO), telega@flow@types:flow_instance()}} | {error, AXRQ})), list(telega@flow@types:conditional_transition(AXRO)), list(telega@flow@types:parallel_config(AXRO)), list(telega@flow@types:subflow_config(AXRO, AXRP, AXRQ, AXRR)), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()}} | {error, AXRQ})), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()}} | {error, AXRQ})), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AXRP, AXRQ, AXRR)} | {error, AXRQ})), gleam@option:option(integer()), gleam@option:option(fun((telega@bot:context(AXRP, AXRQ, AXRR), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AXRP, AXRQ, AXRR)} | {error, AXRQ}))}. -file("src/telega/flow/builder.gleam", 51). ?DOC(" Create a new flow builder\n"). -spec new( binary(), telega@flow@types:flow_storage(AXRS), fun((AXRU) -> binary()), fun((binary()) -> {ok, AXRU} | {error, nil}) ) -> flow_builder(AXRU, any(), AXRS, any()). new(Flow_name, Storage, Step_to_string, String_to_step) -> {flow_builder, Flow_name, maps:new(), Step_to_string, String_to_step, Storage, none, none, [], [], [], [], none, none, none, none, none}. -file("src/telega/flow/builder.gleam", 459). ?DOC(" Helper to create a string_to_step function for a list of steps\n"). -spec create_string_to_step(list({binary(), AYGH})) -> fun((binary()) -> {ok, AYGH} | {error, nil}). create_string_to_step(Steps) -> Step_dict = maps:from_list(Steps), fun(Name) -> gleam_stdlib:map_get(Step_dict, Name) end. -file("src/telega/flow/builder.gleam", 78). ?DOC(" Create a flow builder with default string conversion (uses string.inspect)\n"). -spec new_with_default_converters( binary(), telega@flow@types:flow_storage(AXSD), list({binary(), AXSF}) ) -> flow_builder(AXSF, any(), AXSD, any()). new_with_default_converters(Flow_name, Storage, Steps) -> {flow_builder, Flow_name, maps:new(), fun gleam@string:inspect/1, create_string_to_step(Steps), Storage, none, none, [], [], [], [], none, none, none, none, none}. -file("src/telega/flow/builder.gleam", 104). ?DOC(" Add a step to the flow\n"). -spec add_step( flow_builder(AXSN, AXSO, AXSP, AXSQ), AXSN, fun((telega@bot:context(AXSO, AXSP, AXSQ), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXSO, AXSP, AXSQ), telega@flow@types:flow_action(AXSN), telega@flow@types:flow_instance()}} | {error, AXSP}) ) -> flow_builder(AXSN, AXSO, AXSP, AXSQ). add_step(Builder, Step, Handler) -> Step_name = (erlang:element(4, Builder))(Step), Config = {step_config, Handler, [], none, none}, {flow_builder, erlang:element(2, Builder), gleam@dict:insert(erlang:element(3, Builder), Step_name, Config), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 116). ?DOC(" Add a step with middleware\n"). -spec add_step_with_middleware( flow_builder(AXTD, AXTE, AXTF, AXTG), AXTD, list(fun((telega@bot:context(AXTE, AXTF, AXTG), telega@flow@types:flow_instance(), fun(() -> {ok, {telega@bot:context(AXTE, AXTF, AXTG), telega@flow@types:flow_action(AXTD), telega@flow@types:flow_instance()}} | {error, AXTF})) -> {ok, {telega@bot:context(AXTE, AXTF, AXTG), telega@flow@types:flow_action(AXTD), telega@flow@types:flow_instance()}} | {error, AXTF})), fun((telega@bot:context(AXTE, AXTF, AXTG), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXTE, AXTF, AXTG), telega@flow@types:flow_action(AXTD), telega@flow@types:flow_instance()}} | {error, AXTF}) ) -> flow_builder(AXTD, AXTE, AXTF, AXTG). add_step_with_middleware(Builder, Step, Middlewares, Handler) -> Step_name = (erlang:element(4, Builder))(Step), Config = {step_config, Handler, Middlewares, none, none}, {flow_builder, erlang:element(2, Builder), gleam@dict:insert(erlang:element(3, Builder), Step_name, Config), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 129). ?DOC(" Add a step with lifecycle hooks\n"). -spec add_step_with_hooks( flow_builder(AXTY, AXTZ, AXUA, AXUB), AXTY, fun((telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_action(AXTY), telega@flow@types:flow_instance()}} | {error, AXUA}), gleam@option:option(fun((telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_instance()}} | {error, AXUA})), gleam@option:option(fun((telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXTZ, AXUA, AXUB), telega@flow@types:flow_instance()}} | {error, AXUA})) ) -> flow_builder(AXTY, AXTZ, AXUA, AXUB). add_step_with_hooks(Builder, Step, Handler, On_enter, On_leave) -> Step_name = (erlang:element(4, Builder))(Step), Config = {step_config, Handler, [], On_enter, On_leave}, {flow_builder, erlang:element(2, Builder), gleam@dict:insert(erlang:element(3, Builder), Step_name, Config), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 142). ?DOC(" Add a step with hooks and middleware\n"). -spec add_step_with_hooks_and_middleware( flow_builder(AXUW, AXUX, AXUY, AXUZ), AXUW, fun((telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_action(AXUW), telega@flow@types:flow_instance()}} | {error, AXUY}), list(fun((telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance(), fun(() -> {ok, {telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_action(AXUW), telega@flow@types:flow_instance()}} | {error, AXUY})) -> {ok, {telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_action(AXUW), telega@flow@types:flow_instance()}} | {error, AXUY})), gleam@option:option(fun((telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance()}} | {error, AXUY})), gleam@option:option(fun((telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXUX, AXUY, AXUZ), telega@flow@types:flow_instance()}} | {error, AXUY})) ) -> flow_builder(AXUW, AXUX, AXUY, AXUZ). add_step_with_hooks_and_middleware( Builder, Step, Handler, Middlewares, On_enter, On_leave ) -> Step_name = (erlang:element(4, Builder))(Step), Config = {step_config, Handler, Middlewares, On_enter, On_leave}, {flow_builder, erlang:element(2, Builder), gleam@dict:insert(erlang:element(3, Builder), Step_name, Config), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 158). ?DOC(" Add global middleware that applies to all steps\n"). -spec add_global_middleware( flow_builder(AXVZ, AXWA, AXWB, AXWC), fun((telega@bot:context(AXWA, AXWB, AXWC), telega@flow@types:flow_instance(), fun(() -> {ok, {telega@bot:context(AXWA, AXWB, AXWC), telega@flow@types:flow_action(AXVZ), telega@flow@types:flow_instance()}} | {error, AXWB})) -> {ok, {telega@bot:context(AXWA, AXWB, AXWC), telega@flow@types:flow_action(AXVZ), telega@flow@types:flow_instance()}} | {error, AXWB}) ) -> flow_builder(AXVZ, AXWA, AXWB, AXWC). add_global_middleware(Builder, Middleware) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), lists:append(erlang:element(9, Builder), [Middleware]), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 169). ?DOC(" Add conditional transition\n"). -spec add_conditional( flow_builder(AXWP, AXWQ, AXWR, AXWS), AXWP, fun((telega@flow@types:flow_instance()) -> boolean()), AXWP, AXWP ) -> flow_builder(AXWP, AXWQ, AXWR, AXWS). add_conditional(Builder, From, Condition, On_true, On_false) -> From_str = (erlang:element(4, Builder))(From), Conditional = {conditional_transition, From_str, [{Condition, On_true}], On_false}, {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), lists:append(erlang:element(10, Builder), [Conditional]), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 190). ?DOC(" Add multi-way conditional\n"). -spec add_multi_conditional( flow_builder(AXXB, AXXC, AXXD, AXXE), AXXB, list({fun((telega@flow@types:flow_instance()) -> boolean()), AXXB}), AXXB ) -> flow_builder(AXXB, AXXC, AXXD, AXXE). add_multi_conditional(Builder, From, Conditions, Default) -> From_str = (erlang:element(4, Builder))(From), Conditional = {conditional_transition, From_str, Conditions, Default}, {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), lists:append(erlang:element(10, Builder), [Conditional]), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 217). ?DOC( " Add parallel step execution.\n" "\n" " @deprecated Use `parallel()` instead for cleaner API.\n" ). -spec add_parallel_steps( flow_builder(AXYB, AXYC, AXYD, AXYE), AXYB, list(AXYB), AXYB ) -> flow_builder(AXYB, AXYC, AXYD, AXYE). add_parallel_steps(Builder, Trigger_step, Parallel_steps, Join_at) -> Trigger_str = (erlang:element(4, Builder))(Trigger_step), Config = {parallel_config, Trigger_str, Parallel_steps, Join_at}, {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), lists:append(erlang:element(11, Builder), [Config]), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 205). ?DOC(" Add parallel step execution (simplified API).\n"). -spec parallel(flow_builder(AXXO, AXXP, AXXQ, AXXR), AXXO, list(AXXO), AXXO) -> flow_builder(AXXO, AXXP, AXXQ, AXXR). parallel(Builder, From, Steps, Join) -> add_parallel_steps(Builder, From, Steps, Join). -file("src/telega/flow/builder.gleam", 237). ?DOC(" Add sub-flow\n"). -spec add_subflow( flow_builder(AXYO, AXYP, AXYQ, AXYR), AXYO, telega@flow@types:flow(gleam@dynamic:dynamic_(), AXYP, AXYQ, AXYR), AXYO, fun((telega@flow@types:flow_instance()) -> gleam@dict:dict(binary(), binary())), fun((gleam@dict:dict(binary(), binary()), telega@flow@types:flow_instance()) -> telega@flow@types:flow_instance()) ) -> flow_builder(AXYO, AXYP, AXYQ, AXYR). add_subflow(Builder, Trigger_step, Subflow, Return_to, Map_args, Map_result) -> Trigger_str = (erlang:element(4, Builder))(Trigger_step), Config = {subflow_config, Trigger_str, Subflow, Return_to, Map_args, Map_result}, {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), lists:append(erlang:element(12, Builder), [Config]), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 468). -spec unsafe_coerce(any()) -> any(). unsafe_coerce(Value) -> telega@internal@coerce:unsafe_coerce(Value). -file("src/telega/flow/builder.gleam", 425). ?DOC(" Build the flow\n"). -spec build(flow_builder(AYFT, AYFU, AYFV, AYFW), AYFT) -> telega@flow@types:flow(AYFT, AYFU, AYFV, AYFW). build(Builder, Initial_step) -> {flow, erlang:element(2, Builder), erlang:element(3, Builder), Initial_step, erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 454). -spec string_to_inline_step(binary()) -> {ok, telega@flow@types:inline_step()} | {error, nil}. string_to_inline_step(S) -> {ok, {inline_step, S}}. -file("src/telega/flow/builder.gleam", 450). -spec inline_step_to_string(telega@flow@types:inline_step()) -> binary(). inline_step_to_string(Step) -> erlang:element(2, Step). -file("src/telega/flow/builder.gleam", 259). ?DOC(" Add an inline subflow defined within the parent flow\n"). -spec with_inline_subflow( flow_builder(AXZI, AXZJ, AXZK, AXZL), binary(), AXZI, AXZI, binary(), list({binary(), fun((telega@bot:context(AXZJ, AXZK, AXZL), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AXZJ, AXZK, AXZL), telega@flow@types:flow_action(telega@flow@types:inline_step()), telega@flow@types:flow_instance()}} | {error, AXZK})}) ) -> flow_builder(AXZI, AXZJ, AXZK, AXZL). with_inline_subflow(Builder, Name, Trigger, Return_to, Initial, Steps) -> Inline_flow_name = <<<<(erlang:element(2, Builder))/binary, "::"/utf8>>/binary, Name/binary>>, Inline_storage = erlang:element(6, Builder), Inline_builder = new( Inline_flow_name, Inline_storage, fun inline_step_to_string/1, fun string_to_inline_step/1 ), Inline_builder@1 = gleam@list:fold( Steps, Inline_builder, fun(B, Step_tuple) -> {Step_name, Handler} = Step_tuple, add_step(B, {inline_step, Step_name}, Handler) end ), Inline_flow = build(Inline_builder@1, {inline_step, Initial}), Coerced_flow = unsafe_coerce(Inline_flow), add_subflow( Builder, Trigger, Coerced_flow, Return_to, fun(Instance) -> erlang:element(3, erlang:element(6, Instance)) end, fun(Result, Instance@1) -> {flow_instance, erlang:element(2, Instance@1), erlang:element(3, Instance@1), erlang:element(4, Instance@1), erlang:element(5, Instance@1), begin _record = erlang:element(6, Instance@1), {flow_state, erlang:element(2, _record), maps:merge( erlang:element(3, erlang:element(6, Instance@1)), Result ), erlang:element(4, _record), erlang:element(5, _record), erlang:element(6, _record)} end, erlang:element(7, Instance@1), erlang:element(8, Instance@1), erlang:element(9, Instance@1), erlang:element(10, Instance@1), erlang:element(11, Instance@1)} end ). -file("src/telega/flow/builder.gleam", 313). ?DOC(" Add an inline subflow with custom argument and result mapping\n"). -spec with_inline_subflow_mapped( flow_builder(AYAC, AYAD, AYAE, AYAF), binary(), AYAC, AYAC, binary(), list({binary(), fun((telega@bot:context(AYAD, AYAE, AYAF), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AYAD, AYAE, AYAF), telega@flow@types:flow_action(telega@flow@types:inline_step()), telega@flow@types:flow_instance()}} | {error, AYAE})}), fun((telega@flow@types:flow_instance()) -> gleam@dict:dict(binary(), binary())), fun((gleam@dict:dict(binary(), binary()), telega@flow@types:flow_instance()) -> telega@flow@types:flow_instance()) ) -> flow_builder(AYAC, AYAD, AYAE, AYAF). with_inline_subflow_mapped( Builder, Name, Trigger, Return_to, Initial, Steps, Map_args, Map_result ) -> Inline_flow_name = <<<<(erlang:element(2, Builder))/binary, "::"/utf8>>/binary, Name/binary>>, Inline_storage = erlang:element(6, Builder), Inline_builder = new( Inline_flow_name, Inline_storage, fun inline_step_to_string/1, fun string_to_inline_step/1 ), Inline_builder@1 = gleam@list:fold( Steps, Inline_builder, fun(B, Step_tuple) -> {Step_name, Handler} = Step_tuple, add_step(B, {inline_step, Step_name}, Handler) end ), Inline_flow = build(Inline_builder@1, {inline_step, Initial}), Coerced_flow = unsafe_coerce(Inline_flow), add_subflow(Builder, Trigger, Coerced_flow, Return_to, Map_args, Map_result). -file("src/telega/flow/builder.gleam", 355). ?DOC(" Navigate to next inline step by name\n"). -spec inline_next( telega@bot:context(AYBA, AYBB, AYBC), telega@flow@types:flow_instance(), binary() ) -> {ok, {telega@bot:context(AYBA, AYBB, AYBC), telega@flow@types:flow_action(telega@flow@types:inline_step()), telega@flow@types:flow_instance()}} | {error, AYBB}. inline_next(Ctx, Instance, Step_name) -> {ok, {Ctx, {next, {inline_step, Step_name}}, Instance}}. -file("src/telega/flow/builder.gleam", 364). ?DOC(" Set completion handler\n"). -spec on_complete( flow_builder(AYBK, AYBL, AYBM, AYBN), fun((telega@bot:context(AYBL, AYBM, AYBN), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AYBL, AYBM, AYBN)} | {error, AYBM}) ) -> flow_builder(AYBK, AYBL, AYBM, AYBN). on_complete(Builder, Handler) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), {some, Handler}, erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 373). ?DOC(" Set error handler\n"). -spec on_error( flow_builder(AYCE, AYCF, AYCG, AYCH), fun((telega@bot:context(AYCF, AYCG, AYCH), telega@flow@types:flow_instance(), gleam@option:option(AYCG)) -> {ok, telega@bot:context(AYCF, AYCG, AYCH)} | {error, AYCG}) ) -> flow_builder(AYCE, AYCF, AYCG, AYCH). on_error(Builder, Handler) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), {some, Handler}, erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 385). ?DOC(" Set flow enter hook\n"). -spec set_on_flow_enter( flow_builder(AYCZ, AYDA, AYDB, AYDC), fun((telega@bot:context(AYDA, AYDB, AYDC), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AYDA, AYDB, AYDC), telega@flow@types:flow_instance()}} | {error, AYDB}) ) -> flow_builder(AYCZ, AYDA, AYDB, AYDC). set_on_flow_enter(Builder, Hook) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), {some, Hook}, erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 393). ?DOC(" Set flow leave hook\n"). -spec set_on_flow_leave( flow_builder(AYDO, AYDP, AYDQ, AYDR), fun((telega@bot:context(AYDP, AYDQ, AYDR), telega@flow@types:flow_instance()) -> {ok, {telega@bot:context(AYDP, AYDQ, AYDR), telega@flow@types:flow_instance()}} | {error, AYDQ}) ) -> flow_builder(AYDO, AYDP, AYDQ, AYDR). set_on_flow_leave(Builder, Hook) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), {some, Hook}, erlang:element(15, Builder), erlang:element(16, Builder), erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 401). ?DOC(" Set flow-level TTL (maximum lifetime in milliseconds)\n"). -spec with_ttl(flow_builder(AYED, AYEE, AYEF, AYEG), integer()) -> flow_builder(AYED, AYEE, AYEF, AYEG). with_ttl(Builder, Ms) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), {some, Ms}, erlang:element(17, Builder)}. -file("src/telega/flow/builder.gleam", 409). ?DOC(" Set timeout hook (called when flow or wait expires via lazy check)\n"). -spec on_timeout( flow_builder(AYEP, AYEQ, AYER, AYES), fun((telega@bot:context(AYEQ, AYER, AYES), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AYEQ, AYER, AYES)} | {error, AYER}) ) -> flow_builder(AYEP, AYEQ, AYER, AYES). on_timeout(Builder, Handler) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), erlang:element(15, Builder), erlang:element(16, Builder), {some, Handler}}. -file("src/telega/flow/builder.gleam", 417). ?DOC(" Set flow exit hook\n"). -spec set_on_flow_exit( flow_builder(AYFE, AYFF, AYFG, AYFH), fun((telega@bot:context(AYFF, AYFG, AYFH), telega@flow@types:flow_instance()) -> {ok, telega@bot:context(AYFF, AYFG, AYFH)} | {error, AYFG}) ) -> flow_builder(AYFE, AYFF, AYFG, AYFH). set_on_flow_exit(Builder, Hook) -> {flow_builder, erlang:element(2, Builder), erlang:element(3, Builder), erlang:element(4, Builder), erlang:element(5, Builder), erlang:element(6, Builder), erlang:element(7, Builder), erlang:element(8, Builder), erlang:element(9, Builder), erlang:element(10, Builder), erlang:element(11, Builder), erlang:element(12, Builder), erlang:element(13, Builder), erlang:element(14, Builder), {some, Hook}, erlang:element(16, Builder), erlang:element(17, Builder)}.