radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-02-26 21:53:54 +01:00
Code Issues Activity

simplyfy core thing

Browse Source
This commit is contained in:
KubaPro010
2025-11-16 22:03:50 +01:00
parent 6982bdb370
commit 3abe6281ae
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
radioPlayer.py
View File

@@ -116,7 +116,7 @@ class PlaylistParser:
return global_arguments, out return global_arguments, out
class RadioPlayer: class RadioPlayer:
def __init__(self, output: log95.TextIO): def __init__(self, arg: str | None, output: log95.TextIO):
self.simple_modules: list[PlayerModule] = [] self.simple_modules: list[PlayerModule] = []
self.playlist_modifier_modules: list[PlaylistModifierModule] = [] self.playlist_modifier_modules: list[PlaylistModifierModule] = []
self.playlist_advisor: PlaylistAdvisor | None = None self.playlist_advisor: PlaylistAdvisor | None = None
@@ -129,6 +129,7 @@ class RadioPlayer:
self.procman = ProcessManager() self.procman = ProcessManager()
self.modules: list[tuple] = [] self.modules: list[tuple] = []
self.parser = PlaylistParser(output) self.parser = PlaylistParser(output)
self.arg = arg
def shutdown(self): def shutdown(self):
self.procman.stop_all() self.procman.stop_all()
@@ -196,6 +197,7 @@ class RadioPlayer:
if self.active_modifier: raise Exception("Multiple active modifiers") if self.active_modifier: raise Exception("Multiple active modifiers")
self.active_modifier = md self.active_modifier = md
InterModuleCommunication(self.simple_modules + [self.playlist_advisor, ProcmanCommunicator(self.procman), self.active_modifier]) InterModuleCommunication(self.simple_modules + [self.playlist_advisor, ProcmanCommunicator(self.procman), self.active_modifier])
if self.active_modifier: self.active_modifier.arguments(self.arg)
def start(self): def start(self):
self.logger.info("Core starting, loading modules") self.logger.info("Core starting, loading modules")
@@ -204,7 +206,8 @@ class RadioPlayer:
self.logger.critical_error("Playlist advisor was not found") self.logger.critical_error("Playlist advisor was not found")
raise SystemExit(1) raise SystemExit(1)
def play_playlist(self, playlist_path: Path, starting_index: int = 0): def play_once(self):
if not self.playlist_advisor or not (playlist_path := self.playlist_advisor.advise(self.arg)): return
try: global_args, parsed = self.parser.parse(playlist_path) try: global_args, parsed = self.parser.parse(playlist_path)
except Exception as e: except Exception as e:
self.logger.info(f"Exception ({e}) while parsing playlist, retrying in 15 seconds...") self.logger.info(f"Exception ({e}) while parsing playlist, retrying in 15 seconds...")
@@ -225,7 +228,7 @@ class RadioPlayer:
cross_fade = int(global_args.get("crossfade", 5)) cross_fade = int(global_args.get("crossfade", 5))
max_iterator = len(playlist) max_iterator = len(playlist)
song_i = i = starting_index song_i = i = 0
while i < max_iterator: while i < max_iterator:
if self.exit_pending: if self.exit_pending:
@@ -272,13 +275,10 @@ class RadioPlayer:
if not extend: song_i += 1 if not extend: song_i += 1
def loop(self): def loop(self):
assert self.playlist_advisor
self.logger.info("Starting playback.") self.logger.info("Starting playback.")
try: try:
arg = " ".join(sys.argv[1:]) if len(sys.argv) > 1 else None
if self.active_modifier: self.active_modifier.arguments(arg)
while True: while True:
if playlist := self.playlist_advisor.advise(arg): self.play_playlist(playlist) self.play_once()
if self.exit_pending: raise SystemExit(self.exit_status_code) if self.exit_pending: raise SystemExit(self.exit_status_code)
except Exception as e: except Exception as e:
self.logger.critical_error(f"Unexpected error: {e}") self.logger.critical_error(f"Unexpected error: {e}")
@@ -289,7 +289,7 @@ def main():
log_file_path.touch() log_file_path.touch()
log_file = open(log_file_path, "w") log_file = open(log_file_path, "w")
core = RadioPlayer(log_file) core = RadioPlayer((" ".join(sys.argv[1:]) if len(sys.argv) > 1 else None), log_file)
atexit.register(core.shutdown) atexit.register(core.shutdown)
core.start() core.start()
signal.signal(signal.SIGINT, core.handle_sigint) signal.signal(signal.SIGINT, core.handle_sigint)