Skip to content

Commit

Permalink
Update tests, remove too implementation-dependent assertions
Browse files Browse the repository at this point in the history
  • Loading branch information
janbuchar committed Jan 22, 2025
1 parent c4b45cb commit efea4ff
Showing 1 changed file with 9 additions and 13 deletions.
22 changes: 9 additions & 13 deletions packages/core/test/request-queue/request-queue-v2.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -24,31 +24,27 @@ vitest.setConfig({ restoreMocks: false });
describe('RequestQueueV2#isFinished should use listHead instead of listAndLock', () => {
let queue: RequestQueueV2;
let clientListHeadSpy: MockInstance<typeof queue.client.listHead>;
let listHeadCallCount = 0;
let clientListAndLockHeadSpy: MockInstance<typeof queue.client.listAndLockHead>;
let listAndLockHeadCallCount = 0;
let lockResult: ListAndLockHeadResult;

beforeAll(async () => {
queue = await makeQueue('is-finished', 2);
clientListHeadSpy = vitest.spyOn(queue.client, 'listHead');
clientListAndLockHeadSpy = vitest.spyOn(queue.client, 'listAndLockHead');
});

test('should return false if there are still requests in the queue', async () => {
expect(await queue.isFinished()).toBe(false);
expect(clientListHeadSpy).toHaveBeenCalledTimes(++listHeadCallCount);
});

test('should return false even if all requests are locked', async () => {
lockResult = await queue.client.listAndLockHead({ lockSecs: 60 });

expect(lockResult.items.length).toBe(2);
expect(clientListAndLockHeadSpy).toHaveBeenCalledTimes(++listAndLockHeadCallCount);
queue.client.listAndLockHead = async (options) => ({
lockSecs: options.lockSecs,
queueModifiedAt: new Date(),
limit: 10,
items: [],
queueHasLockedRequests: true,
});

expect(await queue.isFinished()).toBe(false);
expect(clientListHeadSpy).toHaveBeenCalledTimes(++listHeadCallCount);
expect(clientListAndLockHeadSpy).toHaveBeenCalledTimes(listAndLockHeadCallCount);
expect(clientListHeadSpy).not.toHaveBeenCalled();
});
});

Expand Down Expand Up @@ -81,7 +77,7 @@ describe('RequestQueueV2#isFinished should return true once locked requests are
expect(clientListHeadSpy).toHaveBeenCalledWith({ limit: 2 });
expect(clientListHeadSpy).toHaveBeenCalledTimes(++listHeadCallCount);
// One time
expect(clientListAndLockHeadSpy).toHaveBeenCalledTimes(1);
expect(clientListAndLockHeadSpy).toHaveBeenCalled();
});
});

Expand Down

0 comments on commit efea4ff

Please sign in to comment.