Merge pull request #2 from fishjam-cloud/trpc

Trpc

Author: AHGIJMKLKKZNPJKQR

deep-sea-stories/packages/backend/package.json

@@ -5,10 +5,9 @@
 	"type": "module",
 	"dependencies": {
 		"@fishjam-cloud/js-server-sdk": "^0.21.0",
+		"@trpc/server": "^11.6.0",
 		"dotenv": "^17.2.3",
 		"fastify": "^5.6.1",
-		"fastify-plugin": "^5.1.0",
-		"fastify-type-provider-zod": "^6.0.0",
 		"pino-pretty": "^13.1.1",
 		"zod": "^4.1.11"
 	},

deep-sea-stories/packages/backend/src/config.ts

@@ -1,25 +1,13 @@
 import dotenv from 'dotenv';
-import type { FastifyInstance } from 'fastify';
-import fp from 'fastify-plugin';
 import z from 'zod';
 
 dotenv.config();
 
-declare module 'fastify' {
-	interface FastifyInstance {
-		config: ConfigSchema;
-	}
-}
-
 export const configSchema = z.object({
 	PORT: z.coerce.number().int().default(8000),
 	FISHJAM_ID: z.string(),
 	FISHJAM_URL: z.string().optional(),
 	FISHJAM_MANAGEMENT_TOKEN: z.string(),
 });
 
-type ConfigSchema = z.infer<typeof configSchema>;
-
-export const fastifyConfig = fp((fastify: FastifyInstance) => {
-	fastify.decorate('config', configSchema.parse(process.env));
-});
+export const CONFIG = configSchema.parse(process.env);

deep-sea-stories/packages/backend/src/context.ts

@@ -0,0 +1,15 @@
+import { FishjamClient } from '@fishjam-cloud/js-server-sdk';
+import type { CreateFastifyContextOptions } from '@trpc/server/adapters/fastify';
+import { CONFIG } from './config.js';
+
+const fishjam = new FishjamClient({
+	fishjamId: CONFIG.FISHJAM_ID,
+	fishjamUrl: CONFIG.FISHJAM_URL,
+	managementToken: CONFIG.FISHJAM_MANAGEMENT_TOKEN,
+});
+
+export function createContext({ req, res }: CreateFastifyContextOptions) {
+	return { req, res, fishjam };
+}
+
+export type Context = Awaited<ReturnType<typeof createContext>>;

deep-sea-stories/packages/backend/src/controllers/rooms.ts

@@ -1,9 +1,13 @@
-import type { FishjamClient, RoomId } from '@fishjam-cloud/js-server-sdk';
+import type { RoomId } from '@fishjam-cloud/js-server-sdk';
+import { getRoomInputSchema } from '../schemas.js';
+import { publicProcedure } from '../trpc.js';
 
-export async function createRoom(fishjam: FishjamClient) {
-	return await fishjam.createRoom();
-}
+export const createRoom = publicProcedure.mutation(async ({ ctx }) => {
+	return await ctx.fishjam.createRoom();
+});
 
-export async function getRoom(fishjam: FishjamClient, roomId: RoomId) {
-	return await fishjam.getRoom(roomId);
-}
+export const getRoom = publicProcedure
+	.input(getRoomInputSchema)
+	.query(async ({ ctx, input }) => {
+		return await ctx.fishjam.getRoom(input.roomId as RoomId);
+	});

deep-sea-stories/packages/backend/src/main.ts

@@ -1,29 +1,33 @@
-import Fastify from 'fastify';
 import {
-	serializerCompiler,
-	validatorCompiler,
-	type ZodTypeProvider,
-} from 'fastify-type-provider-zod';
-import { fastifyConfig } from './config.js';
-import { fishjamPlugin } from './plugins/fishjam.js';
-import routes from './routes/index.js';
+	type FastifyTRPCPluginOptions,
+	fastifyTRPCPlugin,
+} from '@trpc/server/adapters/fastify';
+import Fastify from 'fastify';
+import { CONFIG } from './config.js';
+import { createContext } from './context.js';
+import { type AppRouter, appRouter } from './router.js';
 
 const fastify = Fastify({
 	logger: { transport: { target: 'pino-pretty' } },
-}).withTypeProvider<ZodTypeProvider>();
-
-fastify.setValidatorCompiler(validatorCompiler);
-fastify.setSerializerCompiler(serializerCompiler);
+});
 
-fastify.register(fastifyConfig);
-fastify.register(fishjamPlugin);
-
-fastify.register(routes, { prefix: '/api/v1' });
+fastify.register(fastifyTRPCPlugin, {
+	prefix: '/api/v1',
+	trpcOptions: {
+		router: appRouter,
+		createContext,
+		onError({ path, error }) {
+			fastify.log.error('Error in tRPC handler on path %s: %O', path, error);
+		},
+	} satisfies FastifyTRPCPluginOptions<AppRouter>['trpcOptions'],
+});
 
 try {
 	await fastify.ready();
-	await fastify.listen({ port: fastify.config.PORT });
+	await fastify.listen({ port: CONFIG.PORT });
 } catch (err) {
 	fastify.log.error(err);
 	process.exit(1);
 }
+
+export type { AppRouter };

deep-sea-stories/packages/backend/src/plugins/fishjam.ts

@@ -0,0 +1,9 @@
+import { createRoom, getRoom } from './controllers/rooms.js';
+import { router } from './trpc.js';
+
+export const appRouter = router({
+	createRoom,
+	getRoom,
+});
+
+export type AppRouter = typeof appRouter;

deep-sea-stories/packages/backend/src/router.ts

@@ -1,10 +1,3 @@
 import z from 'zod';
 
-export const peerSchema = z.object({
-	id: z.string(),
-});
-
-export const roomSchema = z.object({
-	id: z.string(),
-	peers: peerSchema.array(),
-});
+export const getRoomInputSchema = z.object({ roomId: z.string() });