From 55453dee73b99b3fd865eb4d83d55d54cbf9c2b4 Mon Sep 17 00:00:00 2001
From: Xiaochen Wang <wangxiaochen0@gmail.com>
Date: Wed, 11 Dec 2024 02:03:13 -0600
Subject: [PATCH] 1

---
 .../09-hybrid_mode/11-status_spec.lua         | 40 +++++++++++++++++--
 1 file changed, 36 insertions(+), 4 deletions(-)

diff --git a/spec/02-integration/09-hybrid_mode/11-status_spec.lua b/spec/02-integration/09-hybrid_mode/11-status_spec.lua
index 774fda44a2e6..54314e7fc658 100644
--- a/spec/02-integration/09-hybrid_mode/11-status_spec.lua
+++ b/spec/02-integration/09-hybrid_mode/11-status_spec.lua
@@ -4,7 +4,8 @@ local helpers = require "spec.helpers"
 local cp_status_port = helpers.get_available_port()
 local dp_status_port = 8100
 
-for _, v in ipairs({ {"off", "off"}, {"on", "off"}, {"on", "on"}, }) do
+--for _, v in ipairs({ {"off", "off"}, {"on", "off"}, {"on", "on"}, }) do
+for _, v in ipairs({ {"on", "on"}, }) do
   local rpc, inc_sync = v[1], v[2]
 
 for _, strategy in helpers.each_strategy() do
@@ -105,7 +106,7 @@ for _, strategy in helpers.each_strategy() do
 
       -- now dp receive config from cp, so dp should be ready
 
-      it("should return 200 on data plane after configuring", function()
+      it("should return 200 on data plane after configuring #ttt", function()
         helpers.wait_until(function()
           local http_client = helpers.http_client('127.0.0.1', dp_status_port)
 
@@ -165,9 +166,40 @@ for _, strategy in helpers.each_strategy() do
             return true
           end
         end, 10)
+
+        -- insert one entity to make dp ready for incremental sync
+        if inc_sync == "on" then
+          ngx.sleep(1)
+          print("+++++ post /services")
+          local admin_client = helpers.admin_client(10000)
+          local res = assert(admin_client:post("/services", {
+            body = { name = "service-001", url = "https://127.0.0.1:15556/request", },
+            headers = {["Content-Type"] = "application/json"}
+          }))
+          assert.res_status(201, res)
+          admin_client:close()
+
+          print("++++++= sleep")
+          --ngx.sleep(1000000)
+          helpers.wait_until(function()
+            local http_client = helpers.http_client('127.0.0.1', dp_status_port)
+
+            local res = http_client:send({
+              method = "GET",
+              path = "/status/ready",
+            })
+
+            local status = res and res.status
+            http_client:close()
+--            print("++++++++++" .. status)
+
+            if status == 200 then
+              return true
+            end
+          end, 10)
+        end
+       end)
       end)
     end)
-
-  end)
 end -- for _, strategy
 end -- for inc_sync