Lorem Ipsum MCP Server

import type { Effect } from "../Effect.js" import * as Either from "../Either.js" import type * as Api from "../ExecutionPlan.js" import { dual } from "../Function.js" import * as Predicate from "../Predicate.js" import * as core from "./core.js" import * as layer from "./layer.js" import * as InternalSchedule from "./schedule.js" /** @internal */ export const TypeId: Api.TypeId = Symbol.for("effect/ExecutionPlan") as Api.TypeId /** @internal */ export const isExecutionPlan = (u: unknown): u is Api.ExecutionPlan<any> => Predicate.hasProperty(u, TypeId) /** @internal */ export const withExecutionPlan: { <Input, Provides, PlanE, PlanR>( plan: Api.ExecutionPlan<{ provides: Provides input: Input error: PlanE requirements: PlanR }> ): <A, E extends Input, R>(effect: Effect<A, E, R>) => Effect< A, E | PlanE, Exclude<R, Provides> | PlanR > <A, E extends Input, R, Provides, Input, PlanE, PlanR>( effect: Effect<A, E, R>, plan: Api.ExecutionPlan<{ provides: Provides input: Input error: PlanE requirements: PlanR }> ): Effect< A, E | PlanE, Exclude<R, Provides> | PlanR > } = dual(2, <A, E extends Input, R, Provides, Input, PlanE, PlanR>( effect: Effect<A, E, R>, plan: Api.ExecutionPlan<{ provides: Provides input: Input error: PlanE requirements: PlanR }> ) => core.suspend(() => { let i = 0 let result: Either.Either<A, any> | undefined return core.flatMap( core.whileLoop({ while: () => i < plan.steps.length && (result === undefined || Either.isLeft(result)), body: () => { const step = plan.steps[i] let nextEffect: Effect<A, any, any> = layer.effect_provide(effect, step.provide as any) if (result) { let attempted = false const wrapped = nextEffect // ensure the schedule is applied at least once nextEffect = core.suspend(() => { if (attempted) return wrapped attempted = true return result! }) nextEffect = InternalSchedule.scheduleDefectRefail( InternalSchedule.retry_Effect(nextEffect, scheduleFromStep(step, false)!) ) } else { const schedule = scheduleFromStep(step, true) nextEffect = schedule ? InternalSchedule.scheduleDefectRefail(InternalSchedule.retry_Effect(nextEffect, schedule)) : nextEffect } return core.either(nextEffect) }, step: (either) => { result = either i++ } }), () => result! ) })) /** @internal */ export const scheduleFromStep = <Provides, In, PlanE, PlanR>( step: Api.ExecutionPlan<{ provides: Provides input: In error: PlanE requirements: PlanR }>["steps"][number], first: boolean ) => { if (!first) { return InternalSchedule.fromRetryOptions({ schedule: step.schedule ? step.schedule : step.attempts ? undefined : InternalSchedule.once, times: step.attempts, while: step.while }) } else if (step.attempts === 1 || !(step.schedule || step.attempts)) { return undefined } return InternalSchedule.fromRetryOptions({ schedule: step.schedule, while: step.while, times: step.attempts ? step.attempts - 1 : undefined }) }