Add migration for component/services deployed in active cluster (#1107)

Test if there are ServiceInstances and DeploymentConfigs created with previous odo releases. Ask for what to do when detected and update all odo created resources if requested to work with new version of odo.

Author: dgolovin

src/odo.ts

@@ -19,6 +19,8 @@ import * as odo from './odo/config';
 import { ComponentSettings } from './odo/config';
 import { GlyphChars } from './util/constants';
 import { Subject } from 'rxjs';
+import open = require('open');
+import { Progress } from './util/progress';
 
 const Collapsed = TreeItemCollapsibleState.Collapsed;
 
@@ -552,6 +554,10 @@ export class OdoImpl implements Odo {
         if (clusters.length === 0) {
             clusters = await this.getClustersWithOc();
         }
+        if (clusters.length > 0 && clusters[0].contextValue === ContextType.CLUSTER) {
+            // kick out migration
+            this.convertObjectsFromPreviousOdoReleases();
+        }
         return clusters;
     }
 
@@ -1075,4 +1081,53 @@ export class OdoImpl implements Odo {
         }
         return data;
     }
+
+    async convertObjectsFromPreviousOdoReleases() {
+        const getPreviosOdoResourceNames = (resourceId) => `oc get ${resourceId} -l app.kubernetes.io/component-name -o jsonpath="{range .items[*]}{.metadata.name}{\\"\\n\\"}{end}"`;
+        const result1 = await this.execute(getPreviosOdoResourceNames('dc'), __dirname, false);
+        const dcs = result1.stdout.split('\n');
+        const result2 = await this.execute(getPreviosOdoResourceNames('ServiceInstance'), __dirname, false);
+        const sis = result2.stdout.split('\n');
+        if ((result2.stdout !== '' && sis.length > 0) || (result1.stdout !== '' && dcs.length > 0))  {
+            const choice = await window.showWarningMessage(`Some of resources in cluster must be updated to work with latest release of OpenShift Connector Extension.`, 'Learn more...', 'Update', 'Cancel');
+            if (choice === 'Learn more...') {
+                open('https://github.com/redhat-developer/vscode-openshift-tools/wiki/Migration-to-v0.0.24');
+                this.subject.next(new OdoEventImpl('changed', this.getClusters()[0]));
+            } else if (choice === 'Update') {
+                const errors = [];
+                Progress.execFunctionWithProgress('Updating cluster resources to work with latest OpenShift Connector release', async (progress) => {
+                    for (const resourceId of  ['DeploymentConfig', 'Route', 'BuildConfig', 'ImageStream', 'Service', 'pvc', 'Secret', 'ServiceInstance']) {
+                        progress.report({increment: 100/8, message: resourceId});
+                        const cmd = getPreviosOdoResourceNames(resourceId);
+                        const result = await this.execute(cmd, __dirname, false);
+                        const resourceNames = result.error || result.stdout === '' ? [] : result.stdout.split('\n');
+                        for (const resourceName of resourceNames) {
+                            try {
+                                const result = await this.execute(`oc get ${resourceId} ${resourceName} -o json`);
+                                const labels = JSON.parse(result.stdout).metadata.labels;
+                                let command = `oc label ${resourceId} ${resourceName} --overwrite app.kubernetes.io/instance=${labels['app.kubernetes.io/component-name']}`;
+                                command = command + ` app.kubernetes.io/part-of=${labels['app.kubernetes.io/name']}`;
+                                if (labels['app.kubernetes.io/component-type']) {
+                                    command = command + ` app.kubernetes.io/name=${labels['app.kubernetes.io/component-type']}`;
+                                }
+                                if (labels['app.kubernetes.io/component-version']) {
+                                    command = command + ` app.openshift.io/runtime-version=${labels['app.kubernetes.io/component-version']}`;
+                                }
+                                await this.execute(command);
+                                await this.execute(`oc label ${resourceId} ${resourceName} app.kubernetes.io/component-name-`);
+                            } catch (err) {
+                                errors.push(err);
+                            }
+                        }
+                    }
+                    this.subject.next(new OdoEventImpl('changed', this.getClusters()[0]));
+                });
+                if (errors.length) {
+                    window.showErrorMessage('Not all resources were updates, please see log for details.');
+                } else {
+                    window.showInformationMessage('Cluster resources have been successfuly updated.');
+                }
+            }
+        }
+    }
 }

test/odo.test.ts

@@ -117,6 +117,7 @@ suite("odo", () => {
 
         setup(() => {
             execStub = sandbox.stub(odoCli, 'execute');
+            sandbox.stub(odo.OdoImpl.prototype, 'convertObjectsFromPreviousOdoReleases');
             yamlStub = sandbox.stub(jsYaml, 'safeLoad');
             sandbox.stub(fs, 'readFileSync');
         });

test/openshift/component.test.ts

@@ -63,6 +63,7 @@ suite('OpenShift/Component', () => {
         getApps = sandbox.stub(OpenShiftItem, 'getApplicationNames').resolves([appItem]);
         sandbox.stub(OpenShiftItem, 'getComponentNames').resolves([componentItem]);
         sandbox.stub(OpenShiftItem, 'getServiceNames').resolves([serviceItem]);
+        sandbox.stub(OdoImpl.prototype, 'convertObjectsFromPreviousOdoReleases');
     });
 
     teardown(() => {