From f36cd3110932e13bb4fa0ce634e3c772434c8217 Mon Sep 17 00:00:00 2001
From: chronolaw <chrono_cpp@me.com>
Date: Wed, 6 Nov 2024 10:53:47 +0800
Subject: [PATCH] log delta.version

---
 kong/clustering/services/sync/rpc.lua | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/kong/clustering/services/sync/rpc.lua b/kong/clustering/services/sync/rpc.lua
index 4492546a33dd..6c04aa971cff 100644
--- a/kong/clustering/services/sync/rpc.lua
+++ b/kong/clustering/services/sync/rpc.lua
@@ -240,6 +240,7 @@ local function do_sync()
   -- delta should look like:
   -- { type = ..., entity = { ... }, version = 1, ws_id = ..., }
   for _, delta in ipairs(deltas) do
+    local delta_version = delta.version
     local delta_type = delta.type
     local delta_entity = delta.entity
     local ev
@@ -273,7 +274,8 @@ local function do_sync()
 
       ngx_log(ngx_DEBUG,
               "[kong.sync.v2] update entity",
-              ", type ", delta_type,
+              ", version: ", delta_version,
+              ", type: ", delta_type,
               ", pk:", cjson_encode(delta.pk))
 
       ev = { delta_type, crud_event_type, delta_entity, old_entity, }
@@ -295,7 +297,8 @@ local function do_sync()
 
       ngx_log(ngx_DEBUG,
               "[kong.sync.v2] delete entity",
-              ", type ", delta_type,
+              ", version: ", delta_version,
+              ", type: ", delta_type,
               ", pk:", cjson_encode(delta.pk))
 
       ev = { delta_type, "delete", old_entity, }
@@ -305,10 +308,10 @@ local function do_sync()
     crud_events[crud_events_n] = ev
 
     -- delta.version should not be nil or ngx.null
-    assert(type(delta.version) == "number")
+    assert(type(delta_version) == "number")
 
-    if delta.version ~= version then
-      version = delta.version
+    if delta_version ~= version then
+      version = delta_version
     end
   end -- for _, delta