Reviewed-on: #2

@@ -0,0 +1,117 @@
+# Ninja-TANSS Comparison Project Rules

@@ -0,0 +11,4 @@
+# TANSS Login Configuration (for cookie-based authentication)
+TANSS_LOGIN_USERNAME=your_username_here
+TANSS_LOGIN_PASSWORD=your_password_here
+

@@ -0,0 +1,9 @@
+# Secrets

@@ -0,0 +6,4 @@
+    environment:
+      POSTGRES_USER: admin
+      POSTGRES_PASSWORD: secret
+      POSTGRES_DB: syncninja

@@ -0,0 +1,92 @@
+"""CLI and API entry point for the Ninja-TANSS comparison tool."""
+

@@ -0,0 +1,30 @@
+[project]
+name = "ninja-tanss-comparison"

@@ -0,0 +12,4 @@
+from fastapi.responses import HTMLResponse, JSONResponse
+from pydantic import BaseModel, Field
+
+from src.db.postgresql import HiddenDevice, create_tables, get_session

@@ -0,0 +77,4 @@
+            _pipeline_state.running = False
+
+
+@router.post("/api/run-pipeline")

@@ -0,0 +94,4 @@
+    return JSONResponse(status_code=200, content={"status": "started"})
+
+
+@router.websocket("/api/pipeline-ws")

@@ -0,0 +114,4 @@
+        pass
+
+
+class EntityEntry(BaseModel):

@@ -0,0 +125,4 @@
+    tanss_contract: TanssContract | None = None
+
+
+class InvalidStateEntry(BaseModel):

@@ -0,0 +133,4 @@
+    entities: list[EntityEntry] = Field(..., description="List of related entities")
+
+
+class InvalidStatesResponse(BaseModel):

@@ -0,0 +150,4 @@
+    )
+
+
+@router.get(

@@ -0,0 +165,4 @@
+    return store.invalid_states
+
+
+class SystemMetadata(BaseModel):

@@ -0,0 +61,4 @@
+    return []
+
+
+def saveCache(filename: str, data: list) -> None:

@@ -0,0 +31,4 @@
+    Base.metadata.create_all(bind=engine)
+
+
+def get_session():

@@ -0,0 +5,4 @@
+from .logger import logger
+
+
+def printFetching(message: str) -> None:

@@ -0,0 +14,4 @@
+    logger.info(message)
+
+
+def getNested(data: dict, dot_path: str, default=None):

@@ -0,0 +4,4 @@
+import sys
+
+logging.basicConfig(
+    level=logging.INFO,

@@ -0,0 +9,4 @@
+    handlers=[logging.StreamHandler(sys.stdout)],
+)
+
+logger = logging.getLogger("ninja-tanss")

@@ -0,0 +28,4 @@
+            Priority.CRITICAL: logging.ERROR,
+            Priority.HIGH: logging.WARNING,
+            Priority.MEDIUM: logging.INFO,
+            Priority.LOW: logging.DEBUG,

@@ -0,0 +22,4 @@
+from ..logger import logger
+from .oauth2 import oauth
+
+# Hardcoded endpoints

@@ -0,0 +137,4 @@
+
+    url = f"{NINJA_API_BASE_URL}{NINJA_CUSTOM_FIELDS_ENDPOINT.format(id=device_id)}"
+
+    for attempt in range(max_retries):

@@ -0,0 +212,4 @@
+            device.tanssId = fields[0]
+            device.teamviewerId = fields[1]
+
+    saveCache("ninja_devices.json", [d.__dict__ for d in result])

@@ -0,0 +32,4 @@
+        return match.group(1) if match else None
+
+
+class OrganizationSchema(Schema):

@@ -0,0 +13,4 @@
+#
+
+# Hardcoded endpoint
+NINJA_API_BASE_URL = "https://datajob.rmmservice.eu"

@@ -0,0 +47,4 @@
+
+        tanss_display_id = ninja_org.get_tanss_display_id()
+        if tanss_display_id is None:
+            if ninja_org.name == "Meißner EDV - Kunden":

@@ -0,0 +50,4 @@
+            if ninja_org.name == "Meißner EDV - Kunden":
+                # => that's ok
+                continue
+            elif ninja_org.name == "Neue Geräte":

@@ -0,0 +17,4 @@
+logger = logging.getLogger(__name__)
+
+
+def phase2(

@@ -0,0 +142,4 @@
+                                    days_since_contact = (datetime.now().date() - last_contact_date).days
+
+                                    if days_since_contact > 90:  # 3 months
+                                        logger.debug(

@@ -0,0 +166,4 @@
+                )
+                continue
+            else:
+                if tanss_device.is_peripherie:

@@ -0,0 +42,4 @@
+            pass
+        elif tanss_device.teamviewerId != "" and ninja_device.teamviewerId is not None:
+            if tanss_device.teamviewerId != ninja_device.teamviewerId:
+                logger.debug(f"TeamviewerId mismatch for {tanss_device=} and {ninja_device=}")

@@ -0,0 +14,4 @@
+from .devices import getTanssDevices
+
+USERNAME = "user"
+PASSWORD = "HIwURXsB02OECXkk37W5"

@@ -0,0 +55,4 @@
+def getTanssCompany(company_id: str) -> TanssCompany:
+    """Fetch a single TANSS company by company_id."""
+    response = get(
+        f"https://nodered.dev.datajob.de/tanss-wrapper/v1/companies/{company_id}",

@@ -0,0 +159,4 @@
+    next_batch: list[int] = list(tanss_company_ids)
+
+    # Fetch companies and their linked companies in batches using threads
+    with tqdm(unit="company") as pbar:

@@ -0,0 +98,4 @@
+        A list of TanssContract objects containing id, from_date, to_date, and contract_name.
+    """
+    response = get(
+        f"https://ticket.datajob.de/ajax/srv/gv_v4.php?t=showWvTasksInfo&type=1&id={device_id}",

@@ -0,0 +157,4 @@
+    devices = [d for d in getTanssDevices() if not d.is_peripherie]
+    all_contracts: list[TanssContract] = []
+
+    printFetching(f"Fetching TANSS contracts: {len(devices)} items with {MAX_WORKERS} workers")

@@ -0,0 +204,4 @@
+    Returns:
+        The matching Contract enum value, or UNKNOWN if no match.
+    """
+    if (

@@ -0,0 +10,4 @@
+from ..helper import printFetching
+
+# Hardcoded base URL
+TANSS_API_BASE_URL = "https://nodered.dev.datajob.de"

@@ -0,0 +1,651 @@
+<!DOCTYPE html>