Skip to content

Commit b48548d

Browse files
committed
Fix db-search-check async handling
1 parent 00cc3f7 commit b48548d

1 file changed

Lines changed: 15 additions & 10 deletions

File tree

  • packages/mcp-server/app/api/db-search-check

packages/mcp-server/app/api/db-search-check/route.ts

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -26,13 +26,12 @@ const handleDbSearchCheck = Effect.fn("db-search-check")(function* (
2626

2727
const result = yield* Effect.gen(function* () {
2828
const { db, close } = createDatabase(dbUrl);
29-
try {
30-
const repo = createEffectPatternRepository(db);
31-
const rows = await repo.search({ limit: 1 });
32-
return { ok: true, rows };
33-
} catch (error: any) {
34-
return {
35-
ok: false,
29+
const repo = createEffectPatternRepository(db);
30+
31+
const rowsResult = yield* Effect.tryPromise({
32+
try: () => repo.search({ limit: 1 }),
33+
catch: (error: any) => ({
34+
ok: false as const,
3635
error: {
3736
message: error?.message,
3837
code: error?.code,
@@ -45,10 +44,16 @@ const handleDbSearchCheck = Effect.fn("db-search-check")(function* (
4544
where: error?.where,
4645
cause: error?.cause?.message ?? error?.cause,
4746
},
48-
};
49-
} finally {
50-
await close();
47+
}),
48+
});
49+
50+
yield* Effect.promise(() => close());
51+
52+
if (Array.isArray(rowsResult)) {
53+
return { ok: true as const, rows: rowsResult };
5154
}
55+
56+
return rowsResult;
5257
});
5358

5459
return {

0 commit comments

Comments
 (0)