gofmt updates

Author: slimslenderslacks

cmd/docker-mcp/internal/gateway/clientpool.go

@@ -353,8 +353,6 @@ func (cg *clientGetter) GetClient(ctx context.Context) (mcpclient.Client, error)
 				var readOnly *bool
 				if cg.clientConfig != nil {
 					readOnly = cg.clientConfig.readOnly
-				} else {
-					readOnly = nil
 				}
 				args, env := cg.cp.argsAndEnv(cg.serverConfig, readOnly, targetConfig)
 
@@ -381,15 +379,11 @@ func (cg *clientGetter) GetClient(ctx context.Context) (mcpclient.Client, error)
 				},
 			}
 
-			// Use the original context instead of creating a timeout context
-			// to avoid cancellation issues
 			var ss *mcp.ServerSession
 			var server *mcp.Server
 			if cg.clientConfig != nil {
 				ss = cg.clientConfig.serverSession
 				server = cg.clientConfig.server
-			} else {
-				ss = nil
 			}
 			if err := client.Initialize(ctx, initParams, cg.cp.Verbose, ss, server); err != nil {
 				return nil, err

cmd/docker-mcp/internal/gateway/run.go

@@ -17,21 +17,21 @@ import (
 )
 
 type ServerSessionCache struct {
-	Roots          []*mcp.Root
+	Roots []*mcp.Root
 }
 
-type SubsAction int
+// type SubsAction int
 
-const (
-	subscribe SubsAction = 0
-	unsubscribe SubsAction = 1
-)
+// const (
+// subscribe   SubsAction = 0
+// unsubscribe SubsAction = 1
+// )
 
-type SubsMessage struct {
-	uri string
-	action SubsAction
-	ss *mcp.ServerSession
-}
+// type SubsMessage struct {
+// uri    string
+// action SubsAction
+// ss     *mcp.ServerSession
+// }
 
 type Gateway struct {
 	Options
@@ -40,7 +40,7 @@ type Gateway struct {
 	clientPool   *clientPool
 	mcpServer    *mcp.Server
 	health       health.State
-	subsChannel  chan SubsMessage
+	// subsChannel  chan SubsMessage
 
 	sessionCacheMu sync.RWMutex
 	sessionCache   map[*mcp.ServerSession]*ServerSessionCache
@@ -63,7 +63,6 @@ func NewGateway(config Config, docker docker.Client) *Gateway {
 		},
 		clientPool:   newClientPool(config.Options, docker),
 		sessionCache: make(map[*mcp.ServerSession]*ServerSessionCache),
-		subsChannel:  make(chan SubsMessage, 10),
 	}
 }
 
@@ -113,26 +112,26 @@ func (g *Gateway) Run(ctx context.Context) error {
 		Name:    "Docker AI MCP Gateway",
 		Version: "2.0.1",
 	}, &mcp.ServerOptions{
-		SubscribeHandler: func(ctx context.Context, ss *mcp.ServerSession, params *mcp.SubscribeParams) error {
+		SubscribeHandler: func(_ context.Context, _ *mcp.ServerSession, params *mcp.SubscribeParams) error {
 			log("- Client subscribed to URI:", params.URI)
 			// The MCP SDK doesn't provide ServerSession in SubscribeHandler because it already
 			// keeps track of the mapping between ServerSession and subscribed resources in the Server
 			// g.subsChannel <- SubsMessage{uri: params.URI, action: subscribe , ss: ss}
 			return nil
 		},
-		UnsubscribeHandler: func(ctx context.Context, ss *mcp.ServerSession, params *mcp.UnsubscribeParams) error {
+		UnsubscribeHandler: func(_ context.Context, _ *mcp.ServerSession, params *mcp.UnsubscribeParams) error {
 			log("- Client unsubscribed from URI:", params.URI)
 			// The MCP SDK doesn't provide ServerSession in UnsubscribeHandler because it already
 			// keeps track of the mapping ServerSession and subscribed resources in the Server
 			// g.subsChannel <- SubsMessage{uri: params.URI, action: unsubscribe , ss: ss}
 			return nil
 		},
-		RootsListChangedHandler: func(ctx context.Context, ss *mcp.ServerSession, params *mcp.RootsListChangedParams) {
+		RootsListChangedHandler: func(ctx context.Context, ss *mcp.ServerSession, _ *mcp.RootsListChangedParams) {
 			log("- Client roots list changed: ", ss.ID())
 			g.ListRoots(ctx, ss)
 		},
 		CompletionHandler: nil,
-		InitializedHandler: func(ctx context.Context, ss *mcp.ServerSession, params *mcp.InitializedParams) {
+		InitializedHandler: func(ctx context.Context, ss *mcp.ServerSession, _ *mcp.InitializedParams) {
 			log("- Client initialized: ", ss.ID())
 			g.ListRoots(ctx, ss)
 		},

cmd/docker-mcp/internal/gateway/transport.go

@@ -147,7 +147,7 @@ func (t *contextAwareStdioTransport) Connect(ctx context.Context) (mcp.Connectio
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return newContextAwareStdioConn(t.ctx, originalConn), nil
 }
 
@@ -174,7 +174,7 @@ func (c *contextAwareStdioConn) Read(ctx context.Context) (jsonrpc.Message, erro
 		msg jsonrpc.Message
 		err error
 	}
-	
+
 	ch := make(chan result, 1)
 	go func() {
 		msg, err := c.originalConn.Read(context.Background())

cmd/docker-mcp/internal/mcp/remote.go

@@ -61,10 +61,8 @@ func (c *remoteMCPClient) Initialize(ctx context.Context, _ *mcp.InitializeParam
 
 	switch strings.ToLower(transport) {
 	case "sse":
-		// TODO: Need to implement custom HTTP client with headers for SSE
 		mcpTransport = mcp.NewSSEClientTransport(url, &mcp.SSEClientTransportOptions{})
 	case "http", "streamable", "streaming", "streamable-http":
-		// TODO: Need to implement custom HTTP client with headers for streaming
 		mcpTransport = mcp.NewStreamableClientTransport(url, &mcp.StreamableClientTransportOptions{})
 	default:
 		return fmt.Errorf("unsupported remote transport: %s", transport)

cmd/docker-mcp/internal/mcp/stdio.go

@@ -47,7 +47,7 @@ func (c *stdioMCPClient) Initialize(ctx context.Context, _ *mcp.InitializeParams
 	c.client = mcp.NewClient(&mcp.Implementation{
 		Name:    "docker-mcp-gateway",
 		Version: "1.0.0",
-	}, notifications(ss,server))
+	}, notifications(ss, server))
 
 	session, err := c.client.Connect(ctx, transport)
 	if err != nil {