make pipelines editable

Author: mms-gianni

client/src/components/pipelines/new.vue

@@ -194,6 +194,7 @@ export default {
     },
     data: () => ({
       newPipeline: true,
+      resourceVersion: undefined,
       repotab: 'github', //selected tab
       buildpack: undefined,
       buildpackList: [],
@@ -437,6 +438,8 @@ export default {
           .then(response => {
             this.newPipeline = false;
             const p = response.data;
+
+            this.resourceVersion = p.resourceVersion;
             this.pipelineName = p.name;
             this.domain = p.domain;
             this.gitrepo = p.git.repository.ssh_url;
@@ -490,6 +493,7 @@ export default {
       },
       updatePipeline() {
         axios.put(`/api/pipelines/${this.pipeline}`, {
+          resourceVersion: this.resourceVersion,
           pipelineName: this.pipelineName,
           domain: this.domain,
           gitrepo: this.gitrepo,

src/kubero.ts

@@ -128,7 +128,7 @@ export class Kubero {
 
     // creates a new pipeline in the same namespace as the kubero app
     public async newPipeline(pipeline: IPipeline) {
-        debug.debug('create newPipeline: '+pipeline.name);
+        debug.debug('create Pipeline: '+pipeline.name);
 
         // Create the Pipeline CRD
         await this.kubectl.createPipeline(pipeline);
@@ -140,6 +140,21 @@ export class Kubero {
         this._io.emit('updatedPipelines', "created");
     }
 
+    // updates a new pipeline in the same namespace as the kubero app
+    public async updatePipeline(pipeline: IPipeline, resourceVersion: string) {
+        debug.debug('update Pipeline: '+pipeline.name);
+
+        // Create the Pipeline CRD
+        await this.kubectl.updatePipeline(pipeline, resourceVersion);
+        this.updateState();
+
+        this.kubectl.createEvent('Normal', 'Updated', 'pipeline.updated', 'updated pipeline: '+pipeline.name);
+
+        // update agents
+        this._io.emit('updatedPipelines', "updated");
+    }
+
+
     public async listPipelines(): Promise<IPipelineList> {
         debug.debug('listPipelines');
         let pipelines = await this.kubectl.getPipelinesList();
@@ -162,6 +177,7 @@ export class Kubero {
         });
 
         if (pipeline) {
+            pipeline.spec.resourceVersion = pipeline.metadata.resourceVersion;
             return pipeline.spec;
         }
     }

src/modules/kubectl.ts

@@ -103,7 +103,6 @@ export class Kubectl {
         return pipelines.body as IKubectlPipelineList;
     }
 
-
     public async createPipeline(pl: IPipeline) {
         debug.log("create pipeline: " + pl.name);
         let pipeline = new KubectlPipeline(pl);
@@ -120,6 +119,24 @@ export class Kubectl {
         });
     }
 
+    public async updatePipeline(pl: IPipeline, resourceVersion: string ) {
+        debug.log("update pipeline: " + pl.name);
+        let pipeline = new KubectlPipeline(pl);
+        pipeline.metadata.resourceVersion = resourceVersion;
+
+        this.kc.setCurrentContext(process.env.KUBERO_CONTEXT || 'default');
+        await this.customObjectsApi.replaceNamespacedCustomObject(
+            "application.kubero.dev",
+            "v1alpha1",
+            process.env.KUBERO_NAMESPACE || 'kubero',
+            "kuberopipelines",
+            pl.name,
+            pipeline
+        ).catch(error => {
+            debug.log(error);
+        });
+    }
+
     public async deletePipeline(pipelineName: string) {
         debug.log("delete pipeline: " + pipelineName);
         this.kc.setCurrentContext(process.env.KUBERO_CONTEXT || 'default');

src/routes/pipelines.ts

@@ -67,6 +67,25 @@ Router.post('/pipelines',authMiddleware, async function (req: Request, res: Resp
     res.send("new");
 });
 
+
+Router.put('/pipelines/:pipeline',authMiddleware, async function (req: Request, res: Response) {
+    // #swagger.tags = ['UI']
+    // #swagger.summary = 'Edit a pipeline'
+    // #swagger.parameters['body'] = { in: 'body', description: 'Pipeline object', required: true, type: 'object' }
+    let pipeline: IPipeline = {
+        name: req.body.pipelineName,
+        domain: req.body.domain,
+        phases: req.body.phases,
+        buildpack: req.body.buildpack,
+        reviewapps: req.body.reviewapps,
+        git: req.body.git,
+        dockerimage: req.body.dockerimage,
+        deploymentstrategy: req.body.deploymentstrategy,
+    };
+    req.app.locals.kubero.updatePipeline(pipeline, req.body.resourceVersion);
+    res.send("new");
+});
+
 Router.get('/cli/pipelines', bearerMiddleware, async function (req: Request, res: Response) {
     // #swagger.tags = ['Pipeline']
     // #swagger.summary = 'Get a list of available pipelines'

src/types.ts

@@ -145,6 +145,7 @@ export interface IPipeline {
     };
     dockerimage: string;
     deploymentstrategy: 'git' | 'docker',
+    resourceVersion?: string; // required to update resource, not part of spec
 }
 
 export interface IPipelineList {