Revert "Removed IEventQueue"

This reverts commit 3d0e9e3.

Author: niemyjski

packages/core/src/configuration/Configuration.ts

@@ -9,6 +9,7 @@ import { ReferenceIdPlugin } from "../plugins/default/ReferenceIdPlugin.js";
 import { EventPluginContext } from "../plugins/EventPluginContext.js";
 import { IEventPlugin } from "../plugins/IEventPlugin.js";
 import { DefaultEventQueue } from "../queue/DefaultEventQueue.js";
+import { IEventQueue } from "../queue/IEventQueue.js";
 import { ISubmissionClient } from "../submission/ISubmissionClient.js";
 import { DefaultSubmissionClient } from "../submission/DefaultSubmissionClient.js";
 import { guid } from "../Utils.js";
@@ -545,5 +546,5 @@ interface IConfigurationServices {
   log: ILog;
   submissionClient: ISubmissionClient;
   storage: IStorage;
-  queue: DefaultEventQueue;
+  queue: IEventQueue;
 }

packages/core/src/index.ts

@@ -39,6 +39,7 @@ export { EventPluginManager } from "./plugins/EventPluginManager.js";
 export type { IEventPlugin } from "./plugins/IEventPlugin.js";
 
 export { DefaultEventQueue } from "./queue/DefaultEventQueue.js";
+export type { IEventQueue } from "./queue/IEventQueue.js";
 
 export { InMemoryStorage } from "./storage/InMemoryStorage.js";
 export { LocalStorage } from "./storage/LocalStorage.js";

packages/core/src/queue/DefaultEventQueue.ts

@@ -1,14 +1,15 @@
 import { Configuration } from "../configuration/Configuration.js";
 import { ILog } from "../logging/ILog.js";
 import { Event } from "../models/Event.js";
+import { IEventQueue } from "../queue/IEventQueue.js";
 import { Response } from "../submission/Response.js";
 
 interface EventQueueItem {
   file: string,
   event: Event
 }
 
-export class DefaultEventQueue {
+export class DefaultEventQueue implements IEventQueue {
   /**
    * A list of handlers that will be fired when events are submitted.
    * @type {Array}

packages/core/src/queue/IEventQueue.ts

@@ -0,0 +1,17 @@
+import { Event } from "../models/Event.js";
+import { Response } from "../submission/Response.js";
+
+export interface IEventQueue {
+  /** Enqueue an event */
+  enqueue(event: Event): Promise<void>;
+  /** Processes all events in the queue */
+  process(): Promise<void>;
+  /** Starts queue timers */
+  startup(): Promise<void>;
+  /** Suspends queue timers */
+  suspend(): Promise<void>;
+  /** Suspends processing of events for a specific duration */
+  suspendProcessing(durationInMinutes?: number, discardFutureQueuedItems?: boolean, clearQueue?: boolean): Promise<void>;
+  // TODO: See if this makes sense.
+  onEventsPosted(handler: (events: Event[], response: Response) => Promise<void>): void;
+}