133 lines
3 KiB
Python
133 lines
3 KiB
Python
import pygame
|
|
import time
|
|
import json
|
|
from mutagen.mp3 import MP3
|
|
|
|
from state_manager import stateManager
|
|
|
|
class bapsicle():
|
|
state = None
|
|
|
|
__default_state = {
|
|
"filename": "",
|
|
"channel": -1,
|
|
"playing": False,
|
|
"pos": 0,
|
|
"remaining": 0,
|
|
"length": 0,
|
|
"loop": False,
|
|
"output": None
|
|
}
|
|
|
|
def isInit(self):
|
|
try:
|
|
pygame.mixer.music.get_busy()
|
|
except:
|
|
return False
|
|
else:
|
|
return True
|
|
|
|
def isPlaying(self):
|
|
return bool(pygame.mixer.music.get_busy())
|
|
|
|
def play(self):
|
|
|
|
|
|
pygame.mixer.music.play(0)
|
|
|
|
def pause(self):
|
|
pygame.mixer.music.pause()
|
|
|
|
def unpause(self):
|
|
pygame.mixer.music.play(0, self.state.state["pos"])
|
|
|
|
def stop(self):
|
|
pygame.mixer.music.stop()
|
|
|
|
def seek(self, pos):
|
|
if self.isPlaying():
|
|
pygame.mixer.music.play(0, pos)
|
|
else:
|
|
self.updateState(pos)
|
|
|
|
def load(self, filename):
|
|
if not self.isPlaying():
|
|
self.state.update("filename",filename)
|
|
pygame.mixer.music.load(filename)
|
|
if ".mp3" in filename:
|
|
song = MP3(filename)
|
|
self.state.update("length",song.info.length)
|
|
else:
|
|
self.state.update("length",pygame.mixer.Sound(filename).get_length()/1000)
|
|
|
|
def output(self, name = None):
|
|
pygame.mixer.quit()
|
|
try:
|
|
if name:
|
|
pygame.mixer.init(44100, -16, 1, 1024, devicename=name)
|
|
else:
|
|
pygame.mixer.init(44100, -16, 1, 1024)
|
|
except:
|
|
return "FAIL:Failed to init mixer, check sound devices."
|
|
else:
|
|
if name:
|
|
self.state.update("output",name)
|
|
else:
|
|
self.state.update("output","default")
|
|
return "OK"
|
|
|
|
|
|
def updateState(self, pos = None):
|
|
self.state.update("playing",self.isPlaying())
|
|
if (pos):
|
|
self.state.update("pos",pos)
|
|
else:
|
|
self.state.update("pos",pygame.mixer.music.get_pos()/1000)
|
|
print(self.state.state)
|
|
self.state.update("remaining",self.state.state["length"] - self.state.state["pos"])
|
|
|
|
def getDetails(self):
|
|
res = "RESP:DETAILS: " + json.dumps(self.state.state)
|
|
return res
|
|
|
|
|
|
def __init__(self, channel, in_q, out_q):
|
|
|
|
self.state = stateManager("channel" + str(channel), self.__default_state)
|
|
|
|
self.state.update("channel", channel)
|
|
|
|
self.output()
|
|
|
|
|
|
|
|
|
|
while True:
|
|
time.sleep(0.01)
|
|
incoming_msg = in_q.get()
|
|
if (not incoming_msg):
|
|
continue
|
|
if self.isInit():
|
|
self.updateState()
|
|
if (incoming_msg == 'PLAY'):
|
|
self.play()
|
|
if (incoming_msg == 'PAUSE'):
|
|
self.pause()
|
|
if (incoming_msg == 'UNPAUSE'):
|
|
self.unpause()
|
|
if (incoming_msg == 'STOP'):
|
|
self.stop()
|
|
if (incoming_msg.startswith("SEEK")):
|
|
split = incoming_msg.split(":")
|
|
self.seek(float(split[1]))
|
|
if (incoming_msg.startswith("LOAD")):
|
|
split = incoming_msg.split(":")
|
|
self.load(split[1])
|
|
if (incoming_msg == 'DETAILS'):
|
|
out_q.put(self.getDetails())
|
|
|
|
|
|
if (incoming_msg.startswith("OUTPUT")):
|
|
split = incoming_msg.split(":")
|
|
out_q.put(self.output(split[1]))
|
|
|