layerx-labs
diff --git a/‎.github/workflows/ci-cd.yml‎
Lines changed: 11 additions & 0 deletions b/‎.github/workflows/ci-cd.yml‎
Lines changed: 11 additions & 0 deletions
diff --git a/‎package.json‎
Lines changed: 2 additions & 0 deletions b/‎package.json‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎src/__tests__/__mocks__/external-services.ts‎
Lines changed: 212 additions & 0 deletions b/‎src/__tests__/__mocks__/external-services.ts‎
Lines changed: 212 additions & 0 deletions
@@ -32,6 +32,17 @@ jobs:
     - name: Build project
       run: bun run build
 
+    - name: Run tests
+      run: bun test
+
+    - name: Run tests with coverage
+      run: bun test --coverage
+
+    - name: Upload coverage to Codecov
+      uses: codecov/codecov-action@v5
+      with:
+        fail_ci_if_error: false
+
   docker:
     runs-on: ubuntu-latest
     needs: test
 
@@ -9,7 +9,9 @@
     "start": "NODE_ENV=production bun src/main.ts",
     "build": "bun install && bunx prisma generate",
     "test": "bun test",
+    "test:watch": "bun test --watch",
     "test:coverage": "bun test --coverage",
+    "test:debug": "bun test --inspect-brk",
     "lint": "biome lint .",
     "lint:fix": "biome lint --write .",
     "lint:unsafe": "biome lint --write --unsafe .",
 
@@ -0,0 +1,212 @@
+import { mock } from 'bun:test';
+
+/**
+ * Mock for axios HTTP client
+ */
+export const mockAxios = {
+  post: mock(() =>
+    Promise.resolve({
+      status: 200,
+      statusText: 'OK',
+      data: { success: true },
+      headers: {},
+      config: {},
+    })
+  ),
+  get: mock(() =>
+    Promise.resolve({
+      status: 200,
+      statusText: 'OK',
+      data: {},
+      headers: {},
+      config: {},
+    })
+  ),
+  put: mock(() =>
+    Promise.resolve({
+      status: 200,
+      statusText: 'OK',
+      data: {},
+      headers: {},
+      config: {},
+    })
+  ),
+  delete: mock(() =>
+    Promise.resolve({
+      status: 200,
+      statusText: 'OK',
+      data: {},
+      headers: {},
+      config: {},
+    })
+  ),
+  create: mock(() => mockAxios),
+  defaults: {
+    headers: {
+      common: {},
+    },
+  },
+};
+
+/**
+ * Mock for Elasticsearch client
+ */
+export const mockElasticsearchClient = {
+  index: mock(() =>
+    Promise.resolve({
+      _index: 'test-index',
+      _id: 'mock-doc-id',
+      _version: 1,
+      result: 'created',
+    })
+  ),
+  search: mock(() =>
+    Promise.resolve({
+      hits: {
+        total: { value: 0 },
+        hits: [],
+      },
+    })
+  ),
+  delete: mock(() =>
+    Promise.resolve({
+      result: 'deleted',
+    })
+  ),
+  bulk: mock(() =>
+    Promise.resolve({
+      errors: false,
+      items: [],
+    })
+  ),
+  ping: mock(() => Promise.resolve(true)),
+};
+
+/**
+ * Creates a mock Elasticsearch Client class
+ */
+export function createMockElasticsearchClient() {
+  return mockElasticsearchClient;
+}
+
+/**
+ * Mock BullMQ Queue class
+ */
+export class MockQueue {
+  name: string;
+
+  constructor(name: string) {
+    this.name = name;
+  }
+
+  add = mock((jobName: string, data: unknown) =>
+    Promise.resolve({
+      id: 'mock-job-id',
+      name: jobName,
+      data,
+      timestamp: Date.now(),
+    })
+  );
+
+  addBulk = mock((jobs: Array<{ name: string; data: unknown }>) =>
+    Promise.resolve(
+      jobs.map((job, i) => ({
+        id: `mock-job-id-${i}`,
+        name: job.name,
+        data: job.data,
+        timestamp: Date.now(),
+      }))
+    )
+  );
+
+  close = mock(() => Promise.resolve());
+  pause = mock(() => Promise.resolve());
+  resume = mock(() => Promise.resolve());
+
+  getJobs = mock(() => Promise.resolve([]));
+  getJobCounts = mock(() =>
+    Promise.resolve({
+      waiting: 0,
+      active: 0,
+      completed: 0,
+      failed: 0,
+      delayed: 0,
+    })
+  );
+}
+
+/**
+ * Mock Google Sheets API
+ */
+export const mockGoogleSheetsApi = {
+  spreadsheets: {
+    values: {
+      append: mock(() =>
+        Promise.resolve({
+          data: {
+            spreadsheetId: 'mock-spreadsheet-id',
+            tableRange: 'Sheet1!A1:D1',
+            updates: {
+              updatedRows: 1,
+              updatedColumns: 4,
+              updatedCells: 4,
+            },
+          },
+        })
+      ),
+      get: mock(() =>
+        Promise.resolve({
+          data: {
+            values: [],
+          },
+        })
+      ),
+      update: mock(() =>
+        Promise.resolve({
+          data: {
+            updatedRows: 1,
+          },
+        })
+      ),
+    },
+  },
+};
+
+/**
+ * Mock for google.auth.GoogleAuth
+ */
+export class MockGoogleAuth {
+  credentials: unknown;
+
+  constructor(options: { credentials: unknown; scopes: string[] }) {
+    this.credentials = options.credentials;
+  }
+
+  getClient = mock(() => Promise.resolve({}));
+}
+
+/**
+ * Mock for googleapis.google.sheets
+ */
+export const mockGoogleSheets = mock(() => mockGoogleSheetsApi);
+
+/**
+ * Mock fetch function for webhook tests
+ */
+export const mockFetch = mock(() =>
+  Promise.resolve({
+    ok: true,
+    status: 200,
+    statusText: 'OK',
+    json: () => Promise.resolve({ success: true }),
+    text: () => Promise.resolve('OK'),
+  })
+);
+
+/**
+ * Mock Redis connection for BullMQ
+ */
+export const mockRedisConnection = {
+  host: 'localhost',
+  port: 6379,
+};