diff options
| author | Simeon Simeonov | 2015-04-14 23:08:21 +0200 |
|---|---|---|
| committer | Simeon Simeonov | 2015-04-14 23:08:21 +0200 |
| commit | a5a26cba29ba37f3ef7c4f60c6cbf3f663161b27 (patch) | |
| tree | b7fa2ed496cee78ad67c14338039a08a30742814 /beinc_server_.py | |
| parent | 36dda1cca9503fc00c15ed22c4c5969e80edc1f7 (diff) | |
beinc_generic_client.py v.2.0 almost fone
Diffstat (limited to 'beinc_server_.py')
| -rwxr-xr-x | beinc_server_.py | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/beinc_server_.py b/beinc_server_.py index 36cbcd5..ec920c2 100755 --- a/beinc_server_.py +++ b/beinc_server_.py | |||
| @@ -31,7 +31,7 @@ from functools import wraps | |||
| 31 | 31 | ||
| 32 | from twisted.web import xmlrpc, server | 32 | from twisted.web import xmlrpc, server |
| 33 | from twisted.internet import protocol, reactor, ssl | 33 | from twisted.internet import protocol, reactor, ssl |
| 34 | from twisted.python.filepath import FilePath | 34 | from twisted.python import filepath, log |
| 35 | 35 | ||
| 36 | try: | 36 | try: |
| 37 | import pynotify | 37 | import pynotify |
| @@ -188,9 +188,9 @@ class BEINCInstance(object): | |||
| 188 | """ | 188 | """ |
| 189 | Reruens a json representation of the message queue | 189 | Reruens a json representation of the message queue |
| 190 | """ | 190 | """ |
| 191 | jstr = json.dumps(self.__message_queue) | 191 | r_value = self.__message_queue |
| 192 | self.__message_queue = list() | 192 | self.__message_queue = list() |
| 193 | return jstr | 193 | return r_value |
| 194 | 194 | ||
| 195 | def __send_pynotify_messaage(self, title, message): | 195 | def __send_pynotify_messaage(self, title, message): |
| 196 | """ | 196 | """ |
| @@ -339,13 +339,14 @@ def main(): | |||
| 339 | action='version', | 339 | action='version', |
| 340 | version='%(prog)s {0}'.format(__version__), | 340 | version='%(prog)s {0}'.format(__version__), |
| 341 | help='Display program-version and exit') | 341 | help='Display program-version and exit') |
| 342 | log.startLogging(sys.stdout) | ||
| 342 | args = parser.parse_args() | 343 | args = parser.parse_args() |
| 343 | try: | 344 | try: |
| 344 | with open(args.config_file, 'r') as fp: | 345 | with open(args.config_file, 'r') as fp: |
| 345 | config_dict = json.load(fp) | 346 | config_dict = json.load(fp) |
| 346 | except Exception as e: | 347 | except Exception as e: |
| 347 | sys.stderr.write('Unable to parse {0}: {1}\n'.format(args.config_file, | 348 | sys.stderr.write('Unable to parse {0}: {1}\n'.format(args.config_file, |
| 348 | e)) | 349 | e)) |
| 349 | sys.exit(errno.EIO) | 350 | sys.exit(errno.EIO) |
| 350 | try: | 351 | try: |
| 351 | if config_dict.get('config_version') != 2: | 352 | if config_dict.get('config_version') != 2: |
| @@ -364,8 +365,8 @@ def main(): | |||
| 364 | beinc_server = XMLRPCNotifyServer(config_dict) | 365 | beinc_server = XMLRPCNotifyServer(config_dict) |
| 365 | if ssl_certificate and ssl_private_key: | 366 | if ssl_certificate and ssl_private_key: |
| 366 | # SSL connection | 367 | # SSL connection |
| 367 | cert_path = FilePath(ssl_certificate) | 368 | cert_path = filepath.FilePath(ssl_certificate) |
| 368 | key_path = FilePath(ssl_private_key) | 369 | key_path = filepath.FilePath(ssl_private_key) |
| 369 | private_certificate = ssl.PrivateCertificate.loadPEM( | 370 | private_certificate = ssl.PrivateCertificate.loadPEM( |
| 370 | key_path.getContent() + cert_path.getContent()) | 371 | key_path.getContent() + cert_path.getContent()) |
| 371 | options = private_certificate.options() | 372 | options = private_certificate.options() |
