deploy with help + added instruction

Author: HardMax71

.gitignore

@@ -90,3 +90,7 @@ yarn-error.log*
 
 # Build outputs
 frontend/public/build/
+
+# Helm
+helm/*/charts/*.tgz
+helm/*/Chart.lock

backend/Dockerfile.base

@@ -12,8 +12,8 @@ RUN apt-get update && apt-get install -y \
     liblzma-dev \
     && rm -rf /var/lib/apt/lists/*
 
-# Install uv
-COPY --from=ghcr.io/astral-sh/uv:0.9.17 /uv /uvx /bin/
+# Install uv (using Docker Hub mirror - ghcr.io has rate limiting issues)
+COPY --from=astral/uv:latest /uv /uvx /bin/
 
 # Copy dependency files
 COPY pyproject.toml uv.lock ./

backend/app/services/coordinator/coordinator.py

@@ -124,9 +124,10 @@ async def start(self) -> None:
 
         await self.idempotency_manager.initialize()
 
+        settings = get_settings()
         consumer_config = ConsumerConfig(
             bootstrap_servers=self.kafka_servers,
-            group_id= f"{self.consumer_group}.{settings.KAFKA_GROUP_SUFFIX}",
+            group_id=f"{self.consumer_group}.{settings.KAFKA_GROUP_SUFFIX}",
             enable_auto_commit=False,
             session_timeout_ms=30000,  # 30 seconds
             heartbeat_interval_ms=10000,  # 10 seconds (must be < session_timeout / 3)

backend/scripts/create_admin_user.py

@@ -35,13 +35,15 @@ async def create_topics() -> None:
         # Get all required topics and their configs
         all_topics = get_all_topics()
         topic_configs = get_topic_configs()
-        logger.info(f"Total required topics: {len(all_topics)}")
+        topic_prefix = settings.KAFKA_TOPIC_PREFIX
+        logger.info(f"Total required topics: {len(all_topics)} (prefix: '{topic_prefix}')")
 
         # Create topics
         topics_to_create: List[NewTopic] = []
 
         for topic in all_topics:
-            topic_name = topic.value
+            # Apply topic prefix for consistency with consumers/producers
+            topic_name = f"{topic_prefix}{topic.value}"
             if topic_name not in existing_topics:
                 # Get config from topic_configs
                 config = topic_configs.get(topic, {

backend/scripts/create_topics.py

@@ -0,0 +1,96 @@
+#!/usr/bin/env python3
+"""
+Seed default users in MongoDB (idempotent - safe to run multiple times).
+
+Creates:
+  1. Default user (role=user) for testing/demo
+  2. Admin user (role=admin, is_superuser=True) for administration
+
+Environment Variables:
+  MONGODB_URL: Connection string (default: mongodb://mongo:27017/integr8scode)
+  DEFAULT_USER_PASSWORD: Default user password (default: user123)
+  ADMIN_USER_PASSWORD: Admin user password (default: admin123)
+"""
+
+import asyncio
+import os
+from datetime import datetime, timezone
+
+from bson import ObjectId
+from motor.motor_asyncio import AsyncIOMotorClient
+from passlib.context import CryptContext
+
+pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
+
+
+async def upsert_user(db, username: str, email: str, password: str, role: str, is_superuser: bool) -> None:
+    """Create user or update if exists."""
+    existing = await db.users.find_one({"username": username})
+
+    if existing:
+        print(f"User '{username}' exists - updating role={role}, is_superuser={is_superuser}")
+        await db.users.update_one(
+            {"username": username},
+            {"$set": {
+                "role": role,
+                "is_superuser": is_superuser,
+                "is_active": True,
+                "updated_at": datetime.now(timezone.utc)
+            }}
+        )
+    else:
+        print(f"Creating user '{username}' (role={role}, is_superuser={is_superuser})")
+        await db.users.insert_one({
+            "_id": ObjectId(),
+            "user_id": str(ObjectId()),
+            "username": username,
+            "email": email,
+            "hashed_password": pwd_context.hash(password),
+            "role": role,
+            "is_active": True,
+            "is_superuser": is_superuser,
+            "created_at": datetime.now(timezone.utc),
+            "updated_at": datetime.now(timezone.utc)
+        })
+
+
+async def seed_users() -> None:
+    mongodb_url = os.getenv("MONGODB_URL", "mongodb://mongo:27017/integr8scode")
+    print(f"Connecting to MongoDB...")
+
+    client: AsyncIOMotorClient = AsyncIOMotorClient(mongodb_url)
+    db_name = mongodb_url.rstrip("/").split("/")[-1].split("?")[0] or "integr8scode"
+    db = client[db_name]
+
+    # Default user
+    await upsert_user(
+        db,
+        username="user",
+        email="[email protected]",
+        password=os.getenv("DEFAULT_USER_PASSWORD", "user123"),
+        role="user",
+        is_superuser=False
+    )
+
+    # Admin user
+    await upsert_user(
+        db,
+        username="admin",
+        email="[email protected]",
+        password=os.getenv("ADMIN_USER_PASSWORD", "admin123"),
+        role="admin",
+        is_superuser=True
+    )
+
+    print("\n" + "=" * 50)
+    print("SEEDED USERS:")
+    print("=" * 50)
+    print("Default: user / user123  (or DEFAULT_USER_PASSWORD)")
+    print("Admin:   admin / admin123 (or ADMIN_USER_PASSWORD)")
+    print("=" * 50)
+
+    client.close()
+
+
+if __name__ == "__main__":
+    asyncio.run(seed_users())