cobalt/src/modules/stream/stream.js

import { apiJSON } from "../sub/utils.js";
import { verifyStream } from "./manage.js";
import { streamAudioOnly, streamDefault, streamLiveRender, streamVideoOnly } from "./types.js";

export default function(res, ip, id, hmac, exp) {
    try {
        let streamInfo = verifyStream(ip, id, hmac, exp);
        if (!streamInfo.error) {
            if (streamInfo.isAudioOnly && streamInfo.type !== "bridge") {
                streamAudioOnly(streamInfo, res);
            } else {
                switch (streamInfo.type) {
                    case "render":
                        streamLiveRender(streamInfo, res);
                        break;
                    case "mute":
                        streamVideoOnly(streamInfo, res);
                        break;
                    default:
                        streamDefault(streamInfo, res);
                        break;
                }
            }
        } else {
            res.status(streamInfo.status).json(apiJSON(0, { t: streamInfo.error }).body);
        }
    } catch (e) {
        res.status(500).json({ status: "error", text: "Internal Server Error" });
    }
}