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

301 Commity (3d493b88ef5ca93d1f1c841a33a8d54fb238f3b5)

Autor SHA1 Wiadomość Data
Andrew Mirsky fed5b8eb08
shutdown broker when test completes 2025-06-12 11:03:28 -04:00
Andrew Mirsky e7882a3755
fixes amqtt/Yakifo#210 : when reconnect is false, authentication failure causes NoDataError instead of ConnectError 2025-06-12 10:52:44 -04:00
Andrew Mirsky 7b936d785c
loading plugins from config file, bypassing entry points. authenticate and subscribe/publish 2025-06-12 08:37:27 -04:00
Andrew Mirsky e69cb12652
fixing test case for python 3.12 2025-06-09 12:21:22 -04:00
Andrew Mirsky 18bfb6d9c5
python 3.12 requires the connect packet before forcing the socket to disconnect 2025-06-09 00:24:40 -04:00
Andrew Mirsky 2caa792d69
fixes Yakifo/amqtt#51 : plugins which fail to import or load should stop the broker from starting 2025-06-09 00:11:06 -04:00
Andrew Mirsky 2b1599e6af
fixes Yakifo/amqtt#86 : verify that the issue has been fixed 2025-06-08 22:42:49 -04:00
Andrew Mirsky 52b69ee068
fixes Yakifo/amqtt#67 : malformed uri or incorrect scheme should raise a ConnectError (not a ClientError) 2025-06-08 10:29:14 -04:00
Andrew Mirsky 1756d93ebd
removing cli test cases for verifying will messages, better done through unit test cases in test_client.py 2025-06-08 10:00:13 -04:00
Andrew Mirsky ac8782772f
removing inaccurate tests 2025-06-08 07:42:07 -04:00
Andrew Mirsky 58d431f2f5
adding test case for issue 67 2025-06-08 00:06:17 -04:00
Andrew Mirsky 2093cc5961
fixes Yakifo/amqtt#199 : cleanly disconnected clients should not send will messages. fixing client tests, adding additional. and correcting the broker's client handler so that normal or abnormal disconnections end the client's session and stop processing messages from the client 2025-06-07 23:56:30 -04:00
Andrew Mirsky f3291eda2f
fixes Yakifo/amqtt#154 : will message is allowed to have zero length. and the StreamReader can return 'None' or zero and they have different implications. if reading value in order to read from a stream and the length is zero, return a NoDataError. Creating exception class to satisfy EM101 and TRY003 2025-06-07 18:21:08 -04:00
Andrew Mirsky 80016d8cca
Merge pull request #191 from ajmirsky/add_test_coverage 
Add test coverage
 2025-06-05 11:32:05 -04:00
Andrew Mirsky 9d3d9bd7e2
using 'n' messages to force amqtt_sub to exit, instead of SIGINT which seems to cause the process to force quit instead of causing a keyboard interupt 2025-06-03 18:29:13 -04:00
Andrew Mirsky dd666811a5
increasing timeout for longer running cli tests, adding asyncio wrapper on test_client test 2025-06-03 11:55:03 -04:00
Andrew Mirsky 031ce83107
removing unneeded import 2025-06-03 11:15:48 -04:00
Andrew Mirsky 1752895a39
fixes Yakifo/amqtt#159 : tests/test_client.py::test_client_publish_will_with_retain 2025-06-03 10:58:56 -04:00
Andrew Mirsky 2683e0772e
Merge pull request #182 from ajmirsky/qos_test_cases 
Fixing QoS test cases
 2025-06-02 23:34:04 -04:00
