+++ /dev/null
-/**\r
- * Copyright (c) 2017 ZTE Corporation.\r
- * All rights reserved. This program and the accompanying materials\r
- * are made available under the terms of the Eclipse Public License v1.0\r
- * and the Apache License 2.0 which both accompany this distribution,\r
- * and are available at http://www.eclipse.org/legal/epl-v10.html\r
- * and http://www.apache.org/licenses/LICENSE-2.0\r
- *\r
- * Contributors:\r
- * ZTE - initial API and implementation and/or initial documentation\r
- */\r
-\r
-import { Injectable } from '@angular/core';\r
-import { WorkflowNode } from "../model/workflow/workflow-node";\r
-import { PlanModel } from "../model/workflow/plan-model";\r
-import { Position } from "../model/workflow/position";\r
-import { NodeType } from "../model/workflow/node-type.enum";\r
-import { StartEvent } from "../model/workflow/start-event";\r
-import { SequenceFlow } from "../model/workflow/sequence-flow";\r
-import { RestTask } from "../model/workflow/rest-task";\r
-import { PlanTreeviewItem } from "../model/plan-treeview-item";\r
-import { WorkflowConfigService } from "./workflow-config.service";\r
-import { Swagger, SwaggerModelSimple, SwaggerReferenceObject } from "../model/swagger";\r
-import { WorkflowService } from "./workflow.service";\r
-import { IntermediateCatchEvent } from "../model/workflow/intermediate-catch-event";\r
-import { ScriptTask } from "../model/workflow/script-task";\r
-\r
-/**\r
- * WorkflowService\r
- * provides all of the operations about workflow operations.\r
- */\r
-@Injectable()\r
-export class WorkflowProcessService {\r
-\r
- constructor(private workflowService: WorkflowService, private configService: WorkflowConfigService) {\r
-\r
- }\r
-\r
- public getProcess(): WorkflowNode[] {\r
- return this.workflowService.planModel.nodes;\r
- }\r
-\r
- public addNode(name: string, type: string, top: number, left: number): WorkflowNode {\r
- let node: WorkflowNode;\r
- switch (type) {\r
- case NodeType[NodeType.startEvent]:\r
- node = new StartEvent(this.createId(), name, type, new Position(top, left), []);\r
- break;\r
- case NodeType[NodeType.restTask]:\r
- node = new RestTask(this.createId(), name, type, new Position(top, left), []);\r
- break;\r
- case NodeType[NodeType.intermediateCatchEvent]:\r
- node = new IntermediateCatchEvent(this.createId(), name, type, new Position(top, left), []);\r
- break;\r
- case NodeType[NodeType.scriptTask]:\r
- node = new ScriptTask(this.createId(), name, type, new Position(top, left), []);\r
- break;\r
- default:\r
- node = new WorkflowNode(this.createId(), name, type, new Position(top, left), []);\r
- break;\r
- }\r
-\r
- this.getProcess().push(node);\r
- return node;\r
- }\r
-\r
- public deleteNode(nodeId: string): WorkflowNode {\r
- // delete related connections\r
- this.getProcess().forEach(node => this.deleteSequenceFlow(node.id, nodeId));\r
-\r
- // delete current node\r
- const index = this.getProcess().findIndex(node => node.id === nodeId);\r
- if (index !== -1) {\r
- const node = this.getProcess().splice(index, 1)[0];\r
- node.sequenceFlows = [];\r
- return node;\r
- }\r
-\r
- return undefined;\r
- }\r
-\r
- public addSequenceFlow(sourceId: string, targetId: string) {\r
- const node = this.getNodeById(sourceId);\r
- if (node) {\r
- const index = node.sequenceFlows.findIndex(sequenceFlow => sequenceFlow.targetRef === targetId);\r
- if (index === -1) {\r
- node.sequenceFlows.push(new SequenceFlow(sourceId, targetId));\r
- }\r
- }\r
- }\r
-\r
- public deleteSequenceFlow(sourceId: string, targetId: string) {\r
- const node = this.getNodeById(sourceId);\r
- if (node) {\r
- const index = node.sequenceFlows.findIndex(sequenceFlow => sequenceFlow.targetRef === targetId);\r
- if (index !== -1) {\r
- node.sequenceFlows.splice(index, 1);\r
- }\r
- }\r
- }\r
-\r
- public getSequenceFlow(sourceRef: string, targetRef: string): SequenceFlow {\r
- const node = this.getNodeById(sourceRef);\r
- if (node) {\r
- const sequenceFlow = node.sequenceFlows.find(tmp => tmp.targetRef === targetRef);\r
- return sequenceFlow;\r
- } else {\r
- return undefined;\r
- }\r
- }\r
-\r
- public getPlanParameters(nodeId: string): PlanTreeviewItem[] {\r
- const preNodeList = new Array<WorkflowNode>();\r
- this.getPreNodes(nodeId, preNodeList);\r
-\r
- return this.loadNodeOutputs(preNodeList);\r
- }\r
-\r
- private loadNodeOutputs(nodes: WorkflowNode[]): PlanTreeviewItem[] {\r
- const params = new Array<PlanTreeviewItem>();\r
- nodes.forEach(node => {\r
- switch (node.type) {\r
- case NodeType[NodeType.startEvent]:\r
- params.push(this.loadOutput4StartEvent(<StartEvent>node));\r
- break;\r
- case NodeType[NodeType.restTask]:\r
- params.push(this.loadOutput4RestTask(<RestTask>node));\r
- break;\r
- default:\r
- break;\r
- }\r
- });\r
-\r
- return params;\r
- }\r
-\r
- private loadOutput4StartEvent(node: StartEvent): PlanTreeviewItem {\r
- const startItem = new PlanTreeviewItem(node.name, `[${node.id}]`, []);\r
- node.parameters.map(param =>\r
- startItem.children.push(new PlanTreeviewItem(param.name, `[${param.name}]`, [])));\r
- return startItem;\r
- }\r
-\r
- private loadOutput4RestTask(node: RestTask): PlanTreeviewItem {\r
- const item = new PlanTreeviewItem(node.name, `[${node.id}]`, []);\r
- item.children.push(this.createStatusCodeTreeViewItem(node.id));\r
-\r
- if (node.responses.length !== 0) { // load rest responses\r
- const responseItem = this.createResponseTreeViewItem(node.id);\r
- item.children.push(responseItem);\r
- if (node.responses[0]) {\r
- const swagger = this.configService.getSwaggerInfo(node.serviceName, node.serviceVersion);\r
- const swaggerDefinition = this.configService.getDefinition(swagger, node.responses[0].schema.$ref);\r
- this.loadParamsBySwaggerDefinition(responseItem, swagger, <SwaggerModelSimple>swaggerDefinition);\r
- }\r
- }\r
-\r
- return item;\r
- }\r
-\r
- private createStatusCodeTreeViewItem(nodeId: string): PlanTreeviewItem {\r
- return new PlanTreeviewItem('statusCode', `[${nodeId}].[statusCode]`, []);\r
- }\r
-\r
- private createResponseTreeViewItem(nodeId: string): PlanTreeviewItem {\r
- return new PlanTreeviewItem('response', `[${nodeId}].[responseBody]`, []);\r
- }\r
-\r
- private loadParamsBySwaggerDefinition(parentItem: PlanTreeviewItem, swagger: Swagger, definition: SwaggerModelSimple) {\r
- Object.getOwnPropertyNames(definition.properties).map(key => {\r
- const property = definition.properties[key];\r
- const value = `${parentItem.value}.[${key}]`;\r
- const propertyItem = new PlanTreeviewItem(key, value, []);\r
- parentItem.children.push(propertyItem);\r
-\r
- if (property instanceof SwaggerReferenceObject) {\r
- const propertyDefinition = this.configService.getDefinition(swagger, property.$ref);\r
- this.loadParamsBySwaggerDefinition(propertyItem, swagger,\r
- <SwaggerModelSimple>propertyDefinition);\r
- }\r
-\r
- return propertyItem;\r
- });\r
- }\r
-\r
- public getPreNodes(nodeId: string, preNodes: WorkflowNode[]) {\r
- const preNode4CurrentNode = [];\r
- this.getProcess().forEach(node => {\r
- if (this.isPreNode(node, nodeId)) {\r
- const existNode = preNodes.find(tmpNode => tmpNode.id === node.id);\r
- if (existNode) {\r
- // current node already exists in preNodes. this could avoid loop circle.\r
- } else {\r
- preNode4CurrentNode.push(node);\r
- preNodes.push(node);\r
- }\r
- }\r
- });\r
-\r
- preNode4CurrentNode.forEach(node => this.getPreNodes(node.id, preNodes));\r
- }\r
-\r
- public isPreNode(preNode: WorkflowNode, id: string): boolean {\r
- const targetNode = preNode.sequenceFlows.find(connection => connection.targetRef === id);\r
- return targetNode !== undefined;\r
- }\r
-\r
- public getNodeById(sourceId: string): WorkflowNode {\r
- return this.getProcess().find(node => node.id === sourceId);\r
- }\r
-\r
- private createId() {\r
- const idSet = new Set();\r
- this.getProcess().forEach(node => idSet.add(node.id));\r
-\r
- for (let i = 0; i < idSet.size; i++) {\r
- if (!idSet.has('node' + i)) {\r
- return 'node' + i;\r
- }\r
- }\r
-\r
- return 'node' + idSet.size;\r
- }\r
-}\r
Code Review / sdc / sdc-workflow-designer.git / commitdiff