blancer api

circle/dashboard/urls.py

@@ -64,7 +64,7 @@ from .views import (
     SleepInstanceREST, WakeUpInstanceREST, DownloadPersistentDiskREST,
     CreatePersistentDiskREST, GetStorageActivityREST, GetTemplateREST,
     MessageList, MessageDetail, MessageCreate, MessageDelete,
-    SetupPortREST, RulesREST,
+    SetupPortREST, RulesREST, InstanceBalancerTemplateREST,
     EnableTwoFactorView, DisableTwoFactorView,
     AclUserGroupAutocomplete, AclUserAutocomplete,
     RescheduleView, GroupImportView, GroupExportView,
@@ -91,6 +91,7 @@ urlpatterns = [
     path('acpi/vm/<int:pk>/', GetInstanceREST.as_view()),
     path('acpi/template/<int:pk>/', GetTemplateREST.as_view()),
     path('acpi/template/', TemplateREST.as_view()),
+    path('acpi/bvm/', InstanceBalancerTemplateREST.as_view()),
     path('acpi/ft/', InstanceFromTemplateREST.as_view()),
     path('acpi/lease/', LeaseREST.as_view()),
     path('acpi/lease/<int:pk>/', GetLeaseREST.as_view()),

circle/dashboard/views/template.py

@@ -230,6 +230,41 @@ class GetTemplateREST(APIView):
     def delete(self, request, pk, format=None):
         return JsonResponse(status=400)
 
+class InstanceBalancerTemplateREST(APIView):
+    authentication_classes = [TokenAuthentication,BasicAuthentication]
+    permission_classes = [IsAdminUser]
+
+    def post(self, request, format=None):
+        data = JSONParser().parse(request)
+        user = User.objects.filter(username=data['username']).get()
+        template = InstanceTemplate.objects.filter(name=data['template_name']).get()
+        ikwargs = {
+            'name': data['name'],
+            'template': template,
+            'owner': user,
+        }
+        amount = data.get("amount", 1)
+        if 'num_cores' in data:
+            ikwargs.update({'num_cores':data['num_cores']})
+        
+        if 'ram_size' in data:
+            ikwargs.update({'ram_size':data['ram_size']})
+
+        if 'priority' in data:
+            ikwargs.update({'priority':data['priority']})
+
+        if 'max_ram_size' in data:
+            ikwargs.update({'max_ram_size':data['ram_size']})
+
+        instances = Instance.mass_create_from_template(amount=amount,
+                                                       **ikwargs)
+        for i in instances:
+            i.deploy._async(user=user)
+        if amount == 1:
+            serializer = InstanceSerializer(instances, many=True)
+            return JsonResponse(serializer.data, status=201, safe=False)
+        serializer = InstanceSerializer(instances, many=True)
+        return JsonResponse(serializer.data, status=201, safe=False)
 
 class InstanceFromTemplateREST(APIView):
     authentication_classes = [TokenAuthentication,BasicAuthentication]