Skip to main content

​
Decorators Reference

​
@Procedures()

Marks a class as a tRPC procedures container. This decorator also applies @Service() for dependency injection. 
@Procedures()
export class MyProcedures {
  // procedures here
}

​
@TQuery()

Marks a field as a tRPC query procedure. 
@TQuery()
myQuery = createTQuery({
  params: {...},
  returns: {...},
  resolve: async (params) => {...}
})

​
@TMutation()

Marks a field as a tRPC mutation procedure. 
@TMutation()
myMutation = createTMutation({
  params: {...},
  returns: {...},
  resolve: async (params) => {...}
})

​
Procedure Options

Both createTQuery and createTMutation accept the same options:
OptionTypeDescription
paramsSchemaInput validation schema (optional)
returnsSchemaOutput schema for documentation (optional)
resolveFunctionThe resolver function

​
Schema Types

You can use Orionjs schema definitions: 
// Inline schema
createTQuery({
  params: {
    userId: {type: String},
    includeDetails: {type: Boolean, optional: true}
  },
  returns: UserSchema,
  resolve: async ({userId, includeDetails}) => {...}
})

// Array returns
createTQuery({
  returns: [UserSchema],
  resolve: async () => {...}
})

​
Merging Procedures

When using the component system, procedures are merged automatically via mergeComponents(). For standalone usage, you can use mergeProcedures to combine multiple procedure classes while preserving types: 
import {mergeProcedures} from '@orion-js/trpc'

// Supports up to 5 procedure classes with full type inference
const procedures = mergeProcedures([
  UserProcedures,
  PostProcedures,
  CommentProcedures,
])

​
Context and Viewer

The tRPC context includes the Orionjs viewer: 
createTQuery({
  resolve: async (params, viewer) => {
    if (!viewer.user) {
      throw new Error('Unauthorized')
    }
    return await this.service.getData(viewer.user._id)
  }
})

​
Error Handling

Throw errors normally - they’ll be properly serialized by tRPC: 
import {TRPCError} from '@trpc/server'

createTMutation({
  resolve: async (params) => {
    const item = await this.repo.findOne(params.id)

    if (!item) {
      throw new TRPCError({
        code: 'NOT_FOUND',
        message: 'Item not found'
      })
    }

    return item
  }
})