Packages

ferricstore

0.9.0
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore commands set scan.ex
Raw

lib/ferricstore/commands/set/scan.ex 

defmodule Ferricstore.Commands.Set.Scan do

  @moduledoc false



  alias Ferricstore.Commands.CollectionScan



  def typed_scan_opts(opts), do: do_typed_scan_opts(opts, nil, 10)



  def parse_cursor(cursor_str), do: CollectionScan.parse_cursor(cursor_str)



  def parse_sscan_opts(opts), do: do_parse_sscan_opts(opts, nil, 10)



  defp do_typed_scan_opts([], match, count), do: {:ok, match, count}



  defp do_typed_scan_opts([{:match, pattern} | rest], _match, count) when is_binary(pattern) do

    do_typed_scan_opts(rest, pattern, count)

  end



  defp do_typed_scan_opts([{:count, count} | rest], match, _count)

       when is_integer(count) and count > 0 do

    do_typed_scan_opts(rest, match, count)

  end



  defp do_typed_scan_opts(_opts, _match, _count), do: {:error, "ERR syntax error"}



  defp do_parse_sscan_opts([], match, count), do: {:ok, match, count}



  defp do_parse_sscan_opts([opt, value | rest], match, count) do

    case String.upcase(opt) do

      "MATCH" ->

        do_parse_sscan_opts(rest, value, count)



      "COUNT" ->

        case Integer.parse(value) do

          {n, ""} when n > 0 -> do_parse_sscan_opts(rest, match, n)

          _ -> {:error, "ERR value is not an integer or out of range"}

        end



      _ ->

        {:error, "ERR syntax error"}

    end

  end



  defp do_parse_sscan_opts([_ | _], _match, _count) do

    {:error, "ERR syntax error"}

  end

end