Andrew Mirsky f049ee2931
python 3.10 still differentiates between asyncio.TimeoutError and the built-in TimeoutError 2025-06-02 23:32:39 -04:00
Andrew Mirsky b30a52386f
Merge branch 'rc' into test_paho 2025-06-01 11:12:46 -04:00
Andrew Mirsky 371e76fb30
adding test to cover adapter base classes. adding test for BrokerSysPlugin 2025-06-01 11:09:40 -04:00
Andrew Mirsky f439f6fb7d
fixing test case to align with additional warning method 2025-05-31 17:11:16 -04:00
Andrew Mirsky 7f60d8d399
Merge branch 'rc' into test_paho 2025-05-31 12:06:06 -04:00
Andrew Mirsky 1e1e2026d3
cleaning up plugin interface and documentation 2025-05-30 18:50:31 -04:00
Andrew Mirsky 4701ba3faa
disabling rich output for script help 2025-05-30 12:21:15 -04:00
Andrew Mirsky 44dfd58972
disabling rich output to verify usage message is generated correctly 2025-05-30 12:11:47 -04:00
Andrew Mirsky 8f9e8afb63
clean up of the command line docs, caused inconsistent behavior between pub and sub script. limiting to mypy 1.15, since newer version has breaking changes 2025-05-29 16:29:05 -04:00
Andrew Mirsky 97436e5dcd
resolve #170. add tests to verify compatibility with paho-mqtt library 2025-05-26 16:49:57 -04:00
Andrew Mirsky ec31def92c
enhancing the 'test_init_handler' case so that it checks to make sure that the ProtocolHandler defaults to the correct loop. 2025-05-26 10:46:11 -04:00
Andrew Mirsky 5c5305baa6
while the explicit close to the asyncio.open_server docs say that you need to close the writer to have it properly exit, it seems that only python 3.12 requires the explicit close 2025-05-26 09:03:51 -04:00
Andrew Mirsky a7f2ae5746
test_init_handler: protocolhandler gets the current loop, if not provided and self.loop isn't the current loop, it's a new loop; ProtocolHandler.__init__: handler was using the session's keepalive, even though if the keepalive is zero, it needs to bypass 2025-05-26 08:48:10 -04:00
Andrew Mirsky 255e38a947
adding debug statements to determine root cause of qos failures 2025-05-25 12:44:54 -04:00
Andrew Mirsky 6afe0cddbb
disabling color output 2025-05-20 12:43:39 -04:00
Andrew Mirsky 82fe0f0ca1
disable colorized cli output for test_cli 2025-05-20 12:38:17 -04:00
Andrew Mirsky 0a50ff02ce
use 'Self' from typing_extensions to support python 3.10. add cli checks for publisher for required 'will' options. update cli test for pub/sub retain 2025-05-20 12:26:22 -04:00
Andrew Mirsky 0401220c38
turn cli exceptions into error message and error codes. added cli tests 2025-05-19 14:23:51 -04:00
Andrew Mirsky 1f2f7a1f79
since the amqtt broker (and MQTT 3.1) requires that that a CONNECT packet be received for a valid socket connection, need to send one (See BrokerProtocolHandler.init_from_connect) otherewise, the connection is immediately closed. asyncio's behavior in python 3.10, 3.11 & 3.13 seems to defer processing the 'read_or_raise' from the socket. however, python 3.12 prioritizes the 'read_or_raise' in the loop so it, triggers a NoDataError, terminating the socket before we can verify in the test. 2025-05-19 12:45:45 -04:00
MVladislav 12d5cb6866 refactor: modularize broker listener startup and improve session management 
- Extracted listener startup logic into a separate method `_start_listeners` for better readability and maintainability.
- Created helper methods for SSL context creation.
- Improved session cleanup during shutdown by centralizing logic in `_cleanup_session`.
- Refactored message handling and subscription management into dedicated methods for clarity.
- Updated tests to reflect changes in method visibility for matching topics.
 2025-04-06 19:03:30 +02:00
