1 files changed, 0 insertions, 151 deletions
diff --git a/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/rest.service.ts b/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/rest.service.ts
deleted file mode 100644
index e3bde51b..00000000
--- a/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/rest.service.ts
+++ /dev/null
@@ -1,151 +0,0 @@
-/*******************************************************************************
- * 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 { Http, RequestOptionsArgs } from '@angular/http';
-import { Observable } from 'rxjs/Rx';
-import { isNullOrUndefined } from 'util';
-
-import { SwaggerMethod } from '../model/swagger';
-import { SwaggerResponseClass } from '../model/swagger';
-import { Swagger, SwaggerSchemaObject } from '../model/swagger';
-import { RestConfig } from '../model/rest-config';
-import { BroadcastService } from './broadcast.service';
-import { NoticeService } from './notice.service';
-import { SettingService } from './setting.service';
-
-@Injectable()
-export class RestService {
-    private restConfigs: RestConfig[] = [];
-    private runtimeURL = '/openoapi/catalog/v1/sys/config';
-    private msbPublishServiceURL = '/api/msdiscover/v1/publishservicelist';
-
-    constructor(private broadcastService: BroadcastService, private http: Http,
-        private noticeService: NoticeService, private settgingService: SettingService) {
-        this.settgingService.getSetting().subscribe(setting => {
-            if (true === setting.supportRestNode) {
-                this.initSwaggerInfo();
-            } else {
-                this.broadcastService.broadcast(this.broadcastService.updateModelRestConfig, null);
-            }
-        });
-    }
-
-    public getRestConfigs(): RestConfig[] {
-        return this.restConfigs;
-    }
-
-    public getRestConfig(id: string): RestConfig {
-        return this.restConfigs.find(tmp => tmp.id === id);
-    }
-
-    public getSwaggerInfo(id: string): Swagger {
-        const restConfig = this.restConfigs.find(tmp => tmp.id === id);
-        return restConfig === undefined ? undefined : restConfig.swagger;
-    }
-
-    public getResponseParameters(swagger: Swagger, interfaceUrl: string, operation: string): SwaggerResponseClass[] {
-        const path = swagger.paths[interfaceUrl];
-        const method: SwaggerMethod = path[operation];
-        let responses: SwaggerResponseClass[] = [];
-
-        for (const key of Object.keys(method.responses)) {
-            if (key.startsWith('20') && method.responses[key].schema && method.responses[key].schema.$ref) {
-                let response: SwaggerResponseClass = method.responses[key];
-                responses.push(response);
-            }
-        }
-
-        return responses;
-    }
-
-    public getDefinition(swagger: Swagger, position: string): SwaggerSchemaObject {
-        const definitionName = position.substring('#/definitions/'.length);
-        return swagger.definitions[definitionName];
-    }
-
-    private initSwaggerInfo(): void {
-        this.http.get(this.runtimeURL).subscribe(runtimeResponse => {
-            const tenant = runtimeResponse.json().tenant;
-            console.log('Current namespace is:' + tenant);
-            this.initSwaggerInfoByTenant(tenant);
-        }, error => {
-            console.warn('No tenant interface!');
-            this.initSwaggerInfoByTenant('');
-        });
-    }
-
-    private initSwaggerInfoByTenant(tenant: string): void {
-        this.http.get(this.msbPublishServiceURL, { params: { namespace: tenant } }).subscribe(serviceResponse => {
-            if (!Array.isArray(serviceResponse.json())) {
-                return;
-            }
-            const services = serviceResponse.json();
-            const protocel = location.protocol.slice(0, location.protocol.length - 1);
-            const swaggerObservableArray: Observable<any>[] = [];
-            services.forEach(serviceInfo => {
-                if ('REST' === serviceInfo.protocol && protocel === serviceInfo.publish_protocol) {
-                    // this service don't have sawgger file.
-                    if ('/activiti-rest' !== serviceInfo.publish_url) {
-                        const id = serviceInfo.serviceName + '.' + serviceInfo.version;
-                        this.restConfigs.push(new RestConfig(id, serviceInfo.serviceName, serviceInfo.version, serviceInfo.publish_url));
-                        let swaggerUrl = '';
-                        if (undefined !== serviceInfo.swagger_url && '' !== serviceInfo.swagger_url) {
-                            swaggerUrl = serviceInfo.publish_url + '/' + serviceInfo.swagger_url;
-                        } else {
-                            // default swagger url is: '/swagger.json'
-                            swaggerUrl = serviceInfo.publish_url + '/swagger.json';
-                        }
-                        const options: any = {
-                            headers: {
-                                Accept: 'application/json',
-                            }
-                        };
-                        swaggerObservableArray.push(this.http.get(swaggerUrl, options).timeout(5000).catch((error): Observable<any> => {
-                            console.log('Request swagger from:"' + swaggerUrl + '" faild!');
-                            return Observable.of(null);
-                        }));
-                    }
-                }
-            });
-            Observable.forkJoin(swaggerObservableArray).subscribe(
-                responses => {
-                    let deleteArray: number[] = [];
-                    responses.forEach((response, index) => {
-                        // mark http get failed request index or set the swagger into restConfigs
-                        if (null === response) {
-                            deleteArray.push(index);
-                        } else {
-                            try {
-                                const swagger = response.json();
-                                this.restConfigs[index].swagger = new Swagger(swagger);
-                            } catch (e) {
-                                deleteArray.push(index);
-                                console.warn('Do not support this sawgger file format:' + response.text());
-                            }
-                        }
-                    });
-                    console.log('Get all swagger file finish.');
-                    // delete failed request from all restConfigs array
-                    deleteArray.reverse();
-                    deleteArray.forEach(deleteIndex => {
-                        this.restConfigs.splice(deleteIndex, 1);
-                    });
-                    this.broadcastService.broadcast(this.broadcastService.updateModelRestConfig, this.restConfigs);
-                    console.log('Load all swagger finished.');
-                }
-            );
-        });
-
-    }
-}
-