Packages

spear

0.9.0
1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.2 1.0.1 1.0.0 0.11.0 0.10.0 0.10.0-rc.1 0.9.1 0.9.0 0.8.1 0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A sharp EventStoreDB 20+ client backed by mint

HexDocs

Current section

Files

Jump to
Readme
31 Versions
4 Dependencies
Dependants
Files
Activity
spear lib spear rpc.ex
Raw

lib/spear/rpc.ex 

defmodule Spear.Rpc do

  @moduledoc false

  require Record



  # simple struct for an RPC definiton, used by Spear.Service



  @type t :: %__MODULE__{}



  defstruct [

    :request_type,

    :response_type,

    :request_stream?,

    :response_stream?,

    :path,

    :name,

    :service,

    :service_module

  ]



  Record.defrecordp(:rpc, Record.extract(:rpc, from_lib: "gpb/include/gpb.hrl"))



  def expand(service_module, service, rpc) do

    rpc(name: ^rpc) = this_rpc = service_module.fetch_rpc_def(service, rpc)



    %__MODULE__{

      name: rpc(this_rpc, :name),

      request_type: rpc(this_rpc, :input),

      request_stream?: rpc(this_rpc, :input_stream),

      response_type: rpc(this_rpc, :output),

      response_stream?: rpc(this_rpc, :output_stream),

      service: service,

      service_module: service_module,

      path: "/#{service}/#{rpc}"

    }

  end

end