feat(admin): add organization update API and schemas

ddpui/api/admin_portal/organizations_api.py

@@ -0,0 +1,85 @@
+from ninja import Router
+from ninja.errors import HttpError
+
+from ddpui.auth import has_permission
+from ddpui.models.org import Org
+from ddpui.schemas.admin_org_schema import UpdateOrganizationSchema
+
+admin_org_router = Router()
+
+
+@admin_org_router.get("/v1/organizations")
+@admin_org_router.get("/v1/organizations/")
+@has_permission(["can_manage_organization"])
+def get_admin_organizations(request, name: str | None = None):
+    """List organizations with optional filtering."""
+    queryset = Org.objects.all()
+
+    if name:
+        queryset = queryset.filter(name__icontains=name)
+
+    orgs = list(queryset.values("id", "name", "slug"))
+
+    return {
+        "success": True,
+        "count": len(orgs),
+        "data": orgs,
+    }
+
+
+@admin_org_router.get("/v1/organizations/{org_id}")
+@admin_org_router.get("/v1/organizations/{org_id}/")
+@has_permission(["can_manage_organization"])
+def get_single_org(request, org_id: int):
+    """Get single organization by ID."""
+    org = (
+        Org.objects.filter(id=org_id)
+        .values("id", "name", "slug")
+        .first()
+    )
+
+    if not org:
+        raise HttpError(404, "Organization not found")
+
+    return {
+        "success": True,
+        "data": org,
+    }
+
+
+@admin_org_router.put("/v1/organizations/{org_id}")
+@admin_org_router.put("/v1/organizations/{org_id}/")
+@has_permission(["can_manage_organization"])
+def update_organization(
+    request,
+    org_id: int,
+    payload: UpdateOrganizationSchema,
+):
+    """Update organization details."""
+    org = Org.objects.filter(id=org_id).first()
+
+    if not org:
+        raise HttpError(404, "Organization not found")
+
+    existing_slug = (
+        Org.objects.filter(slug=payload.slug)
+        .exclude(id=org_id)
+        .exists()
+    )
+
+    if existing_slug:
+        raise HttpError(400, "Slug already exists")
+
+    org.name = payload.name
+    org.slug = payload.slug
+    org.save()
+
+    return {
+        "success": True,
+        "message": "Organization updated successfully",
+        "data": {
+            "id": org.id,
+            "name": org.name,
+            "slug": org.slug,
+        },
+    }

ddpui/models/airbyte.py

@@ -12,7 +12,10 @@ class SyncStats(models.Model):
     job_id = models.IntegerField(null=True)
     attempt = models.IntegerField(default=0)
     status = models.TextField()
-    sync_type = models.CharField(choices=[("manual", "manual"), ("orchestrate", "orchestrate")])
+    sync_type = models.CharField(
+        max_length=20,
+        choices=[("manual", "manual"), ("orchestrate", "orchestrate")],
+    )
     sync_time = models.DateTimeField()
     sync_duration_s = models.BigIntegerField(default=0)
     sync_records = models.BigIntegerField(default=0)

ddpui/routes.py

@@ -24,14 +24,14 @@
 from ddpui.api.filter_api import filter_router
 from ddpui.api.public_api import public_router
 from ddpui.api.report_api import report_router
+from ddpui.api.admin_portal.organizations_api import admin_org_router
 
 
 src_api = NinjaAPI(
     urls_namespace="api",
     title="Dalgo backend apis",
     description="Open source ELT orchestrator",
     docs_url="/api/docs",
-    # auth=auth.CustomAuthMiddleware(),
     auth=auth.CustomJwtAuthMiddleware(),
 )
 
@@ -87,6 +87,8 @@ def ninja_default_error_handler(
 filter_router.tags = ["Filters"]
 public_router.tags = ["Public"]
 report_router.tags = ["Reports"]
+admin_org_router.tags = ["Admin Organizations"]
+
 
 # mount all the module routes
 src_api.add_router("/api/airbyte/", airbyte_router)
@@ -108,6 +110,8 @@ def ninja_default_error_handler(
 src_api.add_router("/api/dashboards/", dashboard_native_router)
 src_api.add_router("/api/filters/", filter_router)
 src_api.add_router("/api/reports/", report_router)
+src_api.add_router("/api/admin/", admin_org_router)
+
 
 # Public API without authentication
 public_api = NinjaAPI(
@@ -116,4 +120,5 @@ def ninja_default_error_handler(
     description="Public endpoints for shared dashboards - no authentication required",
     docs_url="/api/v1/public/docs",
 )
-public_api.add_router("/api/v1/public/", public_router)
+
+public_api.add_router("/api/v1/public/", public_router)

ddpui/schemas/admin_org_schema.py

@@ -0,0 +1,8 @@
+from ninja import Schema
+
+
+class UpdateOrganizationSchema(Schema):
+    """Schema for updating organization details."""
+
+    name: str
+    slug: str