-module(erlkaf_local_queue).

-include("erlkaf_private.hrl").

-export([
    new/1,
    free/1,
    enq/7,
    deq/1,
    head/1
]).

new(ClientId) ->
    Path = erlkaf_utils:get_priv_path(ClientId),
    ?LOG_INFO("persistent queue path: ~p", [Path]),
    esq:new(Path).

free(undefined) ->
    ok;
free(Queue) ->
    esq:free(Queue).

enq(Queue, TopicName, Partition, Key, Value, Headers, Timestamp) ->
    esq:enq({TopicName, Partition, Key, Value, Headers, Timestamp}, Queue).

deq(Queue) ->
    esq:deq(Queue).

head(Queue) ->
    esq:head(Queue).