streams.py 文件源码

def beam_online(self, stream):
        url = "https://beam.pro/api/v1/channels/" + stream
        try:
            async with aiohttp.get(url) as r:
                data = await r.json(encoding='utf-8')
            if "online" in data:
                if data["online"] is True:
                    data = self.beam_embed(data)
                    return data
                else:
                    return False
            elif "error" in data:
                return None
        except:
            return "error"
        return "error"