Create route functionality added

build/esbuild.mjs

@@ -11,6 +11,7 @@ import * as fs from 'fs/promises';
 const webviews = [
     'cluster',
     'create-service',
+    'create-route',
     'create-component',
     'devfile-registry',
     'helm-chart',

package.json

@@ -177,6 +177,7 @@
 		"survey-core": "^1.10.3",
 		"survey-react-ui": "^1.10.5",
 		"typescript": "^5.4.5",
+		"valid-path": "^2.1.0",
 		"vscode-extension-tester": "^8.1",
 		"xterm-addon-fit": "^0.8.0",
 		"xterm-addon-web-links": "^0.9.0",
@@ -807,6 +808,11 @@
 				"title": "Create Operator-Backed Service",
 				"category": "OpenShift"
 			},
+			{
+				"command": "openshift.route.create",
+				"title": "Create Route",
+				"category": "OpenShift"
+			},
 			{
 				"command": "openshift.deployment.create.fromImageUrl",
 				"title": "Create Deployment from Container Image URL",
@@ -1626,6 +1632,11 @@
 					"when": "view == openshiftProjectExplorer && isLoggedIn && viewItem =~ /openshift.project.*/i && showCreateService",
 					"group": "c2"
 				},
+				{
+					"command": "openshift.route.create",
+					"when": "view == openshiftProjectExplorer && isLoggedIn && viewItem =~ /openshift.project.*/i && showCreateRoute",
+					"group": "c2"
+				},
 				{
 					"command": "openshift.deployment.create.fromImageUrl",
 					"when": "view == openshiftProjectExplorer && isLoggedIn && viewItem =~ /openshift.project.*/i",

src/explorer.ts

@@ -27,15 +27,15 @@ import * as Helm from './helm/helm';
 import { HelmRepo } from './helm/helmChartType';
 import { Oc } from './oc/ocWrapper';
 import { Component } from './openshift/component';
-import { getServiceKindStubs } from './openshift/serviceHelpers';
+import { getServiceKindStubs, getServices } from './openshift/serviceHelpers';
 import { PortForward } from './port-forward';
 import { KubeConfigUtils, getKubeConfigFiles, getNamespaceKind } from './util/kubeUtils';
 import { LoginUtil } from './util/loginUtil';
 import { Platform } from './util/platform';
 import { Progress } from './util/progress';
 import { FileContentChangeNotifier, WatchUtil } from './util/watch';
 import { vsCommand } from './vscommand';
-import { CustomResourceDefinitionStub } from './webview/common/createServiceTypes';
+import { CustomResourceDefinitionStub, K8sResourceKind } from './webview/common/createServiceTypes';
 import { OpenShiftTerminalManager } from './webview/openshift-terminal/openShiftTerminal';
 import { getOutputFormat, helmfsUri, kubefsUri } from './k8s/vfs/kuberesources.virtualfs';
 
@@ -355,6 +355,16 @@ export class OpenShiftExplorer implements TreeDataProvider<ExplorerItem>, Dispos
                 // operator framework is not installed on cluster; do nothing
             }
             void commands.executeCommand('setContext', 'showCreateService', serviceKinds.length > 0);
+
+            // The 'Create Route' menu visibility
+            let services: K8sResourceKind[] = [];
+            try {
+                services = await getServices();
+            }
+            catch (_) {
+                // operator framework is not installed on cluster; do nothing
+            }
+            void commands.executeCommand('setContext', 'showCreateRoute', services.length > 0);
         } else if ('kind' in element && element.kind === 'helmContexts') {
             const helmRepos = {
                 kind: 'helmRepos',
@@ -411,6 +421,12 @@ export class OpenShiftExplorer implements TreeDataProvider<ExplorerItem>, Dispos
                     name: 'pods'
                 },
             } as OpenShiftObject;
+            const routes = {
+                kind: 'routes',
+                metadata: {
+                    name: 'routes'
+                },
+            } as OpenShiftObject;
             const statefulSets = {
                 kind: 'statefulsets',
                 metadata: {
@@ -453,7 +469,7 @@ export class OpenShiftExplorer implements TreeDataProvider<ExplorerItem>, Dispos
                     name: 'build configs'
                 },
             } as OpenShiftObject;
