import * as Effect from "effect/Effect";
import app from "../dist/server/worker.js";
import type { Env } from "./personal-agent";
import { handleRuntimeRequest } from "./http";

export { Conversation } from "./conversation";
export { Sandbox } from "./sandbox";
export { PersonalAgent } from "./personal-agent";

// Octane owns SSR; native Agents own the private runtime protocol.
export default {
  fetch(request, env, ctx) {
    request.signal.throwIfAborted();
    return Effect.runPromise(
      handleRuntimeRequest(request, env, () =>
        Promise.resolve(app.fetch!(request, { ASSETS: env.ASSETS }, ctx)),
      ),
      { signal: request.signal },
    );
  },
} satisfies ExportedHandler<Env>;