feat(metadata): add metadata field to A2ARequest and propagate through pipeline service

Author: DavidsonGomes

pkg/ai/model/a2a.go

@@ -3,11 +3,12 @@ package model
 // A2ARequest carries the data needed to call AI Processor via JSON-RPC 2.0.
 // Fields are NOT serialised directly — the adapter builds the wire format.
 type A2ARequest struct {
-	OutgoingURL    string // full A2A endpoint URL from agent_bot.outgoing_url
-	ContactID      int64  // used for userId in JSON-RPC params
-	ConversationID int64  // used for contextId in JSON-RPC params
-	ApiKey         string // used for X-API-Key header (per-event auth)
-	Message        string // aggregated buffer content (FR-15)
+	OutgoingURL    string         // full A2A endpoint URL from agent_bot.outgoing_url
+	ContactID      int64          // used for userId in JSON-RPC params
+	ConversationID int64          // used for contextId in JSON-RPC params
+	ApiKey         string         // used for X-API-Key header (per-event auth)
+	Message        string         // aggregated buffer content (FR-15)
+	Metadata       map[string]any // CRM metadata passed through to processor (tools context)
 }
 
 // jsonRPCRequest is the JSON-RPC 2.0 envelope sent to AI Processor.

pkg/ai/service/ai_adapter.go

@@ -62,7 +62,7 @@ func (a *aiAdapter) Call(ctx context.Context, req *model.A2ARequest) (*model.Nor
 					{Type: "text", Text: req.Message},
 				},
 			},
-			Metadata: map[string]any{},
+			Metadata: nonNilMetadata(req.Metadata),
 		},
 	}
 
@@ -141,3 +141,11 @@ func extractResponseText(resp *model.A2AResponse) string {
 	}
 	return ""
 }
+
+// nonNilMetadata ensures metadata is never nil (avoids "null" in JSON).
+func nonNilMetadata(m map[string]any) map[string]any {
+	if m == nil {
+		return map[string]any{}
+	}
+	return m
+}

pkg/pipeline/service/pipeline_service.go

@@ -166,6 +166,7 @@ func (s *pipelineService) startDebounce(ctx context.Context, event *model.Messag
 		postbackURL: event.PostbackURL,
 		outgoingURL: event.OutgoingURL,
 		apiKey:      event.ApiKey,
+		metadata:    event.Metadata,
 	})
 
 	if err := s.debounce.Start(ctx, event.ContactID, event.ConversationID, event.MessageContent, event.BotConfig); err != nil {
@@ -183,6 +184,7 @@ func (s *pipelineService) startDebounce(ctx context.Context, event *model.Messag
 		PostbackURL: event.PostbackURL,
 		OutgoingURL: event.OutgoingURL,
 		ApiKey:      event.ApiKey,
+		Metadata:    event.Metadata,
 	}
 	if err := s.repo.SetState(ctx, event.ContactID, event.ConversationID, newState); err != nil {
 		cancel()
@@ -209,6 +211,7 @@ func (s *pipelineService) skipDebounce(ctx context.Context, event *model.Message
 		postbackURL: event.PostbackURL,
 		outgoingURL: event.OutgoingURL,
 		apiKey:      event.ApiKey,
+		metadata:    event.Metadata,
 	})
 
 	// debounce.Start appends to buffer; DebounceTime=0 means no timer (Story 2.1).
@@ -340,13 +343,15 @@ func (s *pipelineService) runAIStage(ctx context.Context, contactID, conversatio
 	)
 	start := time.Now()
 
-	// Retrieve outgoing_url and api_key from the pipeline entry.
+	// Retrieve outgoing_url, api_key and metadata from the pipeline entry.
 	key := pairKey(contactID, conversationID)
 	var outgoingURL, apiKey string
+	var metadata map[string]any
 	if v, ok := s.entries.Load(key); ok {
 		if entry, ok := v.(pipelineEntry); ok {
 			outgoingURL = entry.outgoingURL
 			apiKey = entry.apiKey
+			metadata = entry.metadata
 		}
 	}
 
@@ -356,6 +361,7 @@ func (s *pipelineService) runAIStage(ctx context.Context, contactID, conversatio
 		ConversationID: conversationID,
 		ApiKey:         apiKey,
 		Message:        buffer,
+		Metadata:       metadata,
 	})
 	if err != nil {
 		switch {