Skip to content

Commit a31448d

Browse files
samaaronsamaaron
committed
Tidy - further line ending fixes
1 parent 9b9ca42 commit a31448d

2 files changed

Lines changed: 163 additions & 163 deletions

File tree

‎server/lib/tau5/startup_info.ex‎

Lines changed: 155 additions & 155 deletions
Original file line numberDiff line numberDiff line change
@@ -1,155 +1,155 @@
1-
defmodule Tau5.StartupInfo do
2-
@moduledoc """
3-
Reports server startup information to the parent process (GUI/tau5-node).
4-
This is done as a separate task after the supervision tree starts to ensure
5-
all endpoints are properly initialized and have their actual ports allocated.
6-
"""
7-
8-
require Logger
9-
10-
def report_server_info() do
11-
http_port = get_http_port()
12-
13-
# Wait for Phoenix to actually be ready to serve requests before signaling GUI
14-
if http_port > 0 do
15-
wait_for_http_ready(http_port)
16-
end
17-
18-
pid = System.pid()
19-
heartbeat_port = Tau5.Heartbeat.get_port()
20-
mcp_port = get_mcp_port()
21-
22-
IO.puts(
23-
"[TAU5_SERVER_INFO:PID=#{pid},HTTP_PORT=#{http_port},HEARTBEAT_PORT=#{heartbeat_port},MCP_PORT=#{mcp_port}]"
24-
)
25-
26-
Logger.info(
27-
"Server started - PID: #{pid}, HTTP: #{http_port}, Heartbeat: #{heartbeat_port}, MCP: #{mcp_port}"
28-
)
29-
end
30-
31-
defp wait_for_http_ready(port, attempt \\ 1) do
32-
# Request the health endpoint to verify Phoenix is ready
33-
# Include session token to bypass InternalEndpointSecurity
34-
token = Application.get_env(:tau5, :session_token)
35-
url = if token do
36-
~c"http://127.0.0.1:#{port}/health?token=#{token}"
37-
else
38-
~c"http://127.0.0.1:#{port}/health"
39-
end
40-
41-
# Use full response format and disable automatic redirect following
42-
http_options = [{:timeout, 5000}, {:connect_timeout, 2000}, {:autoredirect, false}]
43-
options = [{:body_format, :binary}]
44-
45-
result = :httpc.request(:get, {url, []}, http_options, options)
46-
47-
case result do
48-
{:ok, {{_, 200, _}, _, _}} ->
49-
if attempt > 1, do: IO.write(" ready\n")
50-
Logger.debug("Phoenix ready after #{attempt * 100}ms")
51-
:ok
52-
53-
{:error, reason} when attempt < 80 ->
54-
# Show progress dots
55-
if attempt == 1, do: IO.write("Waiting for Phoenix")
56-
if rem(attempt, 10) == 0 do
57-
Logger.debug("Health check error (attempt #{attempt}): #{inspect(reason)}")
58-
end
59-
IO.write(".")
60-
61-
# Wait 100ms and retry (max 8 seconds total)
62-
Process.sleep(100)
63-
wait_for_http_ready(port, attempt + 1)
64-
65-
other when attempt < 80 ->
66-
# Show progress dots for unexpected responses
67-
if attempt == 1, do: IO.write("Waiting for Phoenix")
68-
if rem(attempt, 10) == 0 do
69-
Logger.debug("Health check unexpected response (attempt #{attempt}): #{inspect(other)}")
70-
end
71-
IO.write(".")
72-
73-
# Wait 100ms and retry (max 8 seconds total)
74-
Process.sleep(100)
75-
wait_for_http_ready(port, attempt + 1)
76-
77-
_ ->
78-
IO.write(" timeout\n")
79-
Logger.warning("Phoenix not responding after 8 seconds, last result: #{inspect(result)}")
80-
:ok
81-
end
82-
end
83-
84-
@doc """
85-
Reports a startup error to the parent process and then halts.
86-
"""
87-
def report_startup_error(message) do
88-
IO.puts("[TAU5_SERVER_ERROR:#{message}]")
89-
Logger.error("Server startup failed: #{message}")
90-
System.halt(1)
91-
end
92-
93-
defp get_http_port do
94-
if System.get_env("TAU5_NO_LOCAL_ENDPOINT") == "true" do
95-
0
96-
else
97-
get_actual_server_port()
98-
end
99-
end
100-
101-
defp get_mcp_port do
102-
if mcp_enabled?() do
103-
case System.get_env("TAU5_MCP_PORT") do
104-
port_str when is_binary(port_str) ->
105-
case Integer.parse(port_str) do
106-
{port, ""} -> port
107-
_ -> Application.get_env(:tau5, :mcp_port, 5555)
108-
end
109-
110-
_ ->
111-
Application.get_env(:tau5, :mcp_port, 5555)
112-
end
113-
else
114-
0
115-
end
116-
end
117-
118-
defp mcp_enabled? do
119-
case System.get_env("TAU5_MCP_ENABLED") do
120-
"true" -> true
121-
"false" -> false
122-
_ -> Application.get_env(:tau5, :mcp_enabled, true)
123-
end
124-
end
125-
126-
defp get_actual_server_port do
127-
case Tau5Web.Endpoint.server_info(:http) do
128-
{:ok, {_address, port}} when is_integer(port) and port > 0 ->
129-
Logger.debug("Got actual port from server_info: #{port}")
130-
port
131-
132-
{:error, reason} ->
133-
Logger.warning("Could not get server info: #{inspect(reason)}")
134-
get_configured_port()
135-
136-
other ->
137-
Logger.warning("Unexpected server_info response: #{inspect(other)}")
138-
get_configured_port()
139-
end
140-
end
141-
142-
defp get_configured_port do
143-
case Application.get_env(:tau5, Tau5Web.Endpoint)[:http][:port] do
144-
0 ->
145-
Logger.warning("Could not determine actual allocated port")
146-
0
147-
148-
port when is_integer(port) ->
149-
port
150-
151-
_ ->
152-
0
153-
end
154-
end
155-
end
1+
defmodule Tau5.StartupInfo do
2+
@moduledoc """
3+
Reports server startup information to the parent process (GUI/tau5-node).
4+
This is done as a separate task after the supervision tree starts to ensure
5+
all endpoints are properly initialized and have their actual ports allocated.
6+
"""
7+
8+
require Logger
9+
10+
def report_server_info() do
11+
http_port = get_http_port()
12+
13+
# Wait for Phoenix to actually be ready to serve requests before signaling GUI
14+
if http_port > 0 do
15+
wait_for_http_ready(http_port)
16+
end
17+
18+
pid = System.pid()
19+
heartbeat_port = Tau5.Heartbeat.get_port()
20+
mcp_port = get_mcp_port()
21+
22+
IO.puts(
23+
"[TAU5_SERVER_INFO:PID=#{pid},HTTP_PORT=#{http_port},HEARTBEAT_PORT=#{heartbeat_port},MCP_PORT=#{mcp_port}]"
24+
)
25+
26+
Logger.info(
27+
"Server started - PID: #{pid}, HTTP: #{http_port}, Heartbeat: #{heartbeat_port}, MCP: #{mcp_port}"
28+
)
29+
end
30+
31+
defp wait_for_http_ready(port, attempt \\ 1) do
32+
# Request the health endpoint to verify Phoenix is ready
33+
# Include session token to bypass InternalEndpointSecurity
34+
token = Application.get_env(:tau5, :session_token)
35+
url = if token do
36+
~c"http://127.0.0.1:#{port}/health?token=#{token}"
37+
else
38+
~c"http://127.0.0.1:#{port}/health"
39+
end
40+
41+
# Use full response format and disable automatic redirect following
42+
http_options = [{:timeout, 5000}, {:connect_timeout, 2000}, {:autoredirect, false}]
43+
options = [{:body_format, :binary}]
44+
45+
result = :httpc.request(:get, {url, []}, http_options, options)
46+
47+
case result do
48+
{:ok, {{_, 200, _}, _, _}} ->
49+
if attempt > 1, do: IO.write(" ready\n")
50+
Logger.debug("Phoenix ready after #{attempt * 100}ms")
51+
:ok
52+
53+
{:error, reason} when attempt < 80 ->
54+
# Show progress dots
55+
if attempt == 1, do: IO.write("Waiting for Phoenix")
56+
if rem(attempt, 10) == 0 do
57+
Logger.debug("Health check error (attempt #{attempt}): #{inspect(reason)}")
58+
end
59+
IO.write(".")
60+
61+
# Wait 100ms and retry (max 8 seconds total)
62+
Process.sleep(100)
63+
wait_for_http_ready(port, attempt + 1)
64+
65+
other when attempt < 80 ->
66+
# Show progress dots for unexpected responses
67+
if attempt == 1, do: IO.write("Waiting for Phoenix")
68+
if rem(attempt, 10) == 0 do
69+
Logger.debug("Health check unexpected response (attempt #{attempt}): #{inspect(other)}")
70+
end
71+
IO.write(".")
72+
73+
# Wait 100ms and retry (max 8 seconds total)
74+
Process.sleep(100)
75+
wait_for_http_ready(port, attempt + 1)
76+
77+
_ ->
78+
IO.write(" timeout\n")
79+
Logger.warning("Phoenix not responding after 8 seconds, last result: #{inspect(result)}")
80+
:ok
81+
end
82+
end
83+
84+
@doc """
85+
Reports a startup error to the parent process and then halts.
86+
"""
87+
def report_startup_error(message) do
88+
IO.puts("[TAU5_SERVER_ERROR:#{message}]")
89+
Logger.error("Server startup failed: #{message}")
90+
System.halt(1)
91+
end
92+
93+
defp get_http_port do
94+
if System.get_env("TAU5_NO_LOCAL_ENDPOINT") == "true" do
95+
0
96+
else
97+
get_actual_server_port()
98+
end
99+
end
100+
101+
defp get_mcp_port do
102+
if mcp_enabled?() do
103+
case System.get_env("TAU5_MCP_PORT") do
104+
port_str when is_binary(port_str) ->
105+
case Integer.parse(port_str) do
106+
{port, ""} -> port
107+
_ -> Application.get_env(:tau5, :mcp_port, 5555)
108+
end
109+
110+
_ ->
111+
Application.get_env(:tau5, :mcp_port, 5555)
112+
end
113+
else
114+
0
115+
end
116+
end
117+
118+
defp mcp_enabled? do
119+
case System.get_env("TAU5_MCP_ENABLED") do
120+
"true" -> true
121+
"false" -> false
122+
_ -> Application.get_env(:tau5, :mcp_enabled, true)
123+
end
124+
end
125+
126+
defp get_actual_server_port do
127+
case Tau5Web.Endpoint.server_info(:http) do
128+
{:ok, {_address, port}} when is_integer(port) and port > 0 ->
129+
Logger.debug("Got actual port from server_info: #{port}")
130+
port
131+
132+
{:error, reason} ->
133+
Logger.warning("Could not get server info: #{inspect(reason)}")
134+
get_configured_port()
135+
136+
other ->
137+
Logger.warning("Unexpected server_info response: #{inspect(other)}")
138+
get_configured_port()
139+
end
140+
end
141+
142+
defp get_configured_port do
143+
case Application.get_env(:tau5, Tau5Web.Endpoint)[:http][:port] do
144+
0 ->
145+
Logger.warning("Could not determine actual allocated port")
146+
0
147+
148+
port when is_integer(port) ->
149+
port
150+
151+
_ ->
152+
0
153+
end
154+
end
155+
end

‎server/lib/tau5_web/controllers/health_controller.ex‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
defmodule Tau5Web.HealthController do
2-
use Tau5Web, :controller
3-
4-
def index(conn, _params) do
5-
# Minimal health check - if we can respond, Phoenix is ready to serve
6-
text(conn, "ok")
7-
end
8-
end
1+
defmodule Tau5Web.HealthController do
2+
use Tau5Web, :controller
3+
4+
def index(conn, _params) do
5+
# Minimal health check - if we can respond, Phoenix is ready to serve
6+
text(conn, "ok")
7+
end
8+
end

0 commit comments

Comments
 (0)