npm package diff

Package: @forge/events

Versions: 2.0.1-next.0 - 2.0.1-next.1

File: package/src/queue.ts

Index: package/src/queue.ts
===================================================================
--- package/src/queue.ts
+++ package/src/queue.ts
@@ -1,39 +0,0 @@
-import { FetchMethod, __requestAtlassianAsApp } from '@forge/api';
-import { PUSH_PATH, post } from './queries';
-import { validatePushAPIResponse, validatePushEvents, validateQueueKey } from './validators';
-import { QueueParams, PushEvent, PushRequest, PushResult } from './types';
-import { v4 as uuid } from 'uuid';
-import { JobProgress } from './jobProgress';
-
-export class Queue {
-  constructor(
-    private readonly queueParams: QueueParams,
-    private readonly apiClient: FetchMethod = __requestAtlassianAsApp
-  ) {
-    validateQueueKey(this.queueParams.key);
-  }
-
-  async push(events: PushEvent | PushEvent[]): Promise<PushResult> {
-    const validEvents = validatePushEvents(events);
-    const queueName = this.queueParams.key;
-    const jobId = uuid();
-
-    const pushRequest: PushRequest = {
-      queueName: queueName,
-      jobId: jobId,
-      type: 'avi:forge:app:event',
-      schema: 'ari:cloud:ecosystem::forge/app-event-2',
-      payload: validEvents,
-      time: new Date().toISOString()
-    };
-
-    const response = await post(PUSH_PATH, pushRequest, this.apiClient);
-    const result = { jobId };
-    await validatePushAPIResponse(pushRequest, response, result);
-    return result;
-  }
-
-  getJob(jobId: string): JobProgress {
-    return new JobProgress(this.queueParams, jobId, this.apiClient);
-  }
-}