localhost_frssoft/funkwlmpv
1
0
Fork 0
mirror of http://gitea.phreedom.club/localhost_frssoft/funkwlmpv synced 2024-11-25 20:21:28 +00:00
Code Issues Projects Releases Wiki Activity

Compare commits

base: localhost_frssoft:395800f2800f20713622daf73ba783f6a527c5cf
Branches Tags
localhost_frssoft:py_fw_cli
localhost_frssoft:fw-playlists
localhost_frssoft:master
...
compare: localhost_frssoft:200deac9a693c0986bb7f700234f0922adb590e0
Branches Tags
localhost_frssoft:fw-playlists
localhost_frssoft:py_fw_cli
localhost_frssoft:master

3 commits
395800f280 ... 200deac9a6

Author SHA1 Message Date
localhost_frssoft 200deac9a6 tab 2024-07-25 23:23:32 +03:00
localhost_frssoft bc2b7efdd9 compressed request for speed up 2024-07-25 23:12:38 +03:00
localhost_frssoft 309e36db43 oopse, massive add instead replace 2024-07-25 23:02:01 +03:00
1 changed files with 5 additions and 4 deletions
Show stats Expand all files Collapse all files

7
funkwlplay.py
View file

@ -34,7 +34,7 @@ def create_playlist_file(track_list):
def filter_tracks(tracks): def filter_tracks(tracks):
def remove_unreach_tracks(track): def remove_unreach_tracks(track):
try: try:
r = requests.head(track['listen_url'], timeout=2) r = requests.head(track['listen_url'], timeout=2, headers={'Content-Encoding': 'gzip'})
r.raise_for_status() r.raise_for_status()
return 1 return 1
except: except:
@ -75,7 +75,8 @@ def filter_tracks(tracks):
def search_tracks_on_instance(instance, tag='', query='', recursion=args.recursion): def search_tracks_on_instance(instance, tag='', query='', recursion=args.recursion):
r = requests.get(f'https://{instance}/api/v1/tracks', params={'tag': tag, 'q': query, r = requests.get(f'https://{instance}/api/v1/tracks', params={'tag': tag, 'q': query,
'local': True, 'playable': True, 'local': True, 'playable': True,
'ordering': 'random'}, timeout=10) 'ordering': 'random', 'scope': 'all'},
timeout=10, headers={'Content-Encoding': 'gzip'})
r.raise_for_status() r.raise_for_status()
tracks = r.json() tracks = r.json()
@ -112,7 +113,7 @@ with concurrent.futures.ThreadPoolExecutor(max_workers=50) as executor:
filtred_tracks = filter_tracks(tracks['results']) filtred_tracks = filter_tracks(tracks['results'])
after_filter = before_filter - len(filtred_tracks) after_filter = before_filter - len(filtred_tracks)
print(f'{after_filter} tracks filtred on {instance}') print(f'{after_filter} tracks filtred on {instance}')
tracks_stor = filtred_tracks tracks_stor += filtred_tracks
except Exception as E: except Exception as E:
print(E) print(E)
for track in tracks_stor: for track in tracks_stor: