Merge pull request #69 from kokarare1212/deepsource-transform-64a3a0b3
Format code with yapf
This commit is contained in:
commit
4e7d43d4e3
|
@ -155,7 +155,11 @@ class ZeroconfServer(Closeable):
|
||||||
__socket.send(self.__eol)
|
__socket.send(self.__eol)
|
||||||
__socket.send(self.__eol)
|
__socket.send(self.__eol)
|
||||||
return
|
return
|
||||||
aes = AES.new(encryption_key[:16], AES.MODE_CTR, counter=Counter.new(128, initial_value=int.from_bytes(iv, "big")))
|
aes = AES.new(encryption_key[:16],
|
||||||
|
AES.MODE_CTR,
|
||||||
|
counter=Counter.new(128,
|
||||||
|
initial_value=int.from_bytes(
|
||||||
|
iv, "big")))
|
||||||
decrypted = aes.decrypt(encrypted)
|
decrypted = aes.decrypt(encrypted)
|
||||||
self.close_session()
|
self.close_session()
|
||||||
with self.__connection_lock:
|
with self.__connection_lock:
|
||||||
|
@ -229,7 +233,10 @@ class ZeroconfServer(Closeable):
|
||||||
return self
|
return self
|
||||||
|
|
||||||
def create(self) -> ZeroconfServer:
|
def create(self) -> ZeroconfServer:
|
||||||
return ZeroconfServer(ZeroconfServer.Inner(self.device_type, self.device_name, self.device_id, self.preferred_locale, self.conf), self.listen_port)
|
return ZeroconfServer(
|
||||||
|
ZeroconfServer.Inner(self.device_type, self.device_name,
|
||||||
|
self.device_id, self.preferred_locale,
|
||||||
|
self.conf), self.listen_port)
|
||||||
|
|
||||||
class HttpRunner(Closeable, Runnable):
|
class HttpRunner(Closeable, Runnable):
|
||||||
__should_stop = False
|
__should_stop = False
|
||||||
|
@ -242,7 +249,9 @@ class ZeroconfServer(Closeable):
|
||||||
self.__socket.bind((".".join(["0"] * 4), port))
|
self.__socket.bind((".".join(["0"] * 4), port))
|
||||||
self.__socket.listen(5)
|
self.__socket.listen(5)
|
||||||
self.__zeroconf_server = zeroconf_server
|
self.__zeroconf_server = zeroconf_server
|
||||||
self.__zeroconf_server.logger.info("Zeroconf HTTP server started successfully on port {}!".format(port))
|
self.__zeroconf_server.logger.info(
|
||||||
|
"Zeroconf HTTP server started successfully on port {}!".format(
|
||||||
|
port))
|
||||||
|
|
||||||
def close(self) -> None:
|
def close(self) -> None:
|
||||||
pass
|
pass
|
||||||
|
@ -281,11 +290,13 @@ class ZeroconfServer(Closeable):
|
||||||
if method == "POST":
|
if method == "POST":
|
||||||
content_type = headers.get("Content-Type")
|
content_type = headers.get("Content-Type")
|
||||||
if content_type != "application/x-www-form-urlencoded":
|
if content_type != "application/x-www-form-urlencoded":
|
||||||
self.__zeroconf_server.logger.error("Bad Content-Type: {}".format(content_type))
|
self.__zeroconf_server.logger.error(
|
||||||
|
"Bad Content-Type: {}".format(content_type))
|
||||||
return
|
return
|
||||||
content_length_str = headers.get("Content-Length")
|
content_length_str = headers.get("Content-Length")
|
||||||
if content_length_str is None:
|
if content_length_str is None:
|
||||||
self.__zeroconf_server.logger.error("Missing Content-Length header!")
|
self.__zeroconf_server.logger.error(
|
||||||
|
"Missing Content-Length header!")
|
||||||
return
|
return
|
||||||
content_length = int(content_length_str)
|
content_length = int(content_length_str)
|
||||||
body = request.read(content_length).decode()
|
body = request.read(content_length).decode()
|
||||||
|
@ -298,7 +309,8 @@ class ZeroconfServer(Closeable):
|
||||||
params = self.__zeroconf_server.parse_path(path)
|
params = self.__zeroconf_server.parse_path(path)
|
||||||
action = params.get("action")
|
action = params.get("action")
|
||||||
if action is None:
|
if action is None:
|
||||||
self.__zeroconf_server.logger.debug("Request is missing action.")
|
self.__zeroconf_server.logger.debug(
|
||||||
|
"Request is missing action.")
|
||||||
return
|
return
|
||||||
self.handle_request(__socket, http_version, action, params)
|
self.handle_request(__socket, http_version, action, params)
|
||||||
|
|
||||||
|
@ -307,11 +319,13 @@ class ZeroconfServer(Closeable):
|
||||||
if action == "addUser":
|
if action == "addUser":
|
||||||
if params is None:
|
if params is None:
|
||||||
raise RuntimeError
|
raise RuntimeError
|
||||||
self.__zeroconf_server.handle_add_user(__socket, params, http_version)
|
self.__zeroconf_server.handle_add_user(__socket, params,
|
||||||
|
http_version)
|
||||||
elif action == "getInfo":
|
elif action == "getInfo":
|
||||||
self.__zeroconf_server.handle_get_info(__socket, http_version)
|
self.__zeroconf_server.handle_get_info(__socket, http_version)
|
||||||
else:
|
else:
|
||||||
self.__zeroconf_server.logger.warning("Unknown action: {}".format(action))
|
self.__zeroconf_server.logger.warning(
|
||||||
|
"Unknown action: {}".format(action))
|
||||||
|
|
||||||
class Inner:
|
class Inner:
|
||||||
conf: typing.Final[Session.Configuration]
|
conf: typing.Final[Session.Configuration]
|
||||||
|
|
Loading…
Reference in New Issue