🐛 Expose port 5013 in every deployment mode

🐛 Minor typo fix

🐛 Minor typo fix

Author: Jasonxia007

backend/apps/northbound_app.py

@@ -5,6 +5,7 @@
 import uuid
 
 from fastapi import APIRouter, Body, Header, Request
+from fastapi.responses import JSONResponse
 
 from consts.exceptions import UnauthorizedError, LimitExceededError, SignatureValidationError
 from services.northbound_service import (
@@ -194,8 +195,6 @@ async def update_convs_title(
             title=title,
             idempotency_key=idempotency_key,
         )
-        from fastapi.responses import JSONResponse
-
         headers_out = {"Idempotency-Key": result.get("idempotency_key", ""), "X-Request-Id": ctx.request_id}
         return JSONResponse(content=result, headers=headers_out)
 

backend/database/partner_db.py

@@ -27,8 +27,8 @@ def add_mapping_id(
                 updated_by=user_id,
             ))
             session.commit()
-    except SQLAlchemyError:
-        return None
+    except Exception as e:
+        raise e
 
 
 def get_internal_id_by_external(
@@ -55,8 +55,8 @@ def get_internal_id_by_external(
 
             record = query.first()
             return int(record.internal_id) if record and record.internal_id is not None else None
-    except SQLAlchemyError:
-        return None
+    except Exception as e:
+        raise e
 
 
 def get_external_id_by_internal(
@@ -83,6 +83,6 @@ def get_external_id_by_internal(
 
             record = query.first()
             return str(record.external_id) if record and record.external_id is not None else None
-    except SQLAlchemyError:
-        return None
+    except Exception as e:
+        raise e
 

backend/services/northbound_service.py

@@ -115,14 +115,15 @@ def _build_idempotency_key(*parts: Any) -> str:
 
 
 # -----------------------------
-# ID mapping helpers (placeholders for DB-backed mapping)
+# ID mapping helpers
 # -----------------------------
 async def to_external_conversation_id(internal_id: int) -> str:
     if not internal_id:
         raise Exception("invalid internal conversation id")
     external_id = get_external_id_by_internal(internal_id=internal_id, mapping_type="CONVERSATION")
     if not external_id:
-        logger.warning(f"cannot find external id for conversation_id: {internal_id}")
+        logger.error(f"cannot find external id for conversation_id: {internal_id}")
+        raise Exception("cannot find external id")
     return external_id
 
 

backend/utils/auth_utils.py

@@ -6,9 +6,9 @@
 from datetime import datetime, timedelta
 from typing import Optional, Tuple
 
-from fastapi import Request, HTTPException
+from fastapi import Request
 from consts.const import DEFAULT_USER_ID, DEFAULT_TENANT_ID, IS_SPEED_MODE
-from consts.exceptions import SignatureValidationError, UnauthorizedError
+from consts.exceptions import LimitExceededError, SignatureValidationError, UnauthorizedError
 import jwt
 from supabase import create_client
 from database.user_tenant_db import get_user_tenant_by_user_id
@@ -193,8 +193,8 @@ def validate_aksk_authentication(headers: dict, request_body: str = "") -> bool:
             raise SignatureValidationError("Invalid signature")
 
         return True
-    except (UnauthorizedError, SignatureValidationError):
-        raise
+    except (UnauthorizedError, SignatureValidationError, LimitExceededError) as e:
+        raise e
     except Exception as e:
         logger.error(f"Unexpected error during AK/SK authentication: {e}")
         raise UnauthorizedError("Authentication failed")
@@ -287,7 +287,7 @@ def _extract_user_id_from_jwt_token(authorization: str) -> Optional[str]:
         return user_id
     except Exception as e:
         logging.error(f"Failed to extract user ID from token: {str(e)}")
-        raise HTTPException(status_code=401, detail="Invalid or expired authentication token")
+        raise UnauthorizedError("Invalid or expired authentication token")
 
 
 def get_current_user_id(authorization: Optional[str] = None) -> tuple[str, str]:
@@ -308,7 +308,7 @@ def get_current_user_id(authorization: Optional[str] = None) -> tuple[str, str]:
     try:
         user_id = _extract_user_id_from_jwt_token(authorization)
         if not user_id:
-            raise HTTPException(status_code=401, detail="Invalid or expired authentication token")
+            raise UnauthorizedError("Invalid or expired authentication token")
 
         user_tenant_record = get_user_tenant_by_user_id(user_id)
         if user_tenant_record and user_tenant_record.get('tenant_id'):
@@ -322,7 +322,7 @@ def get_current_user_id(authorization: Optional[str] = None) -> tuple[str, str]:
 
     except Exception as e:
         logging.error(f"Failed to get user ID and tanent ID: {str(e)}")
-        raise HTTPException(status_code=401, detail="Invalid or expired authentication token")
+        raise UnauthorizedError("Invalid or expired authentication token")
 
 
 def get_user_language(request: Request = None) -> str:

docker/docker-compose.dev.yml

@@ -7,6 +7,7 @@ services:
     restart: always
     ports:
       - "5010:5010"
+      - "5013:5013"
     volumes:
       - ../:/opt/
       - /opt/backend/.venv/

docker/docker-compose.prod.yml

@@ -93,6 +93,8 @@ services:
         max-file: "3"    # Maximum number of log files to keep
     networks:
       - nexent
+    ports:
+      - "5013:5013"  # Northbound service port
     entrypoint: ["/bin/bash", "-c", "python backend/nexent_mcp_service.py & python backend/northbound_service.py & python backend/main_service.py"]
 
   nexent-web:

docker/docker-compose.yml

@@ -80,6 +80,7 @@ services:
     restart: always
     ports:
       - "5010:5010"  # Backend service port
+      - "5013:5013"  # Northbound service port
     volumes:
       - ${NEXENT_USER_DIR:-$HOME/nexent}:/mnt/nexent
       - ${ROOT_DIR}/openssh-server/ssh-keys:/opt/ssh-keys:ro

test/backend/app/test_northbound_app.py

@@ -5,7 +5,8 @@
 from fastapi import FastAPI
 from fastapi.responses import StreamingResponse
 from fastapi.testclient import TestClient
-
+import types
+import sys as _sys
 
 # Dynamically determine the backend path
 current_dir = os.path.dirname(os.path.abspath(__file__))
@@ -16,11 +17,6 @@
 # Pre-mock heavy dependencies before importing router
 sys.modules['consts'] = MagicMock()
 sys.modules['consts.model'] = MagicMock()
-# Provide stub for consts.exceptions with expected exception classes
-# so that imports in application code succeed during tests.
-# We intentionally use real classes (not MagicMock) so that isinstance checks work if present.
-
-import types
 
 consts_exceptions_mod = types.ModuleType("consts.exceptions")
 
@@ -35,8 +31,7 @@ class SignatureValidationError(Exception):
 consts_exceptions_mod.UnauthorizedError = UnauthorizedError
 consts_exceptions_mod.SignatureValidationError = SignatureValidationError
 
-# Ensure the parent 'consts' is a module (could be MagicMock) and register submodule.
-import sys as _sys
+# Ensure the parent 'consts' is a module
 if 'consts' not in _sys.modules or not isinstance(_sys.modules['consts'], types.ModuleType):
     consts_root = types.ModuleType("consts")
     consts_root.__path__ = []

test/backend/database/test_partner_db.py

@@ -1,5 +1,6 @@
 import sys
 from unittest.mock import MagicMock
+import pytest
 
 # ---------------------------------------------------------------------------
 # Prepare stub modules and objects BEFORE importing the module under test.
@@ -118,13 +119,19 @@ def test_add_mapping_id_success(monkeypatch):
 
 def test_add_mapping_id_exception(monkeypatch):
     # get_db_session will raise _SQLAlchemyError to simulate DB failure.
-    def _boom():
-        raise _SQLAlchemyError("DB down")
+    # Simulate that entering the context raises SQLAlchemyError
+    class _CM:
+        def __enter__(self):
+            raise _SQLAlchemyError("DB down")
 
-    monkeypatch.setattr(partner_db, 'get_db_session', _boom)
+        def __exit__(self, exc_type, exc, tb):
+            return False
 
-    # Function should catch the error and simply return None without raising.
-    assert partner_db.add_mapping_id(1, 'e', 't', 'u') is None
+    monkeypatch.setattr(partner_db, 'get_db_session', lambda: _CM())
+
+    # Function should propagate the exception; verify it raises.
+    with pytest.raises(_SQLAlchemyError):
+        partner_db.add_mapping_id(1, 'e', 't', 'u')
 
 
 # ---------------------------------------------------------------------------
@@ -164,11 +171,17 @@ def test_get_internal_id_by_external_not_found(monkeypatch):
 
 
 def test_get_internal_id_by_external_exception(monkeypatch):
-    def _boom():
-        raise _SQLAlchemyError("fail")
+    # Prepare context manager that raises inside __enter__
+    class _CM:
+        def __enter__(self):
+            raise _SQLAlchemyError("fail")
+
+        def __exit__(self, exc_type, exc, tb):
+            return False
 
-    monkeypatch.setattr(partner_db, 'get_db_session', _boom)
-    assert partner_db.get_internal_id_by_external('any') is None
+    monkeypatch.setattr(partner_db, 'get_db_session', lambda: _CM())
+    with pytest.raises(_SQLAlchemyError):
+        partner_db.get_internal_id_by_external('any')
 
 
 # ---------------------------------------------------------------------------
@@ -206,5 +219,13 @@ def test_get_external_id_by_internal_not_found(monkeypatch):
 
 
 def test_get_external_id_by_internal_exception(monkeypatch):
-    monkeypatch.setattr(partner_db, 'get_db_session', lambda: (_ for _ in ()).throw(_SQLAlchemyError()))
-    assert partner_db.get_external_id_by_internal(1) is None
+    class _CM:
+        def __enter__(self):
+            raise _SQLAlchemyError()
+
+        def __exit__(self, exc_type, exc, tb):
+            return False
+
+    monkeypatch.setattr(partner_db, 'get_db_session', lambda: _CM())
+    with pytest.raises(_SQLAlchemyError):
+        partner_db.get_external_id_by_internal(1)

test/backend/services/test_northbound_service.py

@@ -158,8 +158,8 @@ async def test_to_external_and_internal_conversation_id_success():
 @pytest.mark.asyncio
 async def test_to_external_conversation_id_not_found():
     partner_db_mod.get_external_id_by_internal.return_value = None
-    result = await ns.to_external_conversation_id(123)
-    assert result is None
+    with pytest.raises(Exception):
+        await ns.to_external_conversation_id(123)
 
 
 @pytest.mark.asyncio