

def _get_streams(self):
    match = _url_re.match(self.url)
    channel_name = match.group('channel')
    form = {
        'cid': channel_name,
        'watchTime': 0,
        'firstConnect': 1,
        'ip': 'NaN',
    }
    res = http.post(API_URL, data=form, headers=HEADERS)
    params = parse_query(res.text, schema=_schema)
    if (stream['status'] <= 0):
        return
    if (params['block_type'] != 0):
        if (params['block_type'] == BLOCK_TYPE_VIEWING_LIMIT):
            msg = BLOCKED_MSG_FORMAT.format(params.get('block_time', 'UNKNOWN'), params.get('reconnect_time', 'UNKNOWN'))
            raise PluginError(msg)
        elif (params['block_type'] == BLOCK_TYPE_NO_SLOTS):
            raise PluginError('No free slots available')
        else:
            raise PluginError('Blocked for unknown reasons')
    if ('token' not in params):
        raise PluginError('Server seems busy, retry again later')
    streams = {
        
    }
    stream_names = ['sd']
    if params['multibitrate']:
        stream_names += ['hd']
    for stream_name in stream_names:
        playpath = params['playpath']
        if (stream_name == 'hd'):
            playpath += 'HI'
        stream = RTMPStream(self.session, {
            'rtmp': '{0}/{1}'.format(params['rtmp'], playpath),
            'pageUrl': self.url,
            'swfVfy': SWF_URL,
            'weeb': params['token'],
            'live': True,
        })
        streams[stream_name] = stream
    return streams

dataset/ETHPy150Open chrippa/livestreamer/src/livestreamer/plugins/weeb.py Weeb._get_streams/VarMisuse@88/115 `params`->`stream`