Zipstack
diff --git a/‎.gitignore‎
Lines changed: 0 additions & 23 deletions b/‎.gitignore‎
Lines changed: 0 additions & 23 deletions
diff --git a/‎backend/account_v2/subscription_loader.py‎
Lines changed: 0 additions & 129 deletions b/‎backend/account_v2/subscription_loader.py‎
Lines changed: 0 additions & 129 deletions
diff --git a/‎backend/adapter_processor_v2/views.py‎
Lines changed: 33 additions & 30 deletions b/‎backend/adapter_processor_v2/views.py‎
Lines changed: 33 additions & 30 deletions
diff --git a/‎backend/api_v2/api_deployment_dto_registry.py‎
Lines changed: 11 additions & 5 deletions b/‎backend/api_v2/api_deployment_dto_registry.py‎
Lines changed: 11 additions & 5 deletions
diff --git a/‎backend/api_v2/api_deployment_views.py‎
Lines changed: 10 additions & 10 deletions b/‎backend/api_v2/api_deployment_views.py‎
Lines changed: 10 additions & 10 deletions
diff --git a/‎backend/backend/settings/base.py‎
Lines changed: 1 addition & 1 deletion b/‎backend/backend/settings/base.py‎
Lines changed: 1 addition & 1 deletion
@@ -620,29 +620,6 @@ $RECYCLE.BIN/
 
 ### Unstract ###
 
