Method handleHttp

framework/framework/server.ts:534–618

(ctx: KoaContext, HandlerClass, checker, savedContext: CordisContext)

    }

    private async handleHttp(ctx: KoaContext, HandlerClass, checker, savedContext: CordisContext) {
        const { args } = ctx.HydroContext;
        Object.assign(args, ctx.params);
        await using sub = await forkContextWithScope(savedContext);
        const h = new HandlerClass(ctx, sub.ctx);
        ctx.handler = h;
        const method = ctx.method.toLowerCase();
        const name = ((Object.hasOwn(HandlerClass, kHandler) && typeof HandlerClass[kHandler] === 'string')
            ? HandlerClass[kHandler] : HandlerClass.name).replace(/Handler$/, '');
        this.activeHandlers.set(h, { start: Date.now(), name });
        try {
            const operation = (method === 'post' && ctx.request.body?.operation)
                // eslint-disable-next-line regexp/no-unused-capturing-group
                ? `_${ctx.request.body.operation}`.replace(/_([a-z])/g, (s) => s[1].toUpperCase())
                : '';

            // FIXME: should pass type check
            await (this.ctx.parallel as any)('handler/create', h, 'http');
            await (this.ctx.parallel as any)('handler/create/http', h);

            if (checker) checker.call(h);
            if (typeof h.all !== 'function') {
                if (method === 'post') {
                    if (operation) {
                        if (typeof h[`post${operation}`] !== 'function') {
                            throw new InvalidOperationError(operation);
                        }
                    } else if (typeof h.post !== 'function') {
                        throw new MethodNotAllowedError(method);
                    }
                } else if (typeof h[method] !== 'function') {
                    throw new MethodNotAllowedError(method);
                }
            }

            const steps = [
                'log/__init', 'init', 'handler/init',
                `handler/before-prepare/${name}#${method}`, `handler/before-prepare/${name}`, 'handler/before-prepare',
                'log/__prepare', '__prepare', '_prepare', 'prepare', 'log/__prepareDone',
                `handler/before/${name}#${method}`, `handler/before/${name}`, 'handler/before',
                'log/__method', 'all', method, 'log/__methodDone',
                ...operation ? [
                    `handler/before-operation/${name}`, 'handler/before-operation',
                    `post${operation}`, 'log/__operationDone',
                ] : [], 'after',
                `handler/after/${name}#${method}`, `handler/after/${name}`, 'handler/after',
                'cleanup',
                `handler/finish/${name}#${method}`, `handler/finish/${name}`, 'handler/finish',
                'log/__finish',
            ];

            let current = 0;
            while (current < steps.length) {
                const step = steps[current];
                let control;
                if (step.startsWith('log/')) h.args[step.slice(4)] = Date.now();
                // @ts-ignore
                else if (step.startsWith('handler/')) control = await this.ctx.serial(step, h); // eslint-disable-line no-await-in-loop