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

326 Commity (revert-274-broker_script_logging)

Autor SHA1 Wiadomość Data
Nicolas Jouanin d0e32610bd Add file auth plugin 2015-08-29 15:29:09 +02:00
Nicolas Jouanin 5369e54ffc Add passlib from password checking 2015-08-29 15:28:47 +02:00
nico 933e0065fa map() accepts a filter_plugin argument which can be used to filter effective plugin called 2015-08-21 13:37:57 +02:00
nico b0007676fb map() method now returns a map of result 
{plugin1: ret1, plugin2: ret2...} for each plugin called
 2015-08-21 13:08:52 +02:00
Nicolas Jouanin 22c7ef674e Init plugin logger in context 2015-08-20 21:43:18 +02:00
nico 97bb250427 Add wait paramter to fire_event 2015-08-19 13:54:09 +02:00
Nicolas Jouanin 883b230855 change test formatting options 2015-08-17 21:52:26 +02:00
Nicolas Jouanin 2a82d102d7 Disable debug logging 2015-08-16 21:39:53 +02:00
Nicolas Jouanin a732a5ee72 Implement core PluginManager 2015-08-16 21:37:18 +02:00
nico d2142644b7 Move protocol_name testing to broker 2015-08-14 14:25:24 +02:00
Nicolas Jouanin 9a7ca67097 Fix testing 2015-08-02 16:05:24 +02:00
Nicolas Jouanin e85e319597 Refactor mutt classes for using adapters 2015-07-31 23:01:32 +02:00
Nicolas Jouanin b83784a088 Fix will message encoding/decoding (bytes instead of string) 2015-07-15 23:01:40 +02:00
Nicolas Jouanin abfda6a7c3 Add will_flag test 2015-07-15 22:06:16 +02:00
Nicolas Jouanin 2e2a8dd913 Fix testing 2015-07-10 23:00:49 +02:00
nico b8d2c3b0a6 Needs refactoring 2015-07-06 16:50:31 +02:00
Nicolas Jouanin d397aa8f7d HBMQTT-2 #comment Fix unit tests 2015-07-01 22:18:27 +02:00
nico e320360373 Fix tests 2015-06-30 12:35:57 +02:00
Nicolas Jouanin 233c6105f6 Fix test classes name 2015-06-29 22:37:21 +02:00
Nicolas Jouanin 137e291155 Fix flags settings 2015-06-29 22:37:01 +02:00
Nicolas Jouanin d43ffdce27 Refactor session 
Create ClientProtocolHandler
 2015-06-27 21:38:04 +02:00
Nicolas Jouanin 8b4714db37 Fix testing 2015-06-27 17:55:18 +02:00
Nicolas Jouanin f4bab73381 Refactor session + protocol 2015-06-27 17:42:19 +02:00
Nicolas Jouanin 09e2f208f0 (should) fix tests 2015-06-26 22:26:50 +02:00
Nicolas Jouanin abb20e1a81 Fix assert 2015-06-26 22:15:29 +02:00
Nicolas Jouanin 933f2a2f94 Add test assertion 2015-06-26 22:02:42 +02:00
Nicolas Jouanin 753f347f5c Merge session and protocol classes 
Move client test
 2015-06-26 22:00:26 +02:00
