Method channels

src/http-handler.ts:142–182

(res: HttpResponse)

    }

    channels(res: HttpResponse) {
        this.attachMiddleware(res, [
            this.corkMiddleware,
            this.corsMiddleware,
            this.appMiddleware,
            this.authMiddleware,
            this.readRateLimitingMiddleware,
        ]).then(res => {
            this.server.adapter.getChannelsWithSocketsCount(res.params.appId).then(channels => {
                let response: { [channel: string]: ChannelResponse } = [...channels].reduce((channels, [channel, connections]) => {
                    if (connections === 0) {
                        return channels;
                    }

                    // In case ?filter_by_prefix= is specified, the channel must start with that prefix.
                    if (res.query.filter_by_prefix && !channel.startsWith(res.query.filter_by_prefix)) {
                        return channels;
                    }

                    channels[channel] = {
                        subscription_count: connections,
                        occupied: true,
                    };

                    return channels;
                }, {});

                return response;
            }).catch(err => {
                Log.error(err);

                return this.serverErrorResponse(res, 'A server error has occurred.');
            }).then(channels => {
                let broadcastMessage = { channels };

                this.server.metricsManager.markApiMessage(res.params.appId, {}, broadcastMessage);

                this.sendJson(res, broadcastMessage);
            });
        });
    }

    channel(res: HttpResponse) {
        this.attachMiddleware(res, [