const data = {
...testData.subscriptionUpsert,
topicId,
- }
+ };
await db.context(async (dbCtx) => {
const result = await db.subscriptionUpsert(dbCtx, data);
assert(result.lastInsertRowid);
...testData.subscriptionUpsert,
secret: 'newSecret',
topicId,
- }
+ };
await db.context(async (dbCtx) => {
const result = await db.subscriptionUpsert(dbCtx, data);
assert(result.lastInsertRowid);
});
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);
});