Packages

extreme

0.13.3
1.1.4 1.1.3 1.1.2 1.1.1 1.1.1-rc01 1.1.0 1.1.0-rc9 1.1.0-rc8 1.1.0-rc7 1.1.0-rc6 1.1.0-rc5 1.1.0-rc4 1.1.0-rc3 1.1.0-rc2 1.1.0-rc1 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.13.4 0.13.3 0.13.2 0.13.1 0.13.0 0.12.1 0.12.0 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 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

Elixir TCP client for EventStore.

HexDocs

Current section

Files

Jump to
Readme
55 Versions
4 Dependencies
Dependants
Files
Activity
extreme lib request.ex
Raw

lib/request.ex 

defmodule Extreme.Request do

  alias Extreme.Tools

  require Logger



  def prepare(:ping = cmd) do

    correlation_id = Tools.gen_uuid()

    res = <<Extreme.MessageResolver.encode_cmd(cmd), 0>> <> correlation_id

    size = byte_size(res)

    <<size::32-unsigned-little-integer>> <> res

  end



  def prepare(:heartbeat_response = cmd, correlation_id) do

    res = <<Extreme.MessageResolver.encode_cmd(cmd), 0>> <> correlation_id

    size = byte_size(res)

    <<size::32-unsigned-little-integer>> <> res

  end



  def prepare(protobuf_msg, credentials, correlation_id \\ nil)



  def prepare({cmd, payload}, credentials, correlation_id) do

    correlation_id = correlation_id || Tools.gen_uuid()

    data = payload.__struct__.encode(payload)

    message = to_binary(cmd, correlation_id, {credentials.user, credentials.pass}, data)



    {message, correlation_id}

  end



  def prepare(protobuf_msg, credentials, correlation_id) do

    correlation_id = correlation_id || Tools.gen_uuid()

    cmd = protobuf_msg.__struct__

    data = protobuf_msg.__struct__.encode(protobuf_msg)

    message = to_binary(cmd, correlation_id, {credentials.user, credentials.pass}, data)



    {message, correlation_id}

  end



  defp to_binary(cmd, correlation_id, {login, password}, data) do

    login_len = byte_size(login)

    pass_len = byte_size(password)



    res =

      <<Extreme.MessageResolver.encode_cmd(cmd), 1>> <> correlation_id <> <<login_len::size(8)>>



    res = res <> login <> <<pass_len::size(8)>> <> password <> data

    size = byte_size(res)

    <<size::32-unsigned-little-integer>> <> res

  end

end