From d30aef44b912c4bf6aa669fb058fcc30e3b6f22f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Pawe=C5=82=20Szulik?= <pawel.szulik@intel.com>
Date: Thu, 25 Nov 2021 11:08:12 +0100
Subject: [PATCH] WIP
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Paweł Szulik <pawel.szulik@intel.com>
---
 config/product/kafka.js                 |  45 ++++++
 pages/c/_cluster/kafka/create/index.vue |  19 +++
 pages/c/_cluster/kafka/index.vue        | 207 ++++++++++++++++++++++++
 3 files changed, 271 insertions(+)
 create mode 100644 config/product/kafka.js
 create mode 100644 pages/c/_cluster/kafka/create/index.vue
 create mode 100644 pages/c/_cluster/kafka/index.vue

diff --git a/config/product/kafka.js b/config/product/kafka.js
new file mode 100644
index 0000000000..ba6fe617b8
--- /dev/null
+++ b/config/product/kafka.js
@@ -0,0 +1,45 @@
+import { DSL } from '@/store/type-map';
+
+export const NAME = 'kafka';
+export const CHART_NAME = 'strimzi-kafka-operator';
+
+export function init(store) {
+  const {
+    product,
+    basicType,
+    virtualType,
+    configureType,
+  } = DSL(store, NAME);
+
+  product({
+    //TODO (Creatone): Add condition for Kafka.
+    //ifHave:     IF_HAVE.V2_MONITORING, // possible RBAC issue here if mon turned on but user doesn't have view/read roles on pod monitors
+    icon:       'kafka',
+    weight:     90,
+  });
+
+  virtualType({
+    label:      'Kafka',
+    namespaced: false,
+    name:       'monitoring-overview',
+    weight:     105,
+    route:      { name: 'c-cluster-monitoring' },
+    exact:      true,
+    overview:   true,
+  });
+
+  virtualType({
+    label:         'Create',
+    group:         'kafka',
+    name:     'create',
+    icon:     'globe',
+    route: { name: 'c-cluster-kafka-create' }
+  });
+
+  configureType('create', { showListMasthead: false });
+
+  basicType([
+    'kafka',
+    'create',
+  ]);
+}
diff --git a/pages/c/_cluster/kafka/create/index.vue b/pages/c/_cluster/kafka/create/index.vue
new file mode 100644
index 0000000000..204884d26b
--- /dev/null
+++ b/pages/c/_cluster/kafka/create/index.vue
@@ -0,0 +1,19 @@
+<script>
+import ResourceDetail from '@/components/ResourceDetail';
+
+export default {
+  name: 'RouteReceiverCreate',
+
+  components: { ResourceDetail },
+
+  data() {
+    const { query:{ resource } } = this.$route;
+
+    return { resource };
+  }
+};
+</script>
+
+<template>
+  <ResourceDetail :resource-override="resource" />
+</template>
diff --git a/pages/c/_cluster/kafka/index.vue b/pages/c/_cluster/kafka/index.vue
new file mode 100644
index 0000000000..e407a23083
--- /dev/null
+++ b/pages/c/_cluster/kafka/index.vue
@@ -0,0 +1,207 @@
+<script>
+import isEmpty from 'lodash/isEmpty';
+
+import InstallRedirect from '@/utils/install-redirect';
+import AlertTable from '@/components/AlertTable';
+import { NAME, CHART_NAME } from '@/config/product/kafka';
+import { ENDPOINTS, MONITORING } from '@/config/types';
+import { allHash } from '@/utils/promise';
+import { findBy } from '@/utils/array';
+
+import Banner from '@/components/Banner';
+import LazyImage from '@/components/LazyImage';
+import SimpleBox from '@/components/SimpleBox';
+import { haveV1MonitoringWorkloads } from '@/utils/monitoring';
+
+const CATTLE_MONITORING_NAMESPACE = 'cattle-monitoring-system';
+
+export default {
+  components: {
+    Banner,
+    LazyImage,
+    SimpleBox,
+    AlertTable
+  },
+
+  middleware: InstallRedirect(NAME, CHART_NAME),
+
+  async fetch() {
+    await this.fetchDeps();
+  },
+
+  data() {
+    const grafanaSrc = require('~/assets/images/vendor/grafana.svg');
+    const prometheusSrc = require('~/assets/images/vendor/prometheus.svg');
+    const currentCluster = this.$store.getters['currentCluster'];
+
+    return {
+      availableLinks: {
+        alertmanager: false,
+        grafana:      false,
+        prometheus:   false,
+      },
+      resources:     [MONITORING.ALERTMANAGER, MONITORING.PROMETHEUS],
+      v1Installed:   false,
+      externalLinks: [
+        {
+          enabled:     false,
+          group:       'alertmanager',
+          iconSrc:     prometheusSrc,
+          label:       'monitoring.overview.linkedList.alertManager.label',
+          description:
+            'monitoring.overview.linkedList.alertManager.description',
+          link: `/k8s/clusters/${ currentCluster.id }/api/v1/namespaces/cattle-monitoring-system/services/http:rancher-monitoring-alertmanager:9093/proxy`,
+        },
+        {
+          enabled:     false,
+          group:       'grafana',
+          iconSrc:     grafanaSrc,
+          label:       'monitoring.overview.linkedList.grafana.label',
+          description: 'monitoring.overview.linkedList.grafana.description',
+          link:        `/k8s/clusters/${ currentCluster.id }/api/v1/namespaces/cattle-monitoring-system/services/http:rancher-monitoring-grafana:80/proxy`,
+        },
+        {
+          enabled:     false,
+          group:       'prometheus',
+          iconSrc:     prometheusSrc,
+          label:       'monitoring.overview.linkedList.prometheusPromQl.label',
+          description:
+            'monitoring.overview.linkedList.prometheusPromQl.description',
+          link: `/k8s/clusters/${ currentCluster.id }/api/v1/namespaces/cattle-monitoring-system/services/http:rancher-monitoring-prometheus:9090/proxy/graph`,
+        },
+        {
+          enabled:     false,
+          group:       'prometheus',
+          iconSrc:     prometheusSrc,
+          label:       'monitoring.overview.linkedList.prometheusRules.label',
+          description:
+            'monitoring.overview.linkedList.prometheusRules.description',
+          link: `/k8s/clusters/${ currentCluster.id }/api/v1/namespaces/cattle-monitoring-system/services/http:rancher-monitoring-prometheus:9090/proxy/rules`,
+        },
+        {
+          enabled:     false,
+          group:       'prometheus',
+          iconSrc:     prometheusSrc,
+          label:       'monitoring.overview.linkedList.prometheusTargets.label',
+          description:
+            'monitoring.overview.linkedList.prometheusTargets.description',
+          link: `/k8s/clusters/${ currentCluster.id }/api/v1/namespaces/cattle-monitoring-system/services/http:rancher-monitoring-prometheus:9090/proxy/targets`,
+        },
+      ]
+    };
+  },
+
+  methods: {
+    async fetchDeps() {
+      const { $store, externalLinks } = this;
+
+      this.v1Installed = await haveV1MonitoringWorkloads($store);
+
+      const hash = await allHash({ endpoints: $store.dispatch('cluster/findAll', { type: ENDPOINTS }) });
+
+      if (!isEmpty(hash.endpoints)) {
+        const amMatch = findBy(externalLinks, 'group', 'alertmanager');
+        const grafanaMatch = findBy(externalLinks, 'group', 'grafana');
+        const promeMatch = externalLinks.filter(
+          el => el.group === 'prometheus'
+        );
+        const alertmanager = findBy(
+          hash.endpoints,
+          'id',
+          `${ CATTLE_MONITORING_NAMESPACE }/rancher-monitoring-alertmanager`
+        );
+        const grafana = findBy(
+          hash.endpoints,
+          'id',
+          `${ CATTLE_MONITORING_NAMESPACE }/rancher-monitoring-grafana`
+        );
+        const prometheus = findBy(
+          hash.endpoints,
+          'id',
+          `${ CATTLE_MONITORING_NAMESPACE }/rancher-monitoring-prometheus`
+        );
+
+        if (!isEmpty(alertmanager) && !isEmpty(alertmanager.subsets)) {
+          amMatch.enabled = true;
+        }
+        if (!isEmpty(grafana) && !isEmpty(grafana.subsets)) {
+          grafanaMatch.enabled = true;
+        }
+        if (!isEmpty(prometheus) && !isEmpty(prometheus.subsets)) {
+          promeMatch.forEach((match) => {
+            match.enabled = true;
+          });
+        }
+      }
+    },
+  },
+};
+</script>
+
+<template>
+  <section>
+    <header class="row">
+      <div class="col span-12">
+        <h1>
+          <t k="monitoring.overview.title" />
+        </h1>
+        <div>
+          <t k="monitoring.overview.subtitle" :raw="true" />
+        </div>
+      </div>
+    </header>
+    <div>
+      <Banner v-if="v1Installed" color="warning">
+        <template #default>
+          <t k="monitoring.v1Warning" :raw="true" />
+        </template>
+      </Banner>
+      <div class="create-resource-container">
+        <div class="subtypes-container">
+          <a
+            v-for="fel in externalLinks"
+            :key="fel.label"
+            v-tooltip="
+              !fel.enabled ? t('monitoring.overview.linkedList.na') : undefined
+            "
+            :href="fel.enabled ? fel.link : void 0"
+            :disabled="!fel.enabled"
+            target="_blank"
+            rel="noopener noreferrer"
+            :class="{ 'subtype-banner': true, disabled: !fel.enabled }"
+          >
+            <div class="subtype-content">
+              <div class="title">
+                <div class="subtype-logo round-image">
+                  <LazyImage :src="fel.iconSrc" />
+                </div>
+                <h5>
+                  <span>
+                    <t :k="fel.label" />
+                  </span>
+                </h5>
+                <div class="flex-right">
+                  <i class="icon icon-external-link" />
+                </div>
+              </div>
+              <hr />
+              <div class="description">
+                <span>
+                  <t :k="fel.description" />
+                </span>
+              </div>
+            </div>
+          </a>
+        </div>
+      </div>
+    </div>
+    <div>
+      <SimpleBox
+        class="mt-30"
+        :title="t('monitoring.overview.alertsList.label')"
+      >
+        <AlertTable />
+      </SimpleBox>
+    </div>
+  </section>
+</template>