otf-frontend/client/src/app/shared/factories/bpmn-factory.service.ts

   1 /*  Copyright (c) 2019 AT&T Intellectual Property.                             #\r
   2 #                                                                              #\r
   3 #   Licensed under the Apache License, Version 2.0 (the "License");            #\r
   4 #   you may not use this file except in compliance with the License.           #\r
   5 #   You may obtain a copy of the License at                                    #\r
   6 #                                                                              #\r
   7 #       http://www.apache.org/licenses/LICENSE-2.0                             #\r
   8 #                                                                              #\r
   9 #   Unless required by applicable law or agreed to in writing, software        #\r
  10 #   distributed under the License is distributed on an "AS IS" BASIS,          #\r
  11 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #\r
  12 #   See the License for the specific language governing permissions and        #\r
  13 #   limitations under the License.                                             #\r
  14 ##############################################################################*/\r
  15 \r
  16 \r
  17 import { Injectable } from '@angular/core';\r
  18 import { FileTransferService } from '../services/file-transfer.service';\r
  19 import { TestDefinitionService } from '../services/test-definition.service';\r
  20 import { Observable } from 'rxjs';\r
  21 import { Buffer } from 'buffer';\r
  22 import { BpmnOptions, Bpmn } from '../models/bpmn.model';\r
  23 \r
  24 interface BpmnFactoryOptions extends BpmnOptions {\r
  25   fileId?: String,\r
  26   testDefinitionId?: String,\r
  27   version?: String,\r
  28   xml?: String\r
  29 }\r
  30 \r
  31 @Injectable({\r
  32   providedIn: 'root'\r
  33 })\r
  34 export class BpmnFactoryService {\r
  35 \r
  36   constructor(\r
  37     private filesTransfer: FileTransferService,\r
  38     private testDefinition: TestDefinitionService\r
  39   ) { }\r
  40 \r
  41   public async setup(options: BpmnFactoryOptions): Promise<any> {\r
  42     return new Promise(async (resolve, reject) => {\r
  43       //check for required options\r
  44       if (!options.mode) {\r
  45         console.error('Bpmn options require: mode');\r
  46         reject('Bpmn options require: mode')\r
  47       }\r
  48 \r
  49       let xml = await this.getXml(options);\r
  50 \r
  51       let instance = new Bpmn(xml, {\r
  52         mode: options.mode,\r
  53         options: options.options\r
  54       })\r
  55 \r
  56       resolve(instance);\r
  57     });\r
  58 \r
  59   }\r
  60 \r
  61   public async getXml(options): Promise<any> {\r
  62     return new Promise(async (resolve, reject) => {\r
  63       let xml;\r
  64 \r
  65       //handle the way to retrieve bpmn xml\r
  66       if (options.xml) {\r
  67         xml = options.xml\r
  68       } else if (options.fileId) {\r
  69         xml = await this.loadFile(options.fileId);\r
  70       } else if (options.testDefinitionId && options.version) {\r
  71         let fileId = await this.getFileId(options.testDefinitionId, options.version);\r
  72         xml = await this.loadFile(fileId);\r
  73       } else if (options.testDefinitionId) {\r
  74         let fileId = await this.getFileId(options.testDefinitionId);\r
  75         xml = await this.loadFile(fileId);\r
  76       } else {\r
  77         console.warn('Either xml, fileId, testDefinitionId and version, or testDefinitionId is required to render the bpmn');\r
  78       }\r
  79 \r
  80       resolve(xml);\r
  81 \r
  82     });\r
  83 \r
  84   }\r
  85 \r
  86   private getFileId(id, version?): Observable<Object> {\r
  87     return new Observable(observer => {\r
  88       this.testDefinition.get(id).subscribe(\r
  89         data => {\r
  90           if (data['bpmnInstances']) {\r
  91             if (version) {\r
  92               let index;\r
  93               for (let i = 0; i < data['bpmnInstances'].length; i++) {\r
  94                 if (version == data['bpmnInstances'][i].version) {\r
  95                   index = i;\r
  96                   break;\r
  97                 }\r
  98               }\r
  99               if (index) {\r
 100                 observer.next(data['bpmnInstances'][index].bpmnFileId);\r
 101               } else {\r
 102                 observer.error('No bpmn file');\r
 103               }\r
 104 \r
 105             } else {\r
 106               if (data['bpmnInstances'][data['bpmnInstances'].length - 1].bpmnFileId) {\r
 107                 observer.next(data['bpmnInstances'][data['bpmnInstances'].length - 1].bpmnFileId);\r
 108               } else {\r
 109                 observer.error('No bpmn file');\r
 110               }\r
 111             }\r
 112           } else {\r
 113             observer.error('No bpmn instances');\r
 114           }\r
 115         },\r
 116         err => {\r
 117           observer.error('No test definition found');\r
 118         }\r
 119       )\r
 120     })\r
 121   }\r
 122 \r
 123   public loadFile(bpmnFileId) {\r
 124     return new Promise((resolve, reject) => {\r
 125       this.filesTransfer.get(bpmnFileId).subscribe(content => {\r
 126         resolve(new Buffer(content as Buffer).toString());\r
 127       }, err => {\r
 128         reject(err);\r
 129       });\r
 130     });\r
 131   }\r
 132 }\r