Refactoring

packages/api_platform/package.json

@@ -19,8 +19,7 @@
     "kysely": "^0.28.11",
     "pg": "^8.18.0",
     "redis": "^5.11.0",
-    "resolver": "workspace:*",
-    "vault": "workspace:*"
+    "@enfinyte/services": "workspace:*"
   },
   "devDependencies": {
     "@types/bun": "latest"

packages/api_platform/src/index.ts

@@ -1,9 +1,7 @@
 import { HttpMiddleware, HttpServer } from "@effect/platform";
 import { BunContext, BunHttpServer, BunRuntime } from "@effect/platform-bun";
 import { Effect, flow, Layer } from "effect";
-import { fromEnv as LedgerServiceLive } from "ledger";
-import { ResolverServiceLive } from "resolver";
-import { VaultServiceLive } from "vault";
+import { LedgerServiceLive, ResolverServiceLive, VaultServiceLive } from "@enfinyte/services";
 
 import { router } from "./routes/index";
 import { AppConfig, AppConfigLive } from "./services/config";

packages/api_platform/src/routes/v1/__tests__/responses-streaming.test.ts

@@ -9,7 +9,7 @@
 import { router } from "../..";
 import { AppConfig } from "../../../services/config";
 import { DatabaseService, DatabaseServiceError } from "../../../services/database/postgres";
-import { VaultService } from "vault";
+import { VaultService, LedgerService, ResolverService } from "@enfinyte/services";
 
 type StreamResult = ReturnType<typeof streamText>;
 
@@ -79,9 +79,14 @@
     ),
   executeStream: (_body: CreateResponseBody) =>
     Effect.succeed({
-      stream: mockStream(),
-      result: mockStreamResult(),
+      result: {
+        ...mockStreamResult(),
+        fullStream: mockStream(),
+      },
       resolvedModelAndProvider: { provider: "openai", model: "gpt-4o-mini" },
+      resolutionLatencyMs: 0,
+      llmStartedAt: Date.now(),
+      ttftMs: 5,
     }),
 }));
 
@@ -135,7 +140,7 @@
   const chunks: string[] = [];
 
   while (true) {
     const { done, value } = await reader.read();
     if (done) break;
     buffer += decoder.decode(value, { stream: true });
     let index = buffer.indexOf("\n\n");
@@ -218,11 +223,38 @@
     }),
   );
 
+  const LedgerServiceTest = Layer.succeed(
+    LedgerService,
+    LedgerService.of({
+      insertTransaction: (t) => Effect.succeed(t),
+      getOverview: () => Effect.succeed({
+        total_requests: 0, avg_latency_ms: 0, p50_latency_ms: 0,
+        p95_latency_ms: 0, p99_latency_ms: 0, avg_resolution_latency_ms: 0,
+        total_cost_usd: 0, error_rate: 0, total_errors: 0, total_rate_limits: 0,
+      }),
+      getTimeSeries: () => Effect.succeed([]),
+      getProviderModelLatency: () => Effect.succeed([]),
+      getDailyModelCost: () => Effect.succeed([]),
+      getErrorRate: () => Effect.succeed([]),
+    }),
+  );
+
+  const ResolverServiceTest = Layer.succeed(
+    ResolverService,
+    ResolverService.of({
+      getAvailableModels: () => Effect.succeed({}),
+      resolve: () => Effect.succeed([{ provider: "openai", model: "gpt-4o-mini", category: null }]),
+      getCostForModel: () => Effect.succeed(null),
+    }),
+  );
+
   const HttpServerLayer = BunHttpServer.layer({ port });
   const AllServices = Layer.mergeAll(
     AppConfigTest,
     DatabaseServiceTest,
     VaultServiceTest,
+    LedgerServiceTest,
+    ResolverServiceTest,
     BunContext.layer,
   );
   const AllServicesAndHttpServer = Layer.mergeAll(AllServices, HttpServerLayer);