Handle message forwarded to the router

weni-ai · Apr 8, 2024 · 9322612 · 9322612
1 parent 49e8ce9
commit 9322612
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/tasks/handler/worker.go b/core/tasks/handler/worker.go
@@ -716,6 +716,11 @@ func handleMsgEvent(ctx context.Context, rt *runtime.Runtime, event *MsgEvent) e
 			return errors.Wrap(err, "unable to send message to router")
 		}
 
+		err = models.UpdateMessage(ctx, rt.DB, event.MsgID, models.MsgStatusHandled, models.VisibilityVisible, models.MsgTypeInbox, topupID)
+		if err != nil {
+			return errors.Wrapf(err, "error marking message as handled")
+		}
+
 		return nil
 
 	} else {