From aef70bec7fc5f4902f279be527f4a9cb19ada475 Mon Sep 17 00:00:00 2001
From: Joseph Doherty <dohejw01@gmail.com>
Date: Thu, 19 Mar 2026 11:25:36 -0400
Subject: [PATCH] feat(infra): wire up Program.cs with CLI args, env vars, and
 OPC UA bridge startup

---
 infra/lmxfakeproxy/Program.cs | 54 ++++++++++++++++++++++++++++++++++-
 1 file changed, 53 insertions(+), 1 deletion(-)

diff --git a/infra/lmxfakeproxy/Program.cs b/infra/lmxfakeproxy/Program.cs
index 933d130..c5a8fa0 100644
--- a/infra/lmxfakeproxy/Program.cs
+++ b/infra/lmxfakeproxy/Program.cs
@@ -1,5 +1,57 @@
+using LmxFakeProxy;
+using LmxFakeProxy.Bridge;
+using LmxFakeProxy.Services;
+using LmxFakeProxy.Sessions;
+
 var builder = WebApplication.CreateBuilder(args);
+
+// Configuration: env vars take precedence over CLI args
+var port = Environment.GetEnvironmentVariable("PORT") ?? GetArg(args, "--port") ?? "50051";
+var opcEndpoint = Environment.GetEnvironmentVariable("OPC_ENDPOINT") ?? GetArg(args, "--opc-endpoint") ?? "opc.tcp://localhost:50000";
+var opcPrefix = Environment.GetEnvironmentVariable("OPC_PREFIX") ?? GetArg(args, "--opc-prefix") ?? "ns=3;s=";
+var apiKey = Environment.GetEnvironmentVariable("API_KEY") ?? GetArg(args, "--api-key");
+
+builder.WebHost.ConfigureKestrel(options =>
+{
+    options.ListenAnyIP(int.Parse(port), listenOptions =>
+    {
+        listenOptions.Protocols = Microsoft.AspNetCore.Server.Kestrel.Core.HttpProtocols.Http2;
+    });
+});
+
+// Register services
+builder.Services.AddSingleton(new SessionManager(apiKey));
+builder.Services.AddSingleton(new TagMapper(opcPrefix));
+builder.Services.AddSingleton<IOpcUaBridge>(sp =>
+    new OpcUaBridge(opcEndpoint, sp.GetRequiredService<ILogger<OpcUaBridge>>()));
 builder.Services.AddGrpc();
+
 var app = builder.Build();
+
+app.MapGrpcService<ScadaServiceImpl>();
 app.MapGet("/", () => "LmxFakeProxy is running");
-app.Run();
+
+// Connect to OPC UA backend
+var logger = app.Services.GetRequiredService<ILogger<Program>>();
+logger.LogInformation("LmxFakeProxy starting on port {Port}", port);
+logger.LogInformation("OPC UA endpoint: {Endpoint}, prefix: {Prefix}", opcEndpoint, opcPrefix);
+logger.LogInformation("API key enforcement: {Enforced}", apiKey != null ? "enabled" : "disabled (accept all)");
+
+var bridge = app.Services.GetRequiredService<IOpcUaBridge>();
+try
+{
+    await ((OpcUaBridge)bridge).ConnectAsync();
+    logger.LogInformation("OPC UA bridge connected");
+}
+catch (Exception ex)
+{
+    logger.LogWarning(ex, "Initial OPC UA connection failed — will retry when first request arrives");
+}
+
+await app.RunAsync();
+
+static string? GetArg(string[] args, string name)
+{
+    var idx = Array.IndexOf(args, name);
+    return idx >= 0 && idx + 1 < args.Length ? args[idx + 1] : null;
+}