wip

apps/server/src/config/index.ts

@@ -0,0 +1,7 @@
+import type { ServerOptions } from '../server';
+
+export const serverConfig: ServerOptions = {
+	dev: false,
+	port: 2022,
+	prefix: '/trpc'
+};

apps/server/src/env.js

@@ -0,0 +1,15 @@
+const { z } = require('zod');
+
+/*eslint sort-keys: "error"*/
+const envSchema = z.object({
+	NODE_ENV: z.enum(['development', 'test', 'production']),
+	COOLIFY_SECRET_KEY: z.string()
+});
+
+const env = envSchema.safeParse(process.env);
+
+if (!env.success) {
+	console.error('❌ Invalid environment variables:', JSON.stringify(env.error.format(), null, 4));
+	process.exit(1);
+}
+module.exports.env = env.data;

apps/server/src/index.ts

@@ -0,0 +1,7 @@
+import { serverConfig } from './config';
+import { createServer } from './server';
+
+const server = createServer(serverConfig);
+
+server.start();
+

apps/server/src/prisma.ts

@@ -0,0 +1,21 @@
+/**
+ * Instantiates a single instance PrismaClient and save it on the global object.
+ * @link https://www.prisma.io/docs/support/help-articles/nextjs-prisma-client-dev-practices
+ */
+import { env } from './env';
+import { PrismaClient } from '@prisma/client';
+
+const prismaGlobal = global as typeof global & {
+  prisma?: PrismaClient;
+};
+
+export const prisma: PrismaClient =
+  prismaGlobal.prisma ||
+  new PrismaClient({
+    log:
+      env.NODE_ENV === 'development' ? ['query', 'error', 'warn'] : ['error'],
+  });
+
+if (env.NODE_ENV !== 'production') {
+  prismaGlobal.prisma = prisma;
+}

apps/server/src/router/context.ts

@@ -0,0 +1,19 @@
+import { inferAsyncReturnType } from '@trpc/server';
+import { CreateFastifyContextOptions } from '@trpc/server/adapters/fastify';
+import jwt from 'jsonwebtoken';
+import { env } from '../env';
+export interface User {
+	name: string | string[];
+}
+
+export function createContext({ req, res }: CreateFastifyContextOptions) {
+	const token = req.headers.authorization;
+	if (token) {
+		const user = jwt.verify(token, env.COOLIFY_SECRET_KEY);
+
+		console.log(user);
+	}
+	return { req, res };
+}
+
+export type Context = inferAsyncReturnType<typeof createContext>;

apps/server/src/router/index.ts

@@ -0,0 +1,8 @@
+import { apiRouter } from './routers/api';
+import { router } from './trpc';
+
+export const appRouter = router({
+  api: apiRouter,
+});
+
+export type AppRouter = typeof appRouter;

apps/server/src/router/routers/api.ts

@@ -0,0 +1,18 @@
+// import { z } from 'zod';
+import { publicProcedure, router } from '../trpc';
+// import { prisma } from '../../prisma';
+import { TRPCError } from '@trpc/server';
+
+export const apiRouter = router({
+	getConnection: publicProcedure.query(async () => {
+		try {
+			return { success: true };
+		} catch (error) {
+			throw new TRPCError({
+				code: 'INTERNAL_SERVER_ERROR',
+				message: 'An unexpected error occurred, please try again later.',
+				cause: error
+			});
+		}
+	})
+});

apps/server/src/router/trpc.ts

@@ -0,0 +1,13 @@
+import { initTRPC } from '@trpc/server';
+import superjson from 'superjson';
+import { Context } from './context';
+
+const t = initTRPC.context<Context>().create({
+  transformer: superjson,
+  errorFormatter({ shape }) {
+    return shape;
+  },
+});
+
+export const router = t.router;
+export const publicProcedure = t.procedure;

apps/server/src/server.ts

@@ -0,0 +1,58 @@
+import { fastifyTRPCPlugin } from '@trpc/server/adapters/fastify';
+import fastify from 'fastify';
+import { appRouter } from './router';
+import { createContext } from './router/context';
+import cors from '@fastify/cors';
+import * as path from 'node:path';
+import serve from '@fastify/static';
+// import { prisma } from './prisma';
+
+const isDev = process.env['NODE_ENV'] === 'development';
+
+export interface ServerOptions {
+	dev?: boolean;
+	port?: number;
+	prefix?: string;
+}
+
+export function createServer(opts: ServerOptions) {
+	const dev = opts.dev ?? true;
+	const port = opts.port ?? 3000;
+	const prefix = opts.prefix ?? '/trpc';
+	const server = fastify({ logger: dev, trustProxy: true });
+	server.register(cors);
+	server.register(fastifyTRPCPlugin, {
+		prefix,
+		trpcOptions: { router: appRouter, createContext }
+	});
+	// Serve static files in production. Static files are generated by `yarn build` in the client folder by SvelteKit.
+	if (!isDev) {
+		server.register(serve, {
+			root: path.join(__dirname, './public'),
+			preCompressed: true
+		});
+		server.setNotFoundHandler(async function (request, reply) {
+			if (request.raw.url && request.raw.url.startsWith('/api')) {
+				return reply.status(404).send({
+					success: false
+				});
+			}
+			return reply.status(200).sendFile('index.html');
+		});
+	}
+	server.get('/api', async () => {
+		return { status: 'ok' };
+	});
+	const stop = () => server.close();
+	const start = async () => {
+		try {
+			await server.listen({ host: '0.0.0.0', port });
+			console.log('Server is listening on port', port);
+		} catch (err) {
+			server.log.error(err);
+			process.exit(1);
+		}
+	};
+
+	return { server, start, stop };
+}