wehub-resource-sync
122 lines
5.3 KiB
JavaScript
122 lines
5.3 KiB
JavaScript
// ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
|
|
// ┃ ██████ ██████ ██████ █ █ █ █ █ █▄ ▀███ █ ┃
|
|
// ┃ ▄▄▄▄▄█ █▄▄▄▄▄ ▄▄▄▄▄█ ▀▀▀▀▀█▀▀▀▀▀ █ ▀▀▀▀▀█ ████████▌▐███ ███▄ ▀█ █ ▀▀▀▀▀ ┃
|
|
// ┃ █▀▀▀▀▀ █▀▀▀▀▀ █▀██▀▀ ▄▄▄▄▄ █ ▄▄▄▄▄█ ▄▄▄▄▄█ ████████▌▐███ █████▄ █ ▄▄▄▄▄ ┃
|
|
// ┃ █ ██████ █ ▀█▄ █ ██████ █ ███▌▐███ ███████▄ █ ┃
|
|
// ┣━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┫
|
|
// ┃ Copyright (c) 2017, the Perspective Authors. ┃
|
|
// ┃ ╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌ ┃
|
|
// ┃ This file is part of the Perspective library, distributed under the terms ┃
|
|
// ┃ of the [Apache License 2.0](https://www.apache.org/licenses/LICENSE-2.0). ┃
|
|
// ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛
|
|
|
|
import { test, expect } from "@perspective-dev/test";
|
|
import perspective from "./perspective_client";
|
|
|
|
function it_old_behavior(name, capture) {
|
|
test(name, async function () {
|
|
let done;
|
|
let result = new Promise((x) => {
|
|
done = x;
|
|
});
|
|
|
|
await capture(done);
|
|
await result;
|
|
});
|
|
}
|
|
|
|
function mock_fn() {
|
|
let count = 0;
|
|
let fun = () => {
|
|
count += 1;
|
|
};
|
|
fun.count = () => count;
|
|
return fun;
|
|
}
|
|
|
|
((perspective) => {
|
|
test.describe("Delete", function () {
|
|
test("calls all delete callbacks registered on table", async function () {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
const cb1 = mock_fn();
|
|
const cb2 = mock_fn();
|
|
table.on_delete(cb1);
|
|
table.on_delete(cb2);
|
|
await table.delete();
|
|
expect(cb1.count()).toEqual(1);
|
|
expect(cb2.count()).toEqual(1);
|
|
});
|
|
|
|
test("remove_delete unregisters table delete callbacks", async function () {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
const cb1 = mock_fn();
|
|
const cb2 = mock_fn();
|
|
const sub1 = await table.on_delete(cb1);
|
|
table.on_delete(cb2);
|
|
await table.remove_delete(sub1);
|
|
await table.delete();
|
|
expect(cb1.count()).toEqual(0);
|
|
expect(cb2.count()).toEqual(1);
|
|
});
|
|
|
|
test("calls all delete callbacks registered on view", async function () {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
const view = await table.view();
|
|
const cb1 = mock_fn();
|
|
const cb2 = mock_fn();
|
|
view.on_delete(cb1);
|
|
view.on_delete(cb2);
|
|
await view.delete();
|
|
expect(cb1.count()).toEqual(1);
|
|
expect(cb2.count()).toEqual(1);
|
|
await table.delete();
|
|
});
|
|
|
|
test("remove_delete unregisters view delete callbacks", async function () {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
const view = await table.view();
|
|
const cb1 = mock_fn();
|
|
const cb2 = mock_fn();
|
|
const sub1 = await view.on_delete(cb1);
|
|
view.on_delete(cb2);
|
|
view.remove_delete(sub1);
|
|
await view.delete();
|
|
expect(cb1.count()).toEqual(0);
|
|
expect(cb2.count()).toEqual(1);
|
|
await table.delete();
|
|
});
|
|
|
|
it_old_behavior(
|
|
"properly removes a failed delete callback on a table",
|
|
async function (done) {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
|
|
// when a callback throws, it should delete that callback
|
|
table.on_delete(() => {
|
|
throw new Error("something went wrong!");
|
|
});
|
|
|
|
table.delete();
|
|
done();
|
|
},
|
|
);
|
|
|
|
it_old_behavior(
|
|
"properly removes a failed delete callback on a view",
|
|
async function (done) {
|
|
const table = await perspective.table([{ x: 1 }]);
|
|
const view = await table.view();
|
|
|
|
// when a callback throws, it should delete that callback
|
|
view.on_delete(() => {
|
|
throw new Error("something went wrong!");
|
|
});
|
|
|
|
view.delete();
|
|
table.delete();
|
|
done();
|
|
},
|
|
);
|
|
});
|
|
})(perspective);
|