X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=test%2Fsrc%2Fdb%2Fintegration.js;fp=test%2Fsrc%2Fdb%2Fintegration.js;h=84d1d26b027f0bfa060f0ed4ba83a83fc133aa95;hb=71587de3ea9839d14d9f7bffa6c1db19e52dd9b5;hp=bd28e92a9124c7ba1d7cb2c0a7bc9d256e10c983;hpb=749801f9983b087aee6844ee5fa0f0a7419ec5db;p=websub-hub diff --git a/test/src/db/integration.js b/test/src/db/integration.js index bd28e92..84d1d26 100644 --- a/test/src/db/integration.js +++ b/test/src/db/integration.js @@ -285,7 +285,7 @@ describe('Database Integration', function () { const data = { ...testData.subscriptionUpsert, topicId, - } + }; await db.context(async (dbCtx) => { const result = await db.subscriptionUpsert(dbCtx, data); assert(result.lastInsertRowid); @@ -364,7 +364,7 @@ describe('Database Integration', function () { ...testData.subscriptionUpsert, secret: 'newSecret', topicId, - } + }; await db.context(async (dbCtx) => { const result = await db.subscriptionUpsert(dbCtx, data); assert(result.lastInsertRowid); @@ -416,7 +416,7 @@ describe('Database Integration', function () { }); step('delete expired subscriptions', async function() { await db.context(async (dbCtx) => { - await db.subscriptionDeleteExpired(dbCtx, topicId) + await db.subscriptionDeleteExpired(dbCtx, topicId); const subscription = await db.subscriptionGet(dbCtx, testData.subscriptionUpsert.callback, topicId); assert(!subscription); });