Review: Add Message Handler

[BenediktBurger]

The MessageHandler is the base for single threaded LECO components: It listens in a continuous loop to incoming messages and handles them.

• It tries to sign-in whenever it is told, that it is not signed in.
• It handles ping messages.
• Designed for extension:
  • The continuous loop is divided in three parts: setup, loop-element, close, such that subclasses may change or expand these individual parts instead of writing everything again.
  • Message handling is divided in several steps, such that you can intervene, wherever needed.
  • You can add more methods to the rpc-server such that these messages are handled natively

The MessageHandler is an extended Component (with log level and shutdown).

As dependency, it needs the ZmqLogHandler, which is a logging Handler which publishes log messages via the data protocol (on the log ports).

[github-actions[bot]]

Coverage Report

File	Stmts	Miss	Cover	Missing
pyleco
test.py	61	22	63%	39, 42, 63, 66–67, 70, 76, 84, 96, 106–110, 113, 116, 119, 122–124, 127–128
pyleco/core
internal_protocols.py	12	2	83%	60, 70
pyleco/utils
message_handler.py	175	21	82%	85–>88, 90–>89, 137–>139, 149–150, 184–188, 215–216, 217–>220, 249–250, 260–261, 264–267, 270–273, 301
zmq_log_handler.py	40	11	62%	63–64, 66–68, 70–72, 81–82, 85
TOTAL	447	56	84%

Coverage Summary

Tests	Skipped	Failures	Errors	Time
112	0 :zzz:	0 :x:	0 :fire:	1.297s :stopwatch:

[BenediktBurger]

As a review is not happening in foreseeable future, I make this PRs a draft.

Whenever someone has time to review, I'll push the most recent version.

[github-actions[bot]]

Coverage Report

File	Stmts	Miss	Cover	Missing
pyleco
test.py	114	47	55%	39, 42, 64, 67, 70–71, 74, 80, 99, 103–108, 111–119, 136–>135, 156–160, 163, 166, 169, 172–174, 177, 180–181, 218–220, 223–226, 230–233
pyleco/core
internal_protocols.py	28	13	42%	72, 81, 87–90, 102–106, 110–114
pyleco/utils
data_publisher.py	38	1	95%	61
zmq_log_handler.py	35	4	81%	63, 65–>67, 69–71
TOTAL	616	65	88%

Coverage Summary

Tests	Skipped	Failures	Errors	Time
166	0 :zzz:	0 :x:	0 :fire:	1.097s :stopwatch:

[BenediktBurger]

This PR is now includes the code of #17 as the logging entity uses data messages (it already used the data protocol but implemented it by itself).

Therefore the data_message and data_publisher, including their respective tests, are not part of this PR by itself.

[BenediktBurger]

As it is unknown, when this will be reviewed: Closed.