fix: wait for start of test job

Author: simllll

src/Job.ts

@@ -162,7 +162,7 @@ export class Job<DATA = unknown | void> {
 
 	async isRunning(): Promise<boolean> {
 		const definition = this.agenda.definitions[this.attrs.name];
-		if (!definition) {
+		if (!definition || !this.agenda.isActiveJobProcessor()) {
 			// we have no job definition, therfore we are not the job processor, but a client call
 			// so we get the real state from database
 			await this.fetchStatus();
@@ -198,7 +198,7 @@ export class Job<DATA = unknown | void> {
 
 	async isDead(): Promise<boolean> {
 		const definition = this.agenda.definitions[this.attrs.name];
-		if (!definition) {
+		if (!definition || !this.agenda.isActiveJobProcessor()) {
 			// we have no job definition, therfore we are not the job processor, but a client call
 			// so we get the real state from database
 			await this.fetchStatus();

src/JobProcessor.ts

@@ -500,7 +500,7 @@ export class JobProcessor {
 							}
 
 							resolve(checkIfJobIsStillAlive());
-						}, Math.max(this.processEvery, this.agenda.definitions[job.attrs.name].lockLifetime / 2))
+						}, Math.max(this.processEvery / 2, this.agenda.definitions[job.attrs.name].lockLifetime / 2))
 					);
 				};
 

src/index.ts

@@ -64,6 +64,10 @@ export class Agenda extends EventEmitter {
 
 	readonly ready: Promise<void>;
 
+	isActiveJobProcessor(): boolean {
+		return !!this.jobProcessor;
+	}
+
 	async getRunningStats(fullDetails = false): Promise<IAgendaStatus> {
 		if (!this.jobProcessor) {
 			throw new Error('agenda not running!');
@@ -408,8 +412,6 @@ export class Agenda extends EventEmitter {
 			this.attrs.processEvery
 		);
 
-		await this.jobProcessor.process();
-
 		this.on('processJob', job => this.jobProcessor?.process(job));
 	}
 

test/jobprocessor.test.ts

@@ -77,6 +77,8 @@ describe('JobProcessor', () => {
 			agenda.now('test');
 			await agenda.start();
 
+			await new Promise(resolve => agenda.on('start:test', resolve));
+
 			const status = await agenda.getRunningStats();
 			expect(status).to.have.property('jobStatus');
 			if (status.jobStatus) {
@@ -155,7 +157,7 @@ describe('JobProcessor', () => {
 			'test long',
 			async () => {
 				jobStarted = true;
-				await new Promise(resolve => setTimeout(resolve, 1000));
+				await new Promise(resolve => setTimeout(resolve, 2500));
 			},
 			{ lockLifetime: 500 }
 		);