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