80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
return r
# fetch multiple pages
def api(self, method, path, params):
r = []
while len(r) < int(conf.max_streams):
data = json.loads(ahttp.get( self.base + method + path, params))
r += data["stations"]
if len(r) >= data["meta"]["total_count"] or len(data["stations"]) < 10:
break
else:
params["page"] = int(data["meta"]["current_page"]) + 1
self.parent.status(params["page"] * 9.5 / float(conf.max_streams))
#log.DATA(data)
return r
|
>
>
|
>
>
>
|
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
return r
# fetch multiple pages
def api(self, method, path, params):
r = []
while len(r) < int(conf.max_streams):
try:
data = ahttp.get(self.base + method + path, params)
data = json.loads(data)
except Exception as e:
log.ERR("No data/json received.", e)
return r
r += data["stations"]
if len(r) >= data["meta"]["total_count"] or len(data["stations"]) < 10:
break
else:
params["page"] = int(data["meta"]["current_page"]) + 1
self.parent.status(params["page"] * 9.5 / float(conf.max_streams))
#log.DATA(data)
return r
|