mirror of
https://github.com/OMGeeky/flucto-heisskleber.git
synced 2025-12-26 16:07:50 +01:00
* #129 AsyncTcpSource enhancements - retry connection on startup (behavior is configurable) - reconnect if data receiving fails (EOF received) - add Python logging - add unit tests * remove syncronous implementations. * WIP: Refactor packer/unpacker * Refactor type hints and topic handling in console sink. * Remove comma from tcp config enum definitions * Remove references to deleted synchronous classes. * Hopefully stable interface for Packer and Unpacker. * WIP: Working with protocols and generics * Finalized Sink, Source definition. * Rename mqtt source and sink files * Rename mqtt publisher and subscriber. * Fix start function to async. * Update documentation. * Remove recursion from udp source. * rename unpack to unpacker, stay consistent. * Renaming in tests. * Make MqttSource generic. * Configure pyproject.toml to move to uv * Add nox support. * Update documentation with myst-parser and sphinx. * Mess with autogeneration of __call__ signatures. * Add dynamic versioning to hatch * Asyncio wrapper for pyserial. * Add docstrings for serial sink and source. * Refactor config handling (#171) * Removes deprecated "verbose" and "print_std" parameters * Adds class methods for config generation from dictionary or file (yaml or json at this point) * Run-time type checking via __post_init__() function * Add serial dependency. * WIP * Move broker to bin/ * Update docs. * WIP: Need to update docstrings to make ruff happy. * Move source files to src/ * Fix tests for TcpSource. * WIP: Remove old tests. * Fix docstrings in mqtt classes. * Make default tcp unpacker json_unpacker. * No failed tests if there are no tests * Update test pipeline * Update ruff pre-commit * Updated ruff formatting * Format bin/ * Fix type hints * No type checking * Make stop() async * Only test on ubuntu for now * Don't be so strict about sphinx warnings. * Rename TestConf for pytest naming compability. * Install package in editable mode for ci tests. * Update dependencies for docs generation. * Add keepalive and will to mqtt, fixes #112. * Update readme to reflect changes in usage. * Requested fixes for console adapters. * Raise correct errors in unpacker and packer. * Correct logger name for mqtt sink. * Add config options for stopbits and parity to Serial. * Remove exception logging call from yaml parser. * Add comments to clear up very implicit test. * Rename Sink -> Sender, Source -> Receiver. * Rename sink and source in tests. * Fix tests. --------- Co-authored-by: Adrian Weiler <a.weiler@aldea.de>
53 lines
1.6 KiB
Python
53 lines
1.6 KiB
Python
from __future__ import annotations
|
|
|
|
import argparse
|
|
from pathlib import Path
|
|
|
|
import nox
|
|
|
|
DIR = Path(__file__).parent.resolve()
|
|
|
|
nox.needs_version = ">=2024.3.2"
|
|
nox.options.sessions = ["lint", "tests", "check"]
|
|
nox.options.default_venv_backend = "uv|virtualenv"
|
|
|
|
|
|
@nox.session
|
|
def lint(session: nox.Session) -> None:
|
|
"""Run the linter."""
|
|
session.install("pre-commit")
|
|
session.run("pre-commit", "run", "--all-files", "--show-diff-on-failure", *session.posargs)
|
|
|
|
|
|
@nox.session
|
|
def tests(session: nox.Session) -> None:
|
|
"""Run the unit and regular tests."""
|
|
session.install(".[test]")
|
|
session.run("pytest", *session.posargs)
|
|
|
|
|
|
@nox.session(reuse_venv=True)
|
|
def docs(session: nox.Session) -> None:
|
|
"""Build the docs. Pass --non-interactive to avoid serving. First positional argument is the target directory."""
|
|
parser = argparse.ArgumentParser()
|
|
parser.add_argument("-b", dest="builder", default="html", help="Build target (default: html)")
|
|
parser.add_argument("output", nargs="?", help="Output directory")
|
|
args, posargs = parser.parse_known_args(session.posargs)
|
|
serve = args.builder == "html" and session.interactive
|
|
|
|
session.install("-e.[docs]", "sphinx-autobuild")
|
|
|
|
shared_args = (
|
|
"-n", # nitpicky mode
|
|
"-T", # full tracebacks
|
|
f"-b={args.builder}",
|
|
"docs",
|
|
args.output or f"docs/_build/{args.builder}",
|
|
*posargs,
|
|
)
|
|
|
|
if serve:
|
|
session.run("sphinx-autobuild", "--open-browser", *shared_args)
|
|
else:
|
|
session.run("sphinx-build", "--keep-going", *shared_args)
|