authorgravatar for julius0216@outlook.comJulius Marminge <julius0216@outlook.com> 2026-04-01 08:44:49-07:00
committergravatar for noreply@github.comGitHub <noreply@github.com> 2026-04-01 08:44:49-07:00
log3488ca3570060449d3855eeba79a40e1f9938f9c
tree12e64f22334f51f2ac712dd32eeb123fca335944
parentc542ce336965261dd01c6e670b603434596e3527
signature Signed by PGP key B5690EEEBB952194

[codex] migrate Effect.fn in apps/server/src/persistence/Migrations.ts (#1632)

Co-authored-by: codex <codex@users.noreply.github.com>

1 files changed, 14 insertions(+), 13 deletions(-)

apps/server/src/persistence/Migrations.ts+14-13
...@@ -92,19 +92,20 @@ export interface RunMigrationsOptions {...@@ -92,19 +92,20 @@ export interface RunMigrationsOptions {
92 *92 *
93 * @returns Effect containing array of executed migrations93 * @returns Effect containing array of executed migrations
94 */94 */
95export const runMigrations = ({ toMigrationInclusive }: RunMigrationsOptions = {}) =>95export const runMigrations = Effect.fn("runMigrations")(function* ({
96 Effect.gen(function* () {96 toMigrationInclusive,
97 yield* Effect.log(97}: RunMigrationsOptions = {}) {
98 toMigrationInclusive === undefined98 yield* Effect.log(
99 ? "Running all migrations..."99 toMigrationInclusive === undefined
100 : `Running migrations 1 through ${toMigrationInclusive}...`,100 ? "Running all migrations..."
101 );101 : `Running migrations 1 through ${toMigrationInclusive}...`,
102 const executedMigrations = yield* run({ loader: makeMigrationLoader(toMigrationInclusive) });102 );
103 yield* Effect.log("Migrations ran successfully").pipe(103 const executedMigrations = yield* run({ loader: makeMigrationLoader(toMigrationInclusive) });
104 Effect.annotateLogs({ migrations: executedMigrations.map(([id, name]) => `${id}_${name}`) }),104 yield* Effect.log("Migrations ran successfully").pipe(
105 );105 Effect.annotateLogs({ migrations: executedMigrations.map(([id, name]) => `${id}_${name}`) }),
106 return executedMigrations;106 );
107 });107 return executedMigrations;
108});
108109
109/**110/**
110 * Layer that runs migrations when the layer is built.111 * Layer that runs migrations when the layer is built.