implement tests with kubetest2

Author: Megapixel99

index.js

@@ -64,6 +64,13 @@ app.get('/', (req, res, next) => {
   res.json({
     paths: routes.flat(Math.Infinity).filter((e) => e).map((e) => e.path).flat(Math.Infinity)
   });
+});
+
+app.get('/ping', (req, res) => {
+  if (db.connectionStatus() === 1) {
+    return res.sendStatus(200);
+  }
+  return res.sendStatus(502);
 })
 
 app.use((req, res) => {

package-lock.json

@@ -4,14 +4,14 @@
   "description": "",
   "main": "index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1",
-    "start": "./start.sh",
-    "test": "kubetest2 noop --kubeconfig=./test-config --test=ginkgo"
+    "test": "node ./test/test.js",
+    "start": "./start.sh"
   },
   "author": "",
   "license": "ISC",
   "dependencies": {
     "@wesleytodd/openapi": "^1.0.0",
+    "axios": "^1.6.8",
     "docker-cli-js": "^2.10.0",
     "dotenv": "^16.4.5",
     "express": "^4.19.1",

package.json

@@ -2,17 +2,17 @@ apiVersion: v1
 clusters:
 - cluster:
     insecure-skip-tls-verify: true
-    server: http://host.docker.internal:8080
-  name: host.docker.internal:8080
+    server: http://localhost:8080
+  name: localhost:8080
 contexts:
 - context:
-    cluster: host.docker.internal:8080
-    user: admin/host.docker.internal:8080
-  name: /host.docker.internal:8080/admin
-current-context: /host.docker.internal:8080/admin
+    cluster: localhost:8080
+    user: admin/localhost:8080
+  name: /localhost:8080/admin
+current-context: /localhost:8080/admin
 kind: Config
 preferences: {}
 users:
-- name: admin/host.docker.internal:8080
+- name: admin/localhost:8080
   user:
     token: token

test-config

@@ -0,0 +1,36 @@
+{
+  "kind": "Node",
+  "apiVersion": "v1",
+  "metadata": {
+    "name": "${ip}",
+    "labels": {
+      "name": "my-first-k8s-node"
+    }
+  },
+  "status": {
+    "capacity": {
+      "cpu": "1",
+      "ephemeral-storage": "15625000Ki",
+      "hugepages-1Gi": "0",
+      "hugepages-2Mi": "0",
+      "memory": "15625000Ki",
+      "pods": "250"
+    },
+    "allocatable": {},
+    "conditions": [],
+    "addresses": [
+      {
+        "type": "ExternalIP",
+        "address": "$ip"
+      },
+      {
+        "type": "InternalIP",
+        "address": "$ip"
+      },
+      {
+        "type": "Hostname",
+        "address": "$ip"
+      }
+    ]
+  }
+}

test/templates/node.json

@@ -0,0 +1,66 @@
+const {
+  stopContainer,
+  killContainer,
+  removeContainer,
+  getContainerIP,
+  runImage,
+} = require('../functions.js');
+
+const nodeSpec = require('./templates/node.json');
+const axios = require('axios');
+const { spawn } = require('child_process');
+
+(async () => {
+  let nodeName = 'worker-node-1';
+  await runImage('ubuntu', nodeName);
+  let ip = JSON.parse((await getContainerIP(nodeName)).raw)[0]?.NetworkSettings.Networks.bridge.IPAddress;
+  nodeSpec.metadata.name = ip;
+  nodeSpec.metadata.labels.name = nodeName;
+  nodeSpec.status.addresses = [{
+    "type": "ExternalIP",
+    "address": ip,
+  }, {
+    "type": "InternalIP",
+    "address": ip,
+  }, {
+    "type": "Hostname",
+    "address": ip,
+  }];
+
+  let server = spawn('npm', ['start']);
+
+  server.stdout.on('data', (data) => console.log(`[${new Date()}] [server] ${data}`));
+
+  server.stderr.on('data', (data) => console.log(`[${new Date()}] [server] ${data}`));
+
+  server.on('exit', async (code) => {
+    console.log(`[server] closed`);
+    await killContainer(nodeName);
+    await removeContainer(nodeName);
+    process.exit(0);
+  });
+
+  await new Promise((resolve, reject) => {
+    let i = setInterval(() => {
+      axios.get('http://localhost:8080/ping')
+      .then(() => {
+        clearInterval(i);
+        resolve();
+      })
+      .catch(() => { });
+    }, 10000);
+  });
+
+  await axios.post('http://localhost:8080/api/v1/nodes', nodeSpec);
+  let test = spawn('kubetest2', ['noop', '--kubeconfig=./test-config', '--v', '10', '--test=ginkgo'])
+
+  test.stdout.on('data', (data) => console.log(`[${new Date()}] [test] ${data}`));
+
+  test.stderr.on('data', (data) => console.log(`[${new Date()}] [test] ${data}`));
+
+  test.on('close', async (code) => {
+    console.log(`[test] closed`);
+    await axios.delete(`http://localhost:8080/api/v1/nodes/${ip}`);
+    server.kill('SIGKILL');
+  });
+})();