Packages

pi_bridge

0.6.21
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
11 Dependencies
0 Dependants
Files
Activity
pi_bridge lib pi mcp server.ex
Raw

lib/pi/mcp/server.ex 

defmodule Pi.MCP.Server do

  @moduledoc "Starts the embedded MCP server inside the project Mix context."



  alias Pi.MCP.Router



  def start!(args \\ System.argv()) do

    port = parse_port(args)



    Pi.LogCapture.install()

    Process.flag(:trap_exit, true)



    {actual_port, http_server} = start_http(port)

    wait_until_accepting(actual_port)

    IO.puts("PI_MCP_READY port=#{actual_port} server=#{http_server}")



    receive do

      :stop -> :ok

    end

  end



  defp parse_port(["--port", port | _]), do: String.to_integer(port)

  defp parse_port(_), do: 4041



  defp start_http(port) do

    {:ok, server} = Bandit.start_link(plug: Router, port: port, ip: :loopback)

    actual_port = if port == 0, do: listener_port(server), else: port

    {actual_port, :bandit}

  end



  defp listener_port(server) do

    {:ok, {_, port}} = ThousandIsland.listener_info(server)

    port

  end



  defp wait_until_accepting(port) do

    Enum.reduce_while(1..50, nil, fn _, _ ->

      case :gen_tcp.connect(~c"127.0.0.1", port, [], 100) do

        {:ok, socket} ->

          :gen_tcp.close(socket)

          {:halt, :ok}



        {:error, _} ->

          Process.sleep(100)

          {:cont, nil}

      end

    end)

  end

end