// 1. Create router
// packages/api/src/routers/my-feature.ts
import { router, protectedProcedure } from '../trpc.js';
import { z } from 'zod';
 
export const myFeatureRouter = router({
  create: protectedProcedure
    .input(z.object({ name: z.string() }))
    .mutation(async ({ input, ctx }) => {
      return { success: true, name: input.name };
    }),
});
 
// 2. Register
// packages/api/src/index.ts
registerRouter('myFeature', myFeatureRouter, {
  version: '1.0.0',
  source: 'core',
  description: 'My feature'
});
 
// 3. Use (auto-typed!)
await client.rpc.myFeature.create.mutate({ name: 'test' });

list: publicProcedure.query(async () => {
  return db.select().from(myTable);
}),

create: protectedProcedure
  .input(z.object({ name: z.string() }))
  .mutation(async ({ input }) => {
    await db.insert(myTable).values(input);
    return { success: true };
  }),

publicProcedure.query(...)  // Anyone can call

protectedProcedure.query(({ ctx }) => {
  const userId = ctx.userId;  // Available!
  ...
})

.input(z.object({
  name: z.string().min(1).max(100),
  email: z.string().email().optional(),
  age: z.number().int().positive(),
}))

import { TRPCError } from '@trpc/server';
 
.mutation(async ({ input }) => {
  if (!valid) {
    throw new TRPCError({
      code: 'BAD_REQUEST',
      message: 'Invalid input'
    });
  }
})

import { db, myTable } from '@synap/database';
 
.query(async () => {
  return db.select().from(myTable);
})

import { publishEvent, createMyEvent } from '@synap/events';
 
.mutation(async ({ input, ctx }) => {
  const event = createMyEvent(itemId, input);
  await publishEvent(event, { userId: ctx.userId });
  return { success: true };
})

pnpm test -- intelligence-registry