1 files changed, 34 insertions, 2 deletions
diff --git a/sdc-workflow-designer-ui/src/app/services/workflow.service.ts b/sdc-workflow-designer-ui/src/app/services/workflow.service.ts
index c1eed4af..3f42fa26 100644
--- a/sdc-workflow-designer-ui/src/app/services/workflow.service.ts
+++ b/sdc-workflow-designer-ui/src/app/services/workflow.service.ts
@@ -14,6 +14,8 @@ import { Injectable } from '@angular/core';
 import { DataAccessService } from "./data-access/data-access.service";
 import { Observable } from "rxjs/Observable";
 import { Workflow } from "../model/workflow/workflow";
+import { Configs } from "../model/workflow/configs";
+import { BroadcastService } from "./broadcast.service";
 
 /**
  * WorkflowService
@@ -22,10 +24,16 @@ import { Workflow } from "../model/workflow/workflow";
 @Injectable()
 export class WorkflowService {
 
+    public workflows: Workflow[];
     public workflow: Workflow;
+    public workflowIndex = 0;
 
-    constructor(private dataAccessService: DataAccessService) {
-
+    constructor(private broadcastService: BroadcastService, private dataAccessService: DataAccessService) {
+        this.dataAccessService.catalogService.loadWorkflows().subscribe(workflows => {
+            this.workflows = workflows;
+            this.broadcastWorkflows();
+        });
+        this.broadcastService.workflow.subscribe(workflow => this.workflow = workflow);
     }
 
     public save(): Observable<boolean> {
@@ -33,4 +41,28 @@ export class WorkflowService {
         console.log(JSON.stringify(this.workflow));
         return this.dataAccessService.catalogService.saveWorkflow(this.workflow);
     }
+
+    public getWorkflows(): Workflow[] {
+        return this.workflows;
+    }
+
+    public addWorkflow() {
+        this.workflows.push(new Workflow('wf' + this.workflowIndex, '', [], new Configs([])));
+        this.workflowIndex++;
+        this.broadcastWorkflows();
+    }
+
+    public deleteWorkflow(workflowName: string): Workflow {
+        const index = this.workflows.findIndex(workflow => (workflow.name === workflowName));
+        if(index !== -1) {
+            return this.workflows.splice(index, 1)[0];
+        }
+        this.broadcastWorkflows();
+
+        return undefined;
+    }
+
+    public broadcastWorkflows() {
+        this.broadcastService.broadcast(this.broadcastService.workflows, this.workflows);
+    }
 }