From 7241b2e1030850ba380af3869fb02e4f840c5962 Mon Sep 17 00:00:00 2001 From: thiago bodevan Date: Sun, 2 Aug 2026 21:02:33 -0300 Subject: [PATCH] feat: forward transcribed text to AI processor --- pkg/pipeline/model/pipeline.go | 1 + pkg/pipeline/service/pipeline_service.go | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/pkg/pipeline/model/pipeline.go b/pkg/pipeline/model/pipeline.go index 583ad2c..77873c5 100644 --- a/pkg/pipeline/model/pipeline.go +++ b/pkg/pipeline/model/pipeline.go @@ -45,6 +45,7 @@ type MessageEvent struct { ContactID int64 `json:"contact_id"` MessageID string `json:"message_id"` MessageContent string `json:"message_content"` + TranscribedText string `json:"transcribed_text,omitempty"` ApiKey string `json:"api_key"` OutgoingURL string `json:"outgoing_url"` BotConfig BotConfig `json:"bot_config"` diff --git a/pkg/pipeline/service/pipeline_service.go b/pkg/pipeline/service/pipeline_service.go index d347c57..25ec123 100644 --- a/pkg/pipeline/service/pipeline_service.go +++ b/pkg/pipeline/service/pipeline_service.go @@ -114,6 +114,10 @@ func (s *pipelineService) Start() error { } func (s *pipelineService) Process(ctx context.Context, event *model.MessageEvent) error { + if event.TranscribedText != "" { + event.MessageContent = event.MessageContent + "\n\n[Transcrição do Áudio]:\n" + event.TranscribedText + } + mu, err := s.repo.AcquireLock(ctx, event.ContactID, event.ConversationID) if err != nil { return brtErrors.ErrLockFailed