Implement KubeObjectStatusText extension API (#1188)

Signed-off-by: Lauri Nevala <lauri.nevala@gmail.com>

extensions/kube-object-event-status/Makefile

@@ -0,0 +1,8 @@
+install-deps:
+	npm install
+
+build: install-deps
+	npm run build
+
+test:
+	npm run test

extensions/kube-object-event-status/package.json

@@ -0,0 +1,24 @@
+{
+  "name": "kube-object-event-status",
+  "version": "0.1.0",
+  "description": "Adds kube object status from events",
+  "renderer": "dist/renderer.js",
+  "lens": {
+    "metadata": {},
+    "styles": []
+  },
+  "scripts": {
+    "build": "webpack --config webpack.config.js",
+    "dev": "npm run build --watch",
+    "test": "echo NO TESTS"
+  },
+  "dependencies": {},
+  "devDependencies": {
+    "@k8slens/extensions": "file:../../src/extensions/npm/extensions",
+    "ts-loader": "^8.0.4",
+    "typescript": "^4.0.3",
+    "webpack": "^4.44.2",
+    "mobx": "^5.15.5",
+    "react": "^16.13.1"
+  }
+}

extensions/kube-object-event-status/renderer.tsx

@@ -0,0 +1,42 @@
+import { LensRendererExtension, K8sApi } from "@k8slens/extensions";
+import { resolveStatus, resolveStatusForCronJobs, resolveStatusForPods } from "./src/resolver"
+
+export default class EventResourceStatusRendererExtension extends LensRendererExtension {
+  kubeObjectStatusTexts = [
+    {
+      kind: "Pod",
+      apiVersions: ["v1"],
+      resolve: (pod: K8sApi.Pod) => resolveStatusForPods(pod)
+    },
+    {
+      kind: "ReplicaSet",
+      apiVersions: ["v1"],
+      resolve: (replicaSet: K8sApi.ReplicaSet) => resolveStatus(replicaSet)
+    },
+    {
+      kind: "Deployment",
+      apiVersions: ["apps/v1"],
+      resolve: (deployment: K8sApi.Deployment) => resolveStatus(deployment)
+    },
+    {
+      kind: "StatefulSet",
+      apiVersions: ["apps/v1"],
+      resolve: (statefulSet: K8sApi.StatefulSet) => resolveStatus(statefulSet)
+    },
+    {
+      kind: "DaemonSet",
+      apiVersions: ["apps/v1"],
+      resolve: (daemonSet: K8sApi.DaemonSet) => resolveStatus(daemonSet)
+    },
+    {
+      kind: "Job",
+      apiVersions: ["batch/v1"],
+      resolve: (job: K8sApi.Job) => resolveStatus(job)
+    },
+    {
+      kind: "CronJob",
+      apiVersions: ["batch/v1"],
+      resolve: (cronJob: K8sApi.CronJob) => resolveStatusForCronJobs(cronJob)
+    },
+  ]
+}

extensions/kube-object-event-status/src/resolver.tsx

@@ -0,0 +1,52 @@
+import { K8sApi } from "@k8slens/extensions";
+
+export function resolveStatus(object: K8sApi.KubeObject): K8sApi.KubeObjectStatus {
+  const eventStore = K8sApi.apiManager.getStore(K8sApi.eventApi)
+  const events = (eventStore as K8sApi.EventStore).getEventsByObject(object);
+  let warnings = events.filter(evt => evt.isWarning());
+  if (!events.length || !warnings.length) {
+    return null;
+  }
+  const event = [...warnings, ...events][0]; // get latest event
+  return {
+    level: K8sApi.KubeObjectStatusLevel.WARNING,
+    text: `${event.message}`,
+    timestamp: event.metadata.creationTimestamp
+  }
+}
+
+export function resolveStatusForPods(pod: K8sApi.Pod): K8sApi.KubeObjectStatus {
+  if (!pod.hasIssues()) {
+    return null
+  }
+  const eventStore = K8sApi.apiManager.getStore(K8sApi.eventApi)
+  const events = (eventStore as K8sApi.EventStore).getEventsByObject(pod);
+  let warnings = events.filter(evt => evt.isWarning());
+  if (!events.length || !warnings.length) {
+    return null;
+  }
+  const event = [...warnings, ...events][0]; // get latest event
+  return {
+    level: K8sApi.KubeObjectStatusLevel.WARNING,
+    text: `${event.message}`,
+    timestamp: event.metadata.creationTimestamp
+  }
+}
+
+export function resolveStatusForCronJobs(cronJob: K8sApi.CronJob): K8sApi.KubeObjectStatus {
+  const eventStore = K8sApi.apiManager.getStore(K8sApi.eventApi)
+  let events = (eventStore as K8sApi.EventStore).getEventsByObject(cronJob);
+  let warnings = events.filter(evt => evt.isWarning());
+  if (cronJob.isNeverRun()) {
+    events = events.filter(event => event.reason != "FailedNeedsStart");
+  }
+  if (!events.length || !warnings.length) {
+    return null;
+  }
+  const event = [...warnings, ...events][0]; // get latest event
+  return {
+    level: K8sApi.KubeObjectStatusLevel.WARNING,
+    text: `${event.message}`,
+    timestamp: event.metadata.creationTimestamp
+  }
+}

extensions/kube-object-event-status/tsconfig.json

@@ -0,0 +1,26 @@
+{
+  "compilerOptions": {
+    "outDir": "dist",
+    "module": "CommonJS",
+    "target": "ES2017",
+    "lib": ["ESNext", "DOM", "DOM.Iterable"],
+    "moduleResolution": "Node",
+    "sourceMap": false,
+    "declaration": false,
+    "strict": false,
+    "noImplicitAny": true,
+    "skipLibCheck": true,
+    "esModuleInterop": true,
+    "allowSyntheticDefaultImports": true,
+    "experimentalDecorators": true,
+    "jsx": "react"
+  },
+  "include": [
+    "./*.ts",
+    "./*.tsx"
+  ],
+  "exclude": [
+    "node_modules",
+    "*.js"
+  ]
+}

extensions/kube-object-event-status/webpack.config.js

@@ -0,0 +1,35 @@
+const path = require('path');
+
+module.exports = [
+  {
+    entry: './renderer.tsx',
+    context: __dirname,
+    target: "electron-renderer",
+    mode: "production",
+    module: {
+      rules: [
+        {
+          test: /\.tsx?$/,
+          use: 'ts-loader',
+          exclude: /node_modules/,
+        },
+      ],
+    },
+    externals: [
+      {
+        "@k8slens/extensions": "var global.LensExtensions",
+        "react": "var global.React",
+        "mobx": "var global.Mobx"
+      }
+    ],
+    resolve: {
+      extensions: [ '.tsx', '.ts', '.js' ],
+    },
+    output: {
+      libraryTarget: "commonjs2",
+      globalObject: "this",
+      filename: 'renderer.js',
+      path: path.resolve(__dirname, 'dist'),
+    },
+  },
+];