Middleware

const authedProcedure = effectProcedure.use(function* () {
  const user = yield* CurrentUser;
  yield* requireActiveUser(user);
});

const authedProcedure = effectProcedure.use(function* ({ next }) {
  const user = yield* CurrentUser;
  yield* requireActiveUser(user);

  return yield* next({
    context: { userId: user.id },
  });
});

const authedProcedure = effectProcedure.use(
  Effect.fn("middleware.auth")(function* ({ next }) {
    const user = yield* CurrentUser;
    return yield* next({ context: { userId: user.id } });
  }),
);

const auditedProcedure = effectProcedure.use(({ next }) =>
  Effect.gen(function* () {
    yield* Effect.logDebug("before handler");
    return yield* next();
  }),
);

const wrapped = effectProcedure.use(function* ({ next }, _input, output) {
  const result = yield* next();
  return yield* output({
    ...result.output,
    wrapped: true,
  });
});

const requireAdmin = effectProcedure.middleware(function* ({ next }) {
  const user = yield* CurrentUser;
  yield* requireAdminUser(user);
  return yield* next();
});

const adminProcedure = effectProcedure.use(requireAdmin);

const withRequestLabel = effectProcedure.use(({ context, next }) =>
  next({
    context: {
      requestLabel: `${context.role}:${context.requestId}`,
    },
  }),
);

const checked = effectProcedure.use(({ context }) => {
  if (!context.requestId) throw new Error("missing request id");
  // Returning void is a native guard: the pipeline continues automatically.
});