Merge branch 'develop' into plasorak/controller-configuration-segment…

…-lookup

.github/workflows/lint.yml

@@ -0,0 +1,11 @@
+name: Lint with ruff
+
+on:
+  pull_request:
+
+jobs:
+  ruff:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: astral-sh/ruff-action@v1

.ruff.toml

@@ -0,0 +1,5 @@
+exclude = ["tests/*"]
+
+[lint]
+ignore = ["ALL"]
+select = ["F821"]

src/drunc/broadcast/server/grpc_servicer.py

@@ -4,9 +4,11 @@
 from druncschema.broadcast_pb2_grpc import BroadcastSenderServicer
 from druncschema.broadcast_pb2 import BroadcastRequest
 from druncschema.request_response_pb2 import Request, Response
-from druncschema.generic_pb2 import PlainText
+from druncschema.generic_pb2 import PlainText, StringStringMap
 from druncschema.broadcast_pb2 import BroadcastMessage, BroadcastType
 from druncschema.authoriser_pb2 import ActionType
+from drunc.utils.grpc_utils import unpack_any
+from google.protobuf.any_pb2 import Any
 
 class ListenerRepresentation:
 
@@ -242,7 +244,7 @@ def serve(port:int) -> None:
         try:
             server_thread = Thread(target=serve, kwargs={'port':port}, name=f'serve_thread_{port}')
             server_thread.start()
-            receiver_threads.append(serve_thread)
+            receiver_threads.append(server_thread)
         except:
             pass
 

src/drunc/controller/children_interface/rest_api_child.py

@@ -1,4 +1,5 @@
 from drunc.controller.children_interface.child_node import ChildNode
+from drunc.exceptions import DruncSetupException
 from drunc.utils.utils import ControlType
 from druncschema.request_response_pb2 import Response
 from druncschema.token_pb2 import Token

src/drunc/fsm/actions/thread_pinning.py

@@ -1,6 +1,7 @@
 from drunc.fsm.core import FSMAction
 from drunc.utils.configuration import find_configuration
 from drunc.fsm.exceptions import ThreadPinningFailed
+from drunc.exceptions import DruncSetupException
 
 
 class ThreadPinning(FSMAction):

src/drunc/process_manager/configuration.py

@@ -1,4 +1,5 @@
 from drunc.utils.configuration import ConfHandler
+from rich import print as rprint
 
 from enum import Enum
 

src/drunc/utils/flask_manager.py

@@ -198,7 +198,7 @@ def run(self) -> NoReturn:
 
 def main():
     from drunc.utils.utils import get_new_port
-    from flask import Flask, make_response, jsonify
+    from flask import Flask, make_response, jsonify, request
     from flask_restful import Api, Resource
 
     class DummyEndpoint(Resource):

src/drunc/utils/grpc_utils.py

@@ -1,5 +1,6 @@
 from drunc.exceptions import DruncCommandException,DruncException
-from druncschema.request_response_pb2 import Response
+from druncschema.request_response_pb2 import Response, ResponseFlag
+from druncschema.generic_pb2 import PlainText
 
 class UnpackingError(DruncCommandException):
     def __init__(self, data, format):