Compare commits

..

5 Commits
0.61 ... 0.63

Author SHA1 Message Date
Aleksej Pawlowskij
26102dd832 Increment version 2019-12-17 15:56:37 +01:00
Aleksej Pawlowskij
cdcebda529 SDK-3136: Relax install requirements 2019-12-17 15:43:47 +01:00
Romuald Bierbasz
a83f348d7d Increment version 2019-12-10 16:02:40 +01:00
Romuald Bierbasz
1c196d60d5 SDK-3199: Log response json 2019-12-10 16:00:46 +01:00
Aleksej Pawlowskij
deb125ec48 Add missing psutil setup requirement 2019-12-05 16:22:26 +01:00
2 changed files with 13 additions and 9 deletions

View File

@@ -2,14 +2,15 @@ from setuptools import setup, find_packages
setup(
name="galaxy.plugin.api",
version="0.61",
version="0.63",
description="GOG Galaxy Integrations Python API",
author='Galaxy team',
author_email='galaxy@gog.com',
packages=find_packages("src"),
package_dir={'': 'src'},
install_requires=[
"aiohttp==3.5.4",
"certifi==2019.3.9"
"aiohttp>=3.5.4",
"certifi>=2019.3.9",
"psutil>=5.6.3; sys_platform == 'darwin'"
]
)

View File

@@ -299,11 +299,14 @@ class Connection():
except TypeError:
raise InvalidRequest()
def _send(self, data):
def _send(self, data, sensitive=True):
try:
line = self._encoder.encode(data)
data = (line + "\n").encode("utf-8")
logger.debug("Sending %d byte of data", len(data))
if sensitive:
logger.debug("Sending %d bytes of data", len(data))
else:
logging.debug("Sending data: %s", line)
self._writer.write(data)
except TypeError as error:
logger.error(str(error))
@@ -314,7 +317,7 @@ class Connection():
"id": request_id,
"result": result
}
self._send(response)
self._send(response, sensitive=False)
def _send_error(self, request_id, error):
response = {
@@ -323,7 +326,7 @@ class Connection():
"error": error.json()
}
self._send(response)
self._send(response, sensitive=False)
def _send_request(self, request_id, method, params):
request = {
@@ -332,7 +335,7 @@ class Connection():
"id": request_id,
"params": params
}
self._send(request)
self._send(request, sensitive=True)
def _send_notification(self, method, params):
notification = {
@@ -340,7 +343,7 @@ class Connection():
"method": method,
"params": params
}
self._send(notification)
self._send(notification, sensitive=True)
@staticmethod
def _log_request(request, sensitive_params):