Packages

pi_bridge

0.8.3
0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.22 0.6.21 0.6.20 0.6.19 0.6.18 0.6.17 0.6.16 0.6.15 0.6.14 0.6.13 0.6.12 0.6.11 0.6.10 0.6.9 0.6.8 0.6.7 0.6.6 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.4 0.5.3 0.1.0

BEAM runtime bridge for pi development agents

HexDocs

Current section

Files

Jump to
Readme
33 Versions
13 Dependencies
0 Dependants
Files
Activity
pi_bridge lib pi transport.ex
Raw

lib/pi/transport.ex 

defmodule Pi.Transport do

  @moduledoc "Process-safe outbound boundary for the active extension transport."



  alias Pi.ProcessOwner

  alias Pi.Protocol.Request

  alias Pi.Transport.Payload



  @spec register(pid()) :: :ok

  def register(owner), do: ProcessOwner.register(__MODULE__, owner)



  @spec unregister(pid()) :: :ok

  def unregister(owner), do: ProcessOwner.unregister(__MODULE__, owner)



  @spec request(String.t(), atom(), map()) :: :ok

  def request(id, operation, payload)

      when is_binary(id) and is_atom(operation) and is_map(payload) do

    emit(%Request{type: :request, id: id, op: operation, payload: payload})

  end



  @spec emit(map() | struct()) :: :ok

  def emit(payload) when is_map(payload) do

    ProcessOwner.notify(__MODULE__, {:pi_transport_emit, Payload.encode(payload)})

  end

end