68 lines · 2.2 KB · TypeScript
RawDownload
import { HttpApiBuilder } from "effect/unstable/httpapi";import { Effect } from "effect"; import { ExecutorApi } from "../api";import { formatExecuteResult, formatPausedExecution } from "@executor-js/execution";import { ExecutionEngineService } from "../services";import { capture, captureEngineError } from "@executor-js/api"; export const ExecutionsHandlers = HttpApiBuilder.group(ExecutorApi, "executions", (handlers) =>  handlers    .handle("execute", ({ payload }) =>      capture(Effect.gen(function* () {        const engine = yield* ExecutionEngineService;        const outcome = yield* captureEngineError(engine.executeWithPause(payload.code));         if (outcome.status === "completed") {          const formatted = formatExecuteResult(outcome.result);          return {            status: "completed" as const,            text: formatted.text,            structured: formatted.structured,            isError: formatted.isError,          };        }         const formatted = formatPausedExecution(outcome.execution);        return {          status: "paused" as const,          text: formatted.text,          structured: formatted.structured,        };      })),    )    .handle("resume", ({ params: path, payload }) =>      capture(Effect.gen(function* () {        const engine = yield* ExecutionEngineService;        const result = yield* captureEngineError(          engine.resume(path.executionId, {            action: payload.action,            content: payload.content as Record<string, unknown> | undefined,          }),        );         if (!result) {          return yield* Effect.fail({            _tag: "ExecutionNotFoundError" as const,            executionId: path.executionId,          });        }         if (result.status === "completed") {          const formatted = formatExecuteResult(result.result);          return {            text: formatted.text,            structured: formatted.structured,            isError: formatted.isError,          };        }         const formatted = formatPausedExecution(result.execution);        return {          text: formatted.text,          structured: formatted.structured,          isError: false,        };      })),    ),);