diff --git a/examples/server/main.py b/examples/server/main.py index f7414c5..f026335 100644 --- a/examples/server/main.py +++ b/examples/server/main.py @@ -1,12 +1,13 @@ -from librespot.audio.decoders import AudioQuality -from librespot.core import Session -from librespot.metadata import TrackId -from librespot.player.codecs import VorbisOnlyAudioQuality import os import re import socket import threading +from librespot.audio.decoders import AudioQuality +from librespot.core import Session +from librespot.metadata import TrackId +from librespot.player.codecs import VorbisOnlyAudioQuality + session: Session sock: socket @@ -80,8 +81,9 @@ def response(client: socket.socket, uri: str, header: dict, r"^/audio/track/(?P[0-9a-zA-Z]{22})$", uri) track_id_str = track_id_search.group("TrackID") track_id = TrackId.from_base62(track_id_str) - stream = session.content_feeder() \ - .load(track_id, VorbisOnlyAudioQuality(AudioQuality.VERY_HIGH), False, None) + stream = session.content_feeder().load( + track_id, VorbisOnlyAudioQuality(AudioQuality.VERY_HIGH), False, + None) start = 0 end = stream.input_stream.stream().size() if header.get("range") is not None: @@ -90,9 +92,10 @@ def response(client: socket.socket, uri: str, header: dict, header.get("range")) if range_search is not None: start = int(range_search.group("start")) - end = int(range_search.group("end")) if int( - range_search.group("end")) <= stream.input_stream.stream( - ).size() else stream.input_stream.stream().size() + end = (int(range_search.group("end")) + if int(range_search.group("end")) <= + stream.input_stream.stream().size() else + stream.input_stream.stream().size()) stream.input_stream.stream().skip(start) client.send(b"HTTP/1.0 200 OK\r\n") client.send(b"Access-Control-Allow-Origin: *\r\n") @@ -105,8 +108,8 @@ def response(client: socket.socket, uri: str, header: dict, client.send(b"Content-Type: audio/ogg\r\n") client.send(b"\r\n") while True: - if stream.input_stream.stream().pos( - ) >= stream.input_stream.stream().size(): + if (stream.input_stream.stream().pos() >= + stream.input_stream.stream().size()): break byte = stream.input_stream.stream().read() client.send(bytes([byte]))