Jayden/AFFiNE-Mirror
1
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-02-04 08:38:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(server): do not consume job in test (#11592)

Browse Source
This commit is contained in:
forehalo
2025-04-10 07:02:07 +00:00
parent dbb8451adb
commit 8e1cbc4c5b
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/backend/server/src/base/job/queue/__tests__/queue.spec.ts
View File

@@ -2,7 +2,7 @@ import { getQueueToken } from '@nestjs/bullmq';
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { TestingModule } from '@nestjs/testing'; import { TestingModule } from '@nestjs/testing';
import test from 'ava'; import test from 'ava';
import { Queue as Bullmq } from 'bullmq'; import { Queue as Bullmq, Worker } from 'bullmq';
import Sinon from 'sinon'; import Sinon from 'sinon';
import { createTestingModule } from '../../../../__tests__/utils'; import { createTestingModule } from '../../../../__tests__/utils';
@@ -15,6 +15,7 @@ import { JobHandlerScanner } from '../scanner';
let module: TestingModule; let module: TestingModule;
let queue: JobQueue; let queue: JobQueue;
let executor: JobExecutor; let executor: JobExecutor;
let worker: Worker;
let bullmq: Bullmq; let bullmq: Bullmq;
declare global { declare global {
@@ -69,6 +70,9 @@ test.before(async () => {
queue = module.get(JobQueue); queue = module.get(JobQueue);
executor = module.get(JobExecutor); executor = module.get(JobExecutor);
bullmq = module.get(getQueueToken('nightly'), { strict: false }); bullmq = module.get(getQueueToken('nightly'), { strict: false });
// @ts-expect-error private api
worker = executor.workers.get('nightly')!;
await worker.pause();
}); });
test.beforeEach(async () => { test.beforeEach(async () => {
@@ -116,13 +120,6 @@ test('should remove job from queue', async t => {
// #endregion // #endregion
// #region executor // #region executor
test('should start workers', async t => {
// @ts-expect-error private api
const worker = executor.workers.get('nightly')!;
t.truthy(worker);
});
test('should dispatch job handler', async t => { test('should dispatch job handler', async t => {
const handlers = module.get(JobHandlers); const handlers = module.get(JobHandlers);
const spy = Sinon.spy(handlers, 'handleJob'); const spy = Sinon.spy(handlers, 'handleJob');