Define route, endpoint and service for kubernetes

packages/teleport/src/Kubes/Kubes.tsx

@@ -18,7 +18,7 @@ import React from 'react';
 import { Box, Indicator } from 'design';
 import { Danger } from 'design/Alert';
 import { Attempt } from 'shared/hooks/useAttemptNext';
-import KubeList from 'teleport/components/KubeList';
+import KubeList from 'teleport/Kubes/KubeList';
 import { Kube } from 'teleport/services/kube';
 import {
   FeatureBox,

packages/teleport/src/config.ts

@@ -68,6 +68,7 @@ const cfg = {
     loginErrorCallback: '/web/msg/error/login/callback',
     userInvite: '/web/invite/:tokenId',
     userReset: '/web/reset/:tokenId',
+    kubernetes: '/web/cluster/:clusterId/kubernetes',
     // whitelist sso handlers
     oidcHandler: '/v1/webapi/oidc/*',
     samlHandler: '/v1/webapi/saml/*',
@@ -100,6 +101,7 @@ const cfg = {
     ttyWsAddr:
       'wss://:fqdm/v1/webapi/sites/:clusterId/connect?access_token=:token&params=:params',
     terminalSessionPath: '/v1/webapi/sites/:clusterId/sessions/:sid?',
+    kubernetesPath: '/v1/webapi/sites/:clusterId/kubernetes',
 
     usersPath: '/v1/webapi/users',
     usersDelete: '/v1/webapi/users/:username',
@@ -236,6 +238,10 @@ const cfg = {
     return cfg.baseUrl + generatePath(route, { tokenId });
   },
 
+  getKubernetesRoute(clusterId: string) {
+    return generatePath(cfg.routes.kubernetes, { clusterId });
+  },
+
   getUsersUrl() {
     return cfg.api.usersPath;
   },
@@ -282,6 +288,10 @@ const cfg = {
     return generatePath(cfg.api.rolesPath, { name });
   },
 
+  getKubernetesUrl(clusterId: string) {
+    return generatePath(cfg.api.kubernetesPath, { clusterId });
+  },
+
   init(backendConfig = {}) {
     merge(this, backendConfig);
   },

packages/teleport/src/services/kube/index.ts

@@ -14,4 +14,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
+import KubeService from './kube';
+
 export * from './types';
+export default KubeService;

packages/teleport/src/services/kube/kube.test.ts

@@ -0,0 +1,60 @@
+/*
+Copyright 2021 Gravitational, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import KubeService from './kube';
+import api from 'teleport/services/api';
+
+test('correct processed fetch response formatting', async () => {
+  jest.spyOn(api, 'get').mockResolvedValue(mockApiResponse);
+
+  const kubeService = new KubeService();
+  const response = await kubeService.fetchKubernetes('clusterId');
+
+  expect(response).toEqual([
+    {
+      name: 'tele.logicoma.dev-prod',
+      tags: ['kernal: 4.15.0-51-generic', 'env: prod'],
+    },
+  ]);
+});
+
+test('handling of null fetch response', async () => {
+  jest.spyOn(api, 'get').mockResolvedValue(null);
+
+  const kubeService = new KubeService();
+  const response = await kubeService.fetchKubernetes('clusterId');
+
+  expect(response).toEqual([]);
+});
+
+test('handling of null labels', async () => {
+  jest.spyOn(api, 'get').mockResolvedValue([{ name: 'test', labels: null }]);
+
+  const kubeService = new KubeService();
+  const response = await kubeService.fetchKubernetes('clusterId');
+
+  expect(response).toEqual([{ name: 'test', tags: [] }]);
+});
+
+const mockApiResponse = [
+  {
+    name: 'tele.logicoma.dev-prod',
+    labels: [
+      { name: 'kernal', value: '4.15.0-51-generic' },
+      { name: 'env', value: 'prod' },
+    ],
+  },
+];

packages/teleport/src/services/kube/kube.ts

@@ -0,0 +1,30 @@
+/*
+Copyright 2021 Gravitational, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import { map } from 'lodash';
+import api from 'teleport/services/api';
+import cfg from 'teleport/config';
+import makeKube from './makeKube';
+
+class KubeService {
+  fetchKubernetes(clusterId) {
+    return api
+      .get(cfg.getKubernetesUrl(clusterId))
+      .then(json => map(json, makeKube));
+  }
+}
+
+export default KubeService;

packages/teleport/src/services/kube/makeKube.ts

@@ -0,0 +1,27 @@
+/*
+Copyright 2021 Gravitational, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import { Kube } from './types';
+
+export default function makeKube(json): Kube {
+  const { name } = json;
+  const labels = json.labels || [];
+
+  return {
+    name,
+    tags: labels.map(label => `${label.name}: ${label.value}`),
+  };
+}

packages/teleport/src/teleportContext.tsx

@@ -24,6 +24,7 @@ import sshService from './services/ssh';
 import ResourceService from './services/resources';
 import userService from './services/user';
 import appService from './services/apps';
+import KubeService from './services/kube';
 
 class TeleportContext implements types.Context {
   // stores
@@ -41,6 +42,7 @@ class TeleportContext implements types.Context {
   resourceService = new ResourceService();
   userService = userService;
   appService = appService;
+  kubeService = new KubeService();
 
   isEnterprise = cfg.isEnterprise;