feat(controller): add resource services api

Author: duanhongyi

charts/controller/templates/controller-clusterrole.yaml

@@ -68,9 +68,9 @@ rules:
   resources: ["persistentvolumeclaims"]
   verbs: ["get", "list", "watch", "create", "delete", "patch", "update"]
 - apiGroups: ["servicecatalog.k8s.io"]
-  resources: ["serviceinstances"]
-  verbs: ["get", "list", "watch", "create", "delete", "patch", "update"]
+  resources: ["clusterserviceclasses", "serviceclasses", "clusterserviceplans", "serviceplans"]
+  verbs: ["get", "list", "watch"]
 - apiGroups: ["servicecatalog.k8s.io"]
-  resources: ["servicebindings"]
+  resources: ["serviceinstances", "servicebindings"]
   verbs: ["get", "list", "watch", "create", "delete", "patch", "update"]
 {{- end -}}

rootfs/api/models/__init__.py

@@ -65,8 +65,9 @@ class Meta:
         """Mark :class:`AuditedModel` as abstract."""
         abstract = True
 
+    @classmethod
     @property
-    def _scheduler(self):
+    def _scheduler(cls):
         mod = importlib.import_module(settings.SCHEDULER_MODULE)
         return mod.SchedulerClient(settings.SCHEDULER_URL, settings.K8S_API_VERIFY_TLS)
 

rootfs/api/models/resource.py

@@ -35,6 +35,37 @@ def save(self, *args, **kwargs):
         # Save to DB
         return super(Resource, self).save(*args, **kwargs)
 
+    @classmethod
+    @property
+    def services(cls):
+        services = []
+        for serviceclass in cls._scheduler.svcat.get_serviceclasses().json()["items"]:
+            services.append({
+                "id": serviceclass["spec"]["externalID"],
+                "name": serviceclass["spec"]["externalName"],
+                "updateable": serviceclass["spec"]["planUpdatable"],
+            })
+        return services
+
+    @classmethod
+    def plans(cls, serviceclass_name):
+        serviceclass_id = None
+        for service in cls.services:
+            if service["name"] == serviceclass_name:
+                serviceclass_id = service["id"]
+                break
+    
+        plans = []
+        if serviceclass_id is not None:
+            for serviceplan in cls._scheduler.svcat.get_serviceplans().json()["items"]:
+                if serviceplan["spec"]["clusterServiceClassRef"]["name"] == serviceclass_id:
+                    plans.append({
+                        "id": serviceplan["spec"]["externalID"],
+                        "name": serviceplan["spec"]["externalName"],
+                        "description": serviceplan["spec"]["description"],
+                    })
+        return plans
+
     def attach(self, *args, **kwargs):
         try:
             self._scheduler.svcat.get_instance(self.app.id, self.name)

rootfs/api/urls.py

@@ -88,6 +88,10 @@
     url(r"^apps/(?P<id>{})/volumes/(?P<name>[-_\w]+)/path/?$".format(settings.APP_URL_REGEX),
         views.AppVolumeMountPathViewSet.as_view({'patch': 'path'})),
     # application resources
+    url(r"^resources/services/?$".format(settings.APP_URL_REGEX),
+        views.AppResourcesViewSet.as_view({'get': 'services'})),
+    url(r"^resources/services/(?P<id>[-_\w]+)/plans/?$".format(settings.APP_URL_REGEX),
+        views.AppResourcesViewSet.as_view({'get': 'plans'})),
     url(r"^apps/(?P<id>{})/resources/?$".format(settings.APP_URL_REGEX),
         views.AppResourcesViewSet.as_view({'get': 'list', 'post': 'create'})),
     url(r"^apps/(?P<id>{})/resources/(?P<name>[-_\w]+)/?$".format(settings.APP_URL_REGEX),

rootfs/api/views.py

@@ -777,6 +777,23 @@ class AppResourcesViewSet(AppResourceViewSet):
     model = models.Resource
     serializer_class = serializers.ResourceSerializer
 
+    def services(self, request, *args, **kwargs):
+        results = self.model.services
+        # fake out pagination for now
+        pagination = {'results': results, 'count': len(results)}
+        return Response(data=cache.get_or_set(
+            "resources:services", pagination
+        ))
+
+    def plans(self, request, *args, **kwargs):
+        serviceclass_name = kwargs["id"]
+        results = self.model.plans(serviceclass_name)
+        # fake out pagination for now
+        pagination = {'results': results, 'count': len(results)}
+        return Response(data=cache.get_or_set(
+            "resources:services:%s:plan" % serviceclass_name, pagination     
+        ))
+
 
 class AppSingleResourceViewSet(AppResourceViewSet):
     """RESTful views for resource apps with collaborators."""

rootfs/scheduler/resources/svcat.py

@@ -33,6 +33,30 @@ def service_instance_manifest(namespace, name, version=None, **kwargs):
             data["spec"]["externalID"] = kwargs.get('external_id')
         return data
 
+    def get_serviceclasses(self, namespace=None):
+        if namespace is None:
+            url = self.api('/clusterserviceclasses')
+            message = 'get clusterserviceclasses'
+        else:
+            url = self.api('/namespaces/{}/serviceclasses', namespace)
+            message = 'get serviceclasses ' + namespace
+        response = self.http_get(url)
+        if self.unhealthy(response.status_code):
+            raise KubeHTTPException(response, message)
+        return response
+
+    def get_serviceplans(self, namespace=None):
+        if namespace is None:
+            url = self.api('/clusterserviceplans')
+            message = 'get clusterserviceplans'
+        else:
+            url = self.api('/namespaces/{}/serviceplans', namespace)
+            message = 'get serviceplans ' + namespace
+        response = self.http_get(url)
+        if self.unhealthy(response.status_code):
+            raise KubeHTTPException(response, message)
+        return response
+
     def get_instance(self, namespace, name=None):
         """
         Fetch a single serviceinstance or a list of serviceinstances