feat: begin refactor

deps.ts

@@ -1,2 +1 @@
-export { Queue } from 'jsr:@cm-iv/queue@1.0.0';
-export { delay } from 'jsr:@std/async@1.0.6/delay';
+export { deepMerge as merge } from 'jsr:@cross/deepmerge@1.0.0';

lib/interface/optiion.ts

@@ -0,0 +1,39 @@
+export interface LedgerOptions {
+  /** Transport List */
+  workers: WorkerOptions[];
+
+  /** Control the respawn limitations. */
+  respawn?: {
+    /** The maximum number of restarts for an individual worker. */
+    limit: number;
+    /** The rolling window in ms to decrement the respawn counter. */
+    per: number;
+  };
+}
+
+export interface WorkerOptions {
+  /** Set the Worker Loading Mode. */
+  mode: 'jsr.io' | 'alternative';
+  /** Associated {@link TransportOptions}. */
+  options: TransportOptions;
+  /**
+   * The package to initialize. Approved JSR Types listed, but any string is allowed.
+   *
+   * Mode must be 'disk' to allow alternative packages.
+   */
+  // deno-lint-ignore ban-types
+  package: ApprovedWorkers | string & {};
+}
+
+export interface TransportOptions {
+  /** Control the processing thread. */
+  queue?: {
+    /** The number of events to process concurrently. */
+    threadCount: number;
+  };
+}
+
+/** List of Approved Workers. Official or Approved Workers List for Auto Indexing. */
+export type ApprovedWorkers =
+  | '@ledger/console-transport'
+  | '@ledger/file-transport';

lib/transport.ts

@@ -20,7 +20,8 @@ export class LedgerTransport {
    *
    * @abstract
    */
+  // deno-lint-ignore require-await
   public async consume(payload: TransportHandleMessage): Promise<void> {
-    throw new Error(`Method not implemented when handling consume for '${payload.op}'.`);
+    throw new Error(`Method not implemented when handling consume for '${payload.op}'. This transport is incomplete.`);
   }
 }