import { HttpRouter, HttpServer, HttpServerResponse } from "@effect/platform";
import { BunHttpServer, BunRuntime } from "@effect/platform-bun";
import { Console, Effect, Layer } from "effect";

const Server = HttpRouter.empty.pipe(
  HttpRouter.all("*", HttpServerResponse.empty()),
  HttpRouter.use(() => Effect.fail("BOOM!")), // fine
  HttpServer.serve(() => Effect.fail("KAPAW!")), // drops the request
  Layer.provide(BunHttpServer.layer({ port: 3000 })),
);

Layer.launch(Server).pipe(
  Effect.catchAllCause(Console.error),
  BunRuntime.runMain,
);

import {
  HttpApp,
  HttpMiddleware,
  HttpRouter,
  HttpServerResponse,
} from "@effect/platform";
import { Effect, flow, pipe } from "effect";

export async function brokenFetchHandler(request: Request): Promise<Response> {
  console.log("enter broken fetch handler", { request });
  const myBrokenMiddleware = <E, R>(
    httpApp: HttpApp.Default<E, R>,
  ): HttpApp.Default<E, R> =>
    Effect.succeed(HttpServerResponse.empty({ status: 208 }));
  return pipe(
    request,
    HttpApp.toWebHandler(
      HttpRouter.empty,
      flow(myBrokenMiddleware, HttpMiddleware.logger),
    ),
  );
}