Method constructor

framework/framework/server.ts:388–511

(ctx: CordisContext, public config: ReturnType<typeof WebService.Config>)

    ConnectionHandler = ConnectionHandler;

    constructor(ctx: CordisContext, public config: ReturnType<typeof WebService.Config>) {
        super(ctx, 'server');
        ctx.mixin('server', ['Route', 'Connection', 'withHandlerClass']);
        this.server.keys = this.config.keys;
        this.server.proxy = this.config.proxy;
        const corsAllowHeaders = 'x-requested-with, accept, origin, content-type, upgrade-insecure-requests';
        this.server.use(Compress());
        this.server.use(async (c, next) => {
            if ((c.request.headers.origin || c.request.headers.referer) && this.config.cors) {
                try {
                    const host = new URL(c.request.headers.origin || c.request.headers.referer).host;
                    if (host !== c.request.headers.host && `,${this.config.cors},`.includes(`,${host},`)) {
                        c.set('Access-Control-Allow-Credentials', 'true');
                        c.set('Access-Control-Allow-Headers', corsAllowHeaders);
                        if (c.request.headers.origin) {
                            c.set('Access-Control-Allow-Origin', c.request.headers.origin);
                            c.set('Vary', 'Origin');
                        } else {
                            c.set('Vary', 'Referer');
                        }
                        c.cors = true;
                    }
                } catch (e) {
                    // invalid origin header, ignore
                }
            }
            if (c.request.method.toLowerCase() === 'options') {
                c.body = 'ok';
                return null;
            }
            for (const key in this.captureAllRoutes) {
                if (c.path.startsWith(key)) return this.captureAllRoutes[key](c, next);
            }
            return await next();
        });
        if (process.env.DEV) {
            this.server.use(async (c: Koa.Context, next: Function) => {
                const startTime = Date.now();
                try {
                    await next();
                } finally {
                    const endTime = Date.now();
                    if (!c.nolog && !c.response.headers.nolog) {
                        logger.debug(`${c.request.method} /${c.domainId || 'system'}${c.request.path} \
${c.response.status} ${endTime - startTime}ms ${c.response.length}`);
                    }
                }
            });
        }
        if (this.config.upload) {
            const uploadDir = join(tmpdir(), 'hydro', 'upload', process.env.NODE_APP_INSTANCE || '0');
            fs.ensureDirSync(uploadDir);
            logger.debug('Using upload dir: %s', uploadDir);
            this.server.use(Body({
                multipart: true,
                jsonLimit: '8mb',
                formLimit: '8mb',
                formidable: {