Packages

extreme

0.13.1
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 message_resolver.ex
Raw

lib/message_resolver.ex 

defmodule Extreme.MessageResolver do

  # https://github.com/EventStore/EventStore/blob/master/src/EventStore.ClientAPI/SystemData/TcpCommand.cs

  alias Extreme.Msg, as: Msg



  ## Encode



  def encode_cmd(:heartbeat_response), do: 0x02

  def encode_cmd(:ping), do: 0x03



  # def encode_cmd(:prepare_ack), do: 0x05

  # def encode_cmd(:commit_ack), do: 0x06

  # def encode_cmd(:slave_assignment), do: 0x07

  # def encode_cmd(0x08), do: :clone_assignment

  # def encode_cmd(:subscribe_replica), do: 0x10

  # def encode_cmd(:replica_log_position_ack), do: 0x11

  # def encode_cmd(:create_chunk), do: 0x12

  # def encode_cmd(:raw_chunk_bulk), do: 0x13

  # def encode_cmd(:data_chunk_bulk), do: 0x14

  # def encode_cmd(:replica_subscription_retry), do: 0x15

  # def encode_cmd(:replica_subscribed), do: 0x16

  # def encode_cmd(:create_stream), do: 0x80

  # def encode_cmd(:create_stream_completed), do: 0x81



  # def decode_cmd(0x82), do: Msg.WriteEvents

  # def encode_cmd(Msg.WriteEventsCompleted), do: 0x83



  def encode_cmd(Msg.WriteEvents), do: 0x82

  def encode_cmd(Msg.TransactionStart), do: 0x84

  def encode_cmd(Msg.TransactionWrite), do: 0x86

  def encode_cmd(Msg.TransactionCommit), do: 0x88

  def encode_cmd(Msg.DeleteStream), do: 0x8A



  def encode_cmd(Msg.ReadEvent), do: 0xB0

  def encode_cmd(Msg.ReadStreamEvents), do: 0xB2

  def encode_cmd(Msg.ReadStreamEventsBackward), do: 0xB4

  def encode_cmd(:read_all_events_forward), do: 0xB6

  def encode_cmd(:read_all_events_forward_completed), do: 0xB7

  def encode_cmd(:read_all_events_backward), do: 0xB8

  def encode_cmd(:read_all_events_backward_completed), do: 0xB9



  def encode_cmd(Msg.SubscribeToStream), do: 0xC0

  def encode_cmd(:unsubscribe_from_stream), do: 0xC3

  def encode_cmd(Msg.ConnectToPersistentSubscription), do: 0xC5

  def encode_cmd(Msg.CreatePersistentSubscription), do: 0xC8

  def encode_cmd(Msg.DeletePersistentSubscription), do: 0xCA

  def encode_cmd(Msg.DeletePersistentSubscriptionCompleted), do: 0xCB

  def encode_cmd(Msg.PersistentSubscriptionAckEvents), do: 0xCC

  def encode_cmd(Msg.PersistentSubscriptionNakEvents), do: 0xCD

  def encode_cmd(:update_persistent_subscription), do: 0xCE

  def encode_cmd(:update_persistent_subscription_completed), do: 0xCF



  def encode_cmd(:scavenge_database), do: 0xD0

  def encode_cmd(:scavenge_database_completed), do: 0xD1



  def encode_cmd(:bad_request), do: 0xF0

  def encode_cmd(:not_handled), do: 0xF1

  def encode_cmd(:authenticate), do: 0xF2

  def encode_cmd(:authenticated), do: 0xF3

  def encode_cmd(:not_authenticated), do: 0xF4

  def encode_cmd(Msg.IdentifyClient), do: 0xF5

  def encode_cmd(:client_identified), do: 0xF6



  ## Decode



  def decode_cmd(0x01), do: :heartbeat_request_command

  def decode_cmd(0x04), do: :pong



  def decode_cmd(0x83), do: Msg.WriteEventsCompleted

  def decode_cmd(0x85), do: Msg.TransactionStartCompleted

  def decode_cmd(0x87), do: Msg.TransactionWriteCompleted

  def decode_cmd(0x89), do: Msg.TransactionCommitCompleted

  def decode_cmd(0x8B), do: Msg.DeleteStreamCompleted



  def decode_cmd(0xB1), do: Msg.ReadEventCompleted

  def decode_cmd(0xB3), do: Msg.ReadStreamEventsCompleted

  def decode_cmd(0xB5), do: Msg.ReadStreamEventsCompleted



  def decode_cmd(0xC1), do: Msg.SubscriptionConfirmation

  def decode_cmd(0xC2), do: Msg.StreamEventAppeared

  def decode_cmd(0xC4), do: Msg.SubscriptionDropped



  def decode_cmd(0xC6), do: Msg.PersistentSubscriptionConfirmation

  def decode_cmd(0xC7), do: Msg.PersistentSubscriptionStreamEventAppeared



  def decode_cmd(0xC9), do: Msg.CreatePersistentSubscriptionCompleted

  def decode_cmd(0xCB), do: Msg.DeletePersistentSubscriptionCompleted



  def decode_cmd(0xF4), do: :not_authenticated

  def decode_cmd(0xF6), do: :client_identified

end