MCP server integration + per-conversation vault binding

.gitignore

@@ -26,6 +26,7 @@ vendor/
 .env
 .env.local
 .env.*.local
+.devenv
 
 # Config files (use examples)
 config.json

cmd/server/main.go

@@ -17,6 +17,7 @@ import (
 	"github.com/vultisig/agent-backend/internal/api"
 	"github.com/vultisig/agent-backend/internal/cache/redis"
 	"github.com/vultisig/agent-backend/internal/config"
+	"github.com/vultisig/agent-backend/internal/mcp"
 	"github.com/vultisig/agent-backend/internal/service/agent"
 	mcpclient "github.com/vultisig/agent-backend/internal/service/mcp"
 	"github.com/vultisig/agent-backend/internal/service/plugin"
@@ -72,6 +73,37 @@ func main() {
 	msgRepo := postgres.NewMessageRepository(db.Pool())
 	memRepo := postgres.NewMemoryRepository(db.Pool())
 
+	// Initialize MCP JSON-RPC client for tool discovery and vault operations (optional)
+	var mcpProvider agent.MCPToolProvider
+	if cfg.MCP.ServerURL != "" {
+		cacheTTL := time.Duration(cfg.MCP.ToolCacheTTLSec) * time.Second
+		mcpClient := mcp.NewClient(cfg.MCP.ServerURL, cacheTTL, logger)
+
+		mcpCtx, mcpCancel := context.WithTimeout(ctx, 10*time.Second)
+		defer mcpCancel()
+
+		if err := mcpClient.Initialize(mcpCtx); err != nil {
+			logger.WithError(err).Warn("failed to initialize mcp client, continuing without mcp tools")
+		} else {
+			tools, err := mcpClient.ListTools(mcpCtx)
+			if err != nil {
+				logger.WithError(err).Warn("failed to list mcp tools, continuing without mcp tools")
+			} else {
+				logger.WithField("tool_count", len(tools)).Info("mcp tools loaded")
+				mcpProvider = mcpClient
+			}
+
+			// Pre-warm skill cache (non-fatal)
+			skills, err := mcpClient.ListSkills(mcpCtx)
+			if err != nil {
+				logger.WithError(err).Warn("failed to list mcp skills, continuing without skills")
+			} else {
+				logger.WithField("skill_count", len(skills)).Info("mcp skills loaded")
+			}
+		}
+	}
+
+	// Initialize MCP swap tx builder (optional)
 	var swapTxBuilder agent.SwapTxBuilder
 	if cfg.MCP.URL != "" {
 		mcpCl := mcpclient.NewClient(cfg.MCP.URL)
@@ -80,7 +112,7 @@ func main() {
 	}
 
 	// Initialize agent service
-	agentService := agent.NewAgentService(aiClient, msgRepo, convRepo, memRepo, redisClient, verifierClient, pluginService, swapTxBuilder, logger, cfg.AI.SummaryModel, cfg.Context)
+	agentService := agent.NewAgentService(aiClient, msgRepo, convRepo, memRepo, redisClient, verifierClient, pluginService, mcpProvider, swapTxBuilder, logger, cfg.AI.SummaryModel, cfg.Context)
 
 	// Initialize API server
 	server := api.NewServer(