fix(a2a): usar UUID do contato como userId (corrige 500 Session not found)

Segunda metade do fix de chaveamento de sessão (o commit anterior corrigiu o
session_id via contextId; este corrige o user_id).

A sessão ADK do Processor é chaveada por (app_name, user_id, session_id). O
SessionSync do CRM pré-cria/persiste essa sessão usando o UUID do contato como
user_id. Mas o bot_runtime enviava o ContactID numérico como userId, então o run
a2a buscava a sessão com user_id numérico enquanto a linha persistida tinha o
UUID do contato. Resultado: get_session_by_id (que ignora user_id) achava a
sessão e logava o histórico, mas o runner do ADK (que exige user_id) levantava
"Session not found" → 500 → o agente nunca respondia, mesmo com a sessão e o
histórico existindo.

Correção: extrair o UUID do contato de metadata.evoai_crm_data.contact.id e
usá-lo como userId, com fallback para o ContactID numérico quando o metadata
estiver ausente. Mesmo padrão de extração e fallback do fix do contextId. Isso
alinha os três pontos: escrita do SessionSync, criação e leitura do runner.
O caller Rails (http_request_service) já enviava o contact UUID (sender.id);
este fix alinha o bot_runtime ao mesmo padrão.

Testes: pkg/ai/service passa, cobrindo userId UUID e fallback numérico.

Author: DavidsonGomes

pkg/ai/service/ai_adapter.go

@@ -57,13 +57,22 @@ func (a *aiAdapter) Call(ctx context.Context, req *model.A2ARequest) (*model.Nor
 	// to the numeric ID only when the metadata is absent (e.g. legacy callers).
 	contextID := conversationContextID(req.Metadata, req.ConversationID)
 
+	// userId MUST be the contact UUID, not the numeric ContactID. The Processor's
+	// ADK session is keyed on (app_name, user_id, session_id). The CRM's SessionSync
+	// pre-creates/persists that session with the contact UUID as user_id, so when the
+	// a2a run looks it up with the numeric ContactID the keys diverge and the runner
+	// raises "Session not found" → 500 → the agent never replies (even though the
+	// session and its history exist). Prefer the contact UUID from the CRM metadata;
+	// fall back to the numeric ID only when the metadata is absent (legacy callers).
+	userID := contactUserID(req.Metadata, req.ContactID)
+
 	rpcReq := model.JSONRPCRequest{
 		JSONRPC: "2.0",
 		ID:      fmt.Sprintf("%d:%d", req.ContactID, req.ConversationID),
 		Method:  "message/send",
 		Params: model.JSONRPCParams{
 			ContextID: contextID,
-			UserID:    fmt.Sprintf("%d", req.ContactID),
+			UserID:    userID,
 			Message: model.JSONRPCMessage{
 				Role: "user",
 				Parts: []model.JSONRPCPart{
@@ -187,3 +196,32 @@ func extractConversationUUID(metadata map[string]any) string {
 	}
 	return id
 }
+
+// contactUserID resolves the userId for the JSON-RPC call. It reads the contact
+// UUID the CRM nests at metadata.evoai_crm_data.contact.id (the same value the CRM's
+// SessionSync uses as the ADK session user_id) and returns it; if any hop is missing
+// or empty it falls back to the numeric contact ID (legacy behaviour).
+func contactUserID(metadata map[string]any, contactID int64) string {
+	if uuid := extractContactUUID(metadata); uuid != "" {
+		return uuid
+	}
+	return fmt.Sprintf("%d", contactID)
+}
+
+// extractContactUUID digs metadata.evoai_crm_data.contact.id out of the untyped CRM
+// metadata map. Returns "" when the path is absent or not a string.
+func extractContactUUID(metadata map[string]any) string {
+	crmData, ok := metadata["evoai_crm_data"].(map[string]any)
+	if !ok {
+		return ""
+	}
+	contact, ok := crmData["contact"].(map[string]any)
+	if !ok {
+		return ""
+	}
+	id, ok := contact["id"].(string)
+	if !ok {
+		return ""
+	}
+	return id
+}

pkg/ai/service/ai_adapter_test.go

@@ -16,14 +16,19 @@ import (
 )
 
 // crmMetadata builds the nested CRM metadata map the Rails AgentBotListener sends,
-// carrying the conversation UUID at evoai_crm_data.conversation.id.
-func crmMetadata(conversationUUID string) map[string]any {
+// carrying the conversation UUID at evoai_crm_data.conversation.id and the contact
+// UUID at evoai_crm_data.contact.id.
+func crmMetadata(conversationUUID, contactUUID string) map[string]any {
 	return map[string]any{
 		"evoai_crm_data": map[string]any{
 			"conversation": map[string]any{
 				"id":         conversationUUID,
 				"display_id": 7,
 			},
+			"contact": map[string]any{
+				"id":   contactUUID,
+				"name": "Davidson Gomes",
+			},
 		},
 	}
 }
@@ -58,8 +63,9 @@ func TestCall_Success(t *testing.T) {
 		if req.Params.ContextID != "conv-uuid-abc" {
 			t.Errorf("req.Params.ContextID = %q, want %q", req.Params.ContextID, "conv-uuid-abc")
 		}
-		if req.Params.UserID != "42" {
-			t.Errorf("req.Params.UserID = %q, want %q", req.Params.UserID, "42")
+		// userId must be the contact UUID from metadata, not the numeric ContactID.
+		if req.Params.UserID != "contact-uuid-xyz" {
+			t.Errorf("req.Params.UserID = %q, want %q", req.Params.UserID, "contact-uuid-xyz")
 		}
 		if len(req.Params.Message.Parts) != 1 || req.Params.Message.Parts[0].Text != "hello world" {
 			t.Errorf("message parts = %+v, want single part with text 'hello world'", req.Params.Message.Parts)
@@ -86,7 +92,7 @@ func TestCall_Success(t *testing.T) {
 		ContactID:      42,
 		ConversationID: 7,
 		ApiKey:         "test-key",
-		Metadata:       crmMetadata("conv-uuid-abc"),
+		Metadata:       crmMetadata("conv-uuid-abc", "contact-uuid-xyz"),
 	})
 	if err != nil {
 		t.Fatalf("Call returned unexpected error: %v", err)
@@ -108,6 +114,10 @@ func TestCall_ContextID_FallsBackToNumericID(t *testing.T) {
 		if req.Params.ContextID != "7" {
 			t.Errorf("req.Params.ContextID = %q, want fallback %q", req.Params.ContextID, "7")
 		}
+		// Without metadata, userId falls back to the numeric ContactID.
+		if req.Params.UserID != "42" {
+			t.Errorf("req.Params.UserID = %q, want fallback %q", req.Params.UserID, "42")
+		}
 		json.NewEncoder(w).Encode(aiModel.A2AResponse{
 			Result: &aiModel.A2AResult{
 				Artifacts: []aiModel.A2AArtifact{
@@ -122,9 +132,10 @@ func TestCall_ContextID_FallsBackToNumericID(t *testing.T) {
 	_, err := adapter.Call(context.Background(), &aiModel.A2ARequest{
 		OutgoingURL:    server.URL,
 		Message:        "test",
+		ContactID:      42,
 		ConversationID: 7,
 		ApiKey:         "key",
-		// No Metadata → must fall back to the numeric ConversationID.
+		// No Metadata → must fall back to the numeric ConversationID/ContactID.
 	})
 	if err != nil {
 		t.Fatalf("Call returned unexpected error: %v", err)