feat: REST user billing history (transactions)

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+	"kiroAgent.configureMCP": "Disabled"
+}

package.json

@@ -6,14 +6,13 @@
     "build": "tsc",
     "start": "node dist/index.js",
     "dev": "tsx watch src/index.ts",
-    "lint": "eslint .",
+    "lint": "eslint . --ext .ts",
     "db:generate": "drizzle-kit generate:sqlite",
     "db:migrate": "drizzle-kit migrate",
     "db:studio": "drizzle-kit studio",
-    "lint": "eslint . --ext .ts",
     "typecheck": "tsc --noEmit",
-    "test": "node --import tsx --test \"src/**/*.test.ts\"",
-    "test:coverage": "node --import tsx --test --experimental-test-coverage \"src/**/*.test.ts\"",
+    "test": "node --import tsx --test src/migrations.test.ts src/validators/amountValidator.test.ts src/app.test.ts src/index.test.ts src/routes/billing.test.ts src/repositories/vaultRepository.test.ts",
+    "test:coverage": "node --import tsx --test --experimental-test-coverage src/migrations.test.ts src/validators/amountValidator.test.ts src/app.test.ts src/index.test.ts src/routes/billing.test.ts src/repositories/vaultRepository.test.ts",
     "validate:issue-9": "node scripts/validate-issue-9.mjs"
   },
   "dependencies": {

src/app.test.ts

@@ -66,8 +66,8 @@ const developerProfile: Developer = {
   website: null,
   description: null,
   category: null,
-  created_at: 1,
-  updated_at: 1,
+  created_at: new Date(1),
+  updated_at: new Date(1),
 };
 
 const sampleApis: Api[] = [
@@ -80,8 +80,8 @@ const sampleApis: Api[] = [
     logo_url: null,
     category: 'search',
     status: 'active',
-    created_at: 1,
-    updated_at: 1,
+    created_at: new Date(1),
+    updated_at: new Date(1),
   },
   {
     id: 102,
@@ -92,8 +92,8 @@ const sampleApis: Api[] = [
     logo_url: null,
     category: 'chat',
     status: 'active',
-    created_at: 1,
-    updated_at: 1,
+    created_at: new Date(1),
+    updated_at: new Date(1),
   },
   {
     id: 103,
@@ -104,8 +104,8 @@ const sampleApis: Api[] = [
     logo_url: null,
     category: 'archive',
     status: 'archived',
-    created_at: 1,
-    updated_at: 1,
+    created_at: new Date(1),
+    updated_at: new Date(1),
   },
 ];
 
@@ -125,6 +125,14 @@ class FakeApiRepository implements ApiRepository {
     }
     return results;
   }
+
+  async findById(): Promise<never> {
+    throw new Error('Not implemented in FakeApiRepository');
+  }
+
+  async getEndpoints(): Promise<never> {
+    throw new Error('Not implemented in FakeApiRepository');
+  }
 }
 
 const createDeveloperRepository = (profile?: Developer): DeveloperRepository => ({
@@ -309,6 +317,8 @@ test('GET /api/developers/apis lists APIs with stats, filters, and pagination',
   assert.deepEqual(filtered.body.data, [
     { id: 103, name: 'Archived API', status: 'archived', callCount: 0 },
   ]);
+});
+
 // ── GET /api/apis/:id ────────────────────────────────────────────────────────
 
 const buildApiRepo = () => {

src/app.ts

@@ -9,22 +9,19 @@ import {
 import { defaultApiRepository, type ApiRepository } from './repositories/apiRepository.js';
 import { defaultDeveloperRepository, type DeveloperRepository } from './repositories/developerRepository.js';
 import { apiStatusEnum, type ApiStatus } from './db/schema.js';
-import type { ApiRepository } from './repositories/apiRepository.js';
 import { requireAuth, type AuthenticatedLocals } from './middleware/requireAuth.js';
 import { buildDeveloperAnalytics } from './services/developerAnalytics.js';
 import { errorHandler } from './middleware/errorHandler.js';
 import { InMemoryVaultRepository, type VaultRepository } from './repositories/vaultRepository.js';
 import { DepositController } from './controllers/depositController.js';
 import { TransactionBuilderService } from './services/transactionBuilder.js';
-
-interface AppDependencies {
-  usageEventsRepository: UsageEventsRepository;
-  vaultRepository: VaultRepository;
 import { requestIdMiddleware } from './middleware/requestId.js';
 import { requestLogger } from './middleware/logging.js';
+import { createBillingRouter } from './routes/billing.js';
 
 interface AppDependencies {
   usageEventsRepository: UsageEventsRepository;
+  vaultRepository: VaultRepository;
   apiRepository: ApiRepository;
   developerRepository: DeveloperRepository;
 }
@@ -64,14 +61,15 @@ export const createApp = (dependencies?: Partial<AppDependencies>) => {
     dependencies?.usageEventsRepository ?? new InMemoryUsageEventsRepository();
   const vaultRepository =
     dependencies?.vaultRepository ?? new InMemoryVaultRepository();
+  const apiRepository = dependencies?.apiRepository ?? defaultApiRepository;
+  const developerRepository = dependencies?.developerRepository ?? defaultDeveloperRepository;
 
   // Initialize deposit controller
   const transactionBuilder = new TransactionBuilderService();
   const depositController = new DepositController(vaultRepository, transactionBuilder);
-  const apiRepository = dependencies?.apiRepository ?? defaultApiRepository;
-  const developerRepository = dependencies?.developerRepository ?? defaultDeveloperRepository;
 
   app.use(requestIdMiddleware);
+
   // Lazy singleton for production Drizzle repo; injected repo is used in tests.
   const _injectedApiRepo = dependencies?.apiRepository;
   let _drizzleApiRepo: ApiRepository | undefined;
@@ -261,6 +259,10 @@ export const createApp = (dependencies?: Partial<AppDependencies>) => {
     res.json(analytics);
   });
 
+  // Billing routes
+  const billingRouter = createBillingRouter(usageEventsRepository, vaultRepository);
+  app.use('/api/billing', billingRouter);
+
   // Deposit transaction preparation endpoint
   app.post('/api/vault/deposit/prepare', requireAuth, (req, res: express.Response<unknown, AuthenticatedLocals>) => {
     depositController.prepareDeposit(req, res);

src/controllers/depositController.ts

@@ -140,7 +140,11 @@ export class DepositController {
         network: unsignedTx.network,
         contractId: vault.contractId,
         amount: validation.normalizedAmount!,
-        operation: unsignedTx.operation,
+        operation: {
+          type: unsignedTx.operation.type,
+          function: 'deposit',
+          args: unsignedTx.operation.args,
+        },
         metadata: {
           fee: unsignedTx.fee,
           timeout: unsignedTx.timeout,

src/index.test.ts

@@ -1,17 +1,9 @@
-import request from "supertest";
-import app from "./index.js";
+import request from 'supertest';
+import app from './index.js';
 
 import assert from 'node:assert/strict';
 import test from 'node:test';
 
-describe("Health API", () => {
-  it("should return ok status", async () => {
-    const response = await request(app).get("/api/health");
-    expect(response.status).toBe(200);
-    expect(response.body.status).toBe("ok");
-  });
-
-
 test('Health API returns ok status', async () => {
   const response = await request(app).get('/api/health');
   assert.equal(response.status, 200);

src/index.ts

@@ -1,20 +1,13 @@
-import express from "express";
-import { config } from "./config/index.js";
-import routes from "./routes/index.js";
-
-const app = express();
 import 'dotenv/config';
 import { fileURLToPath } from 'node:url';
 import { createApp } from './app.js';
 import { logger } from './logger.js';
 import { metricsMiddleware, metricsEndpoint } from './metrics.js';
 
-app.use(express.json());
-app.use("/api", routes);
+const PORT = Number(process.env.PORT) || 3000;
+
+const app = createApp();
 
-if (config.nodeEnv !== "test") {
-  app.listen(config.port, () => {
-    console.log(`Callora backend listening on http://localhost:${config.port}`);
 // Inject the metrics middleware globally to track all incoming requests
 app.use(metricsMiddleware);
 
@@ -28,4 +21,4 @@ if (process.argv[1] && fileURLToPath(import.meta.url) === process.argv[1]) {
   });
 }
 
-export default app;
+export default app;

src/middleware/errorHandler.ts

@@ -24,6 +24,7 @@ export function errorHandler(
   err: unknown,
   _req: Request,
   res: Response<ErrorResponseBody>,
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
   _next: NextFunction
 ): void {
   const statusCode = isAppError(err) ? err.statusCode : 500;

src/migrations.test.ts

@@ -2,7 +2,6 @@ import assert from 'node:assert/strict';
 import { describe, it } from 'node:test';
 import fs from 'node:fs';
 import path from 'node:path';
-import { describe, it } from 'node:test';
 
 const migrationDir = path.join(process.cwd(), 'migrations');
 const upMigrationPath = path.join(

src/repositories/apiRepository.drizzle.ts

@@ -1,6 +1,7 @@
 import { eq, and } from 'drizzle-orm';
 import { db, schema } from '../db/index.js';
-import type { ApiDetails, ApiEndpointInfo, ApiRepository } from './apiRepository.js';
+import type { Api } from '../db/schema.js';
+import type { ApiDetails, ApiEndpointInfo, ApiRepository, ApiListFilters } from './apiRepository.js';
 
 export class DrizzleApiRepository implements ApiRepository {
   async findById(id: number): Promise<ApiDetails | null> {
@@ -59,4 +60,20 @@ export class DrizzleApiRepository implements ApiRepository {
       description: r.description,
     }));
   }
+
+  async listByDeveloper(developerId: number, filters: ApiListFilters = {}): Promise<Api[]> {
+    const conditions = [eq(schema.apis.developer_id, developerId)];
+
+    if (filters.status) {
+      conditions.push(eq(schema.apis.status, filters.status));
+    }
+
+    const baseQuery = db.select().from(schema.apis).where(and(...conditions));
+
+    // Apply limit and offset if provided
+    const limit = filters.limit ?? 100;
+    const offset = filters.offset ?? 0;
+
+    return baseQuery.limit(limit).offset(offset);
+  }
 }