Merge pull request #17 from ThinkDeepTech/hm/init-impl

updated api create to return resultant object from the api

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@thinkdeep/k8s",
-  "version": "3.0.2",
+  "version": "3.0.3",
   "description": "K8s node client tag for processing yaml configurations in javascript code.",
   "main": "src/k8s-client.mjs",
   "repository": "[email protected]:ThinkDeepTech/k8s.git",

src/k8s-api.mjs

@@ -125,18 +125,23 @@ class K8sApi {
         }
     }
 
-    createAll(manifests) {
-        return Promise.all(manifests.map(async(manifest) => {
+    async createAll(manifests) {
+        return (await Promise.all(manifests.map(async(manifest) => {
             try {
-                await this._creationStrategy(manifest)();
+
+                const received = await this._creationStrategy(manifest)();
+
+                return this._configuredManifest(received.response.body);
             } catch (e) {
 
                 const {response: {statusCode}} = e;
                 if (statusCode !== 409) {
                     throw e;
                 }
+
+                return null;
             }
-        }));
+        }))).filter((val) => !!val);
     }
 
     _creationStrategy(manifest) {
@@ -327,11 +332,15 @@ class K8sApi {
 
     _deletionStrategy(manifest) {
 
-        if (!manifest?.kind) {
+        if (!manifest) {
+            throw new Error(`The manifest value is invalid: ${manifest}`);
+        }
+
+        if (!manifest.kind) {
             throw new Error(`The manifest requires a kind.`);
         }
 
-        if (!manifest?.apiVersion) {
+        if (!manifest.apiVersion) {
             throw new Error(`The manifest requires an api version.`);
         }
 

src/k8s-client.mjs

@@ -31,9 +31,7 @@ class K8sClient {
 
         const manifest = this._manifest(configuration);
 
-        await this._api.createAll([manifest]);
-
-        return manifest;
+        return (await this._api.createAll([manifest]))[0] || manifest;
     }
 
     async applyAll(configurations) {