MVladislav 338ff39b17 chore: update version to 0.11.0-beta4, add clear_queues method, and improve resource management in PluginManager and BrokerProtocolHandler 2025-04-04 19:18:17 +02:00
MVladislav 0afe361bd0 fix(#0): renaming file and fix usage 
- logging was renamed as logging_a now better as logging_amqtt with fix inside pyproject.toml
- renamed codecs => codecs_a => codecs_amqtt
 2025-01-16 20:01:16 +01:00
MVladislav 57bfec0ea8 refactor: more cleanup/linting especial Pylint 2025-01-12 22:44:19 +01:00
MVladislav 40d1214c79 refactor: checking open pull requests: 
- #119 :: not working in test cases, only comment
- #153 :: updated
- #61 :: removed try block as described
- #72 :: function included
 2025-01-12 21:28:42 +01:00
MVladislav a024b174d0 refactor: more cleanup/linting 2025-01-12 20:52:50 +01:00
MVladislav 1a72fa8e39 refactor: formatting 2024-12-29 19:23:27 +01:00
MVladislav 7c001d69b2 refactor: bigger code upgrade and improves 
- add github workflows
- update project.toml by disable multi parts to not see every needed fix now
- improve tests cases
- improve code quality
- ...
 2024-12-21 11:52:26 +01:00
MVladislav 7cc746e483 refactor: base cleanup and bring project to run with test cases 2024-12-19 20:34:09 +01:00
rparry-jones d0eb64dc19 #126 
- Updated protocol handlers to more reliably remove active waiters when task cancellation occurs
- Fixed checks where expecting a KeyError when it should be checking if not None
- Updated next_packet_id property to correctly check if there are any packet_ids available. Avoids infinite loop if all packet ids are used.
 2023-02-27 18:52:11 +01:00
Marius Kriegerowski 7fcdb0c13b broker: release server connection upon exception 2023-02-11 15:53:13 +01:00
Marius Kriegerowski 4944b0deae unit testing tcp connection to the broker 2023-02-11 15:53:06 +01:00
Fabian Elsner 96e89fb37f Fix test for Python 3.7 2023-02-09 12:42:48 +01:00
Fabian Elsner 604c45ca7a Added test for broadcast loop cancellation 2023-02-09 12:42:48 +01:00
Rémi Cardona a3f982c4d2 allow connections with username only 
Section [MQTT-3.1.2-22] of the MQTT 3.1.1 only says that a password cannot be
given without a user. The reverse should be allowed. Fixes #79.
 2022-04-17 12:05:25 +02:00
Florian Ludwig ecf64a4f82 python pre 3.9 compatibily 2022-02-06 14:42:51 +01:00
Florian Ludwig 42be5c145c reformat with black 2022-02-06 14:42:51 +01:00
Robert Resch 1bc2e06be2 fix flake8 error 2022-02-06 14:42:51 +01:00
Robert Resch 5181289d2b improve has_attr plugin tests 2022-02-06 14:42:51 +01:00
Florian Ludwig d43b36f90c throw exception instance not class and add test 2022-02-06 14:42:51 +01:00
Florian Ludwig 9628a1ce3e remove deprecated loop parameter from tests 2022-01-11 12:55:04 +01:00
Florian Ludwig 4beb912c2a remove legacy cli test 2021-08-17 17:01:58 +02:00
Florian Ludwig 86cec6d2a5 remove hbmqtt plugin namespace compatibility 2021-08-17 17:01:58 +02:00
Stuart Longland 5315e2d865 broker tests: Fix reference to TimeoutError. 
Seems Python 3.8+ moved it, and I took the reference from there.
 2021-08-17 16:20:27 +02:00
Stuart Longland 3b793a706b broker tests: Clean up flake8 warnings 2021-08-17 16:20:27 +02:00
Stuart Longland fed6d2c31c plugins.topic_checking tests: Fix issues identified by flake8 2021-08-17 16:20:27 +02:00
Stuart Longland bf5279911b Pass code through `black` formatter 2021-08-17 16:20:27 +02:00
Stuart Longland 29854264e3 broker tests: Change passwords for user[1…3] 
As pointed out, it's possible to accidentally mix them up if the
passwords are the same.  Obviously, the passwords used for these tests
should _NOT_ be used in production.
 2021-08-17 16:20:27 +02:00
Stuart Longland 744a6868fe plugins.topic_checking: De-indent logging checks 
As pointed out, the `logdog` docs do the checks outside of the context
manager scope, so we should do so as well.
 2021-08-17 16:20:27 +02:00
Stuart Longland 2e52b22c2c plugins.topic_checking tests: Run code formatting tool. 2021-08-17 16:20:27 +02:00
Stuart Longland 0760bd7613 plugins.topic_checking tests: Replace DummyLogger with `logdog` plug-in. 2021-08-17 16:20:27 +02:00
Stuart Longland 5ad48d9129 test config: Enable `pytest_logdog` plug-in 2021-08-17 16:20:27 +02:00
Stuart Longland 73db6a3536 plugins.topic_checking tests: Fix tests broken by Enum change. 2021-08-17 16:20:27 +02:00
Stuart Longland 100ca6e67a plugins.topic_checking tests: Clean up `assert`/`await` calls 2021-08-17 16:20:27 +02:00
Stuart Longland b33fb05991 plugins.topic_checking tests: Add tests for enabled=False 2021-08-17 16:20:27 +02:00
Stuart Longland db5e886c7e broker tests: Add system test for publish authorisation 2021-08-17 16:20:27 +02:00
Stuart Longland 653b6cd89c plugins.topic_checking tests: Drop copyright header 2021-08-17 16:20:27 +02:00
Stuart Longland 9efd152c1b plugins.topic_checking tests: Fix comment statement 2021-08-17 16:20:27 +02:00
Stuart Longland 33531c2f23 test cases: Add fixture for ACL-enabled test server 
This uses the real plug-ins to test the broker correctly responds to the
return values when publishing and subscribing.

The plug-ins themselves are tested elsewhere.
 2021-08-17 16:20:27 +02:00
Stuart Longland f30aa9245d test password file: Add some more users 2021-08-17 16:20:27 +02:00
Stuart Longland 66568122c5 plugin.topic_checking tests: Fix code formatting. 
Yes, too lazy to hold down shift when hitting the `'` key.
 2021-08-17 16:20:27 +02:00
Stuart Longland 18cf5cdd1e plugins.topic_checking: Add remaining tests. 2021-08-17 16:20:27 +02:00
Stuart Longland 8daf173a75 plugins.topic_checking: Test topic_ac static method 2021-08-17 16:20:27 +02:00
Stuart Longland 480a944282 plugins.topic_checking tests: Throw test suite at `black`. 
Clean up the coding style a bit.
 2021-08-17 16:20:27 +02:00
Stuart Longland 0cfce9fd84 plugins.test_topic tests: Add tests for TopicTabooPlugin. 
This is more of a "demo" plug-in, but let's test it anyway.
 2021-08-17 16:20:27 +02:00
Stuart Longland 75b8c33263 plugins.topic_checking tests: Test BaseTopicPlugin. 2021-08-17 16:20:27 +02:00
Marius Kriegerowski f1ac274457 add test_utils 2021-05-03 21:42:19 +02:00
Florian Ludwig 9a1c6643be add smoketest for CLI 2021-04-05 19:11:00 +02:00
Florian Ludwig 478a2d18c8 entrypoint transition code 2021-03-27 17:49:55 +01:00
Florian Ludwig e1c73fc53a update imports in tests 2021-03-27 17:49:55 +01:00
Florian Ludwig 8237912a3b re-enable plugin manager tests 2021-03-21 19:02:02 +01:00
Florian Ludwig 69a7992b66 rename TestPlugin to so it is ignored by pytest 2021-03-21 19:02:02 +01:00
Marius Kriegerowski 613e77f6b4 more strict flake8. Fixed typos. 2021-03-17 10:57:32 +01:00
lrasku c41b01499d Fix topic filter matching 
- re.escape() the whole filter string first to escape _all_ regex
  metacharacters in it, not just $. (# and + are both regex metacharacters,
  so their replace expressions now need a leading \\ to replace the
  escaping, too.)
- # matches topics both with and without a trailing /, so the replace
  expressions adds a '?' before the '.*'. The .lstrip('?') at the end removes
  this in case the # was the first character in the filter.
- + should only match a single level, but it should _also_ match empty levels,
  so use '[^/]*' to replace it.
- Use Regex.fullmatch() to match against the whole topic string, not just
  its start.

Also add two unit tests to test this matching, and fix an incorrect match
against + in test_client_subscribe_publish_dollar_topic_2.
 2021-03-15 13:43:47 +01:00
Marius Kriegerowski 7921e2cc22 linter project with black at default line length 88 2021-03-15 10:18:00 +01:00
Marius Kriegerowski db3dffa857 use black linter with 96 char line length 2021-03-14 21:44:41 +01:00
Florian Ludwig f439ccd1b1 reaplce some more assertEqual 2021-03-09 19:13:32 +01:00
Florian Ludwig 7c56c9caba migrate test_client to pytest 2021-03-09 19:13:32 +01:00
Florian Ludwig 7276075ed8 move broker into pytest fixture 2021-03-09 19:13:32 +01:00
Florian Ludwig b430cc8487 replace assertTrue 2021-03-09 19:13:32 +01:00
Florian Ludwig 5c58fcd59c rework broker tests to use pytest-asyncio 2021-03-09 19:13:32 +01:00
Marius Kriegerowski 6f586c253c Fix missing plugin property 2021-03-09 19:13:32 +01:00