Function testGetDelKeys

integration-tests/tasks_get_del_bucket.ts:25–58

()

})

async function testGetDelKeys() {
    let task1 = await bucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "1" });
    let task2 = await bucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "2" });
    let taskOtherNs = await anotherBucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "1" });
    let taskOtherPlugin = await bucketPluginCustom.schedule({ executeAt: new Date(Date.now() + 1000000), key: "1" });

    assetJsonEquals(await Tasks.getById(task1.id), task1);
    assetJsonEquals(await Tasks.getById(task2.id), task2);
    assetJsonEquals(await Tasks.getById(taskOtherNs.id), taskOtherNs);
    assetJsonEquals(await Tasks.getById(taskOtherPlugin.id), taskOtherPlugin);

    assetJsonEquals(await bucket.getByKey("1"), task1);
    assetJsonEquals(await bucket.getByKey("2"), task2);
    assetJsonEquals(await anotherBucket.getByKey("1"), taskOtherNs);
    assetJsonEquals(await bucketPluginCustom.getByKey("1"), taskOtherPlugin);

    // test deleteAll while cleaning up

    // deleting the guild scoped bucket and ensuring it only deleted that
    await bucket.deleteAll()
    assertExpected(undefined, await bucket.getByKey("1"))
    assertExpected(undefined, await bucket.getByKey("2"))

    assetJsonEquals(taskOtherNs, await anotherBucket.getByKey("1"));
    assetJsonEquals(taskOtherPlugin, await bucketPluginCustom.getByKey("1"));

    // deleting plugin scoped bucket and ensuring it did not touch the guild one
    await bucketPluginCustom.deleteAll()
    assetJsonEquals(taskOtherNs, await anotherBucket.getByKey("1"));
    assertExpected(undefined, await bucketPluginCustom.getByKey("1"));

    await anotherBucket.deleteAll()
    assertExpected(undefined, await anotherBucket.getByKey("1"));
}

async function testGetAll() {
    for (let i = 0; i < 55; i++) {