Skip to content

Commit f7f56a3

Browse files
committed
fix: layers
1 parent dbcf07f commit f7f56a3

2 files changed

Lines changed: 48 additions & 34 deletions

File tree

apps/api/src/http.ts

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -12,20 +12,16 @@ import { HttpScrapeTargetsLive } from "./routes/scrape-targets.http";
1212
import { HttpServiceDiscoveryLive } from "./routes/sd.http";
1313
import { HttpTinybirdLive } from "./routes/tinybird.http";
1414

15-
const HttpGroupsLive = Layer.mergeAll(
16-
HttpAuthPublicLive,
17-
HttpAuthLive,
18-
HttpApiKeysLive,
19-
HttpCloudflareLogpushLive,
20-
HttpDashboardsLive,
21-
HttpIngestKeysLive,
22-
HttpOrgTinybirdSettingsLive,
23-
HttpScrapeTargetsLive,
24-
HttpServiceDiscoveryLive,
25-
HttpTinybirdLive,
26-
HttpQueryEngineLive,
27-
)
28-
2915
export const HttpApiRoutes = HttpApiBuilder.layer(MapleApi).pipe(
30-
Layer.provide(HttpGroupsLive),
16+
Layer.provide(HttpAuthPublicLive),
17+
Layer.provide(HttpAuthLive),
18+
Layer.provide(HttpApiKeysLive),
19+
Layer.provide(HttpCloudflareLogpushLive),
20+
Layer.provide(HttpDashboardsLive),
21+
Layer.provide(HttpIngestKeysLive),
22+
Layer.provide(HttpOrgTinybirdSettingsLive),
23+
Layer.provide(HttpScrapeTargetsLive),
24+
Layer.provide(HttpServiceDiscoveryLive),
25+
Layer.provide(HttpTinybirdLive),
26+
Layer.provide(HttpQueryEngineLive),
3127
);

apps/api/src/index.ts

Lines changed: 37 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -33,13 +33,43 @@ const DocsRoute = HttpApiScalar.layer(MapleApi, {
3333
path: "/docs",
3434
});
3535

36+
const InfraLive = Database.layer.pipe(
37+
Layer.provideMerge(Env.layer),
38+
)
39+
40+
const CoreServicesLive = Layer.mergeAll(
41+
AuthService.layer,
42+
ApiKeysService.layer,
43+
CloudflareLogpushService.layer,
44+
DashboardPersistenceService.layer,
45+
OrgIngestKeysService.layer,
46+
OrgTinybirdSettingsService.layer,
47+
ScrapeTargetsService.layer,
48+
).pipe(
49+
Layer.provideMerge(InfraLive),
50+
)
51+
52+
const TinybirdServiceLive = TinybirdService.layer.pipe(
53+
Layer.provideMerge(CoreServicesLive),
54+
)
55+
56+
const QueryEngineServiceLive = QueryEngineService.layer.pipe(
57+
Layer.provideMerge(TinybirdServiceLive),
58+
)
59+
60+
const MainLive = Layer.mergeAll(
61+
CoreServicesLive,
62+
TinybirdServiceLive,
63+
QueryEngineServiceLive,
64+
)
65+
3666
const AllRoutes = Layer.mergeAll(
3767
HttpApiRoutes,
68+
AutumnRouter,
69+
McpLive,
3870
HealthRouter,
3971
McpGetFallback,
4072
DocsRoute,
41-
AutumnRouter,
42-
McpLive,
4373
).pipe(
4474
Layer.provideMerge(
4575
HttpRouter.cors({
@@ -51,24 +81,8 @@ const AllRoutes = Layer.mergeAll(
5181
),
5282
);
5383

54-
const MainLive = Layer.mergeAll(
55-
Env.layer,
56-
Database.layer,
57-
TinybirdService.layer,
58-
QueryEngineService.layer,
59-
AuthService.layer,
60-
ApiKeysService.layer,
61-
CloudflareLogpushService.layer,
62-
DashboardPersistenceService.layer,
63-
OrgIngestKeysService.layer,
64-
OrgTinybirdSettingsService.layer,
65-
ScrapeTargetsService.layer,
66-
);
67-
6884
const RuntimeLive = Layer.mergeAll(
69-
MainLive,
7085
TracerLive,
71-
AuthorizationLive,
7286
Layer.succeed(
7387
HttpMiddleware.TracerDisabledWhen,
7488
(request: { url: string; method: string }) =>
@@ -82,6 +96,10 @@ const RuntimeLive = Layer.mergeAll(
8296
).pipe(Layer.orDie),
8397
)
8498

85-
const app = HttpRouter.serve(AllRoutes).pipe(Layer.provide(RuntimeLive));
99+
const app = HttpRouter.serve(AllRoutes).pipe(
100+
Layer.provide(RuntimeLive),
101+
Layer.provide(MainLive),
102+
Layer.provide(AuthorizationLive.pipe(Layer.provideMerge(Env.layer))),
103+
);
86104

87105
BunRuntime.runMain(app.pipe(Layer.launch as never));

0 commit comments

Comments
 (0)