mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność
865 Commity
16 Gałęzie
13 Tagi
10 MiB
Wykres commitów

211 Commity (pre-commit)

Autor SHA1 Wiadomość Data
Nico 20a43e5b25 Refactored client connection 
allow auto-reconnect
 2015-09-29 21:54:09 +02:00
Nico 32c7c7242d Add attach_session() detach_session() methods. (will be used for reconnection handling) 2015-09-28 22:51:18 +02:00
Nico fdf83b912f replace deprecated calls to warn() 2015-09-27 22:06:27 +02:00
Nico 464fa81a81 Remove obsolete files 2015-09-27 21:48:42 +02:00
Nico 5e889f5059 Ignore writer.close() error on handler stop 2015-09-27 21:39:17 +02:00
Nico cbf86e9605 remove unused 2015-09-27 21:17:28 +02:00
Nico cecf88c2c9 Manage already done handler (shouldn't happen) 2015-09-23 21:55:35 +02:00
Nico e85838512e code cleanup 2015-09-23 21:25:26 +02:00
Nico 13b1d17b01 Python 3.4 compatibility 2015-09-23 21:17:44 +02:00
Nico 0b5fa53152 Add debug message 2015-09-22 22:44:06 +02:00
Nico c05aee5468 Fix tests except QOS2 receive 2015-09-21 23:05:35 +02:00
Nico 7998824ef4 run message handling async for not blocking the messages reception 2015-09-16 22:17:56 +02:00
Nico 7954ac4f0a Forgot message delivery 2015-09-16 22:17:21 +02:00
Nico 417bb01148 Receive messages FIX 2015-09-15 23:17:55 +02:00
Nico 4b7be2b879 Add QOS1 message test and fix 2015-09-15 21:47:42 +02:00
Nico 2d5d1c3d45 Add and fix QOS_0 message receive 2015-09-15 21:31:07 +02:00
Nico 2c60b3c1a0 Commit with test failure 2015-09-13 22:36:22 +02:00
Nico cf9e78e4bb move stop() method 2015-09-12 15:54:18 +02:00
Nicolas Jouanin e3ac527924 implement QOS_2 handling 2015-09-12 14:16:22 +02:00
Nicolas Jouanin 586b898c63 Remove writer coro + WIP for publish message protocol flow management 2015-09-11 22:39:47 +02:00
nico 785d363b2f Refactoring WIP 2015-09-11 13:54:14 +02:00
Nicolas Jouanin 2f3c143554 Refactor publish message sent acknowledgment management 2015-09-10 22:41:54 +02:00
Nicolas Jouanin a1c8655463 Change use of deprecated method 2015-09-10 21:34:45 +02:00
Nicolas Jouanin 8b3ca8cbbe add protocol_ts attribute which is initialized to current timestamp when a packet is read or written to the network. This is known as the protocol timestamp 2015-09-10 21:33:34 +02:00
nico 9996b289ff Add LoggingAdapter 2015-09-10 14:01:53 +02:00
nico beb3fd4400 Fix missing plugin call 2015-09-10 13:32:08 +02:00
Nicolas Jouanin 0cbbaa6763 Refactoring WIP 2015-09-09 23:01:11 +02:00
Nicolas Jouanin 5d6732b1ac remove packet_type from repr() as given by the class name 2015-09-09 22:29:55 +02:00
nico 008b99b5a4 Begin publish message management refactoring 2015-09-09 14:22:32 +02:00
nico 15468b7849 Improve handler stopping (remove wait delay when disconnecting) 2015-09-08 15:01:37 +02:00
Nicolas Jouanin 60cc2da745 Refactoring 2015-09-06 22:23:06 +02:00
Nicolas Jouanin c3dc01daf3 Merge branch 'develop' of https://github.com/beerfactory/hbmqtt into develop 2015-09-03 21:26:44 +02:00
nico 7b79f56199 Add a method to facilitate access to packet data structure. 2015-09-03 16:48:11 +02:00
Nicolas Jouanin 313c4a367a Remove useless Task creation 2015-09-02 22:41:24 +02:00
Nicolas Jouanin bcf14ef6b8 subscription refactoring 2015-09-01 22:42:23 +02:00
Nicolas Jouanin e4a2097499 Add missing loop arguments 
HBMQTT-28
 2015-08-20 22:12:33 +02:00
Nicolas Jouanin 18cba2f53d Add packet logger plugin 2015-08-17 23:15:40 +02:00
nico d2142644b7 Move protocol_name testing to broker 2015-08-14 14:25:24 +02:00
Nicolas Jouanin 1e563ee257 Move writer.close() after writer_coro is done 2015-08-11 22:15:02 +02:00
Nicolas Jouanin 0077c61943 Test client reconnection (and messages buffering while connection lost) 2015-08-10 23:17:22 +02:00
Nicolas Jouanin b14cd1b5a4 Close writer sooner on handler stop to stop reader_coro 2015-08-10 22:05:30 +02:00
Nicolas Jouanin bc248f9fc5 Move debug trace to get packet length 2015-08-09 23:19:17 +02:00
Nicolas Jouanin c8705a059f Add packet sent/received signals 2015-08-08 22:04:55 +02:00
Nicolas Jouanin afed8acf72 Generate packet ID only for QOS > 0 messages. 2015-08-08 22:01:08 +02:00
Nicolas Jouanin 9adbbdfc3a Remove unused 2015-08-08 13:58:21 +02:00
Nicolas Jouanin 7b5145da72 Add to_bytes() method on Packet 2015-08-08 13:57:17 +02:00
Nicolas Jouanin 2bfc70eebf SSL fixes 2015-08-02 23:37:49 +02:00
Nicolas Jouanin 737cb53b90 Move reserved packet management to handler. 2015-08-02 16:00:57 +02:00
Nicolas Jouanin e8cda5ca51 Remove unused imports 2015-08-01 22:21:06 +02:00
Nicolas Jouanin 8d33a38901 Manage reader/writer adapters inside broker (test passing) 2015-08-01 22:16:39 +02:00
Nicolas Jouanin 771469a582 fix to_bytes 2015-08-01 22:16:11 +02:00
Nicolas Jouanin bdb0f2e4e5 Fix returned code after enum remove 2015-08-01 21:51:59 +02:00
Nicolas Jouanin a3df055f34 return None if EOF received 2015-08-01 21:51:37 +02:00
Nicolas Jouanin dd19fbb511 Manage reader,writer in handler 2015-08-01 21:51:20 +02:00
Nicolas Jouanin e85e319597 Refactor mutt classes for using adapters 2015-07-31 23:01:32 +02:00
Nicolas Jouanin 5166236645 Add network protocol adapter + begin Packet refactoring 2015-07-29 23:37:39 +02:00
Nicolas Jouanin 02d790e47b decrease verbosity 2015-07-27 15:46:35 +02:00
Nicolas Jouanin b9c034918f Fix delivery on reconnect conformance test 2015-07-27 15:38:38 +02:00
Nicolas Jouanin 54b0383e2f Internally set packet_id for QOS_0 messages 2015-07-27 15:01:16 +02:00
Nicolas Jouanin 7ce1c62637 Fix keep_alive conformance test 
HBMQTT-12
 2015-07-27 15:00:50 +02:00
Nicolas Jouanin df317319d4 Fix disconnection management 2015-07-26 22:53:11 +02:00
Nicolas Jouanin 0bbba69ffb Refactor incoming / outgoing message management 2015-07-26 21:21:35 +02:00
Nicolas Jouanin 238069e5d8 rename structure 2015-07-26 13:35:59 +02:00
Nicolas Jouanin c72f5e3bec Use common qos calculation method 2015-07-26 07:24:15 +02:00
Nicolas Jouanin 6c61d2577e Create InflightMessage subclass for incoming/outgoing messages 2015-07-26 07:23:40 +02:00
Nicolas Jouanin 2dc782adc0 clean unused 2015-07-26 07:23:15 +02:00
Nicolas Jouanin 814b4aef56 Handle message delivery retries 2015-07-26 07:00:55 +02:00
Nicolas Jouanin 9dc3615c16 PEP8 2015-07-26 07:00:35 +02:00
Nicolas Jouanin d74cdf2665 Refactor mqtt_publish and inflight messages management 2015-07-25 23:21:25 +02:00
Nicolas Jouanin 541e45db86 rollback message handling scheduling 2015-07-25 21:13:08 +02:00
Nicolas Jouanin cbdb97aefc Disconnection and message handling refactoring 2015-07-24 21:47:05 +02:00
Nicolas Jouanin 5aa358d17c Handler disconnection from broker in handler 
HBMQTT-1
 2015-07-18 13:36:37 +02:00
Nicolas Jouanin 5ef5b1874e Handle will message 
HBMQTT-15
 2015-07-15 23:02:36 +02:00
Nicolas Jouanin b83784a088 Fix will message encoding/decoding (bytes instead of string) 2015-07-15 23:01:40 +02:00
Nicolas Jouanin 879c021e6e Fix QOS flags setter 2015-07-15 22:06:40 +02:00
Nicolas Jouanin ff5ae364d3 Refactor subscriptions 2015-07-15 21:00:12 +02:00
Nicolas Jouanin 5aebe98913 Clean coro stopping 2015-07-14 14:19:28 +02:00
Nicolas Jouanin a8e240a2b2 Handle unsubscription 
HBMQTT-16
 2015-07-13 22:07:12 +02:00
Nicolas Jouanin 7ebe1cdd6b Fix from_stream reading topics list 2015-07-13 22:06:25 +02:00
Nicolas Jouanin 23a81449f5 Add instance builder 2015-07-13 22:06:02 +02:00
Nicolas Jouanin d6980af4fb HBMQTT-16 
HBMQTT-18
Commit work in progress
 2015-07-12 22:35:56 +02:00
Nicolas Jouanin 4618b89c99 Add repr 2015-07-12 14:40:31 +02:00
Nicolas Jouanin e124bbe949 HBMQTT-16 
Add unsubscription management in handler
 2015-07-12 13:37:40 +02:00
Nicolas Jouanin d2d843fec4 HBMQTT-17 
Handle timeout on broker side (disconnect client if not message received until timeout specified on CONNECT)
 2015-07-11 22:42:50 +02:00
Nicolas Jouanin 0181795192 HBMQTT-16 
Add subscriptions management to broker
 2015-07-11 22:22:33 +02:00
Nicolas Jouanin 752ca73af2 fix reading topics list 2015-07-11 22:17:46 +02:00
Nicolas Jouanin c8d78e2578 add build class method 2015-07-11 22:17:29 +02:00
Nicolas Jouanin 4c63b720c4 Add logging for unhandled messages 2015-07-11 21:08:03 +02:00
Nicolas Jouanin 6c8313f1b7 Move CONNECT/CONNACK handling to broker class 2015-07-10 22:55:22 +02:00
Nicolas Jouanin 8f13cd0682 PEP8 + default argument on build() 2015-07-10 22:41:26 +02:00
Nicolas Jouanin ec8b73cfaf Handle pingreq 2015-07-08 22:47:21 +02:00
Nicolas Jouanin c744169a7d Implement stupid connect handle 2015-07-08 22:42:29 +02:00
Nicolas Jouanin 0bb316374b Fix connack tostream 2015-07-08 22:42:04 +02:00
Nicolas Jouanin f44ea4a058 Fix typo 2015-07-08 22:30:42 +02:00
Nicolas Jouanin bec3302c00 Add build packet classmethod 2015-07-08 22:30:27 +02:00
Nicolas Jouanin 63fd3cff2f Add handlers 2015-07-08 22:05:56 +02:00
Nicolas Jouanin 15c63dc2e4 Implement client connection/disconnection 
HBMQTT-13
 2015-07-08 21:54:10 +02:00
Nicolas Jouanin f53ae9e10a Remove config argument to handler 2015-07-08 21:22:47 +02:00
Nicolas Jouanin b681de96de Source tree refactoring 2015-07-07 21:55:17 +02:00
Nicolas Jouanin 9ee40bc19b Handle incoming publish messages 2015-07-06 21:58:09 +02:00