feat: add asynchronous setup for webserver and transporter, and update dependencies for RabbitMQ and Uvicorn

main.py

@@ -1,16 +1,33 @@
 #!/usr/bin/env python3
-
 import logging
 import os
 from pathlib import Path
 from typing import Dict
+import asyncio
 
+async def setup_webserver() -> None:
+    """Setup web server configuration."""
+    # Placeholder for web server setup logic
+    from src.modules.api import server
+    await server()
 
-def main() -> None:
+async def setup_transporter() -> None:
+    """Setup transporter configuration."""
+    # Placeholder for transporter setup logic
+    # import src.modules.
+    import src.modules.transporter
+    
+async def main() -> None:
     """Main application entry point."""
     try:
         print("Start app...")
-        import src.modules.api
+        # import src.modules.transporter
+        task1 = asyncio.create_task(setup_webserver())
+        task2 = asyncio.create_task(setup_transporter())
+        await asyncio.gather(task1, task2)
+        print("App started successfully.")
+      
+        
 
     except Exception as e:
         logging.error(f"Application failed to start: {e}", exc_info=True)
@@ -18,4 +35,4 @@ def main() -> None:
 
 
 if __name__ == "__main__":
-    main()
+    asyncio.run(main())

pyproject.toml

@@ -8,7 +8,10 @@ dependencies = [
     "fastapi[standard]>=0.115.8",
     "ipykernel>=6.29.5",
     "numpy>=2.2.3",
+    "pika>=1.3.2",
     "pytest>=8.3.4",
+    "rabbitmq>=0.2.0",
+    "uvicorn>=0.34.0",
 ]
 
 [tool.black]

shell.nix

@@ -0,0 +1,34 @@
+{ pkgs ? import <nixpkgs> {} }:
+
+let
+  # Common environment variables
+  envVars = {
+    NODE_ENV = "development";
+  };
+
+in pkgs.mkShell {
+  buildInputs = with pkgs; [
+    docker
+    docker-compose
+    nodejs_18
+    nodePackages.ts-node
+  ];
+
+  shellHook = ''
+    echo "Sync packages"
+    uv sync
+
+    # Activate venv
+    if [ -d ".venv" ]; then
+      source .venv/bin/activate
+    else
+      echo "Virtual environment not found, creating one..."
+    fi
+
+    alias dev='python3 main.py'
+    alias python='python3'
+    
+    which python3
+
+  '';
+}

uv.lock

@@ -1,4 +1,5 @@
 version = 1
+revision = 1
 requires-python = ">=3.11"
 
 [[package]]
@@ -101,7 +102,7 @@ name = "click"
 version = "8.1.8"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "colorama", marker = "platform_system == 'Windows'" },
+    { name = "colorama", marker = "sys_platform == 'win32'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/b9/2e/0090cbf739cee7d23781ad4b89a9894a41538e4fcf4c31dcdd705b78eb8b/click-8.1.8.tar.gz", hash = "sha256:ed53c9d8990d83c2a27deae68e4ee337473f6330c040a31d4225c9574d16096a", size = 226593 }
 wheels = [
@@ -322,7 +323,7 @@ name = "ipykernel"
 version = "6.29.5"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "appnope", marker = "platform_system == 'Darwin'" },
+    { name = "appnope", marker = "sys_platform == 'darwin'" },
     { name = "comm" },
     { name = "debugpy" },
     { name = "ipython" },
@@ -584,6 +585,15 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/9e/c3/059298687310d527a58bb01f3b1965787ee3b40dce76752eda8b44e9a2c5/pexpect-4.9.0-py2.py3-none-any.whl", hash = "sha256:7236d1e080e4936be2dc3e326cec0af72acf9212a7e1d060210e70a47e253523", size = 63772 },
 ]
 
+[[package]]
+name = "pika"
+version = "1.3.2"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/db/db/d4102f356af18f316c67f2cead8ece307f731dd63140e2c71f170ddacf9b/pika-1.3.2.tar.gz", hash = "sha256:b2a327ddddf8570b4965b3576ac77091b850262d34ce8c1d8cb4e4146aa4145f", size = 145029 }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/f9/f3/f412836ec714d36f0f4ab581b84c491e3f42c6b5b97a6c6ed1817f3c16d0/pika-1.3.2-py3-none-any.whl", hash = "sha256:0779a7c1fafd805672796085560d290213a465e4f6f76a6fb19e378d8041a14f", size = 155415 },
+]
+
 [[package]]
 name = "platformdirs"
 version = "4.3.6"
@@ -884,6 +894,17 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/17/fc/b79f0b72891cbb9917698add0fede71dfb64e83fa3481a02ed0e78c34be7/pyzmq-26.2.1-cp313-cp313t-musllinux_1_1_x86_64.whl", hash = "sha256:17f88622b848805d3f6427ce1ad5a2aa3cf61f12a97e684dab2979802024d460", size = 1399943 },
 ]
 
+[[package]]
+name = "rabbitmq"
+version = "0.2.0"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "cffi" },
+]
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/bc/1d/6b4397309786eaba2dee82285773c383d41ab4b3ffdb933d9af48de52025/rabbitmq-0.2.0-py2.py3-none-any.whl", hash = "sha256:74cfbc0f365019a8f318cd1ad9b1f85682768568fa3816740df37509a6dfbc2d", size = 7865 },
+]
+
 [[package]]
 name = "rich"
 version = "13.9.4"
@@ -972,7 +993,10 @@ dependencies = [
     { name = "fastapi", extra = ["standard"] },
     { name = "ipykernel" },
     { name = "numpy" },
+    { name = "pika" },
     { name = "pytest" },
+    { name = "rabbitmq" },
+    { name = "uvicorn" },
 ]
 
 [package.metadata]
@@ -980,7 +1004,10 @@ requires-dist = [
     { name = "fastapi", extras = ["standard"], specifier = ">=0.115.8" },
     { name = "ipykernel", specifier = ">=6.29.5" },
     { name = "numpy", specifier = ">=2.2.3" },
+    { name = "pika", specifier = ">=1.3.2" },
     { name = "pytest", specifier = ">=8.3.4" },
+    { name = "rabbitmq", specifier = ">=0.2.0" },
+    { name = "uvicorn", specifier = ">=0.34.0" },
 ]
 
 [[package]]