108 lines
2.9 KiB
Python
Executable File
108 lines
2.9 KiB
Python
Executable File
import os
|
|
import json
|
|
import socket
|
|
import subprocess
|
|
|
|
UDP_IP_ADDRESS = "127.0.0.1"
|
|
UDP_PORT_NO = 7123
|
|
serverSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
serverSock.bind((UDP_IP_ADDRESS, UDP_PORT_NO))
|
|
|
|
|
|
SIDS = ('S1', 'S2', 'S3')
|
|
mplayers = dict(S1=None, S2=None, S3=None)
|
|
|
|
import io
|
|
PIPE = io.StringIO()
|
|
|
|
SOUNDS = dict(blubber='/home/kombinat/player/test.mp3', short='/home/kombinat/player/cough.mp3')
|
|
|
|
|
|
|
|
#for sid in SIDS:
|
|
# if os.path.isdir(f'/tmp/mplayerctrl{sid}'):
|
|
# os.unlink(f'/tmp/mplayerctrl{sid}')
|
|
# os.mkfifo(f'/tmp/mplayerctrl{sid}')
|
|
|
|
|
|
def _get_current():
|
|
res = []
|
|
with open('play.json') as playconf:
|
|
for screen_id, filepath in json.loads(playconf.read()).items():
|
|
if filepath == '':
|
|
continue
|
|
res.append((screen_id, filepath))
|
|
return res
|
|
|
|
|
|
def _mplayer_command(screen_id, mplayercmd):
|
|
with open(f'/tmp/mplayerctrl{screen_id}', 'a') as ctrl:
|
|
ctrl.write(mplayercmd)
|
|
|
|
|
|
def get_time():
|
|
for screen_id, filepath in _get_current():
|
|
_mplayer_command(screen_id, 'pausing_keep_force get_time_pos\n')
|
|
|
|
def load_current():
|
|
for screen_id, filepath in _get_current():
|
|
cmd = f'loadfile storage/{filepath}\npause\npausing_keep get_time_length\n'
|
|
_mplayer_command(screen_id, cmd)
|
|
_mplayer_command(screen_id, f'pausing_keep_force run "echo ${{pause}} > {screen_id}_pause"\n')
|
|
|
|
def play_sound(cmd):
|
|
cmd = cmd[6:]
|
|
if cmd.startswith('kill'):
|
|
snd = cmd[5:]
|
|
os.system(f'kill -9 `cat {snd}.pid`')
|
|
os.unlink(f'{snd}.pid')
|
|
return
|
|
cmd, addr = cmd.split('#')
|
|
bank, btn = addr.split('_')
|
|
os.system(f'./play_sound.sh {SOUNDS[cmd]} {cmd} {int(bank)} {int(btn)} &')
|
|
|
|
|
|
|
|
def play_current():
|
|
for screen_id, filepath in _get_current():
|
|
_mplayer_command(screen_id, f'pause\n')
|
|
_mplayer_command(screen_id, f'pausing_keep_force run "echo ${{pause}} > {screen_id}_pause"\n')
|
|
|
|
|
|
def stop_current():
|
|
for screen_id, filepath in _get_current():
|
|
with open(f'/tmp/mplayerctrl{screen_id}', 'a') as ctrl:
|
|
ctrl.write("stop\n")
|
|
os.unlink(f'curtime_{screen_id}.json')
|
|
|
|
def ninja(cmd):
|
|
for sid in SIDS:
|
|
if f'{sid}' in cmd:
|
|
scr = sid
|
|
break
|
|
scr = scr[1]
|
|
if cmd.endswith('start'):
|
|
os.system(f'./start_ninja.sh {scr}')
|
|
elif cmd.endswith('stop'):
|
|
os.system(f'./stop_ninja.sh {scr}')
|
|
|
|
|
|
while True:
|
|
data, addr = serverSock.recvfrom(1024)
|
|
commands = data.decode("utf8").splitlines()
|
|
for cmd in commands:
|
|
if cmd == 'load_current':
|
|
load_current()
|
|
elif cmd == 'play_current':
|
|
play_current()
|
|
elif cmd == 'stop_current':
|
|
stop_current()
|
|
elif cmd == 'get_time':
|
|
get_time()
|
|
elif cmd.startswith('sound'):
|
|
play_sound(cmd)
|
|
elif cmd.startswith('ninja'):
|
|
ninja(cmd)
|
|
else:
|
|
print(f"{cmd} not found!")
|