Skip to content

Commit 9da430c

Browse files
Refactor recoverable Effect fallbacks to orElseSucceed (#2968)
1 parent a084fbb commit 9da430c

42 files changed

Lines changed: 182 additions & 318 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

apps/desktop/src/app/DesktopAppIdentity.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ const make = Effect.gen(function* () {
5252
Effect.map((parsed) =>
5353
Option.fromNullishOr(parsed.t3codeCommitHash).pipe(Option.flatMap(normalizeCommitHash)),
5454
),
55-
Effect.catch(() => Effect.succeed(Option.none<string>())),
55+
Effect.orElseSucceed(() => Option.none<string>()),
5656
),
5757
});
5858
});

apps/desktop/src/backend/tailscaleEndpointProvider.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,11 +116,11 @@ export const resolveTailscaleAdvertisedEndpoints = Effect.fn("resolveTailscaleAd
116116
input.statusJson === undefined
117117
? yield* readTailscaleStatus.pipe(
118118
Effect.map((status) => status.magicDnsName),
119-
Effect.catch(() => Effect.succeed(null)),
119+
Effect.orElseSucceed(() => null),
120120
)
121121
: input.statusJson
122122
? yield* parseTailscaleMagicDnsName(input.statusJson).pipe(
123-
Effect.catch(() => Effect.succeed(null)),
123+
Effect.orElseSucceed(() => null),
124124
)
125125
: null;
126126
const magicDnsEndpoint = yield* resolveTailscaleMagicDnsAdvertisedEndpoint({

apps/desktop/src/settings/DesktopAppSettings.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ function readSettings(
209209
onSome: (raw) =>
210210
decodeDesktopSettingsJson(raw).pipe(
211211
Effect.map((parsed) => normalizeDesktopSettingsDocument(parsed, appVersion)),
212-
Effect.catch(() => Effect.succeed(defaultSettings)),
212+
Effect.orElseSucceed(() => defaultSettings),
213213
),
214214
}),
215215
),

apps/desktop/src/settings/DesktopClientSettings.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ const readClientSettings = (
6363
onSome: (raw) =>
6464
decodeClientSettingsJson(raw).pipe(
6565
Effect.map((settings) => Option.some(settings)),
66-
Effect.catch(() => Effect.succeed(Option.none<ClientSettings>())),
66+
Effect.orElseSucceed(() => Option.none<ClientSettings>()),
6767
),
6868
}),
6969
),

apps/desktop/src/settings/DesktopSavedEnvironments.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ function readRegistryDocument(
185185
onSome: (raw) =>
186186
decodeSavedEnvironmentRegistryDocumentJson(raw).pipe(
187187
Effect.map(normalizeSavedEnvironmentRegistryDocument),
188-
Effect.catch(() => Effect.succeed({ version: 1, records: [] })),
188+
Effect.orElseSucceed(() => ({ version: 1, records: [] })),
189189
),
190190
}),
191191
),

apps/desktop/src/shell/DesktopShellEnvironment.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ const runCommandOutput = Effect.fn("desktop.shellEnvironment.runCommandOutput")(
196196
.pipe(
197197
Effect.timeoutOption(input.timeout),
198198
Effect.map(Option.getOrElse(() => "")),
199-
Effect.catch(() => Effect.succeed("")),
199+
Effect.orElseSucceed(() => ""),
200200
);
201201
});
202202

apps/desktop/src/updates/DesktopUpdates.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ function parseAppUpdateYml(raw: string): Effect.Effect<Option.Option<AppUpdateYm
120120

121121
return decodeAppUpdateYmlConfig(entries).pipe(
122122
Effect.map((config) => (config.provider ? Option.some(config) : Option.none())),
123-
Effect.catch(() => Effect.succeed(Option.none<AppUpdateYmlConfig>())),
123+
Effect.orElseSucceed(() => Option.none<AppUpdateYmlConfig>()),
124124
);
125125
}
126126

apps/server/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
"@t3tools/shared": "workspace:*",
3939
"@t3tools/tailscale": "workspace:*",
4040
"@t3tools/web": "workspace:*",
41-
"@types/bun": "catalog:",
41+
"@types/bun": "1.3.14",
4242
"@types/node": "catalog:",
4343
"effect-acp": "workspace:*",
4444
"effect-codex-app-server": "workspace:*",

apps/server/src/checkpointing/Layers/CheckpointStore.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ const makeCheckpointStore = Effect.gen(function* () {
3535
const isGitRepository: CheckpointStoreShape["isGitRepository"] = (cwd) =>
3636
vcsRegistry.resolve({ cwd, requestedKind: "git" }).pipe(
3737
Effect.map(() => true),
38-
Effect.catch(() => Effect.succeed(false)),
38+
Effect.orElseSucceed(() => false),
3939
);
4040

4141
const captureCheckpoint: CheckpointStoreShape["captureCheckpoint"] = Effect.fn(

apps/server/src/cloud/ManagedEndpointRuntime.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -152,9 +152,7 @@ export const makeCloudManagedEndpointRuntime = Effect.gen(function* () {
152152
const nextConfigKey = runtimeConfigKey(config);
153153
const active = yield* Ref.get(activeRef);
154154
if (active?.configKey === nextConfigKey) {
155-
const isRunning = yield* active.child.isRunning.pipe(
156-
Effect.catch(() => Effect.succeed(false)),
157-
);
155+
const isRunning = yield* active.child.isRunning.pipe(Effect.orElseSucceed(() => false));
158156
if (isRunning) {
159157
return {
160158
status: "running",

0 commit comments

Comments
 (0)