Merge pull request #437 from mattia-lau/@features/doesExist

[Reopen] Add API for checking the task is existing without throwing error

lib/scheduler.registry.ts

@@ -8,6 +8,19 @@ export class SchedulerRegistry {
   private readonly timeouts = new Map<string, any>();
   private readonly intervals = new Map<string, any>();
 
+  doesExists(type: 'cron' | 'timeout' | 'interval', name: string) {
+    switch (type) {
+      case 'cron':
+        return this.cronJobs.has(name);
+      case 'interval':
+        return this.intervals.has(name);
+      case 'timeout':
+        return this.timeouts.has(name);
+      default:
+        return false;
+    }
+  }
+
   getCronJob(name: string) {
     const ref = this.cronJobs.get(name);
     if (!ref) {

tests/e2e/cron-jobs.spec.ts

@@ -172,6 +172,20 @@ describe('Cron', () => {
     expect(clock.countTimers()).toBe(0);
   });
 
+  it('should return true for dynamic cron job', async () => {
+    const service: CronService = app.get(CronService);
+    await app.init();
+
+    service.addCronJob();
+    expect(service.doesExists('dynamic')).toEqual(true);
+  });
+
+  it('should return false for dynamic cron job', async () => {
+    const service: CronService = app.get(CronService);
+    await app.init();
+    expect(service.doesExists('dynamic')).toEqual(false);
+  });
+
   afterEach(async () => {
     await app.close();
   });

tests/e2e/interval.spec.ts

@@ -98,6 +98,20 @@ describe('Interval', () => {
     expect(jest.getTimerCount()).toBe(0);
   });
 
+  it('should return true for dynamic interval', async () => {
+    const service: IntervalService = app.get(IntervalService);
+    await app.init();
+
+    service.addInterval();
+    expect(service.doesExists('dynamic')).toEqual(true);
+  });
+
+  it('should return false for dynamic interval', async () => {
+    const service: IntervalService = app.get(IntervalService);
+    await app.init();
+    expect(service.doesExists('dynamic')).toEqual(false);
+  });
+
   afterEach(async () => {
     await app.close();
   });

tests/e2e/timeout.spec.ts

@@ -98,6 +98,20 @@ describe('Timeout', () => {
     expect(jest.getTimerCount()).toBe(0);
   });
 
+  it('should return true for dynamic timeout', async () => {
+    const service: TimeoutService = app.get(TimeoutService);
+    await app.init();
+
+    service.addTimeout();
+    expect(service.doesExists('dynamic')).toEqual(true);
+  });
+
+  it('should return false for dynamic timeout', async () => {
+    const service: TimeoutService = app.get(TimeoutService);
+    await app.init();
+    expect(service.doesExists('dynamic')).toEqual(false);
+  });
+
   afterEach(async () => {
     await app.close();
   });

tests/src/cron.service.ts

@@ -68,4 +68,8 @@ export class CronService {
     this.schedulerRegistry.addCronJob('dynamic', job);
     return job;
   }
+
+  doesExists(name: string): boolean {
+    return this.schedulerRegistry.doesExists('cron', name);
+  }
 }

tests/src/interval.service.ts

@@ -26,4 +26,8 @@ export class IntervalService {
       (intervalRef as unknown) as number,
     );
   }
+
+  doesExists(name: string): boolean {
+    return this.schedulerRegistry.doesExists('interval', name);
+  }
 }

tests/src/timeout.service.ts

@@ -25,4 +25,8 @@ export class TimeoutService {
       (timeoutRef as unknown) as number,
     );
   }
+
+  doesExists(name: string): boolean {
+    return this.schedulerRegistry.doesExists('timeout', name);
+  }
 }