Implement default and remove methods

Author: pmuens

Diff for: serverless.js

@@ -1,14 +1,30 @@
+const path = require('path')
 const { isEmpty, mergeDeepRight } = require('ramda')
+const kubernetes = require('@kubernetes/client-node')
 const { Component } = require('@serverless/core')
 
 const defaults = {
-  foo: 'bar'
+  kubeConfigPath: path.join(process.env.HOME, '.kube', 'config'),
+  name: 'default'
 }
 
 class KubernetesNamespace extends Component {
   async default(inputs = {}) {
     const config = mergeDeepRight(defaults, inputs)
 
+    const k8sCore = this.getKubernetesClient(config.kubeConfigPath, kubernetes.CoreV1Api)
+
+    let namespaceExists = true
+    try {
+      await this.readNamespace(k8sCore, config)
+    } catch (error) {
+      namespaceExists = error.response.body.code === 404 ? false : true
+    }
+
+    if (!namespaceExists) {
+      await this.createNamespace(k8sCore, config)
+    }
+
     this.state = config
     await this.save()
     return this.state
@@ -20,10 +36,34 @@ class KubernetesNamespace extends Component {
       config = this.state
     }
 
+    const k8sCore = this.getKubernetesClient(config.kubeConfigPath, kubernetes.CoreV1Api)
+
+    await this.deleteNamespace(k8sCore, config)
+
     this.state = {}
     await this.save()
     return {}
   }
+
+  // "private" methods
+  getKubernetesClient(configPath, type) {
+    let kc = new kubernetes.KubeConfig()
+    kc.loadFromFile(configPath)
+    kc = kc.makeApiClient(type)
+    return kc
+  }
+
+  async createNamespace(k8s, { name }) {
+    return k8s.createNamespace({ metadata: { name } })
+  }
+
+  async readNamespace(k8s, { name }) {
+    return k8s.readNamespace(name)
+  }
+
+  async deleteNamespace(k8s, { name }) {
+    return k8s.deleteNamespace(name)
+  }
 }
 
 module.exports = KubernetesNamespace