Current section

Files

Jump to
bolty lib boltx bolt_protocol message commit_message.ex
Raw

lib/boltx/bolt_protocol/message/commit_message.ex

defmodule Bolty.BoltProtocol.Message.CommitMessage do
@moduledoc false
alias Bolty.BoltProtocol.MessageEncoder
@signature 0x12
def encode(bolt_version) when is_float(bolt_version) and bolt_version >= 3.0 do
message = []
MessageEncoder.encode(@signature, message)
end
def encode(_) do
{:error,
Bolty.Error.wrap(__MODULE__, %{
code: :unsupported_message_version,
message: "COMMIT message version not supported"
})}
end
end