CONSOLE-4806: Remove static extensions from knative-plugin

frontend/packages/console-dynamic-plugin-sdk/docs/console-extensions.md

@@ -1158,7 +1158,7 @@ Topology Data Model Factory Extension
 | ---- | ---------- | -------- | ----------- |
 | `id` | `string` | no | Unique ID for the factory. |
 | `priority` | `number` | no | Priority for the factory |
-| `resources` | `WatchK8sResourcesGeneric` | yes | Resources to be fetched from useK8sWatchResources hook. |
+| `resources` | `WatchK8sResourcesGeneric \| CodeRef<() => Promise<WatchK8sResourcesGeneric>>` | yes | Resources to be fetched from useK8sWatchResources hook. |
 | `workloadKeys` | `string[]` | yes | Keys in resources containing workloads. |
 | `getDataModel` | `CodeRef<TopologyDataModelGetter>` | yes | Getter for the data model factory |
 | `isResourceDepicted` | `CodeRef<TopologyDataModelDepicted>` | yes | Getter for function to determine if a resource is depicted by this model factory |

frontend/packages/console-dynamic-plugin-sdk/src/extensions/topology.ts

@@ -41,7 +41,7 @@ export type TopologyDataModelFactory = ExtensionDeclaration<
     /** Priority for the factory */
     priority: number;
     /** Resources to be fetched from useK8sWatchResources hook. */
-    resources?: WatchK8sResourcesGeneric;
+    resources?: WatchK8sResourcesGeneric | CodeRef<() => Promise<WatchK8sResourcesGeneric>>;
     /** Keys in resources containing workloads. */
     workloadKeys?: string[];
     /** Getter for the data model factory */

frontend/packages/knative-plugin/console-extensions.json

@@ -2008,5 +2008,71 @@
     "flags": {
       "required": ["KNATIVE_EVENTING"]
     }
+  },
+  {
+    "type": "console.topology/data/factory",
+    "properties": {
+      "id": "knative-serving-topology-model-factory",
+      "priority": 100,
+      "resources": {
+        "$codeRef": "getKnativeResources.getKnativeServingResources"
+      },
+      "workloadKeys": ["ksservices"],
+      "getDataModel": {
+        "$codeRef": "dataTransformer.getKnativeServingTopologyDataModel"
+      },
+      "isResourceDepicted": {
+        "$codeRef": "isKnativeResource.isKnativeResource"
+      }
+    },
+    "flags": {
+      "required": [
+        "KNATIVE_SERVING_CONFIGURATION",
+        "KNATIVE_SERVING",
+        "KNATIVE_SERVING_REVISION",
+        "KNATIVE_SERVING_ROUTE",
+        "KNATIVE_SERVING_SERVICE"
+      ]
+    }
+  },
+  {
+    "type": "console.topology/data/factory",
+    "properties": {
+      "id": "knative-eventing-topology-model-factory",
+      "priority": 100,
+      "resources": {
+        "$codeRef": "getKnativeResources.getKnativeEventingResources"
+      },
+      "workloadKeys": ["eventingsubscription"],
+      "getDataModel": {
+        "$codeRef": "dataTransformer.getKnativeEventingTopologyDataModel"
+      },
+      "isResourceDepicted": {
+        "$codeRef": "isKnativeResource.isKnativeResource"
+      }
+    },
+    "flags": {
+      "required": ["KNATIVE_EVENTING", "FLAG_KNATIVE_EVENTING_ENABLED"]
+    }
+  },
+  {
+    "type": "console.topology/data/factory",
+    "properties": {
+      "id": "knative-kamelets-topology-model-factory",
+      "priority": 100,
+      "resources": {
+        "$codeRef": "getKnativeResources.getKnativeEventingKameletsResources"
+      },
+      "workloadKeys": ["kameletbindings"],
+      "getDataModel": {
+        "$codeRef": "dataTransformer.getKnativeKameletsTopologyDataModel"
+      },
+      "isResourceDepicted": {
+        "$codeRef": "isKnativeResource.isKnativeResource"
+      }
+    },
+    "flags": {
+      "required": ["KNATIVE_EVENTING", "FLAG_CAMEL_KAMELETS"]
+    }
   }
 ]

frontend/packages/knative-plugin/package.json

@@ -14,7 +14,7 @@
     "@console/topology": "0.0.0-fixed"
   },
   "consolePlugin": {
-    "entry": "src/plugin.tsx",
+    "entry": "src/plugin.ts",
     "exposedModules": {
       "actions": "src/actions/providers.ts",
       "icons": "src/utils/icons.tsx",
@@ -65,7 +65,9 @@
       "fetchDynamicEventSourcesUtils": "src/utils/fetch-dynamic-eventsources-utils.ts",
       "EventSourceBreadcrumbs": "src/providers/useEventSourceDetailPageBreadcrumbs.ts",
       "ChannelBreadcrumbs": "src/providers/useChannelDetailPageBreadcrumbs.ts",
-      "BrokerBreadcrumbs": "src/providers/useBrokerDetailPageBreadcrumbs.ts"
+      "BrokerBreadcrumbs": "src/providers/useBrokerDetailPageBreadcrumbs.ts",
+      "getKnativeResources": "src/utils/get-knative-resources.ts",
+      "isKnativeResource": "src/topology/isKnativeResource.ts"
     }
   }
 }

