0.1.0-beta.13

const sendEmail = s.$input(z.object({ to: z.string(), subject: z.string(), body: z.string() })).$task({
  name: 'send-email',
  resolve: async ({ input, ctx }) => {
    await ctx.mailer.send(input)
    return { sent: true }
  },
})

const createUser = s.$resolve(async ({ input, ctx }) => {
  const user = await ctx.db.users.create(input)
  sendEmail.dispatch({ to: input.email, subject: 'Welcome' }, ctx)
  return user
})

users/create — 2 spans, 4.2ms total
├─ db.users.create     (db)     1.1ms
└─ task:send-email     (queue)  92.3ms

const dailyReport = s.$task({
  name: 'daily-report',
  cron: '0 9 * * *',
  resolve: async ({ ctx }) => ctx.db.reports.generateDaily(),
})

import { createSafeClient } from 'silgi/client'

const client = createSafeClient<AppRouter>(link)
const { error, data, isError, isSuccess } = await client.users.list()

import { withOtel } from 'silgi/client/plugins'

const link = withOtel(baseLink, {
  tracer: trace.getTracer('my-frontend'),
})
// Spans: rpc.client/users.list, rpc.client/users.create, etc.

import { consumeWithReconnect } from 'silgi/client/consume'

await consumeWithReconnect({
  connect: (lastEventId) => client.events.subscribe(undefined, { lastEventId }),
  onEvent: (data) => updateUI(data),
  maxReconnects: 10,
  reconnectDelay: 2000,
})

import { WSLink } from 'silgi/client/ws'

const link = new WSLink({ url: 'ws://localhost:3000/ws' })
const client = createClient<AppRouter>(link)