import * as Effect from "effect/Effect";import * as SqlClient from "effect/unstable/sql/SqlClient"; export default Effect.gen(function* () { const sql = yield* SqlClient.SqlClient; const columns = yield* sql<{ readonly name: string }>` PRAGMA table_info(projection_threads) `; if (columns.some((column) => column.name === "archived_at")) { return; } yield* sql` ALTER TABLE projection_threads ADD COLUMN archived_at TEXT `;});
import * as Effect from "effect/Effect";
import * as SqlClient from "effect/unstable/sql/SqlClient";
export default Effect.gen(function* () {
const sql = yield* SqlClient.SqlClient;
const columns = yield* sql<{ readonly name: string }>`
PRAGMA table_info(projection_threads)
`;
if (columns.some((column) => column.name === "archived_at")) {
return;
}
yield* sql`
ALTER TABLE projection_threads
ADD COLUMN archived_at TEXT
`;
});