From b45421c1a7c3b3730727cf1608fe4b9819528284 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Sat, 6 Jul 2024 10:28:59 -0400
Subject: [PATCH] kafka message

---
 www-api/app/Controllers/WrenchHooks.php | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/www-api/app/Controllers/WrenchHooks.php b/www-api/app/Controllers/WrenchHooks.php
index 99efc0a7..3cc806f4 100644
--- a/www-api/app/Controllers/WrenchHooks.php
+++ b/www-api/app/Controllers/WrenchHooks.php
@@ -41,8 +41,12 @@ class WrenchHooks extends BaseController
 
         try {
             if ( $enable_event_publish ==  true  && !empty($in)  ){
+                $eventMsg = [
+                    "message" => serialize($in)
+                ];
+                
                 $local_url = "http://".$this->micro_service_net1.":".$microPort."/flutterOkHook";
-                $out = $this->APIcall('POST', $local_url, $in);
+                $out = $this->APIcall('POST', $local_url, $eventMsg);  //kafKa Lane
             }
         } catch (Exception $e) {
             log_message('critical', "WrenchHooks flutter Kafka fail => ".$e->getMessage());