chore: licenses and pre-commit

Author: rachwalk

src/rai_core/rai/communication/http/api.py

@@ -13,11 +13,10 @@
 # limitations under the License.
 
 import asyncio
+import logging
 import threading
 from enum import IntFlag
-from typing import Callable, Optional, Any
-import json
-import logging
+from typing import Callable, Optional
 
 import aiohttp
 from aiohttp import ClientSession, ClientTimeout, web
@@ -153,4 +152,3 @@ def shutdown(self):
             except Exception as e:
                 logging.warning(f"Background request failed or timed out: {e}")
         self.unresolved_futures.clear()
-

src/rai_core/rai/communication/http/connectors/base.py

@@ -12,8 +12,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import time
-from functools import partial
 from typing import Any, Callable, Dict, Optional, TypeVar
 
 from aiohttp import web
@@ -76,7 +74,9 @@ def service_call(
             payload=message.payload,
             headers=message.metadata.get("headers"),
         )
-        return self.T_class(payload=ret, method=message.method, metadata={"return_code": code})  # type: ignore[call-arg]
+        return self.T_class(
+            payload=ret, method=message.method, metadata={"return_code": code}
+        )  # type: ignore[call-arg]
 
     def create_service(
         self,

src/rai_core/rai/communication/http/connectors/hri_connector.py

@@ -12,7 +12,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-from typing import Any, Callable, Optional
 
 from rai.communication import HRIConnector
 from rai.communication.http.api import HTTPConnectorMode
@@ -66,12 +65,10 @@ def payload_to_message(data: dict) -> HTTPHRIMessage:
         return HTTPHRIMessage(
             text=data.get("text", ""),
             images=[
-                HTTPHRIMessage._base64_to_image(img)
-                for img in data.get("images", [])
+                HTTPHRIMessage._base64_to_image(img) for img in data.get("images", [])
             ],
             audios=[
-                HTTPHRIMessage._base64_to_audio(aud)
-                for aud in data.get("audios", [])
+                HTTPHRIMessage._base64_to_audio(aud) for aud in data.get("audios", [])
             ],
             message_author=data.get("message_author", "human"),
             communication_id=data.get("communication_id"),

src/rai_core/rai/communication/http/messages.py

@@ -12,7 +12,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-from typing import Optional, Literal
+from typing import Literal, Optional
+
 from rai.communication.base_connector import BaseMessage
 from rai.communication.hri_connector import HRIMessage
 

tests/communication/__init__.py

@@ -0,0 +1,13 @@
+# Copyright (C) 2026 Kajetan Rachwał
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.

tests/communication/http/__init__.py

@@ -0,0 +1,13 @@
+# Copyright (C) 2026 Kajetan Rachwał
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.

tests/communication/http/test_api.py

@@ -1,15 +1,28 @@
+# Copyright (C) 2026 Kajetan Rachwał
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
 import asyncio
-import threading
 import time
-import pytest
 from unittest.mock import AsyncMock, MagicMock, patch
-from aiohttp import web
 
+import pytest
+from aiohttp import web
 from rai.communication.http.api import HTTPAPI, HTTPAPIError, HTTPConnectorMode
 
-
 # ── Fixtures ──────────────────────────────────────────────────────────────────
 
+
 @pytest.fixture
 def client_api():
     api = HTTPAPI(mode=HTTPConnectorMode.client)
@@ -36,6 +49,7 @@ def client_server_api():
 
 # ── HTTPConnectorMode ─────────────────────────────────────────────────────────
 
+
 class TestHTTPConnectorMode:
     def test_client_value(self):
         assert HTTPConnectorMode.client == 1
@@ -58,11 +72,15 @@ def test_server_flag_in_client_server(self):
         assert HTTPConnectorMode.server & HTTPConnectorMode.client_server
 
     def test_client_flag_not_in_server_only(self):
-        assert not (HTTPConnectorMode.client & HTTPConnectorMode.server == HTTPConnectorMode.client_server)
+        assert not (
+            HTTPConnectorMode.client & HTTPConnectorMode.server
+            == HTTPConnectorMode.client_server
+        )
 
 
 # ── Initialisation ────────────────────────────────────────────────────────────
 
+
 class TestHTTPAPIInit:
     def test_default_attributes(self):
         api = HTTPAPI()
@@ -91,6 +109,7 @@ def test_started_event_initially_unset(self):
 
 # ── run() / stop() lifecycle ──────────────────────────────────────────────────
 
+
 class TestLifecycle:
     def test_run_sets_started_event(self, client_api):
         assert client_api._started_event.is_set()
@@ -118,6 +137,7 @@ def test_double_stop_does_not_raise(self, client_api):
 
 # ── add_route() ───────────────────────────────────────────────────────────────
 
+
 class TestAddRoute:
     def test_add_route_ignored_in_client_only_mode(self, client_api):
         client_api.add_route("GET", "/ignored", AsyncMock())
@@ -163,21 +183,20 @@ async def handler(request):
 
 # ── send_request() ────────────────────────────────────────────────────────────
 
+
 class TestSendRequest:
     def test_raises_in_server_only_mode(self, server_api):
         with pytest.raises(HTTPAPIError, match="client mode disabled"):
             server_api.send_request(
-                "GET", "http://example.com", timeout=1.0,
-                payload=None, headers=None
+                "GET", "http://example.com", timeout=1.0, payload=None, headers=None
             )
 
     def test_returns_empty_string_and_200_when_no_timeout(self, client_api):
         """Fire-and-forget path (timeout=None) returns immediately."""
         with patch.object(client_api, "_request", new_callable=AsyncMock) as mock_req:
             mock_req.return_value = ("", 200)
             body, status = client_api.send_request(
-                "GET", "http://example.com", timeout=None,
-                payload=None, headers=None
+                "GET", "http://example.com", timeout=None, payload=None, headers=None
             )
         assert body == ""
         assert status == 200
@@ -244,8 +263,7 @@ def test_future_added_to_unresolved(self, client_api):
             mock_req.return_value = ("", 200)
             before = len(client_api.unresolved_futures)
             client_api.send_request(
-                "GET", "http://example.com", timeout=None,
-                payload=None, headers=None
+                "GET", "http://example.com", timeout=None, payload=None, headers=None
             )
             time.sleep(0.05)
             # future is appended even for fire-and-forget
@@ -264,6 +282,7 @@ def test_404_response(self, client_server_api):
 
 # ── shutdown() ────────────────────────────────────────────────────────────────
 
+
 class TestShutdown:
     def test_shutdown_clears_unresolved_futures(self, client_api):
         mock_future = MagicMock()
@@ -299,6 +318,7 @@ def test_shutdown_with_no_futures_is_noop(self, client_api):
 
 # ── _request() (internal async helper) ───────────────────────────────────────
 
+
 class TestInternalRequest:
     def test_request_returns_text_and_status(self, client_server_api):
         async def handler(request):

tests/communication/http/test_connectors.py

@@ -1,21 +1,31 @@
+# Copyright (C) 2026 Kajetan Rachwał
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
 import base64
-import threading
 import time
 from io import BytesIO
-from typing import Any
-from unittest.mock import MagicMock, patch
 
 import pytest
 from aiohttp import web
 from PIL import Image
-
 from rai.communication.http.api import HTTPConnectorMode
 from rai.communication.http.connectors import HTTPConnector, HTTPHRIConnector
 from rai.communication.http.messages import HTTPHRIMessage, HTTPMessage
 
-
 # ── Helpers ───────────────────────────────────────────────────────────────────
 
+
 def _make_image() -> Image.Image:
     img = Image.new("RGB", (4, 4), color=(255, 0, 0))
     return img
@@ -29,6 +39,7 @@ def _image_b64(img: Image.Image) -> str:
 
 # ── Fixtures ──────────────────────────────────────────────────────────────────
 
+
 @pytest.fixture
 def client_connector():
     c = HTTPConnector(host="localhost", port=19080, mode=HTTPConnectorMode.client)
@@ -46,7 +57,9 @@ def server_connector():
 @pytest.fixture
 def cs_connector():
     """Client-server connector, useful for end-to-end tests."""
-    c = HTTPConnector(host="localhost", port=19082, mode=HTTPConnectorMode.client_server)
+    c = HTTPConnector(
+        host="localhost", port=19082, mode=HTTPConnectorMode.client_server
+    )
     yield c
     c.shutdown()
 
@@ -60,13 +73,16 @@ def hri_client_connector():
 
 @pytest.fixture
 def hri_cs_connector():
-    c = HTTPHRIConnector(host="localhost", port=19084, mode=HTTPConnectorMode.client_server)
+    c = HTTPHRIConnector(
+        host="localhost", port=19084, mode=HTTPConnectorMode.client_server
+    )
     yield c
     c.shutdown()
 
 
 # ── HTTPConnector – initialisation ────────────────────────────────────────────
 
+
 class TestHTTPConnectorInit:
     def test_api_started(self, client_connector):
         assert client_connector.api._started_event.is_set()
@@ -80,6 +96,7 @@ def test_thread_alive(self, client_connector):
 
 # ── HTTPConnector – service_call (request-response) ───────────────────────────
 
+
 class TestHTTPConnectorServiceCall:
     def test_service_call_returns_http_message(self, cs_connector):
         async def handler(request):
@@ -89,7 +106,9 @@ async def handler(request):
         time.sleep(0.1)
 
         msg = HTTPMessage(method="GET", payload=None)
-        response = cs_connector.service_call(msg, "http://localhost:19082/ping", timeout_sec=5.0)
+        response = cs_connector.service_call(
+            msg, "http://localhost:19082/ping", timeout_sec=5.0
+        )
 
         assert isinstance(response, HTTPMessage)
         assert response.payload == "pong"
@@ -119,12 +138,15 @@ async def handler(request):
         time.sleep(0.1)
 
         msg = HTTPMessage(method="PUT", payload=None)
-        response = cs_connector.service_call(msg, "http://localhost:19082/put", timeout_sec=5.0)
+        response = cs_connector.service_call(
+            msg, "http://localhost:19082/put", timeout_sec=5.0
+        )
         assert response.method == "PUT"
 
 
 # ── HTTPConnector – create_service ────────────────────────────────────────────
 
+
 class TestHTTPConnectorCreateService:
     def test_create_service_returns_path(self, cs_connector):
         handle = cs_connector.create_service("/svc", lambda data: None)
@@ -183,6 +205,7 @@ def test_create_service_none_result_returns_200(self, cs_connector):
 
 # ── HTTPConnector – shutdown ───────────────────────────────────────────────────
 
+
 class TestHTTPConnectorShutdown:
     def test_shutdown_stops_event_loop(self):
         c = HTTPConnector(host="localhost", port=19090, mode=HTTPConnectorMode.client)
@@ -193,6 +216,7 @@ def test_shutdown_stops_event_loop(self):
 
 # ── HTTPHRIConnector – build_message (HRIConnector mixin) ────────────────────
 
+
 class TestHTTPHRIConnectorBuildMessage:
     def test_build_message_from_human_message(self, hri_client_connector):
         from langchain_core.messages import HumanMessage