tests(dao) fix DAO testss erroring with Cassandra

We need to flush the shm after it stores C* nodes as being down due to intentional failure to connect to it.
Kong · Feb 3, 2017 · 27059d4 · 27059d4
1 parent 38d590f
commit 27059d4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/spec/02-integration/02-dao/02-migrations_spec.lua b/spec/02-integration/02-dao/02-migrations_spec.lua
@@ -10,6 +10,11 @@ helpers.for_each_dao(function(kong_config)
       local f = Factory(kong_config)
       f:drop_schema()
     end)
+
+    teardown(function()
+      ngx.shared.cassandra:flush_expired()
+    end)
+
     before_each(function()
       factory = Factory(kong_config)
     end)
@@ -105,6 +110,7 @@ helpers.for_each_dao(function(kong_config)
           kong_config.pg_port = pg_port
           kong_config.cassandra_port = cassandra_port
           kong_config.cassandra_timeout = cassandra_timeout
+          ngx.shared.cassandra:flush_all()
         end)
         kong_config.pg_port = 3333
         kong_config.cassandra_port = 3333

diff --git a/spec/02-integration/02-dao/03-crud_spec.lua b/spec/02-integration/02-dao/03-crud_spec.lua
@@ -45,6 +45,7 @@ helpers.for_each_dao(function(kong_config)
     end)
     teardown(function()
       factory:truncate_tables()
+      ngx.shared.cassandra:flush_expired()
     end)
 
     describe("insert()", function()
@@ -701,6 +702,7 @@ helpers.for_each_dao(function(kong_config)
           kong_config.pg_port = pg_port
           kong_config.cassandra_port = cassandra_port
           kong_config.cassandra_timeout = cassandra_timeout
+          ngx.shared.cassandra:flush_all()
         end)
         kong_config.pg_port = 3333
         kong_config.cassandra_port = 3333