import * as SqlClient from "effect/unstable/sql/SqlClient";import * as Effect from "effect/Effect";export default Effect.gen(function* () { const sql = yield* SqlClient.SqlClient; yield* sql` CREATE TABLE IF NOT EXISTS orchestration_command_receipts ( command_id TEXT PRIMARY KEY, aggregate_kind TEXT NOT NULL, aggregate_id TEXT NOT NULL, accepted_at TEXT NOT NULL, result_sequence INTEGER NOT NULL, status TEXT NOT NULL, error TEXT ) `; yield* sql` CREATE INDEX IF NOT EXISTS idx_orch_command_receipts_aggregate ON orchestration_command_receipts(aggregate_kind, aggregate_id) `; yield* sql` CREATE INDEX IF NOT EXISTS idx_orch_command_receipts_sequence ON orchestration_command_receipts(result_sequence) `;});
import * as SqlClient from "effect/unstable/sql/SqlClient";
import * as Effect from "effect/Effect";
export default Effect.gen(function* () {
const sql = yield* SqlClient.SqlClient;
yield* sql`
CREATE TABLE IF NOT EXISTS orchestration_command_receipts (
command_id TEXT PRIMARY KEY,
aggregate_kind TEXT NOT NULL,
aggregate_id TEXT NOT NULL,
accepted_at TEXT NOT NULL,
result_sequence INTEGER NOT NULL,
status TEXT NOT NULL,
error TEXT
)
`;
yield* sql`
CREATE INDEX IF NOT EXISTS idx_orch_command_receipts_aggregate
ON orchestration_command_receipts(aggregate_kind, aggregate_id)
`;
yield* sql`
CREATE INDEX IF NOT EXISTS idx_orch_command_receipts_sequence
ON orchestration_command_receipts(result_sequence)
`;
});