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

Format code with yapf 

This commit fixes the style issues introduced in 6382c13 according to the output
from yapf.

Details: https://deepsource.io/gh/kokarare1212/librespot-python/transform/69dadbca-d159-4a13-a0ba-4cfbfe74193a/
This commit is contained in:
deepsource-autofix[bot] 2021-09-14 12:06:10 +00:00 committed by GitHub
parent 6382c13fd0
commit 638120ebc4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 28 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
librespot/core.py
View File

@ -1111,7 +1111,11 @@ class Session(Closeable, MessageListener, SubListener):
sha1 = SHA1.new()
sha1.update(device_id.encode())
secret = sha1.digest()
base_key = PBKDF2(secret, username.encode(), 20, 0x100, hmac_hash_module=SHA1)
base_key = PBKDF2(secret,
username.encode(),
20,
0x100,
hmac_hash_module=SHA1)
sha1 = SHA1.new()
sha1.update(base_key)
key = sha1.digest() + b"\x00\x00\x00\x14"

35
librespot/player/__init__.py
View File

@ -24,13 +24,16 @@ class DeviceStateHandler(Closeable, MessageListener, RequestListener):
self.__session = session
self.__device_info = self.initialize_device_info(session, conf)
self.__put_state = Connect.PutStateRequest(
device=Connect.Device(
device_info=self.__device_info,
),
device=Connect.Device(device_info=self.__device_info, ),
member_type=Connect.MemberType.CONNECT_STATE,
)
self.__session.dealer().add_message_listener(self, ["hm://pusher/v1/connections/", "hm://connect-state/v1/connect/volume", "hm://connect-state/v1/cluster"])
self.__session.dealer().add_request_listener(self, "hm://connect-state/v1/")
self.__session.dealer().add_message_listener(self, [
"hm://pusher/v1/connections/",
"hm://connect-state/v1/connect/volume",
"hm://connect-state/v1/cluster"
])
self.__session.dealer().add_request_listener(self,
"hm://connect-state/v1/")
def close(self) -> None:
self.__closing = True
@ -38,7 +41,8 @@ class DeviceStateHandler(Closeable, MessageListener, RequestListener):
self.__session.dealer().remove_request_listener(self)
self.__put_state_worker.shutdown()
def initialize_device_info(self, session: Session, conf: PlayerConfiguration) -> Connect.Device:
def initialize_device_info(self, session: Session,
conf: PlayerConfiguration) -> Connect.Device:
return Connect.DeviceInfo(
can_play=True,
capabilities=Connect.Capabilities(
@ -68,14 +72,16 @@ class DeviceStateHandler(Closeable, MessageListener, RequestListener):
def put_connect_state(self, request: Connect.PutStateRequest):
self.__session.api().put_connect_state(self.__connection_id, request)
self.logger.info("Put state. [ts: {}, connId: {}, reason: {}]".format(request.client_side_timestamp, self.__connection_id, request.put_state_reason))
self.logger.info("Put state. [ts: {}, connId: {}, reason: {}]".format(
request.client_side_timestamp, self.__connection_id,
request.put_state_reason))
def update_connection_id(self, newer: str) -> None:
newer = urllib.parse.unquote(newer)
if self.__connection_id is None or self.__connection_id != newer:
self.__connection_id = newer
self.logger.debug("Updated Spotify-Connection-Id: {}".format(newer))
self.logger.debug(
"Updated Spotify-Connection-Id: {}".format(newer))
class Player:
@ -183,12 +189,17 @@ class StateWrapper(MessageListener):
__player: Player
__session: Session
def __init__(self, session: Session, player: Player, conf: PlayerConfiguration):
def __init__(self, session: Session, player: Player,
conf: PlayerConfiguration):
self.__session = session
self.__player = player
self.__device = DeviceStateHandler(session, conf)
self.__conf = conf
session.dealer().add_message_listener(self, ["spotify:user:attributes:update", "hm://playlist/", "hm://collection/collection/" + session.username() + "/json"])
session.dealer().add_message_listener(self, [
"spotify:user:attributes:update", "hm://playlist/",
"hm://collection/collection/" + session.username() + "/json"
])
def on_message(self, uri: str, headers: typing.Dict[str, str], payload: bytes):
def on_message(self, uri: str, headers: typing.Dict[str, str],
payload: bytes):
pass