Move files into core directory (#12)

Only index and resonate remain at top level.

jest.config.js

@@ -2,5 +2,5 @@
 module.exports = {
   preset: "ts-jest",
   testEnvironment: "node",
-  testPathIgnorePatterns: ["lib/loggers/test.ts"],
+  testPathIgnorePatterns: ["lib/core/loggers/test.ts"],
 };

lib/core/loggers/logger.ts

@@ -0,0 +1,75 @@
+import { ILogger, ITrace } from "../logger";
+
+type LogLevel = "debug" | "info" | "warn" | "error";
+
+export class Logger implements ILogger {
+  private _level: number;
+
+  constructor(public level: LogLevel = "info") {
+    switch (level) {
+      case "debug":
+        this._level = 0;
+        break;
+      case "info":
+        this._level = 1;
+        break;
+      case "warn":
+        this._level = 2;
+        break;
+      case "error":
+        this._level = 3;
+        break;
+    }
+  }
+
+  startTrace(id: string, attrs?: Record<string, string>): ITrace {
+    return new Trace(this, id, attrs);
+  }
+
+  private log(level: number, args: any[]): void {
+    if (this._level <= level) {
+      console.log(...args);
+    }
+  }
+
+  debug(...args: any[]): void {
+    this.log(0, args);
+  }
+
+  info(...args: any[]): void {
+    this.log(1, args);
+  }
+
+  warn(...args: any[]): void {
+    this.log(2, args);
+  }
+
+  error(...args: any[]): void {
+    this.log(3, args);
+  }
+}
+
+class Trace implements ITrace {
+  private timestamp: number = Date.now();
+
+  constructor(
+    private logger: Logger,
+    private id: string,
+    private attrs?: Record<string, string>,
+    private parent?: string,
+  ) {}
+
+  start(id: string, attrs?: Record<string, string>): ITrace {
+    return new Trace(this.logger, id, attrs, this.id);
+  }
+
+  end(): void {
+    this.logger.debug({
+      id: this.id,
+      parentId: this.parent,
+      timestamp: this.timestamp,
+      duration: Date.now() - this.timestamp,
+      attrs: this.attrs,
+    });
+  }
+}

lib/retries/retry.ts → lib/core/retries/retry.ts

@@ -1,4 +1,4 @@
-import { Context } from "../resonate";
+import { Context } from "../../resonate";
 import { IRetry } from "../retry";
 
 export class Retry implements IRetry {

lib/retry.ts → lib/core/retry.ts

@@ -1,4 +1,4 @@
-import { Context } from "./resonate";
+import { Context } from "../resonate";
 
 export interface IRetry {
   next(context: Context): { done: boolean; delay?: number };

lib/resonate.ts

@@ -1,25 +1,25 @@
-import { Opts, isPartialOpts } from "./opts";
-import { IPromiseStore } from "./store";
+import { Opts, isPartialOpts } from "./core/opts";
+import { IPromiseStore } from "./core/store";
 import {
   DurablePromise,
   isCanceledPromise,
   isPendingPromise,
   isRejectedPromise,
   isResolvedPromise,
   isTimedoutPromise,
-} from "./promise";
-import { IRetry } from "./retry";
-import { Retry } from "./retries/retry";
-import { IBucket } from "./bucket";
-import { Bucket } from "./buckets/bucket";
-import { VolatilePromiseStore } from "./stores/volatile";
-import { DurablePromiseStore } from "./stores/durable";
-import { ILogger, ITrace } from "./logger";
-import { Logger } from "./loggers/logger";
-import { IEncoder } from "./encoder";
-import { JSONEncoder } from "./encoders/json";
-import { ErrorEncoder } from "./encoders/error";
-import { ErrorCodes, ResonateError } from "./error";
+} from "./core/promise";
+import { IRetry } from "./core/retry";
+import { Retry } from "./core/retries/retry";
+import { IBucket } from "./core/bucket";
+import { Bucket } from "./core/buckets/bucket";
+import { VolatilePromiseStore } from "./core/stores/volatile";
+import { DurablePromiseStore } from "./core/stores/durable";
+import { ILogger, ITrace } from "./core/logger";
+import { Logger } from "./core/loggers/logger";
+import { IEncoder } from "./core/encoder";
+import { JSONEncoder } from "./core/encoders/json";
+import { ErrorEncoder } from "./core/encoders/error";
+import { ErrorCodes, ResonateError } from "./core/error";
 
 // Types
 

test/retry.test.ts

@@ -1,7 +1,7 @@
 import { jest, describe, test, expect, beforeEach } from "@jest/globals";
 import { Resonate, Context } from "../lib/resonate";
-import { IRetry } from "../lib/retry";
-import { Retry } from "../lib/retries/retry";
+import { IRetry } from "../lib/core/retry";
+import { Retry } from "../lib/core/retries/retry";
 
 // Set a larger timeout for hooks (e.g., 10 seconds)
 jest.setTimeout(10000);

test/store.test.ts

@@ -1,7 +1,7 @@
 import { jest, describe, test, expect } from "@jest/globals";
 
-import { DurablePromiseStore } from "../lib/stores/durable";
-import { VolatilePromiseStore } from "../lib/stores/volatile";
+import { DurablePromiseStore } from "../lib/core/stores/durable";
+import { VolatilePromiseStore } from "../lib/core/stores/volatile";
 
 // Set a larger timeout for hooks (e.g., 10 seconds)
 jest.setTimeout(10000);

test/trace.test.ts

@@ -2,7 +2,7 @@
 
 import { jest, describe, test, expect } from "@jest/globals";
 import { Resonate, Context } from "../lib/resonate";
-import { TestLogger } from "../lib/loggers/test";
+import { TestLogger } from "../lib/core/loggers/test";
 
 jest.setTimeout(100000); // 100 seconds