Merge pull request #18 from kokarare1212/deepsource-transform-930b5e33
Format code with yapf
This commit is contained in:
commit
10d5814047
|
@ -6,5 +6,6 @@ if typing.TYPE_CHECKING:
|
||||||
|
|
||||||
|
|
||||||
class AudioQualityPicker:
|
class AudioQualityPicker:
|
||||||
def get_file(self, files: typing.List[Metadata.AudioFile]) -> Metadata.AudioFile:
|
def get_file(self,
|
||||||
|
files: typing.List[Metadata.AudioFile]) -> Metadata.AudioFile:
|
||||||
pass
|
pass
|
||||||
|
|
|
@ -382,7 +382,8 @@ class Session(Closeable, SubListener, DealerClient.MessageListener):
|
||||||
listener.on_closed()
|
listener.on_closed()
|
||||||
self._closeListeners: typing.List[Session.CloseListener] = []
|
self._closeListeners: typing.List[Session.CloseListener] = []
|
||||||
|
|
||||||
self._reconnectionListeners: typing.List[Session.ReconnectionListener] = []
|
self._reconnectionListeners: typing.List[
|
||||||
|
Session.ReconnectionListener] = []
|
||||||
|
|
||||||
self._LOGGER.info("Closed session. device_id: {}".format(
|
self._LOGGER.info("Closed session. device_id: {}".format(
|
||||||
self._inner.device_id))
|
self._inner.device_id))
|
||||||
|
|
|
@ -16,9 +16,10 @@ class ApiClient(Closeable):
|
||||||
self._session = session
|
self._session = session
|
||||||
self._baseUrl = "https://{}".format(ApResolver.get_random_spclient())
|
self._baseUrl = "https://{}".format(ApResolver.get_random_spclient())
|
||||||
|
|
||||||
def build_request(self, method: str, suffix: str,
|
def build_request(
|
||||||
headers: typing.Union[None, typing.Dict[str, str]],
|
self, method: str, suffix: str,
|
||||||
body: typing.Union[None, bytes]) -> requests.PreparedRequest:
|
headers: typing.Union[None, typing.Dict[str, str]],
|
||||||
|
body: typing.Union[None, bytes]) -> requests.PreparedRequest:
|
||||||
request = requests.PreparedRequest()
|
request = requests.PreparedRequest()
|
||||||
request.method = method
|
request.method = method
|
||||||
request.data = body
|
request.data = body
|
||||||
|
@ -30,8 +31,8 @@ class ApiClient(Closeable):
|
||||||
request.url = self._baseUrl + suffix
|
request.url = self._baseUrl + suffix
|
||||||
return request
|
return request
|
||||||
|
|
||||||
def send(self, method: str, suffix: str, headers: typing.Union[None, typing.Dict[str,
|
def send(self, method: str, suffix: str,
|
||||||
str]],
|
headers: typing.Union[None, typing.Dict[str, str]],
|
||||||
body: typing.Union[None, bytes]) -> requests.Response:
|
body: typing.Union[None, bytes]) -> requests.Response:
|
||||||
resp = self._session.client().send(
|
resp = self._session.client().send(
|
||||||
self.build_request(method, suffix, headers, body))
|
self.build_request(method, suffix, headers, body))
|
||||||
|
|
|
@ -249,7 +249,8 @@ class MercuryClient(PacketsReceiver.PacketsReceiver, Closeable):
|
||||||
payload: typing.List[bytes]
|
payload: typing.List[bytes]
|
||||||
status_code: int
|
status_code: int
|
||||||
|
|
||||||
def __init__(self, header: Mercury.Header, payload: typing.List[bytes]):
|
def __init__(self, header: Mercury.Header,
|
||||||
|
payload: typing.List[bytes]):
|
||||||
self.uri = header.uri
|
self.uri = header.uri
|
||||||
self.status_code = header.status_code
|
self.status_code = header.status_code
|
||||||
self.payload = payload[1:]
|
self.payload = payload[1:]
|
||||||
|
|
|
@ -55,5 +55,6 @@ class StateWrapper(DeviceStateHandler.Listener, DealerClient.MessageListener):
|
||||||
self._device.update_state(Connect.PutStateReason.NEW_DEVICE, 0,
|
self._device.update_state(Connect.PutStateReason.NEW_DEVICE, 0,
|
||||||
self._state)
|
self._state)
|
||||||
|
|
||||||
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
|
pass
|
||||||
|
|
|
@ -27,7 +27,8 @@ class AudioQuality(enum.Enum):
|
||||||
return AudioQuality.VERY_HIGH
|
return AudioQuality.VERY_HIGH
|
||||||
raise RuntimeError("Unknown format: {}".format(format))
|
raise RuntimeError("Unknown format: {}".format(format))
|
||||||
|
|
||||||
def get_matches(self, files: typing.List[AudioFile]) -> typing.List[AudioFile]:
|
def get_matches(self,
|
||||||
|
files: typing.List[AudioFile]) -> typing.List[AudioFile]:
|
||||||
file_list = []
|
file_list = []
|
||||||
for file in files:
|
for file in files:
|
||||||
if hasattr(file, "format") and AudioQuality.get_quality(
|
if hasattr(file, "format") and AudioQuality.get_quality(
|
||||||
|
|
|
@ -26,7 +26,8 @@ class VorbisOnlyAudioQuality(AudioQualityPicker):
|
||||||
return None
|
return None
|
||||||
|
|
||||||
def get_file(self, files: typing.List[Metadata.AudioFile]):
|
def get_file(self, files: typing.List[Metadata.AudioFile]):
|
||||||
matches: typing.List[Metadata.AudioFile] = self.preferred.get_matches(files)
|
matches: typing.List[Metadata.AudioFile] = self.preferred.get_matches(
|
||||||
|
files)
|
||||||
vorbis: Metadata.AudioFile = VorbisOnlyAudioQuality.get_vorbis_file(
|
vorbis: Metadata.AudioFile = VorbisOnlyAudioQuality.get_vorbis_file(
|
||||||
matches)
|
matches)
|
||||||
if vorbis is None:
|
if vorbis is None:
|
||||||
|
|
Loading…
Reference in New Issue