From 7f4d1836df509a1a06e4b7635a84a71b79084d6e Mon Sep 17 00:00:00 2001 From: Lvbo163 Date: Thu, 7 Sep 2017 10:02:49 +0800 Subject: support quote output of rest task rest task's parameters can quote output parameter of previous rest tasks. Issue-ID: SDC-121 Change-Id: I94f2058f7b8b2ad600ffb99c8838b37da5bb5b9d Signed-off-by: Lvbo163 --- .../src/app/services/workflow-process.service.ts | 206 +++++++++++++++++++++ 1 file changed, 206 insertions(+) create mode 100644 sdc-workflow-designer-ui/src/app/services/workflow-process.service.ts (limited to 'sdc-workflow-designer-ui/src/app/services/workflow-process.service.ts') diff --git a/sdc-workflow-designer-ui/src/app/services/workflow-process.service.ts b/sdc-workflow-designer-ui/src/app/services/workflow-process.service.ts new file mode 100644 index 00000000..4c701ec3 --- /dev/null +++ b/sdc-workflow-designer-ui/src/app/services/workflow-process.service.ts @@ -0,0 +1,206 @@ +/** + * Copyright (c) 2017 ZTE Corporation. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * and the Apache License 2.0 which both accompany this distribution, + * and are available at http://www.eclipse.org/legal/epl-v10.html + * and http://www.apache.org/licenses/LICENSE-2.0 + * + * Contributors: + * ZTE - initial API and implementation and/or initial documentation + */ + +import { Injectable } from '@angular/core'; +import { WorkflowNode } from "../model/workflow/workflow-node"; +import { Workflow } from "../model/workflow/workflow"; +import { Position } from "../model/workflow/position"; +import { NodeType } from "../model/workflow/node-type.enum"; +import { StartEvent } from "../model/workflow/start-event"; +import { SequenceFlow } from "../model/workflow/sequence-flow"; +import { RestTask } from "../model/workflow/rest-task"; +import { PlanTreeviewItem } from "../model/plan-treeview-item"; +import { WorkflowConfigService } from "./workflow-config.service"; +import { Swagger, SwaggerModelSimple, SwaggerReferenceObject } from "../model/swagger"; +import { WorkflowService } from "./workflow.service"; + +/** + * WorkflowService + * provides all of the operations about workflow operations. + */ +@Injectable() +export class WorkflowProcessService { + + constructor(private workflowService: WorkflowService, private configService: WorkflowConfigService) { + + } + + public getProcess(): WorkflowNode[] { + return this.workflowService.workflow.nodes; + } + + public addNode(name: string, type: string, top: number, left: number): WorkflowNode { + let node: WorkflowNode; + switch (type) { + case NodeType[NodeType.startEvent]: + node = new StartEvent(this.createId(), name, type, new Position(top, left), []); + break; + case NodeType[NodeType.restTask]: + node = new RestTask(this.createId(), name, type, new Position(top, left), []); + break; + default: + node = new WorkflowNode(this.createId(), name, type, new Position(top, left), []); + break; + } + + this.getProcess().push(node); + return node; + } + + public deleteNode(nodeId: string): WorkflowNode { + // delete related connections + this.getProcess().forEach(node => this.deleteSequenceFlow(node.id, nodeId)); + + // delete current node + const index = this.getProcess().findIndex(node => node.id === nodeId); + if (index !== -1) { + const node = this.getProcess().splice(index, 1)[0]; + node.sequenceFlows = []; + return node; + } + + return undefined; + } + + public addSequenceFlow(sourceId: string, targetId: string) { + const node = this.getNodeById(sourceId); + if (node) { + const index = node.sequenceFlows.findIndex(sequenceFlow => sequenceFlow.targetRef === targetId); + if (index === -1) { + node.sequenceFlows.push(new SequenceFlow(sourceId, targetId)); + } + } + } + + public deleteSequenceFlow(sourceId: string, targetId: string) { + const node = this.getNodeById(sourceId); + if (node) { + const index = node.sequenceFlows.findIndex(sequenceFlow => sequenceFlow.targetRef === targetId); + if (index !== -1) { + node.sequenceFlows.splice(index, 1); + } + } + } + + public getPlanParameters(nodeId: string): PlanTreeviewItem[] { + const preNodeList = new Array(); + this.getPreNodes(nodeId, preNodeList); + + return this.loadNodeOutputs(preNodeList); + } + + private loadNodeOutputs(nodes: WorkflowNode[]): PlanTreeviewItem[] { + const params = new Array(); + nodes.forEach(node => { + switch (node.type) { + case NodeType[NodeType.startEvent]: + params.push(this.loadOutput4StartEvent(node)); + break; + case NodeType[NodeType.restTask]: + params.push(this.loadOutput4RestTask(node)); + break; + default: + break; + } + }); + + return params; + } + + private loadOutput4StartEvent(node: StartEvent): PlanTreeviewItem { + const startItem = new PlanTreeviewItem(node.name, `[${node.id}]`, []); + node.parameters.map(param => + startItem.children.push(new PlanTreeviewItem(param.name, `[${param.name}]`, []))); + return startItem; + } + + private loadOutput4RestTask(node: RestTask): PlanTreeviewItem { + const item = new PlanTreeviewItem(node.name, `[${node.id}]`, []); + item.children.push(this.createStatusCodeTreeViewItem(node.id)); + + if (node.responses.length !== 0) { // load rest responses + const responseItem = this.createResponseTreeViewItem(node.id); + item.children.push(responseItem); + if (node.responses[0]) { + const swagger = this.configService.getSwaggerInfo(node.serviceName, node.serviceVersion); + const swaggerDefinition = this.configService.getDefinition(swagger, node.responses[0].schema.$ref); + this.loadParamsBySwaggerDefinition(responseItem, swagger, swaggerDefinition); + } + } + + return item; + } + + private createStatusCodeTreeViewItem(nodeId: string): PlanTreeviewItem { + return new PlanTreeviewItem('statusCode', `[${nodeId}].[statusCode]`, []); + } + + private createResponseTreeViewItem(nodeId: string): PlanTreeviewItem { + return new PlanTreeviewItem('response', `[${nodeId}].[responseBody]`, []); + } + + private loadParamsBySwaggerDefinition(parentItem: PlanTreeviewItem, swagger: Swagger, definition: SwaggerModelSimple) { + Object.getOwnPropertyNames(definition.properties).map(key => { + const property = definition.properties[key]; + const value = `${parentItem.value}.[${key}]`; + const propertyItem = new PlanTreeviewItem(key, value, []); + parentItem.children.push(propertyItem); + + if (property instanceof SwaggerReferenceObject) { + const propertyDefinition = this.configService.getDefinition(swagger, property.$ref); + this.loadParamsBySwaggerDefinition(propertyItem, swagger, + propertyDefinition); + } + + return propertyItem; + }); + } + + public getPreNodes(nodeId: string, preNodes: WorkflowNode[]) { + const preNode4CurrentNode = []; + this.getProcess().forEach(node => { + if (this.isPreNode(node, nodeId)) { + const existNode = preNodes.find(tmpNode => tmpNode.id === node.id); + if (existNode) { + // current node already exists in preNodes. this could avoid loop circle. + } else { + preNode4CurrentNode.push(node); + preNodes.push(node); + } + } + }); + + preNode4CurrentNode.forEach(node => this.getPreNodes(node.id, preNodes)); + } + + public isPreNode(preNode: WorkflowNode, id: string): boolean { + const targetNode = preNode.sequenceFlows.find(connection => connection.targetRef === id); + return targetNode !== undefined; + } + + public getNodeById(sourceId: string): WorkflowNode { + return this.getProcess().find(node => node.id === sourceId); + } + + private createId() { + const idSet = new Set(); + this.getProcess().forEach(node => idSet.add(node.id)); + + for (let i = 0; i < idSet.size; i++) { + if (!idSet.has('node' + i)) { + return 'node' + i; + } + } + + return 'node' + idSet.size; + } +} -- cgit 1.2.3-korg