Merge pull request #17 from dolittle/feature/k8s-api-mock

Kubernetes Mock API

Author: pavsaund

.vscode/settings.json

@@ -7,7 +7,7 @@
         "**/.DS_Store": true
     },
     "editor.codeActionsOnSave": {
-        "source.fixAll.eslint": true
+        "source.fixAll.eslint": false
     },
     "cSpell.words": [
         "Deduplication",

Environment/nginx.conf

@@ -21,6 +21,13 @@ http {
             proxy_set_header Tenant-ID 508c1745-5f2a-4b4c-b7a5-2fbb1484346d;
         }
 
+        location /api/v1 {
+            proxy_pass http://host.docker.internal:3001;
+            proxy_set_header Host localhost:9000;
+            proxy_set_header X-Forwarded-Proto $scheme;
+            proxy_set_header Tenant-ID 508c1745-5f2a-4b4c-b7a5-2fbb1484346d;
+        }
+
         location /api/k8s {
             proxy_pass http://host.docker.internal:3001;
             proxy_set_header Host localhost:9000;

Source/Applications/Backend/applications/ApplicationQueries.ts

@@ -6,6 +6,11 @@ import { ILogger } from '@shared/backend/logging';
 import { injectable } from 'tsyringe';
 import { Application, ApplicationModel } from './Application';
 
+import { NamespaceList } from '@shared/backend/k8s/NamespaceList';
+
+import { Guid } from '@dolittle/rudiments';
+import fetch from 'node-fetch';
+
 @injectable()
 @Resolver(Application)
 export class ApplicationQueries {
@@ -14,6 +19,18 @@ export class ApplicationQueries {
 
     @Query(returns => [Application])
     async allApplications() {
-        return ApplicationModel.find();
+
+        const response = await fetch('http://localhost:3001/api/v1/namespaces');
+        const namespaces = await response.json() as NamespaceList;
+
+        const applications = namespaces.items.map(_ => {
+            const guid = _.metadata.name.replace('application-', '');
+            const application = new Application();
+            application._id = Guid.parse(guid);
+            application.name = _.metadata.labels.application || 'unknown';
+            return application;
+        });
+
+        return applications;
     }
 }

Source/K8sMock/index.ts

@@ -24,9 +24,10 @@ import { PartitionedFilterResult } from '@dolittle/sdk.events.filtering';
         dolittleRuntimePort: 50055,
         graphQLSchema: schema,
         defaultDatabaseName: 'k8s',
+        defaultEventStoreDatabaseName: 'event_store_k8smock',
         expressCallback: _ => {
             _.use(
-                '/api/k8s/swagger',
+                '/api/swagger',
                 swaggerUi.serve,
                 swaggerUi.setup(swagger)
             );

Source/K8sMock/k8s-swagger.json

@@ -0,0 +1,17 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+import { Controller, Get, Route, Tags } from 'tsoa';
+import { NamespaceList } from '@shared/backend/k8s/NamespaceList';
+
+const namespaces = require('./namespaces.json') as NamespaceList;
+
+@Route('api/v1/namespaces')
+@Tags('core_v1')
+export class NamespacesController extends Controller {
+
+    @Get()
+    async getNamespaces(): Promise<NamespaceList> {
+        return namespaces;
+    }
+}

Source/K8sMock/namespaces/NamespacesController.ts

@@ -0,0 +1,43 @@
+{
+    "apiVersion": "v1",
+    "items": [
+      {
+        "metadata": {
+          "name": "Portal",
+          "creationTimestamp": "2020-12-07T17:00:28Z",
+          "labels": {
+            "app": "Something"
+          }
+        },
+        "spec": {
+          "containers": [
+            {
+              "name": "Portal",
+              "image": "dolittle/studio/portal:1.0.0",
+              "args": []
+            }
+          ]
+        }
+      }
+    ],
+    "status": {
+      "phase": "Running",
+      "startTime": "2020-12-07T17:00:28Z",
+      "containerStatuses": [
+        {
+          "containerID": "docker://9656265f3d8207d2ec8ce5962f3d25b34f784a9466c268492f06766f03665881",
+          "name": "Portal",
+          "image": "dolittle/studio/portal:1.0.0",
+          "imageID": "docker-pullable://docker/desktop-vpnkit-controller@sha256:6800d69751e483710a0949fbd01c459934a18ede9d227166def0af44f3a46970",
+          "ready": true,
+          "started": true,
+          "state": {
+            "running": {
+              "startedAt": "2020-12-07T17:06:07Z"
+            }
+          },
+          "lastState": {}
+        }
+      ]
+    }
+  }

Source/K8sMock/namespaces/namespaces-full-sample.json

@@ -0,0 +1,15 @@
+{
+    "apiVersion": "v1",
+    "kind": "NamespaceList",
+    "items": [
+        {
+            "metadata": {
+                "name": "application-fe7736bb-57fc-4166-bb91-6954f4dd4eb7",
+                "labels": {
+                    "tenant": "Dolittle",
+                    "application": "Studio"
+                }
+            }
+        }
+    ]
+}

Source/K8sMock/namespaces/namespaces.json

@@ -8,6 +8,7 @@
     "scripts": {
         "dev": "concurrently \"nodemon -x tsoa spec-and-routes\" \"nodemon index.ts\"",
         "debug": "nodemon --inspect -e ts --exec node -r ts-node/register index.ts",
+        "k8s-api": "docker run --rm -p 80:8080 -e SWAGGER_JSON=/k8s-swagger.json -v $(pwd)/k8s-swagger.json:/k8s-swagger.json swaggerapi/swagger-ui",
         "start": "ts-node index.ts",
         "build": "tsc -b --clean && tsc -b"
     },

Source/K8sMock/package.json

@@ -0,0 +1,17 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+import { Controller, Get, Route, Tags } from 'tsoa';
+import { PodList } from '@shared/backend/k8s/PodList';
+
+const pods = require('./pods.json') as PodList;
+
+@Route('api/v1/namespaces')
+@Tags('core_v1')
+export class PodsController extends Controller {
+
+    @Get('{namespace}/pods')
+    async getPods(): Promise<PodList> {
+        return pods;
+    }
+}