Endpoint get-issues-queue created

libs/event-emitter/src/events/redmine-events.gateway.ts

@@ -87,6 +87,10 @@ export class RedmineEventsGateway {
     return this.issuesChangesQueue.getQueueSize();
   }
 
+  getQueueIssues(): number[] {
+    return this.issuesChangesQueue.getItems();
+  }
+
   private sendWebHookFullDataEvents(data: RedmineIssueData[]): void {
     const webhooks = this.config.get<WebhookConfigItemModel[]>('webhooks');
     webhooks.forEach((webhook) => {

libs/event-emitter/src/main/main.controller.ts

@@ -21,4 +21,9 @@ export class MainController {
   getIssuesQueueSize(): number {
     return this.redmineEventsGateway.getQueueSize();
   }
+
+  @Get('get-issues-queue')
+  getIssuesQueue(): number[] {
+    return this.redmineEventsGateway.getQueueIssues();
+  }
 }

libs/event-emitter/src/queue/queue.ts

@@ -32,6 +32,10 @@ export class Queue<T, NT> {
     return this.items.length;
   }
 
+  getItems(): T[] {
+    return this.items;
+  }
+
   private updateTimeout;
 
   private async update(): Promise<void> {