mirror of
https://gitea.phreedom.club/localhost_frssoft/funkwlmpv
synced 2024-11-30 02:53:02 +00:00
Compare commits
8 Commits
92a52dd2b8
...
200deac9a6
Author | SHA1 | Date | |
---|---|---|---|
200deac9a6 | |||
bc2b7efdd9 | |||
309e36db43 | |||
395800f280 | |||
0e6b7cccbf | |||
89a8133de7 | |||
61265cceb8 | |||
a9b3fddffe |
14
README.md
14
README.md
@ -1,6 +1,20 @@
|
|||||||
# funkwlplay
|
# funkwlplay
|
||||||
|
|
||||||
basic functional for create playlist tracks. Be simple as possible. No implement player and tui. Just bare cli solution.
|
basic functional for create playlist tracks. Be simple as possible. No implement player and tui. Just bare cli solution.
|
||||||
|
Random powered, good luck :3
|
||||||
|
|
||||||
|
Example usage:
|
||||||
|
```
|
||||||
|
./funkwlplay.py # just get random tracks from instances
|
||||||
|
|
||||||
|
./funkwlplay.py -s 'dance with the dead' # search on instances
|
||||||
|
|
||||||
|
./funkwlplay.py -t house # search tag house on instances
|
||||||
|
|
||||||
|
./funkwlplay.py -r 1 -d 10 -i funk.deko.cloud # get 10 pages random tracks from instance
|
||||||
|
|
||||||
|
$YOUR_FAVORITE_PLAYER playlist.m3u8 # just plays tracks. Remember at this moment playlist will be rewriten after every call ./funkwlplay.py
|
||||||
|
```
|
||||||
|
|
||||||
[1]**Warning:** may content _unofficial instances_
|
[1]**Warning:** may content _unofficial instances_
|
||||||
**Warning 2:** This software not userfriendly. Maybe developerfriendly.
|
**Warning 2:** This software not userfriendly. Maybe developerfriendly.
|
||||||
|
@ -34,13 +34,12 @@ 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=1)
|
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:
|
||||||
return 0
|
return 0
|
||||||
with concurrent.futures.ThreadPoolExecutor(max_workers=50) as executor:
|
with concurrent.futures.ThreadPoolExecutor(max_workers=50) as executor:
|
||||||
before = len(tracks)
|
|
||||||
res = [executor.submit(remove_unreach_tracks, track) for track in tracks]
|
res = [executor.submit(remove_unreach_tracks, track) for track in tracks]
|
||||||
concurrent.futures.wait(res)
|
concurrent.futures.wait(res)
|
||||||
avalaible = []
|
avalaible = []
|
||||||
@ -49,8 +48,6 @@ def filter_tracks(tracks):
|
|||||||
if is_avalaible == 1:
|
if is_avalaible == 1:
|
||||||
avalaible.append(track)
|
avalaible.append(track)
|
||||||
tracks = avalaible
|
tracks = avalaible
|
||||||
after = before - len(tracks)
|
|
||||||
print(f'-{after} unreach tracks')
|
|
||||||
|
|
||||||
Path('filter_tags').touch()
|
Path('filter_tags').touch()
|
||||||
Path('filter_artists').touch()
|
Path('filter_artists').touch()
|
||||||
@ -63,7 +60,7 @@ def filter_tracks(tracks):
|
|||||||
|
|
||||||
with open('filter_raw_urls') as raw_urls_file:
|
with open('filter_raw_urls') as raw_urls_file:
|
||||||
block_raw_urls = raw_urls_file.read().strip().split('\n')
|
block_raw_urls = raw_urls_file.read().strip().split('\n')
|
||||||
|
filtred_tracks = []
|
||||||
for i in tracks:
|
for i in tracks:
|
||||||
if [tag.lower() for tag in i['tags']] in block_tags:
|
if [tag.lower() for tag in i['tags']] in block_tags:
|
||||||
continue
|
continue
|
||||||
@ -71,14 +68,15 @@ def filter_tracks(tracks):
|
|||||||
continue
|
continue
|
||||||
if i['listen_url'].lower() in block_raw_urls:
|
if i['listen_url'].lower() in block_raw_urls:
|
||||||
continue
|
continue
|
||||||
tracks_stor.append(i)
|
filtred_tracks.append(i)
|
||||||
|
return filtred_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()
|
||||||
|
|
||||||
@ -111,10 +109,16 @@ with concurrent.futures.ThreadPoolExecutor(max_workers=50) as executor:
|
|||||||
for idx, instance in enumerate(instances):
|
for idx, instance in enumerate(instances):
|
||||||
try:
|
try:
|
||||||
tracks = res[idx].result()
|
tracks = res[idx].result()
|
||||||
filter_tracks(tracks['results'])
|
before_filter = len(tracks['results'])
|
||||||
|
filtred_tracks = filter_tracks(tracks['results'])
|
||||||
|
after_filter = before_filter - len(filtred_tracks)
|
||||||
|
print(f'{after_filter} tracks filtred on {instance}')
|
||||||
|
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:
|
||||||
artist, album, title, play_url = track['artist']['name'], track['album']['title'], track['title'], track['listen_url']
|
artist, album, title, play_url, track_duration, fid = track['artist']['name'], track['album']['title'], track['title'], track['listen_url'], track.get('duration'), track['fid']
|
||||||
playlist_files.append(f'#EXTINF:-1,{artist} - {album} - {title}\n{play_url}')
|
if not track_duration:
|
||||||
|
track_duration = -1
|
||||||
|
playlist_files.append(f'#EXTINF:{track_duration},{artist} - {album} - {title} url="{fid}"\n{play_url}')
|
||||||
create_playlist_file(playlist_files)
|
create_playlist_file(playlist_files)
|
||||||
|
Loading…
Reference in New Issue
Block a user