Integrating Astro with Effect: Scopes, Layers, and ManagedRuntime

export class Auth extends Context.Tag('astro-auth-prototype/lib/Auth')<
  Auth,
  {
    currentUser(headers: Headers): Effect.Effect<Option.Option<User>, Error>
  }
>() {
  static Live = Layer.succeed(Auth, {
    currentUser: (headers) =>
      Effect.tryPromise(async () => {
        const session = await auth.api.getSession({ headers })
        return Option.fromNullable(session?.user)
      }).pipe(Effect.catchAll(() => Effect.succeed(Option.none()))),
  })
}

export class CurrentRequest extends Context.Tag(
  'astro-auth-prototype/lib/AstroRuntime/CurrentRequest'
)<CurrentRequest, Request>() {
  static layerAstro = (Astro: AstroGlobal) => Layer.succeed(this, Astro.request)
}

export class CurrentUser extends Context.Tag(
  'astro-auth-prototype/lib/AstroRuntime/CurrentUser'
)<CurrentUser, Option.Option<User>>() {
  static layerAstro = (Astro: AstroGlobal) =>
    Layer.effect(
      this,
      Effect.gen(function* () {
        const auth = yield* Auth
        return yield* auth.currentUser(Astro.request.headers)
      })
    )
}

export const defineAstroRuntime = (Astro: AstroGlobal) =>
  ManagedRuntime.make(
    Layer.mergeAll(
      CurrentRequest.layerAstro(Astro),
      CurrentUser.layerAstro(Astro).pipe(Layer.provide(Auth.Live))
    )
  )

const requestHandler = Effect.gen(function* () {
  yield* Effect.log('Hello from Effect')
  return yield* CurrentUser
})

const user = await defineAstroRuntime(Astro).runPromise(requestHandler)