catalog-ui/src/app/ng2/services/workflow.service.ts

   1 import { Injectable, Inject } from "@angular/core";
   2 import { Response } from "@angular/http";
   3 import { Observable } from "rxjs/Observable";
   4 import { HttpService } from "./http.service";
   5 import { SdcConfigToken, ISdcConfig } from "../config/sdc-config.config";
   6 import { Component, OperationModel } from "app/models";
   7
   8 interface WorkflowOutputParameter {
   9     name: string,
  10     type: string,
  11     mandatory: boolean
  12 }
  13
  14 interface WorkflowInputParameter extends WorkflowOutputParameter {
  15     property: string;
  16 }
  17
  18 @Injectable()
  19 export class WorkflowServiceNg2 {
  20
  21     protected baseUrl;
  22     protected catalogBaseUrl;
  23
  24     WF_STATE_ACTIVE = 'ACTIVE';
  25     WF_STATE_ARCHIVED = 'ARCHIVED';
  26     VERSION_STATE_CERTIFIED = 'CERTIFIED';
  27
  28     constructor(private http: HttpService, @Inject(SdcConfigToken) sdcConfig: ISdcConfig) {
  29         this.baseUrl = sdcConfig.api.workflow_root;
  30         this.catalogBaseUrl = sdcConfig.api.POST_workflow_artifact;
  31     }
  32
  33     public associateWorkflowArtifact(component: Component, operation: OperationModel): Observable<any> {
  34         return this.http.post(this.baseUrl + '/workflows/' + operation.workflowId + '/versions/' + operation.workflowVersionId + '/artifact-deliveries', {
  35                 endpoint: this.catalogBaseUrl + '/' + component.getTypeUrl() + component.uuid + '/interfaces/' + operation.interfaceId + '/operations/' + operation.uniqueId + '/artifacts/' + operation.implementation.artifactUUID,
  36                 method: 'POST'
  37             })
  38             .map((res:Response) => {
  39                 return res.json();
  40             });
  41     }
  42
  43     public getWorkflows(filterCertified: boolean = true): Observable<any> {
  44         return this.http.get(this.baseUrl + '/workflows' + (filterCertified ? '?versionState=' + this.VERSION_STATE_CERTIFIED : ''))
  45             .map((res:Response) => {
  46                 return res.json().items;
  47             });
  48     }
  49
  50     public getWorkflowVersions(workflowId: string, filterCertified: boolean = true): Observable<any> {
  51         return this.http.get(this.baseUrl + '/workflows/' + workflowId + '/versions' + (filterCertified ? '?state=' + this.VERSION_STATE_CERTIFIED : ''))
  52             .map((res:Response) => {
  53                 return _.map(res.json().items, version => version);
  54             });
  55     }
  56
  57     public updateWorkflowVersion(workflowId: string, versionId: string, payload: any): Observable<any> {
  58         return this.http.put(this.baseUrl + '/workflows/' + workflowId + '/versions/' + versionId, payload)
  59             .map((res:Response) => {
  60                 return res.json();
  61             });
  62     }
  63
  64 }