-            result.push(pods,
+            result.push(pods, routes,
                 statefulSets, daemonSets, jobs, cronJobs);
             if (isOpenshiftCluster) {
                 result.push(deploymentConfigs, imageStreams, buildConfigs);

src/extension.ts

@@ -101,6 +101,7 @@ export async function activate(extensionContext: ExtensionContext): Promise<unkn
             './openshift/project',
             './openshift/cluster',
             './openshift/service',
+            './openshift/route',
             './k8s/console',
             './yamlFileCommands',
             './registriesView',

src/k8s/olm/types.ts

@@ -352,4 +352,9 @@ export type CapabilityProps<C extends SpecCapability | StatusCapability> = {
   value: any;
 };
 
+export type Service = {
+    apiVersion: string;
+    items: K8sResourceKind[];
+}
+
 export type Error = { message: string };

src/k8s/route.ts

@@ -2,7 +2,6 @@
  *  Copyright (c) Red Hat, Inc. All rights reserved.
  *  Licensed under the MIT License. See LICENSE file in the project root for license information.
  *-----------------------------------------------------------------------------------------------*/
-
 import { KubeConfig } from '@kubernetes/client-node';
 import { commands, Uri } from 'vscode';
 import { Oc } from '../oc/ocWrapper';

src/oc/ocWrapper.ts

@@ -12,6 +12,7 @@ import { KubeConfigUtils } from '../util/kubeUtils';
 import { Platform } from '../util/platform';
 import { Project } from './project';
 import { ClusterType, KubernetesConsole } from './types';
+import validator from 'validator';
 
 /**
  * A wrapper around the `oc` CLI tool.
@@ -501,6 +502,37 @@ export class Oc {
             });
     }
 
+    public async createRoute(routeName: string, serviceName: string, hostName: string, path: string, port: { number: string, name: string, protocol: string },
+        isSecured: boolean): Promise<string> {
+        let cmdText: CommandText;
+        if (isSecured) {
+
+            cmdText = new CommandText('oc', `create route edge ${routeName}`, [
+                new CommandOption('--service', serviceName),
+                new CommandOption('--port', port.number),
+            ]);
+
+        } else {
+            cmdText = new CommandText('oc', `expose service ${serviceName.trim()}`, [
+                new CommandOption('--name', routeName),
+                new CommandOption('--port', port.number),
+                new CommandOption('--protocol', port.protocol)
+            ]);
+        }
+
+        if (!validator.isEmpty(hostName)) {
+            cmdText.addOption(new CommandOption('--hostname', hostName));
+        }
+
+        if (!validator.isEmpty(path)) {
+            cmdText.addOption(new CommandOption('--path', path));
+        }
+        return await CliChannel.getInstance().executeTool(
+            cmdText
+        )
+            .then((result) => result.stdout);
+    }
+
     /**
      * Changes which project is currently being used.
      *

src/openshift/nameValidator.ts

@@ -5,6 +5,7 @@
 
 import * as path from 'path';
 import validator from 'validator';
+import validPath = require('valid-path');
 
 export function emptyName(message: string, value: string): string | null {
     return validator.isEmpty(value) ? message : null;
@@ -22,6 +23,10 @@ export function validateMatches(message: string, value: string): string | null {
     return validator.matches(value, '^[a-z]([-a-z0-9]*[a-z0-9])*$') ? null : message;
 }
 
+export function validatePath(message: string, value: string): string | null {
+    return validPath(value).valid ? null : message;
+}
+
 export function validateFilePath(message: string, value: string): string | null {
     const proposedPath = path.parse(value);
     return /^devfile\.ya?ml$/i.test(proposedPath.base) ? null : message;

src/openshift/route.ts

@@ -0,0 +1,17 @@
+/*-----------------------------------------------------------------------------------------------
+ *  Copyright (c) Red Hat, Inc. All rights reserved.
+ *  Licensed under the MIT License. See LICENSE file in the project root for license information.
+ *-----------------------------------------------------------------------------------------------*/
+
+import { vsCommand } from '../vscommand';
+import CreateRouteViewLoader from '../webview/create-route/createRouteViewLoader';
+
+/**
+ * Wraps commands that are used for interacting with routes.
+ */
+export class Route {
+    @vsCommand('openshift.route.create')
+    static async createNewRoute() {
+        await CreateRouteViewLoader.loadView();
+    }
+}

src/openshift/serviceHelpers.ts

@@ -3,6 +3,7 @@
  *  Licensed under the MIT License. See LICENSE file in the project root for license information.
  *-----------------------------------------------------------------------------------------------*/
 
+import { K8sResourceKind } from '../k8s/olm/types';
 import { Oc } from '../oc/ocWrapper';
 import {
     ClusterServiceVersion,
@@ -21,3 +22,9 @@ export async function getServiceKindStubs(): Promise<CustomResourceDefinitionStu
         return serviceKinds;
     });
 }
