tRPC
The following examples only work with tRPC over HTTP, you cannot use this framework to support websocket or subscriptions.
First, you need to ensure you have the libs installed, so run this code:
npm i --save @trpc/server body-parser
body-parser
is needed to parse the body of the request to JSON.
Then, you just need to use the TrpcFramework when you create your adapter, like:
import * as trpc from '@trpc/server';
import { ServerlessAdapter } from '@h4ad/serverless-adapter';
import { TrpcFramework, TrpcAdapterContext, TrpcFrameworkOptions } from '@h4ad/serverless-adapter/frameworks/trpc';
import { JsonBodyParserFramework } from '@h4ad/serverless-adapter/frameworks/body-parser';
import { CorsFramework } from '@h4ad/serverless-adapter/frameworks/cors';
import { z } from 'zod';
type CustomContext = { currentDate: Date };
type TrpcContext = TrpcAdapterContext<CustomContext>;
const t = trpc.initTRPC.context<TrpcContext>().create();
const appRouter = t.router({
getUser: t.procedure.input(z.string()).query((req) => {
req.input; // string
return { id: req.input, name: 'Bilbo' };
}),
createUser: t.procedure
// validate input with Zod
.input(z.object({ name: z.string().min(5) }))
.mutation(({ input }) => {
return {
created: true,
newName: input.name,
};
})
});
const frameworkOptions: TrpcFrameworkOptions<CustomContext> = {
createContext: () => ({ currentDate: new Date() }),
};
const framework = new TrpcFramework<TrpcContext>(frameworkOptions);
const jsonFramework = new JsonBodyParserFramework(framework);
const corsFramework = new CorsFramework(jsonFramework); // see more about: https://serverless-adapter.viniciusl.com.br/docs/main/frameworks/cors
export const handler = ServerlessAdapter.new(appRouter)
.setFramework(corsFramework)
// continue to set the other options here.
//.setHandler(new DefaultHandler())
//.setResolver(new PromiseResolver())
//.addAdapter(new AlbAdapter())
//.addAdapter(new SQSAdapter())
//.addAdapter(new SNSAdapter())
// after put all methods necessary, just call the build method.
.build();
Need more examples? See more examples here.
Integrating with Adapters
This framework is a little special when dealing with request URLs because of the structure of tRPC.
So when you integrate with an adapter like SQSAdapter, when you receive an event, the adapter will forward the request to /sqs
by default
but because of the structure of tRPC, the framework will change the request URL to just sqs
.
With this behavior, to integrate with SQSAdapter, you will create the following mutation:
import type { SQSEvent } from 'aws-lambda';
import * as trpc from '@trpc/server';
import { TrpcAdapterContext } from '@h4ad/serverless-adapter/frameworks/trpc';
import { z } from 'zod';
type TrpcContext = TrpcAdapterContext<unknown>;
const t = trpc.initTRPC.context<TrpcContext>().create();
const appRouter = t.router({
sqs: t.procedure
.input(z.object({Records: z.array(z.any())}))
.mutation(({ctx, input}) => {
if (ctx.getHeader('host') !== 'sqs.amazonaws.com')
throw new TRPCError({
code: 'UNAUTHORIZED',
message: 'Wrong host.',
});
const event = input as SQSEvent;
// Do whatever you want
// and you dont need to return nothing
}),
});
Never forget to check the host header as you could introduce a security hole when adding support for AWS Api Gateway and other adapters.
You can see a working example here.
Default Context and Custom context
By default, we provide you with a few methods to get information from the request and modify the response, to learn more, take a look at TrpcAdapterBaseContext.
Also, you can pass new properties to the context by setting the createContext
function inside the options,
like the code below:
import * as trpc from '@trpc/server';
import { ServerlessAdapter } from '@h4ad/serverless-adapter';
import { TrpcFramework, TrpcAdapterContext, TrpcFrameworkOptions } from '@h4ad/serverless-adapter/frameworks/trpc';
import { JsonBodyParserFramework } from '@h4ad/serverless-adapter/frameworks/body-parser';
import { CorsFramework } from '@h4ad/serverless-adapter/frameworks/cors';
type CustomContext = { potato: boolean };
type TrpcContext = TrpcAdapterContext<CustomContext>;
const t = trpc.initTRPC.context<TrpcContext>().create();
const appRouter = t.router({
add: t.procedure
.mutation(({ ctx }) => {
// get the request url
const requestUrl = ctx.getUrl();
// this will change the status code of the request to 204.
ctx.setStatus(204);
}),
});
const frameworkOptions: TrpcFrameworkOptions<TrpcContext> = {
// you can return a promise
createContext: () => Promise.resolve({ potato: true }),
// createContext: () => ({ potato: false }),
};
const framework = new TrpcFramework<TrpcContext>(frameworkOptions);
const jsonFramework = new JsonBodyParserFramework(framework);
const corsFramework = new CorsFramework(jsonFramework); // see more about: https://serverless-adapter.viniciusl.com.br/docs/main/frameworks/cors
export const handler = ServerlessAdapter.new(appRouter)
.setFramework(corsFramework)
// continue to set the other options here.
//.setHandler(new DefaultHandler())
//.setResolver(new PromiseResolver())
//.addAdapter(new AlbAdapter())
//.addAdapter(new SQSAdapter())
//.addAdapter(new SNSAdapter())
// after put all methods necessary, just call the build method.
.build();
Is your application instance creation asynchronous? Look the LazyFramework which helps you in asynchronous startup.
Need to deal with CORS? See CorsFramework which helps you to add correct headers.