Request-scoped services

import { Context, Effect } from "effect";

class CurrentUser extends Context.Service<
  CurrentUser,
  { readonly id: string; readonly role: "admin" | "member" }
>()("CurrentUser") {}

const authedProcedure = eos
  .provide(AppLive)
  .$context<{ user: { id: string; role: "admin" | "member" } }>()
  .provide(CurrentUser, ({ context }) => Effect.succeed(context.user));

const me = authedProcedure.effect(function* () {
  return yield* CurrentUser;
});

class TenantId extends Context.Service<TenantId, string>()("TenantId") {}

const tenantProcedure = eos
  .provide(AppLive)
  .input(z.object({ tenantId: z.string() }))
  .provide(TenantId, ({ input }) => Effect.succeed(input.tenantId))
  .effect(function* () {
    const tenantId = yield* TenantId;
    const projectsRepo = yield* ProjectsRepo;
    return yield* projectsRepo.listForTenant(tenantId);
  });

const authedProcedure = eos.$context<{ user: User }>().provide(
  CurrentUser,
  Effect.fn("current-user.resolve")(function* ({ context }) {
    yield* Effect.logDebug("resolving current user");
    return context.user;
  }),
);

import { Option } from "effect";

const maybeAuthed = eos
  .$context<{ user?: { id: string } }>()
  .provideOptional(CurrentUser, ({ context }) =>
    Effect.succeed(Option.fromNullishOr(context.user)),
  )
  .effect(function* () {
    return yield* Effect.serviceOption(CurrentUser);
  });