+
+export async function getServices(): Promise<K8sResourceKind[]> {
+    return (await Oc.Instance.getKubernetesObjects(
+        'service'
+    )) as unknown as K8sResourceKind[];
+}

src/webview/common-ext/utils.ts

@@ -61,8 +61,8 @@ function isGitURL(host: string): boolean {
     ].includes(host);
 }
 
-export function validateURL(event: Message): validateURLProps {
-    if (typeof event.data === 'string' && (event.data).trim().length === 0) {
+export function validateURL(event: Message | { command: string; data: object }, isRequired = true): validateURLProps {
+    if (isRequired && typeof event.data === 'string' && (event.data).trim().length === 0) {
         return {
             url: event.data,
             error: true,
@@ -78,7 +78,7 @@ export function validateURL(event: Message): validateURLProps {
     return {
         url: event.data,
         error: false,
-        helpText: 'URL is valid'
+        helpText: !isRequired ? '' : 'URL is valid'
     } as validateURLProps
 }
 
@@ -119,13 +119,20 @@ export function validateGitURL(event: Message): validateURLProps {
 }
 
 export function validateName(value: string): string | null {
-    let validationMessage = NameValidator.emptyName('Required', value.trim());
+    let validationMessage = NameValidator.emptyName('Required', JSON.parse(value) as unknown as string);
     if (!validationMessage) {
         validationMessage = NameValidator.validateMatches(
             'Only lower case alphabets and numeric characters or \'-\', start and ends with only alphabets',
-            value,
+            JSON.parse(value) as unknown as string
         );
     }
     if (!validationMessage) { validationMessage = NameValidator.lengthName('Should be between 2-63 characters', value, 0); }
     return validationMessage;
 }
+
+export function validatePath(value: string): string | null {
+    return NameValidator.validatePath(
+        'Given path is not valid',
+        JSON.parse(value) as unknown as string
+    );
+}

src/webview/common/createServiceTypes.ts

@@ -64,3 +64,76 @@ export type SpecDescriptor = {
      */
     path: string;
 }
+
+export type OwnerReference = {
+    name: string;
+    kind: string;
+    uid: string;
+    apiVersion: string;
+    controller?: boolean;
+    blockOwnerDeletion?: boolean;
+};
+
+
+export type ObjectMetadata = {
+    annotations?: { [key: string]: string };
+    clusterName?: string;
+    creationTimestamp?: string;
+    deletionGracePeriodSeconds?: number;
+    deletionTimestamp?: string;
+    finalizers?: string[];
+    generateName?: string;
+    generation?: number;
+    labels?: { [key: string]: string };
+    managedFields?: any[];
+    name?: string;
+    namespace?: string;
+    ownerReferences?: OwnerReference[];
+    resourceVersion?: string;
+    uid?: string;
+};
+
+// Properties common to (almost) all Kubernetes resources.
+export type K8sResourceCommon = {
+    apiVersion?: string;
+    kind?: string;
+    metadata?: ObjectMetadata;
+};
+
+
+
+
+export type MatchExpression = {
+    key: string;
+    operator: 'Exists' | 'DoesNotExist' | 'In' | 'NotIn' | 'Equals' | 'NotEqual';
+    values?: string[];
+    value?: string;
+};
+
+export type MatchLabels = {
+    [key: string]: string;
+};
+
+export type Selector = {
+    matchLabels?: MatchLabels;
+    matchExpressions?: MatchExpression[];
+};
+
+export type Port = {
+    name: string;
+    port: string;
+    protocol: string;
+    targetPort: string;
+};
+
+// Generic, unknown kind. Avoid when possible since it allows any key in spec
+// or status, weakening type checking.
+export type K8sResourceKind = K8sResourceCommon & {
+    spec?: {
+        selector?: Selector | MatchLabels;
+        ports?: Port[];
+        [key: string]: any;
+    };
+    status?: { [key: string]: any };
+    data?: { [key: string]: any };
+};