Add sahara createMultipleClusters

Author: ekasitk

samples/data_processing/nodegroup_template/create_nodegrouptemplate.php

@@ -31,6 +31,7 @@
     'name'          => '{nodeGroupTemplateName}',
     'flavorId'      => '{flavorId}',
     'floatingIpPool' => '{floatingIpPool}',
+    'autoSecurityGroup' => '{trueOrFalse}',
     'isProtected'   => '{trueOrFalse}',
 ];
 

src/DataProcessing/v1/Api.php

@@ -279,6 +279,7 @@ public function postNodeGroupTemplate()
                 'imageId'          => $this->params->imageId(),
                 'floatingIpPool'   => $this->params->floatingIpPool(),
                 'useAutoconfig'    => $this->params->useAutoconfig(),
+                'autoSecurityGroup'    => $this->params->autoSecurityGroup(),
                 'isProxyGateway'   => $this->params->isProxyGateway(),
                 'isPublic'         => $this->params->isPublic(),
                 'isProtected'      => $this->params->isProtected(),
@@ -319,6 +320,7 @@ public function putNodeGroupTemplate()
                 'imageId'          => $this->params->imageId(),
                 'floatingIpPool'   => $this->params->floatingIpPool(),
                 'useAutoconfig'    => $this->params->useAutoconfig(),
+                'autoSecurityGroup'    => $this->params->autoSecurityGroup(),
                 'isProxyGateway'   => $this->params->isProxyGateway(),
                 'isPublic'         => $this->params->isPublic(),
                 'isProtected'      => $this->params->isProtected(),

src/DataProcessing/v1/Models/NodeGroupTemplate.php

@@ -89,7 +89,7 @@ public function delete()
 
     public function update()
     {
-        $response = $this->execute($this->api->putNodeGroupTemplate(), $this->getAttrs(['id', 'name', 'description', 'flavorId', 'availabilityZone', 'imageId', 'floatingIpPool', 'useAutoconfig', 'isProxyGateway', 'isPublic', 'isProtected']));
+        $response = $this->execute($this->api->putNodeGroupTemplate(), $this->getAttrs(['id', 'name', 'description', 'flavorId', 'availabilityZone', 'imageId', 'floatingIpPool', 'useAutoconfig', 'autoSecurityGroup', 'isProxyGateway', 'isPublic', 'isProtected']));
         $this->populateFromResponse($response);
     }
 }

src/DataProcessing/v1/Params.php

@@ -298,6 +298,16 @@ public function useAutoconfig(): array
         ];
     }
 
+    public function autoSecurityGroup(): array
+    {
+        return [
+            'type'        => self::BOOL_TYPE,
+            'required'    => false,
+            'sentAs'      => 'auto_security_group',
+            'description' => 'If set to True, the cluster group is automatically secured.',
+        ];
+    }
+
     public function isProxyGateway(): array
     {
         return [

src/DataProcessing/v1/Service.php

@@ -3,6 +3,7 @@
 namespace OpenStack\DataProcessing\v1;
 
 use OpenStack\Common\Service\AbstractService;
+use OpenStack\Common\Transport\Utils;
 use OpenStack\DataProcessing\v1\Models\Cluster;
 use OpenStack\DataProcessing\v1\Models\ClusterTemplate;
 use OpenStack\DataProcessing\v1\Models\DataSource;
@@ -37,6 +38,26 @@ public function createCluster(array $options = []): Cluster
         return $this->model(Cluster::class)->create($options);
     }
 
+    public function createMultipleClusters(array $options = []) 
+    {
+        if (!array_key_exists("count", $options)) {
+            throw new \RuntimeException("Require 'count'");        
+        }
+
+        $response = $this->execute($this->api->postClusters(), $options);
+        # For multiple clusters, the current API returns only cluster IDs.
+        $ids = Utils::flattenJson(Utils::jsonDecode($response), 'clusters');
+        if ($response->getStatusCode() === 204 || empty($ids)) {
+            return;
+        } 
+        foreach ($ids as $id) {
+            $cluster = $this->model(Cluster::class);
+            $cluster->id = $id;
+            yield $cluster;
+        }
+
+    } 
+
     public function scaleCluster(array $options = []): Cluster
     {
         return $this->model(Cluster::class)->scale($options);