Mirrored_Repos/houdini
1
0
Fork 0
mirror of https://github.com/solero/houdini.git synced 2024-11-24 14:37:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Broadcast next track if sharing is disabled whilst track is live

Browse Source
This commit is contained in:
Ben 2020-06-12 15:20:30 +01:00
parent 42a3cefe80
commit 112eabf2df
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
houdini/handlers/play/music.py
View File

@ -44,13 +44,14 @@ class SoundStudio:
self.current_track = self.playlist[0] self.current_track = self.playlist[0]
await self.send_broadcasted_tracks() await self.send_broadcasted_tracks()
song_length = determine_song_length(self.current_track.pattern)
await asyncio.sleep(song_length)
async def broadcast_tracks(self): async def broadcast_tracks(self):
while self.broadcasting: while self.broadcasting:
await self.broadcast_next_track() await self.broadcast_next_track()
if self.broadcasting:
song_length = determine_song_length(self.current_track.pattern)
await asyncio.sleep(song_length)
async def start_broadcasting(self): async def start_broadcasting(self):
if not self.broadcasting: if not self.broadcasting:
self.broadcasting = True self.broadcasting = True
@ -241,6 +242,10 @@ async def handle_share_my_music_track(p, track_id: int, sharing: int):
await PenguinTrack.update.values(sharing=bool(sharing))\ await PenguinTrack.update.values(sharing=bool(sharing))\
.where((PenguinTrack.id == track_id) .where((PenguinTrack.id == track_id)
& (PenguinTrack.owner_id == p.id)).gino.status() & (PenguinTrack.owner_id == p.id)).gino.status()
if p.server.music.current_track is not None and \
p.server.music.current_track.id == track_id and \
p.server.music.current_track.owner_id == p.id:
await p.server.music.broadcast_next_track()
await p.send_xt('sharemymusictrack', 1) await p.send_xt('sharemymusictrack', 1)