frontend/packages/knative-plugin/src/plugin.ts

@@ -0,0 +1,2 @@
+// See console-extensions.json instead
+export default [];

frontend/packages/knative-plugin/src/utils/get-knative-resources.ts

@@ -21,10 +21,7 @@ import {
   KafkaConnectionModel,
 } from '../models';
 import { Traffic } from '../types';
-import {
-  getDynamicEventSourcesWatchers,
-  getDynamicEventingChannelWatchers,
-} from './fetch-dynamic-eventsources-utils';
+import { fetchEventSourcesCrd, fetchChannelsCrd } from './fetch-dynamic-eventsources-utils';
 
 export type KnativeItem = {
   revisions?: K8sResourceKind[];
@@ -438,31 +435,87 @@ export const getSinkableResources = (namespace: string): FirehoseResource[] => {
     : [];
 };
 
-export const getKnativeServingResources = (namespace: string) => {
-  return {
-    ...knativeServingResourcesRevisionWatchers(namespace),
-    ...knativeServingResourcesConfigurationsWatchers(namespace),
-    ...knativeServingResourcesRoutesWatchers(namespace),
-    ...knativeServingResourcesServicesWatchers(namespace),
-    ...knativeCamelDomainMappingResourceWatchers(namespace),
-  };
-};
+export const getKnativeServingResources = () =>
+  Promise.resolve({
+    revisions: {
+      model: { group: 'serving.knative.dev', version: 'v1', kind: 'Revision' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    configurations: {
+      model: { group: 'serving.knative.dev', version: 'v1', kind: 'Configuration' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    ksroutes: {
+      model: { group: 'serving.knative.dev', version: 'v1', kind: 'Route' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    ksservices: {
+      model: { group: 'serving.knative.dev', version: 'v1', kind: 'Service' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    domainmappings: {
+      model: { group: 'serving.knative.dev', version: 'v1beta1', kind: 'DomainMapping' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+  });
+
+export const getKnativeEventingResources = async () => {
+  // Fetch dynamic event sources and channels at runtime
+  const eventSourceModels = await fetchEventSourcesCrd();
+  const eventingChannels = await fetchChannelsCrd();
+
+  const dynamicEventSources = eventSourceModels.reduce((acc, model) => {
+    const ref = referenceForModel(model);
+    acc[ref] = {
+      model: { group: model.apiGroup, version: model.apiVersion, kind: model.kind },
+      opts: { isList: true, optional: true, namespaced: true },
+    };
+    return acc;
+  }, {});
+
+  const dynamicChannels = eventingChannels.reduce((acc, model) => {
+    const ref = referenceForModel(model);
+    acc[ref] = {
+      model: { group: model.apiGroup, version: model.apiVersion, kind: model.kind },
+      opts: { isList: true, optional: true, namespaced: true },
+    };
+    return acc;
+  }, {});
 
-export const getKnativeEventingResources = (namespace: string) => {
   return {
-    ...knativeEventingResourcesSubscriptionWatchers(namespace),
-    ...getDynamicEventSourcesWatchers(namespace),
-    ...getDynamicEventingChannelWatchers(namespace),
-    ...knativeEventingBrokerResourceWatchers(namespace),
-    ...knativeEventingTriggerResourceWatchers(namespace),
+    eventingsubscription: {
+      model: { group: 'messaging.knative.dev', version: 'v1', kind: 'Subscription' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    brokers: {
+      model: { group: 'eventing.knative.dev', version: 'v1', kind: 'Broker' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    triggers: {
+      model: { group: 'eventing.knative.dev', version: 'v1', kind: 'Trigger' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    ...dynamicEventSources,
+    ...dynamicChannels,
   };
 };
 
-export const getKnativeEventingKameletsResources = (namespace: string) => {
-  return {
-    ...knativeCamelIntegrationsResourceWatchers(namespace),
-    ...knativeCamelKameletBindingResourceWatchers(namespace),
-    ...knativeCamelDomainMappingResourceWatchers(namespace),
-    ...knativeCamelKameletResourceWatchers(namespace),
-  };
-};
+export const getKnativeEventingKameletsResources = () =>
+  Promise.resolve({
+    integrations: {
+      model: { group: 'camel.apache.org', version: 'v1', kind: 'Integration' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    kameletbindings: {
+      model: { group: 'camel.apache.org', version: 'v1alpha1', kind: 'KameletBinding' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    domainmappings: {
+      model: { group: 'serving.knative.dev', version: 'v1beta1', kind: 'DomainMapping' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+    kamelets: {
+      model: { group: 'camel.apache.org', version: 'v1alpha1', kind: 'Kamelet' },
+      opts: { isList: true, optional: true, namespaced: true },
+    },
+  });