rdelaage
/
librespot-python
mirror of https://github.com/kokarare1212/librespot-python.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #42 from kokarare1212/restyled/deepsource-transform-2e7b1565 

Restyle Format code with yapf
This commit is contained in:
こうから 2021-05-25 13:54:53 +09:00 committed by GitHub
parent 160f300381 7b4fb2a825
commit eb46e4a0ba
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
examples/server/main.py
View File

@ -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<TrackID>[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]))