joplin/packages/app-cli/tests/TaskQueue.js

/* eslint-disable no-unused-vars */


const { asyncTest, fileContentEqual, setupDatabase, revisionService, setupDatabaseAndSynchronizer, db, synchronizer, fileApi, sleep, clearDatabase, switchClient, syncTargetId, objectsEqual, checkThrowAsync } = require('./test-utils.js');
const TaskQueue = require('@joplin/lib/TaskQueue.js');

process.on('unhandledRejection', (reason, p) => {
	console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
});

describe('TaskQueue', function() {

	beforeEach(async (done) => {
		await setupDatabaseAndSynchronizer(1);
		await switchClient(1);
		done();
	});

	it('should queue and execute tasks', asyncTest(async () => {
		const queue = new TaskQueue();

		queue.push(1, async () => { await sleep(0.5); return 'a'; });
		queue.push(2, async () => { await sleep(0.5); return 'b'; });
		queue.push(3, async () => { await sleep(0.5); return 'c'; });

		const results = [];

		results.push(await queue.waitForResult(1));
		results.push(await queue.waitForResult(2));
		results.push(await queue.waitForResult(3));

		expect(results[0].id).toBe(1);
		expect(results[0].result).toBe('a');
		expect(results[1].id).toBe(2);
		expect(results[1].result).toBe('b');
		expect(results[2].id).toBe(3);
		expect(results[2].result).toBe('c');
	}));

	it('should handle errors', asyncTest(async () => {
		const queue = new TaskQueue();

		queue.push(1, async () => { await sleep(0.5); return 'a'; });
		queue.push(2, async () => { await sleep(0.5); throw new Error('e'); });

		const results = [];

		results.push(await queue.waitForResult(1));
		results.push(await queue.waitForResult(2));

		expect(results[0].id).toBe(1);
		expect(results[0].result).toBe('a');
		expect(results[1].id).toBe(2);
		expect(!results[1].result).toBe(true);
		expect(results[1].error.message).toBe('e');
	}));

});