wehub-resource-sync
117 lines
3.9 KiB
Lua
117 lines
3.9 KiB
Lua
local helpers = require "spec.helpers"
|
|
|
|
|
|
for _, strategy in helpers.each_strategy() do
|
|
describe("kong.db [#" .. strategy .. "]", function()
|
|
local db, bp, cs
|
|
|
|
lazy_setup(function()
|
|
bp, db = helpers.get_db_utils(strategy, {
|
|
"clustering_data_planes",
|
|
})
|
|
end)
|
|
|
|
describe("Clustering DP status", function()
|
|
|
|
before_each(function()
|
|
cs = assert(bp.clustering_data_planes:insert())
|
|
end)
|
|
|
|
it("can update the row", function()
|
|
local p, err = db.clustering_data_planes:update(cs, { config_hash = "a9a166c59873245db8f1a747ba9a80a7", })
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
end)
|
|
|
|
describe("updates", function()
|
|
it(":upsert()", function()
|
|
local p, err = db.clustering_data_planes:upsert({ id = "eb51145a-aaaa-bbbb-cccc-22087fb081db", },
|
|
{ config_hash = "a9a166c59873245db8f1a747ba9a80a7",
|
|
hostname = "localhost",
|
|
ip = "127.0.0.1",
|
|
})
|
|
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
|
|
it(":update()", function()
|
|
-- this time update instead of insert
|
|
local p, err = db.clustering_data_planes:update({ id = "eb51145a-aaaa-bbbb-cccc-22087fb081db", },
|
|
{ config_hash = "a9a166c59873245db8f1a747ba9a80a7", })
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
end)
|
|
|
|
describe("labels", function()
|
|
it(":upsert()", function()
|
|
local p, err = db.clustering_data_planes:upsert({ id = "eb51145a-aaaa-bbbb-cccc-22087fb081db", },
|
|
{ config_hash = "a9a166c59873245db8f1a747ba9a80a7",
|
|
hostname = "localhost",
|
|
ip = "127.0.0.1",
|
|
labels = {
|
|
deployment = "mycloud",
|
|
region = "us-east-1",
|
|
}
|
|
})
|
|
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
|
|
it(":update()", function()
|
|
-- this time update instead of insert
|
|
local p, err = db.clustering_data_planes:update({ id = "eb51145a-aaaa-bbbb-cccc-22087fb081db", },
|
|
{ config_hash = "a9a166c59873245db8f1a747ba9a80a7",
|
|
labels = { deployment = "aws", region = "us-east-2" }
|
|
})
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
end)
|
|
|
|
describe("cert_details", function()
|
|
it(":upsert()", function()
|
|
local p, err =
|
|
db.clustering_data_planes:upsert(
|
|
{
|
|
id = "eb51145a-aaaa-bbbb-cccc-22087fb081db",
|
|
},
|
|
{
|
|
config_hash = "a9a166c59873245db8f1a747ba9a80a7",
|
|
hostname = "localhost",
|
|
ip = "127.0.0.1",
|
|
cert_details = {
|
|
expiry_timestamp = 1897136778,
|
|
}
|
|
}
|
|
)
|
|
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
|
|
it(":update()", function()
|
|
-- this time update instead of insert
|
|
local p, err =
|
|
db.clustering_data_planes:update(
|
|
{
|
|
id = "eb51145a-aaaa-bbbb-cccc-22087fb081db",
|
|
},
|
|
{
|
|
config_hash = "a9a166c59873245db8f1a747ba9a80a7",
|
|
cert_details = {
|
|
expiry_timestamp = 1888983905,
|
|
}
|
|
}
|
|
)
|
|
|
|
assert.is_truthy(p)
|
|
assert.is_nil(err)
|
|
end)
|
|
end)
|
|
end) -- kong.db [strategy]
|
|
end
|