[~] Refactor
This commit is contained in:
parent
5dc72ab291
commit
494d3fc5d0
1
d1/f1.sh
1
d1/f1.sh
@ -1,5 +1,6 @@
|
|||||||
#!/bin/sh
|
#!/bin/sh
|
||||||
|
|
||||||
|
mkdir -p ~/.local/bin
|
||||||
cp dotfiles/.local/bin/commands ~/.local/bin/commands
|
cp dotfiles/.local/bin/commands ~/.local/bin/commands
|
||||||
mkdir -p ~/.sway
|
mkdir -p ~/.sway
|
||||||
cp dotfiles/.sway/config ~/.sway/config
|
cp dotfiles/.sway/config ~/.sway/config
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
#!/usr/bin/python3
|
#!env python3
|
||||||
import os
|
import os
|
||||||
import json
|
import json
|
||||||
import traceback
|
import traceback
|
||||||
@ -438,6 +438,38 @@ done'
|
|||||||
shell=True
|
shell=True
|
||||||
)
|
)
|
||||||
|
|
||||||
|
def player_v1(folder_url, item_id):
|
||||||
|
import sys
|
||||||
|
import urllib.parse
|
||||||
|
import re
|
||||||
|
import subprocess
|
||||||
|
import os
|
||||||
|
import tqdm
|
||||||
|
t4 = folder_url
|
||||||
|
t1 = subprocess.check_output(['curl', '-s', t4]).decode('utf-8')
|
||||||
|
t2 = re.compile(r"href=\"(.*\.mp3)\"");
|
||||||
|
t3 = [o.group(1) for o in t2.finditer(t1)];
|
||||||
|
t5 = ['%s/%s' % (t4, o) for o in t3]
|
||||||
|
t6 = item_id
|
||||||
|
t9 = range(t6, len(t5))
|
||||||
|
with tqdm.tqdm(
|
||||||
|
total=len(t5),
|
||||||
|
) as progress_bar:
|
||||||
|
progress_bar.update(t6)
|
||||||
|
for k in t9:
|
||||||
|
t7 = t5[k]
|
||||||
|
t9 = urllib.parse.unquote(os.path.split(t7)[1])
|
||||||
|
progress_bar.set_description('%03d %s' % (k, t9))
|
||||||
|
with subprocess.Popen(['ffprobe', '-hide_banner', '-i', t7], stderr=subprocess.PIPE, stdout=subprocess.PIPE) as p:
|
||||||
|
p.wait()
|
||||||
|
assert p.returncode == 0
|
||||||
|
t8 = p.stderr.read().decode('utf-8')
|
||||||
|
#print(t8)
|
||||||
|
with subprocess.Popen(['ffplay', '-hide_banner', '-nodisp', '-autoexit', '-loop', '1', t7], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL) as p:
|
||||||
|
p.wait()
|
||||||
|
assert p.returncode == 0
|
||||||
|
progress_bar.update(1)
|
||||||
|
|
||||||
def status():
|
def status():
|
||||||
return ' | '.join([
|
return ' | '.join([
|
||||||
subprocess.check_output(o, shell=True).decode('utf-8').strip()
|
subprocess.check_output(o, shell=True).decode('utf-8').strip()
|
||||||
@ -535,6 +567,11 @@ try:
|
|||||||
ip_addr=sys.argv[2],
|
ip_addr=sys.argv[2],
|
||||||
ethernet_device=sys.argv[3],
|
ethernet_device=sys.argv[3],
|
||||||
)
|
)
|
||||||
|
elif sys.argv[1] == 'player':
|
||||||
|
player_v1(
|
||||||
|
folder_url=sys.argv[2],
|
||||||
|
item_id=int(sys.argv[3]),
|
||||||
|
)
|
||||||
elif sys.argv[1] == 'desktop-services':
|
elif sys.argv[1] == 'desktop-services':
|
||||||
assert all([
|
assert all([
|
||||||
env_name in os.environ
|
env_name in os.environ
|
||||||
|
Loading…
Reference in New Issue
Block a user