-# Authentication Plugins
-backend/plugins/authentication/*
-!backend/plugins/authentication/auth_sample
-
-# Processor Plugins
-backend/plugins/processor/*
-
-# Subscription Plugins
-backend/plugins/subscription/*
-
-
-# API Deployment Plugins
-backend/plugins/api/**
-
-# Notification Plugin
-backend/plugins/notification/**
-
-# Configuration Plugin
-backend/plugins/configuration/**
-
-# Verticals Usage Plugin
-backend/plugins/verticals_usage/**
-
 # BE pluggable-apps
 backend/pluggable_apps/*
 
 
@@ -342,37 +342,40 @@ def partial_update(
         # Send email notifications to newly shared users
         if response.status_code == 200 and AdapterKeys.SHARED_USERS in request.data:
             try:
-                from plugins.notification.constants import ResourceType
-                from plugins.notification.sharing_notification import (
-                    SharingNotificationService,
-                )
-
-                adapter.refresh_from_db()
-                new_shared_users = set(adapter.shared_users.all())
-                newly_shared_users = new_shared_users - current_shared_users
-
-                if newly_shared_users:
-                    # Map adapter type to specific resource type
-                    adapter_type_to_resource = {
-                        "LLM": ResourceType.LLM.value,
-                        "EMBEDDING": ResourceType.EMBEDDING.value,
-                        "VECTOR_DB": ResourceType.VECTOR_DB.value,
-                        "X2TEXT": ResourceType.X2TEXT.value,
-                    }
-
-                    resource_type = adapter_type_to_resource.get(
-                        adapter.adapter_type, ResourceType.LLM.value
-                    )
+                from plugins import get_plugin
+
+                notification_plugin = get_plugin("notification")
+                if notification_plugin:
+                    from plugins.notification.constants import ResourceType
+
+                    adapter.refresh_from_db()
+                    new_shared_users = set(adapter.shared_users.all())
+                    newly_shared_users = new_shared_users - current_shared_users
+
+                    if newly_shared_users:
+                        # Map adapter type to specific resource type
+                        adapter_type_to_resource = {
+                            "LLM": ResourceType.LLM.value,
+                            "EMBEDDING": ResourceType.EMBEDDING.value,
+                            "VECTOR_DB": ResourceType.VECTOR_DB.value,
+                            "X2TEXT": ResourceType.X2TEXT.value,
+                        }
+
+                        resource_type = adapter_type_to_resource.get(
+                            adapter.adapter_type, ResourceType.LLM.value
+                        )
 
-                    notification_service = SharingNotificationService()
-                    notification_service.send_sharing_notification(
-                        resource_type=resource_type,
-                        resource_name=adapter.adapter_name,
-                        resource_id=str(adapter.id),
-                        shared_by=request.user,
-                        shared_to=list(newly_shared_users),
-                        resource_instance=adapter,
-                    )
+                        # Get notification service from plugin
+                        service_class = notification_plugin["service_class"]
+                        notification_service = service_class()
+                        notification_service.send_sharing_notification(
+                            resource_type=resource_type,
+                            resource_name=adapter.adapter_name,
+                            resource_id=str(adapter.id),
+                            shared_by=request.user,
+                            shared_to=list(newly_shared_users),
+                            resource_instance=adapter,
+                        )
             except Exception as e:
                 logger.exception(f"Failed to send sharing notification: {e}")
 
 
@@ -1,7 +1,7 @@
 import logging
 from typing import Any
 
-from plugins.api.dto import metadata
+from plugins import get_plugin
 
 from api_v2.postman_collection.dto import PostmanCollection
 
@@ -13,10 +13,16 @@ class ApiDeploymentDTORegistry:
 
     @classmethod
     def load_dto(cls) -> Any | None:
-        class_name = PostmanCollection.__name__
-        if metadata.get(class_name):
-            return metadata[class_name].class_name
-        return PostmanCollection  # Return as soon as we find a valid DTO
+        """Load DTO from plugin or return default PostmanCollection.
+
+        Checks if the api_dto plugin is available and gets the Postman DTO
+        via the service, otherwise returns the base PostmanCollection class.
+        """
+        plugin = get_plugin("api_dto")
+        if plugin:
+            service = plugin["service_class"]()
+            return service.get_postman_dto()
+        return PostmanCollection
 
     @classmethod
     def get_dto(cls) -> type | None:
 
@@ -7,6 +7,7 @@
 from django.db.models import QuerySet
 from django.http import HttpResponse
 from permissions.permission import IsOwner, IsOwnerOrSharedUserOrSharedToOrg
+from plugins import get_plugin
 from prompt_studio.prompt_studio_registry_v2.models import PromptStudioRegistry
 from rest_framework import serializers, status, views, viewsets
 from rest_framework.decorators import action
@@ -33,15 +34,12 @@
     SharedUserListSerializer,
 )
 
-try:
-    from plugins.notification.constants import ResourceType
-    from plugins.notification.sharing_notification import SharingNotificationService
+# Check if notification plugin is available
+notification_plugin = get_plugin("notification")
 
-    NOTIFICATION_PLUGIN_AVAILABLE = True
-    sharing_notification_service = SharingNotificationService()
-except ImportError:
-    NOTIFICATION_PLUGIN_AVAILABLE = False
-    sharing_notification_service = None
+# Import constants from notification plugin if available
+if notification_plugin:
+    from plugins.notification.constants import ResourceType
 
 logger = logging.getLogger(__name__)
 
@@ -319,15 +317,17 @@ def partial_update(self, request: Request, *args: Any, **kwargs: Any) -> Respons
         if (
             response.status_code == 200
             and "shared_users" in request.data
-            and NOTIFICATION_PLUGIN_AVAILABLE
+            and notification_plugin
         ):
             try:
                 instance.refresh_from_db()
                 new_shared_users = set(instance.shared_users.all())
                 newly_shared_users = new_shared_users - current_shared_users
 
                 if newly_shared_users:
-                    notification_service = SharingNotificationService()
+                    # Get notification service from plugin
+                    service_class = notification_plugin["service_class"]
+                    notification_service = service_class()
                     notification_service.send_sharing_notification(
                         resource_type=ResourceType.API_DEPLOYMENT.value,
                         resource_name=instance.display_name,
 
@@ -308,7 +308,7 @@ def filter(self, record):
     "drf_yasg",
     "docs",
     # Plugins
-    "plugins",
+    "plugins.apps.PluginsConfig",
     "feature_flag",
     "django_celery_beat",
     # For additional helper commands