Commit Graph

97 Commits

Author SHA1 Message Date
Felix Weiler
26a1127ac5 Add source_id to MqttConf (#102)
* Introduced source_id field in mqtt config, added config export.

* Bump patch version.
2024-03-11 17:15:09 +08:00
Felix Weiler-Detjen
d33e3a64fb Bump patch version. 2024-03-09 19:25:24 +08:00
Felix Weiler
a183f28cad Fix mqtt publisher connection issue. (#100) 2024-03-09 11:33:53 +08:00
Felix Weiler
0fdada71c2 Async tcp source (#96)
* Added AsyncTcpSource.

* Refine async tcp

* Bump patch version.
2024-03-08 15:54:35 +08:00
Felix Weiler
79913647d5 Fix default is_connected value of async zmq subscriber. (#92)
* Fix default is_connected value of async zmq subscriber.

* Bump patch version.
2024-03-02 10:08:25 +08:00
Aljoscha Sander
e2c2d01de6 Fix/exception verbose output only (#91)
* made the print statement of when unpacking a message fails controlled by the verbose flag

* bump to 0.5.3
2024-02-27 19:10:38 +08:00
Aljoscha Sander
1ab1cbf521 bump to 0.5.2 2024-02-25 22:27:50 +08:00
Aljoscha Sander
d855e3e13d added error handling to decode in receive (#83) 2024-02-25 22:24:52 +08:00
Felix Weiler
efb8333aaa Add usage to readme. (#82) 2024-02-23 21:56:02 +08:00
Aljoscha Sander
b331821b25 updated to 0.5.1 2024-02-23 21:55:07 +08:00
Felix Weiler
334f8a257d Fix coverage report generation. (#81)
* Fix coverage report generation.

* Only run action on push to main

* Don't run tests on tests themselves.

* Fix on push directive
2024-02-23 11:14:23 +08:00
Felix Weiler
d9df091d2f Feature/async udp (#80)
* First draft of async udp source.

* Add async udp publisher. UDP integration tests.

* Renamed publisher to sink, subscriber to source.
2024-02-22 19:23:33 +08:00
Felix Weiler
8c985bdf3c Refactor/background tasks (#75)
* Add start, stop and __repr__ to sink and source types.

* Merge conflicts on mqtt async pub and resampler.

* Add start() and stop() functions to udp and zmq.

Change tests accordingly.

* Rename broker, ip, interface to common config name "host".

* Updated "host" entry in config files.

* Add lazyload to mqtt-source.
2024-02-22 18:50:13 +08:00
dependabot[bot]
01eebe3cbd Bump cryptography from 41.0.7 to 42.0.4 (#79)
Bumps [cryptography](https://github.com/pyca/cryptography) from 41.0.7 to 42.0.4.
- [Changelog](https://github.com/pyca/cryptography/blob/main/CHANGELOG.rst)
- [Commits](https://github.com/pyca/cryptography/compare/41.0.7...42.0.4)

---
updated-dependencies:
- dependency-name: cryptography
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 11:07:39 +08:00
Felix Weiler-Detjen
1a5114db5f Bump minor version. 2024-02-22 10:48:37 +08:00
dependabot[bot]
0908b63b40 Bump virtualenv from 20.23.0 to 20.25.0 in /.github/workflows (#38)
Bumps [virtualenv](https://github.com/pypa/virtualenv) from 20.23.0 to 20.25.0.
- [Release notes](https://github.com/pypa/virtualenv/releases)
- [Changelog](https://github.com/pypa/virtualenv/blob/main/docs/changelog.rst)
- [Commits](https://github.com/pypa/virtualenv/compare/20.23.0...20.25.0)

---
updated-dependencies:
- dependency-name: virtualenv
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:27:06 +08:00
dependabot[bot]
2fd6dbc58f Bump safety from 2.3.4 to 2.3.5 (#35)
Bumps [safety](https://github.com/pyupio/safety) from 2.3.4 to 2.3.5.
- [Release notes](https://github.com/pyupio/safety/releases)
- [Changelog](https://github.com/pyupio/safety/blob/main/CHANGELOG.md)
- [Commits](https://github.com/pyupio/safety/compare/2.3.4...2.3.5)

---
updated-dependencies:
- dependency-name: safety
  dependency-type: direct:development
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Aljoscha Sander <aljoscha.sander@mailbox.org>
2024-02-22 09:26:49 +08:00
dependabot[bot]
1d7e4affa9 Bump tornado from 6.3.3 to 6.4 (#40)
Bumps [tornado](https://github.com/tornadoweb/tornado) from 6.3.3 to 6.4.
- [Changelog](https://github.com/tornadoweb/tornado/blob/master/docs/releases.rst)
- [Commits](https://github.com/tornadoweb/tornado/compare/v6.3.3...v6.4.0)

---
updated-dependencies:
- dependency-name: tornado
  dependency-type: indirect
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:23:23 +08:00
dependabot[bot]
1e4f1ffddf Bump actions/setup-python from 4.6.1 to 5.0.0 (#41)
Bumps [actions/setup-python](https://github.com/actions/setup-python) from 4.6.1 to 5.0.0.
- [Release notes](https://github.com/actions/setup-python/releases)
- [Commits](https://github.com/actions/setup-python/compare/v4.6.1...v5.0.0)

---
updated-dependencies:
- dependency-name: actions/setup-python
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:23:00 +08:00
dependabot[bot]
622ec310cc Bump mypy from 1.7.1 to 1.8.0 (#43)
Bumps [mypy](https://github.com/python/mypy) from 1.7.1 to 1.8.0.
- [Changelog](https://github.com/python/mypy/blob/master/CHANGELOG.md)
- [Commits](https://github.com/python/mypy/compare/v1.7.1...v1.8.0)

---
updated-dependencies:
- dependency-name: mypy
  dependency-type: direct:development
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:22:45 +08:00
dependabot[bot]
3fb4b8e284 Bump importlib-metadata from 6.8.0 to 7.0.1 (#44)
Bumps [importlib-metadata](https://github.com/python/importlib_metadata) from 6.8.0 to 7.0.1.
- [Release notes](https://github.com/python/importlib_metadata/releases)
- [Changelog](https://github.com/python/importlib_metadata/blob/main/NEWS.rst)
- [Commits](https://github.com/python/importlib_metadata/compare/v6.8.0...v7.0.1)

---
updated-dependencies:
- dependency-name: importlib-metadata
  dependency-type: indirect
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:22:29 +08:00
dependabot[bot]
0e81b49e4a Bump idna from 3.4 to 3.6 (#33)
Bumps [idna](https://github.com/kjd/idna) from 3.4 to 3.6.
- [Changelog](https://github.com/kjd/idna/blob/master/HISTORY.rst)
- [Commits](https://github.com/kjd/idna/compare/v3.4...v3.6)

---
updated-dependencies:
- dependency-name: idna
  dependency-type: indirect
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:21:55 +08:00
dependabot[bot]
bd5798f41b Bump actions/cache from 2 to 4 (#53)
Bumps [actions/cache](https://github.com/actions/cache) from 2 to 4.
- [Release notes](https://github.com/actions/cache/releases)
- [Changelog](https://github.com/actions/cache/blob/main/RELEASES.md)
- [Commits](https://github.com/actions/cache/compare/v2...v4)

---
updated-dependencies:
- dependency-name: actions/cache
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:21:35 +08:00
dependabot[bot]
576e557853 Bump pip from 23.3.1 to 24.0 in /.github/workflows (#59)
Bumps [pip](https://github.com/pypa/pip) from 23.3.1 to 24.0.
- [Changelog](https://github.com/pypa/pip/blob/main/NEWS.rst)
- [Commits](https://github.com/pypa/pip/compare/23.3.1...24.0)

---
updated-dependencies:
- dependency-name: pip
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:21:11 +08:00
dependabot[bot]
392548b61a Bump furo from 2023.9.10 to 2024.1.29 in /docs (#60)
Bumps [furo](https://github.com/pradyunsg/furo) from 2023.9.10 to 2024.1.29.
- [Release notes](https://github.com/pradyunsg/furo/releases)
- [Changelog](https://github.com/pradyunsg/furo/blob/main/docs/changelog.md)
- [Commits](https://github.com/pradyunsg/furo/compare/2023.09.10...2024.01.29)

---
updated-dependencies:
- dependency-name: furo
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:20:56 +08:00
dependabot[bot]
18d44704a1 Bump codecov/codecov-action from 3 to 4 (#66)
Bumps [codecov/codecov-action](https://github.com/codecov/codecov-action) from 3 to 4.
- [Release notes](https://github.com/codecov/codecov-action/releases)
- [Changelog](https://github.com/codecov/codecov-action/blob/main/CHANGELOG.md)
- [Commits](https://github.com/codecov/codecov-action/compare/v3...v4)

---
updated-dependencies:
- dependency-name: codecov/codecov-action
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2024-02-22 09:20:31 +08:00
Felix Weiler
0311ad40cf Add reconnection to mqtt async publisher. (#73) 2024-02-17 12:23:11 +08:00
Felix Weiler
4ad5176847 Fix/resampler typecheck (#72)
* Add type checks to resampler.py, drops all non-numeric values.

* Single type check with ValueError raised if non-numeric.
2024-02-17 12:21:53 +08:00
Felix Weiler
1d1e762912 Add verbose and pretty flags to hkcli. (#71)
* Add verbose and pretty flags to hkcli.

Adds testing for console sink.

* Add argparse help strings to hkcli.
2024-02-17 12:20:45 +08:00
Felix Weiler
c3fcb395e9 Removed last remaining reference to MSB. Closes #49. (#63) 2024-02-12 08:21:05 +08:00
Felix Weiler
03e6a056ff Add codecov action and dependencies. (#58) 2024-02-08 10:25:47 +01:00
Aljoscha Sander
e987e6111c hotfix zmqbroker: adedd main() 2024-01-30 16:40:32 +01:00
Felix Weiler
f2809c26ee Fixed error handling in cli.py (#57)
* Fixed error handling in cli.py

* Removed reference to MSB_CONFIG_DIR

* Add annotations to joint.

* Release patch 0.4.5
2024-01-26 17:30:34 +01:00
Felix Weiler
bbcdbb624f Feature/command line interface (#54)
* Move scripts to dedicated run folder to be available from other sources.

* Additioal cmdline args for hkcli

* Add scripts.

* Remove deprecated PATH from factory.

* Skipping factory tests, need to redo.

* Add config options for hkcli.

* Bump patch version.
2024-01-22 19:00:17 +01:00
Felix Weiler
f5caeff3c0 Fix python version from 3.10 to ^3.9 (#51) 2024-01-22 15:37:04 +01:00
Felix Weiler
78ba98a587 Feature/async sources (#46)
* WIP: Added async file reader.

* Async resampling and synchronization refactored.

* Add async mqtt publisher. Remove queue from joint.

* Add async zmq publisher and subscriber.

* Modify integration tests for streaming.

* Name refactoring resampler.

* Added async source/sink to factory.

* Refactor joint and add integration tests.

* Add termcolor dev dependency

* Add conosole source and sink

* Add cli interface for different protocols

* Removed files unfit for merge.

* Fix review requests.

* Restore use of $MSB_CONFIG_DIR for now.

It seems that the default behaviour is not looking for
.config/heisskleber

* Remove version test, causing unnecessary failures.
2024-01-22 11:23:00 +01:00
Aljoscha Sander
d25130b848 Merge pull request #48 from flucto-gmbh/udp-listener
added udp-listener.py
2024-01-17 16:24:19 +01:00
P-Bent
34b73596f7 added udp-listener.py 2024-01-17 16:23:03 +01:00
Felix Weiler
5e1f4d46c6 Merge pull request #31 from flucto-gmbh/zmq-broker-test
Add zMQ broker, some testing, a few config files.
2023-11-28 17:42:20 +01:00
felix
e7ba510423 Remove unnecessary configs. Increase wait in zmq integration test. 2023-11-28 17:39:39 +01:00
felix
936e1f4c1c Add resources/zmq.yaml for tests. 2023-11-28 14:53:26 +01:00
felix
799ec8f2cd Remove test of zmq broker executable. 2023-11-28 14:49:01 +01:00
felix
74a1fcacdd Solve merge conflicts by rerunning poetry lock. 2023-11-28 12:47:24 +01:00
Aljoscha Sander
b37a871f79 added broker test 2023-11-27 14:52:46 +01:00
Aljoscha Sander
43a6071ad3 fixed mixed up publisher subscriber addresses 2023-11-27 11:58:58 +01:00
Aljoscha Sander
07508d2899 WIP: working on zmq pub sub test 2023-11-27 09:27:07 +01:00
Aljoscha Sander
510c60a78b fixed broken tests 2023-11-27 07:32:54 +01:00
Aljoscha Sander
e1ef65ef66 WIP: pub and sub won't talk to each other (zmq) 2023-11-27 00:12:28 +01:00
Aljoscha Sander
ef4bd9bb9f fixed version assert 2023-11-26 20:34:32 +01:00
Aljoscha Sander
7b6df59c10 bumped version up to 0.3.1 2023-11-26 18:13:51 +01:00