chore: add lint script for example app

Author: nodkz

.vscode/settings.json

@@ -1,6 +1,6 @@
 {
   "javascript.validate.enable": false,
-  "typescript.tsdk": "node_modules/typescript/lib",
+  "typescript.tsdk": "./node_modules/typescript/lib",
   "editor.codeActionsOnSave": {
     "source.fixAll.eslint": true
   },

example/package.json

@@ -13,6 +13,9 @@
     "ts-node-dev": "^1.0.0-pre.44"
   },
   "scripts": {
-    "watch": "ts-node-dev ./src/index.ts --no-notify"
+    "watch": "ts-node-dev ./src/index.ts --no-notify",
+    "tscheck": "../node_modules/.bin/tsc --noEmit",
+    "eslint": "../node_modules/.bin/eslint --ext .ts ./src",
+    "lint": "yarn eslint && yarn tscheck"
   }
 }

example/src/config.ts

@@ -1,7 +1,7 @@
 //import 'dotenv/config'
 
 const BULL_REDIS_URI = {
-  port: process.env.REDIS_PORT || 6379,
+  port: parseInt(process.env.REDIS_PORT || '6379'),
   host: process.env.REDIS_HOST || '127.0.0.1',
   password: process.env.REDIS_PASSWORD || '',
 };

example/src/queues/fetchMetrics.ts

@@ -35,17 +35,19 @@ const metricsWorker = new Worker(
     //https://github.com/taskforcesh/bullmq/issues/69
     console.log(new Date().toISOString(), 'Starting name: ' + job.name + ', job: ' + job.id);
     return new Promise((resolve) => {
-      setTimeout(() =>
-        resolve({
-          status: 'job completed',
-          result: new Date().toISOString(),
-        })
+      setTimeout(
+        () =>
+          resolve({
+            status: 'job completed',
+            result: new Date().toISOString(),
+          }),
+        0
       );
     });
   },
   {
     prefix,
-    connection: metricsQueue.client,
+    connection: BULL_REDIS_URI,
   }
 );
 

example/src/schema/mutation/_helpers.ts

@@ -10,11 +10,11 @@ import { PayloadStatusEnum, ErrorCodeEnum } from '../types/enums';
 import { PayloadError } from '../../declarations/errors';
 
 export function getQueue(queueName: string, context: any): Queue {
-  const Queue = context?.Queues?.get(queueName);
-  if (!Queue) {
+  const queue = context?.Queues?.get(queueName);
+  if (!queue) {
     throw new PayloadError('Queue not found!', ErrorCodeEnum.QUEUE_NOT_FOUND);
   }
-  return Queue;
+  return queue;
 }
 
 type FieldConfig = Omit<ObjectTypeComposerFieldConfigAsObjectDefinition<any, any>, 'type'> & {

example/src/schema/types/queue/waitingJobs.ts

@@ -13,7 +13,7 @@ export function createWaitingJobsFC({ JobTC }) {
         defaultValue: -1,
       },
     },
-    resolve: async (queue: Queue, { status, start, end }) => {
+    resolve: async (queue: Queue, { start, end }) => {
       return await queue.getWaiting(start, end);
     },
   };