Nicolas Jouanin 52fd303438 Clean test 2015-06-24 23:31:14 +02:00
Nicolas Jouanin b173b3f5aa WIP 2015-06-24 23:19:25 +02:00
nico cc0454d335 WIP 2015-06-24 16:52:08 +02:00
Nicolas Jouanin 4c89b2ecde Implement first handler testing 2015-06-23 22:46:53 +02:00
Nicolas Jouanin 7a7ecb8181 Fix suback packet reading 2015-06-21 22:17:41 +02:00
Nicolas Jouanin f71651ab71 Implement publish with QOS_0 2015-06-18 19:41:12 +02:00
Nicolas Jouanin a22809d2b7 Add publish payload data 2015-06-18 19:30:13 +02:00
Nicolas Jouanin 68003c6bd5 Add client test file 2015-06-18 11:38:44 +02:00
Nicolas Jouanin 4af3b69e0f Fix missing assignement 2015-06-18 10:32:34 +02:00
Nicolas Jouanin 1cc9d53364 Add Unsuback packet 2015-06-18 10:28:54 +02:00
Nicolas Jouanin 82479dfc18 Add Unsuscribe packet 2015-06-18 10:22:46 +02:00
Nicolas Jouanin 4884ae2004 Implement SUBACK messages 2015-06-17 22:28:21 +02:00
Nicolas Jouanin 7c289dc46c Add subscribe message 2015-06-17 22:06:11 +02:00
Nicolas Jouanin 9c14f6d01d Factorize VariableHeader with packet id 2015-06-17 21:08:13 +02:00
Nicolas Jouanin 3da64bc65d Add PUBCOMP, PUBREL messages 2015-06-17 17:28:36 +02:00
Nicolas Jouanin 14f7fe0644 Add PUBACK , PUBREC messages 2015-06-17 17:19:31 +02:00
Nicolas Jouanin a07c225d26 PEP8 2015-06-17 17:06:48 +02:00
Nicolas Jouanin fa496dd995 Add to_bytes test 2015-06-17 17:04:03 +02:00
Nicolas Jouanin d0801e7384 Add publish packet class 2015-06-17 16:48:52 +02:00
Nicolas Jouanin 0668548887 Remove unused 2015-06-13 15:05:54 +02:00
Nicolas Jouanin 5fa686de6a Test connect packet 2015-06-13 15:05:42 +02:00
Nicolas Jouanin 6f9023ffe8 Refactor tests 2015-06-13 14:38:59 +02:00
Nicolas Jouanin 0c97edd020 Package rename 2015-06-12 22:53:43 +02:00
Nicolas Jouanin 8cccf099c8 Moved 2015-06-12 21:55:01 +02:00
Nicolas Jouanin 84adc1d693 Add Fixed header test cases 2015-06-12 21:29:54 +02:00
Nicolas Jouanin 7d678fcb24 Unused 2015-06-12 21:29:19 +02:00
Nicolas Jouanin 8eff6bcc15 Work in progress (tons of errors remaining) 2015-06-11 23:12:29 +02:00
Nicolas Jouanin 556b982864 Refactoring in progress 2015-06-11 13:54:37 +02:00
nico 1afe952a35 Fix some tests 2015-06-09 14:03:50 +02:00
Nicolas Jouanin f58e7da2b3 Move broker stuff in specific package (for separation with future MQTT client stuffs) 2015-06-02 22:26:07 +02:00
Nicolas Jouanin 4be588ec4e Encode fixed header by default 2015-05-31 17:22:39 +02:00
Nicolas Jouanin 520f991791 Fix unit testing 2015-05-31 15:13:54 +02:00
Nicolas Jouanin 9cea683700 Add Connect encoder 2015-05-31 14:59:39 +02:00
Nicolas Jouanin 874a304a81 add encode_string method 2015-05-31 14:30:32 +02:00
Nicolas Jouanin da08f0909b Rename read_string -> decode_string 2015-05-31 14:23:45 +02:00
Nicolas Jouanin 5708922398 Add header encoder 2015-05-31 14:11:59 +02:00
Nicolas Jouanin b90e59a007 Use asyncio.streams 2015-05-30 22:31:23 +02:00
Nicolas Jouanin b62b00f370 Add connect codec 2015-05-30 22:29:56 +02:00
Nicolas Jouanin 904bae2295 Rename codec 2015-05-30 21:34:47 +02:00
Nicolas Jouanin 4c079f9a66 Make codes methods statics 2015-05-30 14:15:17 +02:00
Nicolas Jouanin 5a70775bd5 Rename streams -> codecs 2015-05-30 13:58:59 +02:00
Nicolas Jouanin 16c3a0cdce Move utils 2015-05-30 13:58:29 +02:00
Nicolas Jouanin eca1e47e9c Add read_string + tests 2015-05-29 22:50:07 +02:00
Nicolas Jouanin a25ba48c3b Change flags management 2015-05-29 22:18:52 +02:00
Nicolas Jouanin 3048c1b836 Add decode() testing 2015-05-29 15:51:15 +02:00
Nicolas Jouanin 17ea5f8fc2 Do some refactoring 2015-05-29 15:28:36 +02:00
Nicolas Jouanin 05ec91f481 Init package 2015-05-28 23:19:15 +02:00
Nicolas Jouanin d3f09dc4ed Init message streaming for message encoding/decoding 2015-05-28 23:18:42 +02:00
Nicolas Jouanin 05c0e4b851 initial commit 2015-05-26 22:06:59 +02:00