import { MicroserviceListComponent } from "./components/menu/microservice/microservice-list/microservice-list.component";
import { ModalModule } from "ngx-bootstrap/modal";
import { WorkflowConfigService } from "./services/workflow-config.service";
+import { RestTaskComponent } from "./components/property/rest-task/rest-task.component";
@NgModule({
declarations: [
NodeComponent,
ParameterComponent,
PropertiesComponent,
+ RestTaskComponent,
StartEventParametersComponent,
ToolbarComponent,
],
<!-- TODO add property for different node types -->
<b4t-start-event-parameters *ngIf="'startEvent' == node.type" [node]="node"></b4t-start-event-parameters>
+ <b4t-rest-task *ngIf="node.type == 'restTask'" [node]="node"></b4t-rest-task>
</div>
--- /dev/null
+<!--
+/*******************************************************************************
+ * 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
+ *******************************************************************************/
+-->
+
+<div class="form-group row">
+ <label class="col-md-3 form-control-label text-md-right">Service</label>
+ <div class="col-md-9">
+ <select class="form-control" [ngModel]="selectedMicroservice"
+ (ngModelChange)="serviceChanged($event)">
+ <option *ngFor="let microservice of microservices" [ngValue]=microservice>{{getText4Microservice(microservice)}}</option>
+ </select>
+ </div>
+</div>
+
+<div class="form-group row">
+ <label class="col-md-3 form-control-label text-md-right">Path</label>
+ <div class="col-md-9">
+ <select class="form-control" [ngModel]="node.url"
+ (ngModelChange)="urlChanged($event)">
+ <option *ngFor="let interface of restInterfaces" value="{{interface}}">{{interface}}</option>
+ </select>
+ </div>
+</div>
+
+<div class="form-group row">
+ <label class="col-md-3 form-control-label text-md-right">Method</label>
+ <div class="col-md-9">
+ <select class="form-control" [ngModel]="node.method"
+ (ngModelChange)="methodChanged($event)">
+ <option *ngFor="let operation of restOperations" value="{{operation}}">{{operation}}</option>
+ </select>
+ </div>
+</div>
+<hr>
--- /dev/null
+/*******************************************************************************
+ * 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 { AfterViewInit, Component, Input, OnInit } from '@angular/core';
+import { Subscription } from 'rxjs/Subscription';
+
+import { Swagger, SwaggerMethod, SwaggerParameter, SwaggerResponse } from '../../../model/swagger';
+import { ValueSource } from '../../../model/value-source.enum';
+import { ValueType } from '../../../model/value-type.enum';
+import { RestTask } from '../../../model/workflow/rest-task';
+import { BroadcastService } from '../../../services/broadcast.service';
+import { WorkflowConfigService } from '../../../services/workflow-config.service';
+import { Microservice } from "../../../model/workflow/microservice";
+
+@Component({
+ selector: 'b4t-rest-task',
+ templateUrl: 'rest-task.component.html',
+})
+export class RestTaskComponent implements AfterViewInit, OnInit {
+ @Input() public node: RestTask;
+ public swaggerJson: any = {};
+ public restInterfaces: any[];
+ public restOperations: any = [];
+ public microservices: Microservice[];
+ public selectedMicroservice: Microservice;
+ private swagger: Swagger;
+
+ constructor(private broadcastService: BroadcastService,
+ private configService: WorkflowConfigService) { }
+
+ ngOnInit(): void {
+ this.microservices = this.configService.getMicroservices();
+ this.selectedMicroservice = this.microservices.find(service =>
+ (this.node.serviceName === service.name && this.node.serviceVersion === service.version));
+ }
+ public ngAfterViewInit() {
+ setTimeout(() => {
+ this.loadInterfaces();
+ }, 0);
+ }
+
+ public getText4Microservice(microservice: Microservice): string {
+ return `${microservice.name} [${microservice.version}] `;
+ }
+
+ public serviceChanged(service: Microservice) {
+ this.selectedMicroservice = service;
+ this.node.serviceName = service.name;
+ this.node.serviceVersion = service.version;
+ this.urlChanged('');
+ this.loadInterfaces();
+ }
+
+ public urlChanged(url: string) {
+ this.node.url = url;
+
+ this.node.consumes = [];
+ this.node.produces = [];
+ this.methodChanged('');
+
+ this.loadOperations();
+ }
+
+ public methodChanged(method: string) {
+ this.node.method = method;
+
+ this.node.parameters = [];
+ this.node.responses = [];
+
+ this.updateMethodInfo();
+ }
+
+
+ private loadInterfaces() {
+ if (this.node.serviceName && this.node.serviceVersion) {
+ this.swagger = this.configService.getSwaggerInfo(this.node.serviceName, this.node.serviceVersion);
+
+ if (this.swagger) {
+ this.restInterfaces = [];
+ for (const key of Object.keys(this.swagger.paths)) {
+ this.restInterfaces.push(key);
+ }
+ this.loadOperations();
+ } else {
+ // TODO error handler
+ }
+ }
+ }
+
+ private loadOperations() {
+ if (this.node.url) {
+ const swaggerPath: any = this.swagger.paths[this.node.url];
+
+ this.restOperations = [];
+ for (const key of Object.keys(swaggerPath)) {
+ this.restOperations.push(key);
+ }
+ }
+ }
+
+ private updateMethodInfo() {
+ // TODO update parameters
+ console.log('rest task updated');
+ }
+}
--- /dev/null
+/**
+ * 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 { Parameter } from './parameter';
+import { WorkflowNode } from './workflow-node';
+
+export class RestParameter extends Parameter {
+ constructor(name: string, value: string, valueSource: string, type: string,
+ public position: string, public schema: any) {
+ super(name, value, valueSource, type);
+ }
+}
--- /dev/null
+/**
+ * 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 { RestParameter } from './rest-parameter';
+import { WorkflowNode } from './workflow-node';
+
+export class RestTask extends WorkflowNode {
+ public serviceName: string;
+ public serviceVersion: string;
+ public url: string;
+ public method: string;
+ public operationId: string;
+ public produces: string[] = [];
+ public consumes: string[] = [];
+ public parameters: RestParameter[] = [];
+ public responses: any[] = [];
+}
import { Microservice } from "../model/workflow/microservice";\r
import { Observable } from "rxjs/Rx";\r
import { HttpService } from "../util/http.service";\r
+import { Swagger } from "../model/swagger";\r
\r
/**\r
* WorkflowConfigService\r
};\r
return this.httpService.get(url).map(response => response.data);\r
}\r
+\r
+ public getSwaggerInfo(serviceName: string, version: string): Swagger {\r
+ const microservice = this.getMicroservices().find(service => (service.name === serviceName && service.version === version));\r
+ if(microservice) {\r
+ return microservice.swagger;\r
+ } else {\r
+ return undefined;\r
+ }\r
+ }\r
}\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
\r
/**\r
* WorkflowService\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
default:\r
node = new WorkflowNode(this.createId(), name, type, new Position(top, left), []);\r
break;\r
Code Review / sdc / sdc-workflow-designer.git / commitdiff