lamb

-module(lamb).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch]).

-export([all/2, count/2, batch/3, continue/1]).
-export_type([partial/1, step/0]).

-type partial(GPJ) :: {records, list(GPJ), step()} | {'end', list(GPJ)}.

-type step() :: any().

-file("/Users/chouzar/Bench/Projects/lamb/src/lamb.gleam", 10).
-spec all(lamb@table:table(GPK, GPL), lamb@query:'query'(GPK, GPL)) -> list(any()).
all(Table, Query) ->
    Table_id = erlang:element(2, Table),
    ets:select(Table_id, [Query]).

-file("/Users/chouzar/Bench/Projects/lamb/src/lamb.gleam", 31).
-spec count(lamb@table:table(GQC, GQD), lamb@query:'query'(GQC, GQD)) -> integer().
count(Table, Query) ->
    Table_id = erlang:element(2, Table),
    ets:select_count(
        Table_id,
        [begin
                _pipe = Query,
                lamb_query_erlang_ffi:update_body(_pipe, true)
            end]
    ).

-file("/Users/chouzar/Bench/Projects/lamb/src/lamb.gleam", 18).
-spec batch(lamb@table:table(GPS, GPT), integer(), lamb@query:'query'(GPS, GPT)) -> partial(any()).
batch(Table, Limit, Query) ->
    Table_id = erlang:element(2, Table),
    lamb_erlang_ffi:search(Table_id, Limit, [Query]).

-file("/Users/chouzar/Bench/Projects/lamb/src/lamb.gleam", 27).
-spec continue(step()) -> partial(any()).
continue(Step) ->
    lamb_erlang_ffi:search(Step).