Commit graph

3512 commits

Author SHA1 Message Date
Fabio Manganiello
7e79fa0418 Support for custom message handlers on the listener 2017-12-20 22:12:32 +01:00
Fabio Manganiello
bd5c80175f - Major refactoring.
- More consistent naming for many methods, plus added a more extensive doc.

- Refactored the entry points for the daemon and the pusher into two
  classes, easier to encapsulate and wrap into tests.

- Removed the local backend - managing the concurrency of two processes
  reading and writing on the same socket at the same time was too much,
  and its utility outside of the tests (which can have mock backends as
  well) is quite modest.

- Managing stop events on the bus. Still some work to do tho.

- Fixed several bugs.
2017-12-20 20:25:08 +01:00
Fabio Manganiello
84e36a13e9 Force exit on pusher response timeout 2017-12-18 22:58:31 +01:00
Fabio Manganiello
8ea943ffe1 Version bump 2017-12-18 22:45:55 +01:00
Fabio Manganiello
86f339cbee Printing response on pusher 2017-12-18 22:45:03 +01:00
Fabio Manganiello
21381e7c0f [#23] Request/Response ID chaining fixes
[#17] Response wait and response timeout implementation on pusher side
2017-12-18 22:40:56 +01:00
Fabio Manganiello
08f7fce028 exit all the threads on termination 2017-12-18 03:23:18 +01:00
Fabio Manganiello
18a5902ac4 Locking requests and responses with ids 2017-12-18 03:09:38 +01:00
Fabio Manganiello
97b6fab376 Updated README 2017-12-18 01:53:32 +01:00
Fabio Manganiello
93be9e3912 Fixed plugin name 2017-12-18 01:25:30 +01:00
Fabio Manganiello
4a04e51da7 Major refactoring #2 2017-12-18 01:10:51 +01:00
Fabio Manganiello
546ea1b9b9 Removed unneeded imports 2017-12-17 16:52:22 +01:00
Fabio Manganiello
1a6d726b19 Passing arguments to the plugin 2017-12-17 16:41:52 +01:00
Fabio Manganiello
339e7b73a5 Major refactoring.
Solves, among the others, #2, #18 and #22
2017-12-17 16:15:44 +01:00
Fabio Manganiello
cb423dab03 Removed short circuit on the response 2017-12-16 07:01:25 +01:00
Fabio Manganiello
6c7c08f7aa Version bump 2017-12-16 05:00:29 +01:00
Fabio Manganiello
8c89a10710 Simplified backend interface, fixed some bugs with response management 2017-12-16 04:56:43 +01:00
Fabio Manganiello
97f2733308 Fixed mpd package name 2017-12-16 02:27:51 +01:00
Fabio Manganiello
ea3eef379a No reference to self in static method 2017-12-14 01:58:42 +01:00
Fabio Manganiello
ee5b8e21a0 * If we get a push tickle on PushBullet, get that latest push
* Fixed device_id attribute name clash
2017-12-13 23:55:38 +01:00
Fabio Manganiello
dfb4620e0a Added __init__.py 2017-12-13 04:24:59 +01:00
Fabio Manganiello
33c4d9fb52 s/platypush.response/platypush.message.response/g 2017-12-13 04:21:26 +01:00
Fabio Manganiello
462dc2f1c9 * Sending responses back on the backend channel
* Version bump
2017-12-13 04:14:46 +01:00
Fabio Manganiello
491c2cd571 * More consistent management of responses
* Better per-plugin/per-backend logging management
2017-12-13 03:37:28 +01:00
Fabio Manganiello
91cf4478d0 Version bump 2017-12-13 01:17:52 +01:00
Fabio Manganiello
bf49fb8af3 #11 Kafka topics are now in the format topic.device_id so messages aren't broadcast to all the listeners of the same topic 2017-12-13 01:07:46 +01:00
Fabio Manganiello
c62a1a2bd3 Initialize the local fifo only when the backend is run 2017-12-13 01:04:04 +01:00
Fabio Manganiello
898a4ffdef Syntax error 2017-12-12 20:16:00 +01:00
Fabio Manganiello
f7202fd205 * PushbulletBackend.send_msg method refactored and removed pushbullet.py dependency
* Management of optional dependencies moved to setup.py
2017-12-12 20:14:02 +01:00
Fabio Manganiello
4b0706380e Consistent logging info 2017-12-12 19:26:23 +01:00
Fabio Manganiello
7a58add0ad #5 pusher script moved to its own module and entrypoint 2017-12-11 23:09:45 +01:00
Fabio Manganiello
00e9965305 setup.cfg 2017-12-11 20:41:50 +01:00
Fabio Manganiello
598ab223ab Ignore .pypirc 2017-12-11 20:39:46 +01:00
Fabio Manganiello
ca68aeb0e9 Installation notes 2017-12-11 20:34:13 +01:00
Fabio Manganiello
a8eead4327 Installation notes 2017-12-11 20:33:36 +01:00
Fabio Manganiello
d533052a33 Version bump 2017-12-11 20:31:42 +01:00
Fabio Manganiello
6c2ea3767c s/runbullet/platypush/g 2017-12-11 20:30:57 +01:00
Fabio Manganiello
50413dd89d Implemented send_msg on Pushbullet backend 2017-12-11 19:49:08 +01:00
Fabio Manganiello
e9e0512a52 Implemented local backend 2017-12-11 16:48:28 +01:00
Fabio Manganiello
3b74ed2bb7 Don't include disabled sections in the config 2017-12-11 10:05:45 +01:00
Fabio Manganiello
b4c445ecec Implemented retry mechanism 2017-12-11 04:45:55 +01:00
Fabio Manganiello
ab9e86dc25 Updated README 2017-12-11 04:24:05 +01:00
Fabio Manganiello
bc1289f2a9 Removed a debug print 2017-12-11 04:18:47 +01:00
Fabio Manganiello
687a91dad3 Support for Philips Hue scenes 2017-12-11 04:18:25 +01:00
Fabio Manganiello
1e75d2bda1 Implemented Philips Hue plugin 2017-12-11 03:53:26 +01:00
Fabio Manganiello
9183599664 Supporting multiple backends on pusher script 2017-12-11 01:23:22 +01:00
Fabio Manganiello
47e289ed8f Fixed method name 2017-11-29 03:37:33 +01:00
Fabio Manganiello
9790541362 Should flush the connection before exiting 2017-11-29 03:18:01 +01:00
Fabio Manganiello
83cbbb26ac Doing proper message encoding on kafka producer 2017-11-29 03:12:50 +01:00
Fabio Manganiello
9a868fc875 Remove extra pusher attribute on consumer side 2017-11-29 03:01:12 +01:00