Implement the nfm_reply field in input

weni-ai · Feb 1, 2024 · b0bb75d · b0bb75d
1 parent 386ea31
commit b0bb75d
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/core/tasks/handler/worker.go b/core/tasks/handler/worker.go
@@ -611,6 +611,19 @@ func handleMsgEvent(ctx context.Context, rt *runtime.Runtime, event *MsgEvent) e
 			}
 			msgIn.SetOrder(order)
 		}
+		mdValue, ok = metadata["nfm_reply"]
+		if ok {
+			var nfmReply *flows.NFMReply
+			asJSON, err := json.Marshal(mdValue)
+			if err != nil {
+				log.WithError(err).Error("unable to marshal metadata from msg event")
+			}
+			err = json.Unmarshal(asJSON, &nfmReply)
+			if err != nil {
+				log.WithError(err).Error("unable to unmarshal orderJSON from metadata[\"nfm_reply\"]")
+			}
+			msgIn.SetNFMReply(nfmReply)
+		}
 	}
 
 	// build our hook to mark a flow message as handled