1import * as SqlClient from "effect/sql/SqlClient";
2import * as Effect from "effect/Effect";
3
4export default Effect.gen(function* () {
5 const sql = yield* SqlClient.SqlClient;
6
7 yield* sql`
8 ALTER TABLE projection_threads
9 ADD COLUMN latest_user_message_at TEXT
10 `.pipe(Effect.catch(() => Effect.void));
11
12 yield* sql`
13 ALTER TABLE projection_threads
14 ADD COLUMN pending_approval_count INTEGER NOT NULL DEFAULT 0
15 `.pipe(Effect.catch(() => Effect.void));
16
17 yield* sql`
18 ALTER TABLE projection_threads
19 ADD COLUMN pending_user_input_count INTEGER NOT NULL DEFAULT 0
20 `.pipe(Effect.catch(() => Effect.void));
21
22 yield* sql`
23 ALTER TABLE projection_threads
24 ADD COLUMN has_actionable_proposed_plan INTEGER NOT NULL DEFAULT 0
25 `.pipe(Effect.catch(() => Effect.void));
26});