index.js

import fp from 'fastify-plugin';
import Etag from '@fastify/etag';
import Util from './lib/util.js';
import Email from './lib/email.js';
import Redis from './lib/redis.js';
import Bearer from './lib/bearer.js';
import Mobile from './lib/mobile.js';
import Pbkdf2 from './lib/pbkdf2.js';
import Postgre from './lib/postgre/index.js';
import Discord, { postToDiscord } from './lib/discord.js';
import Envvars from './lib/envvars.js';
import GeoCode from './lib/geocode.js';
import Corscap from './lib/corscap.js';
import Security from './lib/security.js';
import Pressure from './lib/pressure.js';
import Httpcode from './lib/httpcode.js';
import Indexpage from './lib/indexpage.js';
import Ratelimit from './lib/ratelimit.js';
import Recaptcha from './lib/recaptcha.js';
import Privilege from './lib/privilege.js';
import FileStore from './lib/filestore.js';

async function schwing (fastify, opts) {
  try {
    fastify.setErrorHandler(async (error, request, reply) => {
      if (error.message && error.message.includes('invalid authorization')) {
        return reply.unauthorized();
      }
      if (!error.statusCode || (error.statusCode >= 500 &&
        error.message !== 'Internal Server Error')) {
        request.log.error(error);
        await postToDiscord(error);
      }
      if (error.statusCode) {
        reply.status(error.statusCode).send(error);
      } else {
        reply.internalServerError();
      }
    });
    await fastify.register(Envvars, opts).after(async () => {
      await fastify.register(Etag);
      await fastify.register(Util, opts);
      await fastify.register(Email, opts);
      await fastify.register(Redis, opts);
      await fastify.register(Bearer, opts);
      await fastify.register(Mobile, opts);
      await fastify.register(Pbkdf2, opts);
      await fastify.register(Postgre, opts);
      await fastify.register(Discord, opts);
      await fastify.register(GeoCode, opts);
      await fastify.register(Corscap, opts);
      await fastify.register(Security, opts);
      await fastify.register(Pressure, opts);
      await fastify.register(Httpcode, opts);
      await fastify.register(Indexpage, opts);
      await fastify.register(Ratelimit, opts);
      await fastify.register(Recaptcha, opts);
      await fastify.register(Privilege, opts);
      await fastify.register(FileStore, opts);
    });
  } catch (err) {
    if (err.code === 'AVV_ERR_READY_TIMEOUT') {
      console.error('Schwing [Error]: Check redis connection');
    }
    throw err;
  }
}

export default fp(schwing, {
  name: 'schwing',
  fastify: '>=3.x'
});

export { default as Model } from './lib/postgre/model.js';
export { HashPassword, VerifyPassword } from './lib/pbkdf2.js';
export { Worker, Server, Instance } from './lib/cluster.js';
export {
  IsJSONStr, EachAsync, ResizeDataUri, MakeColumnJSON, TitleCase, GetIp, AggJSONb,
  IsJSONObj, FixMobile, MakeAggObject, MakeSearchQuery, Capitalize, GetAge,
  ToOrdinal, PadString, MakeJSONQuery, ToLowerCaseJSON, ToMonetary, ColFix
} from './lib/util.js';