kv_sessions

-module(kv_sessions@actor_adapter).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export([new/0]).
-export_type([message/1]).

-type message(TXL) :: shutdown |
    {get_session,
        gleam@erlang@process:subject({ok, kv_sessions@session:session()} |
            {error, nil}),
        kv_sessions@session:session_id()} |
    {set_session,
        gleam@erlang@process:subject(kv_sessions@session:session()),
        kv_sessions@session:session()} |
    {delete_session, kv_sessions@session:session_id()} |
    {gleam_phantom, TXL}.

-spec delete_session(gleam@erlang@process:subject(message(any()))) -> fun((kv_sessions@session:session_id()) -> {ok,
        nil} |
    {error, any()}).
delete_session(Db) ->
    fun(Session_id) ->
        gleam@erlang@process:send(Db, {delete_session, Session_id}),
        {ok, nil}
    end.

-spec handle_message(
    message(TYB),
    gleam@dict:dict(kv_sessions@session:session_id(), kv_sessions@session:session())
) -> gleam@otp@actor:next(message(TYB), gleam@dict:dict(kv_sessions@session:session_id(), kv_sessions@session:session())).
handle_message(Message, Db) ->
    case Message of
        shutdown ->
            {stop, normal};

        {get_session, Client, Session_id} ->
            Session = gleam@dict:get(Db, Session_id),
            gleam@erlang@process:send(Client, Session),
            gleam@otp@actor:continue(Db);

        {set_session, Client@1, Session@1} ->
            gleam@erlang@process:send(Client@1, Session@1),
            gleam@otp@actor:continue(
                gleam@dict:insert(Db, erlang:element(2, Session@1), Session@1)
            );

        {delete_session, Session_id@1} ->
            gleam@otp@actor:continue(gleam@dict:delete(Db, Session_id@1))
    end.

-spec get_session(gleam@erlang@process:subject(message(any()))) -> fun((kv_sessions@session:session_id()) -> {ok,
        gleam@option:option(kv_sessions@session:session())} |
    {error, any()}).
get_session(Db) ->
    fun(Session_id) ->
        {ok,
            begin
                _pipe = gleam@erlang@process:call(
                    Db,
                    fun(_capture) -> {get_session, _capture, Session_id} end,
                    3000
                ),
                _pipe@1 = gleam@result:map(
                    _pipe,
                    fun(Session) -> {some, Session} end
                ),
                _pipe@2 = gleam@option:from_result(_pipe@1),
                gleam@option:flatten(_pipe@2)
            end}
    end.

-spec save_session(gleam@erlang@process:subject(message(any()))) -> fun((kv_sessions@session:session()) -> {ok,
        kv_sessions@session:session()} |
    {error, any()}).
save_session(Db) ->
    fun(Session) ->
        {ok,
            gleam@erlang@process:call(
                Db,
                fun(_capture) -> {set_session, _capture, Session} end,
                3000
            )}
    end.

-spec new() -> {ok, kv_sessions@session_config:session_store()} |
    {error, kv_sessions@session:session_error()}.
new() ->
    gleam@result:map(
        begin
            _pipe = gleam@otp@actor:start(
                gleam@dict:new(),
                fun handle_message/2
            ),
            gleam@result:replace_error(_pipe, db_setup_error)
        end,
        fun(Db) ->
            {session_store,
                get_session(Db),
                save_session(Db),
                delete_session(Db)}
        end
    ).