Function buildServer

src/server.ts:49–200

* Initializes and configures the Fastify server, including database connection, * authentication, CORS settings, cron jobs, error handling, and routes. * * @returns {Promise } A promise that resolves to the configured Fastify server instance.

()

 * @returns {Promise<FastifyInstance>} A promise that resolves to the configured Fastify server instance.
 */
async function buildServer() {
  // Create a new Fastify server instance with pretty print logging enabled.
  const server = Fastify({
    logger: {
      transport: {
        target: "pino-pretty",
      },
    },
  }).withTypeProvider<TypeBoxTypeProvider>();

  try {
    // Connect to the database using the TypeORM plugin.
    await server.register(dbConn, { connection: PostgresDataSource });
  } catch (err) {
    // Log and exit if the database connection fails.
    console.log("Error connecting to database");
    console.log(err);
    process.exit(1);
  }

  // server.setErrorHandler(async (error, request, reply) => {
  //   console.log('Error: ', error);
  //   Sentry.captureException(error);
  //   reply.status(500).send({ error: error.message || "Something went wrong" });
  // });
  // Register JWT support for authentication.
  // eslint-disable-next-line @typescript-eslint/no-var-requires
  server.register(require("@fastify/jwt"), {
    secret: process.env.JWT_SECRET,
    sign: {
      expiresIn: "14d",
    },
  });

  // Register the authentication decorator for the server.
  server.decorate("authenticate", async (request, reply) => {
    try {
      const secret = request.headers["ws-secret"];
      if (!secret) {
        await request.jwtVerify();
        return;
      }

      if (secret === process.env.WS_SECRET) {
        return;
      }

      const orm = request.server.orm;
      const user = await orm.getRepository(User).findOne({ where: { apikey: secret } });
      if (user) {
        request.user = user;
        return;
      }

      reply.code(401).send({ message: "Unauthorized" });
    } catch (err) {
      reply.code(401).send({ message: "Unauthorized" });
    }