Added unix-socket support in msgpack Router

cmaglie · web-flow · commit ff72af056597 · 2025-05-23T17:41:04.000+02:00
diff --git a/internal/orchestrator/orchestrator.go b/internal/orchestrator/orchestrator.go
@@ -665,9 +665,10 @@ func getDevices() []string {
 }
 
 func disconnectSerialFromRPCRouter(ctx context.Context, portAddress string) func() {
-	c, err := net.Dial("tcp", ":8900")
+	var msgPackRouterAddr = paths.TempDir().Join("msgpack-router.sock").String()
+	c, err := net.Dial("unix", msgPackRouterAddr)
 	if err != nil {
-		slog.Error("Failed to connect to router", "addr", ":8900", "err", err)
+		slog.Error("Failed to connect to router", "addr", msgPackRouterAddr, "err", err)
 		return func() {}
 	}
 	conn := msgpackrpc.NewConnection(c, c, nil, nil, nil)

Original file line number	Diff line number	Diff line change
`@@ -665,9 +665,10 @@ func getDevices() []string {`
`665`	`665`	`}`
`666`	`666`
`667`	`667`	`func disconnectSerialFromRPCRouter(ctx context.Context, portAddress string) func() {`
`668`		`- c, err := net.Dial("tcp", ":8900")`
	`668`	`+ var msgPackRouterAddr = paths.TempDir().Join("msgpack-router.sock").String()`
	`669`	`+ c, err := net.Dial("unix", msgPackRouterAddr)`
`669`	`670`	`if err != nil {`
`670`		`- slog.Error("Failed to connect to router", "addr", ":8900", "err", err)`
	`671`	`+ slog.Error("Failed to connect to router", "addr", msgPackRouterAddr, "err", err)`
`671`	`672`	`return func() {}`
`672`	`673`	`}`
`673`	`674`	`conn := msgpackrpc.NewConnection(c, c, nil, nil, nil)`