Method message

framework/framework/api.ts:247–265

(message)

    }

    async message(message) {
        if (!this.isRpc) throw new BadRequestError('Only RPC operations are supported');
        if (typeof message === 'string') {
            try {
                message = JSON.parse(message);
            } catch (e) {
                throw new BadRequestError('Invalid message');
            }
        }
        if (!APIS[message.op]) throw new BadRequestError(`Invalid API operation: ${message.op}`);
        if (APIS[message.op].type !== 'Subscription') {
            throw new BadRequestError('Only subscription operations are supported');
        }
        handleArguments(message);
        const result = await this.ctx.api.execute(
            this, message.op, message.args, (m, args) => (this.ctx.parallel as any)(m, args), message.projection,
        );
        this.send(result);
    }

    async cleanup() {
        await this.dispose?.();