import { InMemoryCacheAdapter } from "@ethicdevs/fastify-stream-react-views";
import {
AppServer,
makeAppServer,
startAppServer,
stopAppServerAndExit,
} from "@ethicdevs/react-monolith";
import cuid from "cuid";
import fastifyCookie, { CookieSerializeOptions } from "@fastify/cookie";
import fastifyCustomSession, {
PrismaSessionAdapter,
} from "@ethicdevs/fastify-custom-session";
import fastifyFormBody from "@fastify/formbody";
import fastifyGitServer from "@ethicdevs/fastify-git-server";
import fastifyServeStatic from "fastify-static";
import { PrismaClient } from "@prisma/client";
import * as Paths from "../paths";
import { version as appVersion } from "../package.json";
import { Const } from "./const";
import { Env } from "./env";
import { cryptoPlugin, prismaPlugin } from "./plugins";
import { makeGitServerService } from "./services/gitServer";
import {
getEnv,
localAppDomainPreHandler,
makeRequestHandler,
} from "./utils/server";
const HOST = process.env.HOST || "localhost";
const PORT = process.env.PORT || 4100;
let server: null | AppServer = null;
async function main(): Promise<AppServer> {
const env = getEnv();
const gitService = makeGitServerService({});
const prisma = new PrismaClient();
const depsBaseUrl = `/${Paths.PUBLIC_FOLDER_NAME}/${Paths.ASSET_DEPS_FOLDER_NAME}`;
const publicBaseUrl = `/${Paths.PUBLIC_FOLDER_NAME}`;
const cookiesOpts: CookieSerializeOptions = {
domain: `.${Env.DEPLOYMENT_DOMAIN}`,
httpOnly: true,
path: "/",
secure: false,
sameSite: "lax",
signed: true,
};
server = await makeAppServer(HOST, PORT, {
appName: Const.APP_NAME,
appVersion,
env,
a11y: {
localeDirection: "ltr",
},
assets: {
depsFolder: Paths.ASSET_DEPS_FOLDER_NAME,
importPrefix: publicBaseUrl,
},
cacheAdapter: new InMemoryCacheAdapter({
maxSize: Const.SSR_CACHE_MAX_SIZE_BYTES,
}),
featureFlags: {
withIncrementalBuild: true,
withImportsMap: true,
withInstantRouter: true,
withStyledSSR: true,
withTreeShaking: true,
},
paths: {
assetsOutFolder: Paths.PUBLIC_FOLDER,
distFolder: Paths.DIST_FOLDER,
islandsFolder: Paths.ISLANDS_FOLDER,
rootFolder: Paths.ROOT_FOLDER,
routesFile: Paths.ROUTES_FILE,
viewsFolder: Paths.VIEWS_FOLDER,
},
externalDependencies: {
"cross-fetch": "CrossFetch",
"markdown-to-jsx": "MarkdownToJSX",
},
baseHeadTags: [
{
kind: "meta",
name: "og:site_name",
content: Const.APP_NAME,
},
],
baseScriptTags: [
{
async: true,
id: "es-importmap-shim",
src: `${depsBaseUrl}/es-module-shims.production.min.js`,
type: "application/javascript",
},
],
setupServerBeforeRoutes(s) {
s.addHook("preHandler", localAppDomainPreHandler);
s.decorateReply("makeRequestHandler", makeRequestHandler);
s.register(cryptoPlugin);
s.register(prismaPlugin, { prisma });
s.register(fastifyFormBody);
s.register(fastifyServeStatic, {
root: Paths.PUBLIC_FOLDER,
prefix: publicBaseUrl,
});
s.register(fastifyCookie, {
secret: Env.COOKIE_SECRET,
parseOptions: cookiesOpts,
});
s.register(fastifyCustomSession, {
cookieName: Env.COOKIE_NAME,
cookieOptions: cookiesOpts,
getUniqId: cuid as () => string,
password: Env.COOKIE_SECRET,
storeAdapter: new PrismaSessionAdapter(prisma) as any,
ttl: Const.SESSION_TTL_SECONDS,
initialSession: {
sessionId: null,
authenticated: false,
curr_user_avatar_uri: null,
curr_user_uid: null,
curr_user_username: null,
curr_user_role: "GUEST",
flash_message: null,
flash_message_shown_once: false,
two_factor_lock: false,
two_factor_complete: false,
},
});
s.register(fastifyGitServer, {
withSideBandMessages: true,
authorizationResolver: gitService.authorizationResolver,
repositoryResolver: gitService.repositoryResolver,
onPush: gitService.onPushEvent,
});
s.get("/interceptor-imsw.js", {}, async (_, reply) => {
return reply.sendFile("interceptor-imsw.js");
});
s.get("/register-imsw.js", {}, async (_, reply) => {
return reply.sendFile("register-imsw.js");
});
},
});
await startAppServer(server);
return server;
}
["unhandledRejection", "uncaughtException"].forEach((exception) => {
process.on(exception, async (reason: Error) => {
await stopAppServerAndExit(server, reason);
});
});
["SIGQUIT", "SIGTERM", "SIGINT"].forEach((killSignal) => {
process.on(killSignal, async () => {
await stopAppServerAndExit(server);
});
});
main()
.then((server) => {
const { $config, $host, $port } = server.reactMonolith!;
console.log(
`[🚀][${$config.env}] App Server ready at http://${$host}:${$port} !`
);
})
.catch(async (err) => {
const error = err as Error;
console.error(`[❌] Cannot start App Server. Error: ${error.message}`);
await stopAppServerAndExit(null, error);
});