feat: add durationAvg field

* fix: job name not necessarily

* fix: job timestamp not necessary

* feat: completed jobs duration average field

Co-authored-by: Boris Dorofeev <bdorofeev@bdorofeev-laptop.corp.ps.kz>

Author: intpro

src/types/job/Job.ts

@@ -14,7 +14,7 @@ export function getJobTC(sc: SchemaComposer<any>, opts: Options) {
       data: jobDataTC,
       progress: 'Int',
       delay: 'Int',
-      timestamp: 'Date!',
+      timestamp: 'Date',
       attemptsMade: 'Int',
       failedReason: 'JSON',
       stacktrace: '[String!]',

src/types/queue/Queue.durationAvg.ts

@@ -0,0 +1,31 @@
+import { SchemaComposer, ObjectTypeComposerFieldConfigDefinition } from 'graphql-compose';
+import { Queue } from 'bullmq';
+import { Options } from '../../definitions';
+
+export function createDurationAvgFC(
+  sc: SchemaComposer<any>,
+  opts: Options
+): ObjectTypeComposerFieldConfigDefinition<any, any> {
+  return {
+    type: 'Int!',
+    args: {
+      limit: {
+        type: 'Int',
+        defaultValue: 1000,
+      },
+    },
+    resolve: async (queue: Queue, { limit }) => {
+      const jobs = await queue.getCompleted(0, limit);
+
+      const amount = jobs.reduce((acc, job) => {
+        if (job?.finishedOn && job?.processedOn) {
+          return acc + job.finishedOn - job?.processedOn;
+        }
+
+        return acc;
+      }, 0);
+
+      return (amount / jobs.length).toFixed(0);
+    },
+  };
+}

src/types/queue/Queue.ts

@@ -8,6 +8,7 @@ import { createActiveJobsFC } from './Queue.activeJobs';
 import { createDelayedJobsFC } from './Queue.delayedJobs';
 import { createFailedJobsFC } from './Queue.failedJobs';
 import { createWorkersTC } from './Queue.workers';
+import { createDurationAvgFC } from './Queue.durationAvg';
 import { SchemaComposer } from 'graphql-compose';
 import { Options } from '../../definitions';
 
@@ -27,6 +28,7 @@ export function getQueueTC(sc: SchemaComposer<any>, opts: Options) {
       jobsDelayed: createDelayedJobsFC(sc, opts),
       jobsFailed: createFailedJobsFC(sc, opts),
       activeWorkers: createWorkersTC(sc, opts),
+      durationAvg: createDurationAvgFC(sc, opts),
     });
   });
 }