fix: unit test for migration to vitest

Author: Arun-KumarH

test/grpc_acs.spec.ts

@@ -1,9 +1,9 @@
-import {} from 'mocha';
+import { } from 'mocha';
 import should from 'should';
 import { marshallProtobufAny } from '../src/utilts.js';
 import { Worker } from '../src/worker.js';
 import { Topic } from '@restorecommerce/kafka-client';
-import { 
+import {
   JobServiceDefinition as SchedulingServiceDefinition,
   JobServiceClient as SchedulingServiceClient,
   JobOptions_Priority,
@@ -92,12 +92,13 @@ interface MethodWithOutput {
   output: any;
 };
 
-const PROTO_PATH = 'io/restorecommerce/access_control.proto';
+const PROTO_PATH = './io/restorecommerce/access_control.proto';
+const PROTO_ROOT = './test/protos';
 const PKG_NAME = 'io.restorecommerce.access_control';
 const SERVICE_NAME = 'AccessControlService';
 const pkgDef: grpc.GrpcObject = grpc.loadPackageDefinition(
   proto_loader.loadSync(PROTO_PATH, {
-    includeDirs: ['node_modules/@restorecommerce/protos'],
+    includeDirs: PROTO_ROOT ? [PROTO_ROOT] : [],
     keepCase: true,
     longs: String,
     enums: String,
@@ -210,7 +211,6 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
   let grpcSchedulingSrv: SchedulingServiceClient;
 
   beforeAll(async function (): Promise<any> {
-    this.timeout(40000);
     worker = new Worker();
     cfg.set('events:kafka:groupId', testSuffix + 'grpc');
     await worker.start(cfg);
@@ -236,9 +236,11 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
         method: 'WhatIsAllowed',
         output: jobPolicySetRQ
       },
-      { method: 'IsAllowed',
-        output: { decision: Effect.PERMIT } }
-      ]
+      {
+        method: 'IsAllowed',
+        output: { decision: Effect.PERMIT }
+      }
+    ]
     );
 
     // start mock ids-srv needed for findByToken response and return subject
@@ -279,7 +281,7 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
     }
 
     payloadShouldBeEmpty(await grpcSchedulingSrv.read(JobReadRequest.fromPartial({ subject }), {}), false);
-  });
+  }, 40000);
   beforeEach(async () => {
     for (const event of ['jobsCreated', 'jobsDeleted']) {
       await jobEvents.on(event, () => { });
@@ -293,7 +295,6 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
     ]);
   });
   afterAll(async function (): Promise<any> {
-    this.timeout(20000);
     await Promise.allSettled([
       stopACSGrpcMockServer(),
       stopIDSGrpcMockServer(),
@@ -303,9 +304,8 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
       await worker.schedulingService.clear(),
     ]);
     await worker.stop();
-  });
-  describe(`create a one-time job ${testSuffix}`, function postJob(): void {
-    this.timeout(30000);
+  }, 20000);
+  describe(`create a one-time job ${testSuffix}`, { timeout: 30000 }, () => {
     it(`should create a new job and execute it immediately ${testSuffix}`, async () => {
       const w = await runWorker('test-job', 1, cfg, logger, worker.events, async (job) => {
         validateScheduledJob(job, 'ONCE', logger);
@@ -462,8 +462,7 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
     //   createResponse.operation_status!.message!.should.equal('success');
     // });
   });
-  describe(`should create a recurring job ${testSuffix}`, function (): void {
-    this.timeout(8000);
+  describe(`should create a recurring job ${testSuffix}`, { timeout: 8000 }, function (): void {
     it(`should create a recurring job and delete it after some executions ${testSuffix}`, async () => {
       let jobExecs = 0;
       const w = await runWorker('test-job', 1, cfg, logger, worker.events, async (job) => {
@@ -583,8 +582,7 @@ describe(`testing scheduling-srv ${testSuffix}: gRPC`, () => {
       result!.operation_status!.message!.should.equal('success');
     });
   });
-  describe(`managing jobs ${testSuffix}`, function (): void {
-    this.timeout(10000);
+  describe(`managing jobs ${testSuffix}`, { timeout: 10000 }, function (): void {
     it('should schedule some jobs for tomorrow', async () => {
       const data = {
         timezone: 'Europe/Berlin',

test/kafka_acs.spec.ts

@@ -1,4 +1,4 @@
-import {} from 'mocha';
+import { } from 'mocha';
 import should from 'should';
 import * as _ from 'lodash-es';
 
@@ -83,12 +83,13 @@ interface MethodWithOutput {
   output: any;
 };
 
-const PROTO_PATH = 'io/restorecommerce/access_control.proto';
+const PROTO_PATH = './io/restorecommerce/access_control.proto';
+const PROTO_ROOT = './test/protos';
 const PKG_NAME = 'io.restorecommerce.access_control';
 const SERVICE_NAME = 'AccessControlService';
 const pkgDef: grpc.GrpcObject = grpc.loadPackageDefinition(
   proto_loader.loadSync(PROTO_PATH, {
-    includeDirs: ['node_modules/@restorecommerce/protos'],
+    includeDirs: PROTO_ROOT ? [PROTO_ROOT] : [],
     keepCase: true,
     longs: String,
     enums: String,
@@ -186,7 +187,6 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
   let jobTopic: Topic;
   let schedulingService: SchedulingService;
   beforeAll(async function (): Promise<any> {
-    this.timeout(12000);
     worker = new Worker();
 
     cfg.set('events:kafka:groupId', testSuffix + 'kafka');
@@ -251,7 +251,7 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
     }
 
     payloadShouldBeEmpty(await schedulingService.read(JobReadRequest.fromPartial({ subject }), {}));
-  });
+  }, 12000);
   beforeEach(async () => {
     for (let event of ['jobsCreated', 'jobsDeleted']) {
       await jobTopic.on(event, () => { });
@@ -265,7 +265,6 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
     ]);
   });
   afterAll(async function (): Promise<any> {
-    this.timeout(20000);
     await Promise.allSettled([
       stopACSGrpcMockServer(),
       stopIDSGrpcMockServer(),
@@ -275,9 +274,8 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
       worker.schedulingService.clear(),
     ]);
     await worker.stop();
-  });
-  describe('create a one-time job', function postJob(): void {
-    this.timeout(15000);
+  }, 20000);
+  describe('create a one-time job', { timeout: 15000 }, function postJob(): void {
     it('should create a new job and execute it immediately', async () => {
       const w = await runWorker('test-job', 1, cfg, logger, worker.events, async (job) => {
         validateScheduledJob(job, 'ONCE', logger);
@@ -393,8 +391,7 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
     });
   });
 
-  describe('creating a recurring job', function (): void {
-    this.timeout(15000);
+  describe('creating a recurring job', { timeout: 15000 }, function (): void {
     it('should create a recurring job and delete it after some executions', async () => {
       let jobExecs = 0;
       const w = await runWorker('test-job', 1, cfg, logger, worker.events, async (job) => {
@@ -464,8 +461,7 @@ describe(`testing scheduling-srv ${testSuffix}: Kafka`, async () => {
     });
   });
 
-  describe('managing jobs', function (): void {
-    this.timeout(15000);
+  describe('managing jobs', { timeout: 15000 }, function (): void {
     it('should schedule some jobs for tomorrow', async () => {
       const data = {
         timezone: 'Europe/Berlin',