Request-scoped services

import { Context, Effect } from "effect";

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

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;
});

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

const tenantProcedure = eos
  .input(z.object({ tenantId: z.string() }))
  .provide(TenantId, ({ input }) =>
    Effect.gen(function* () {
      yield* Effect.logDebug("resolving tenant");
      return input.tenantId;
    }),
  );

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

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

import { Option } from "effect";

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