added updated code for test env
[it/otf.git] / otf-frontend / server / src / feathers / services / bpmn-validate / bpmn-validate.class.js
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 const axios = require('axios');\r
18 const Response = require('http-response-object');\r
19 const logger = require('../../../lib/logger');\r
20 const util = require('../../../lib/otf-util');\r
21 const beautify = require('json-beautify');\r
22 const Bpmn = require('./bpmn.class');\r
23 const Readable = require('stream').Readable;\r
24 const request = require('request');\r
25 \r
26 class Service {\r
27         constructor (options) {\r
28                 this.options = options || {};\r
29         }\r
30 \r
31         async find (params) {\r
32                 return [];\r
33         }\r
34 \r
35         // Check process definition key to see if unique\r
36         async get (id, params) {\r
37                 let errors = {};\r
38                 // Get List of Definition keys from Camunda\r
39                 let options = {\r
40                         url: this.options.app.get('camundaApi').url + 'otf/tcu/testDefinition/v1/processDefinitionKey/' + id,\r
41                         headers: {\r
42                                 'Authorization': 'Basic ' + new Buffer(this.options.app.get('serviceApi').aafId + ':' + this.options.app.get('serviceApi').aafPassword).toString('base64')\r
43                         },\r
44                         rejectUnauthorized: false\r
45                 };\r
46 \r
47                 return await new Promise(async (resolve, reject) => {\r
48                         request.get(options, (err, response, body) => {\r
49                                 if(err){\r
50                                         reject(err);\r
51                                 }\r
52                                 resolve(response);\r
53                         });\r
54                 })\r
55                 .then(\r
56                         result => {\r
57                                 if (result.statusCode == 200) {\r
58                                         //check to make sure they have access\r
59                                         params.query.$limit = '-1';\r
60                                         params.query.processDefinitionKey = id;\r
61                                         return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(params).then(\r
62                                                 res => {\r
63                                                         if(res.length > 0){\r
64                                                                 return new Response(200, {}, res);\r
65                                                         }else{\r
66                                                                 let resp = new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}});\r
67                                                                 return resp;\r
68                                                         }\r
69                                                 }\r
70                                         );\r
71                                 }else{\r
72                                         return new Response(200, {});\r
73                                 }\r
74                         }\r
75                 ).catch(err => {\r
76                         return new Response(400, {});\r
77                 });\r
78 \r
79                 // return await axios.get(\r
80                 //      this.options.app.get('camundaApi').url + 'otf/tcu/testDefinition/v1/processDefinitionKey/' + id,\r
81                 //      {\r
82                 //              headers: {\r
83                 //                      Authorization: 'Basic ' + new Buffer(this.options.app.get('serviceApi').aafId + ':' + this.options.app.get('serviceApi').aafPassword).toString('base64')\r
84                 //              }\r
85                 //      })\r
86                 //      .then(result => {\r
87                 //              console.log(result);\r
88                 //              if (result.status === 200) {\r
89                 //                      //check to make sure they have access\r
90                 //                      params.query.$limit = '-1';\r
91                 //                      params.query.processDefinitionKey = id;\r
92                 //                      return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(params).then(\r
93                 //                              res => {\r
94                 //                                      console.log('res 1');\r
95                 //                                      console.log(res);\r
96                 //                                      if(res.length > 0){\r
97                 //                                              return new Response(200, {}, res);\r
98                 //                                      }else{\r
99 \r
100                 //                                              console.log('err 1');\r
101                 //                                              let resp = new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}});\r
102                 //                                              console.log(resp);\r
103                 //                                              return resp;\r
104                 //                                      }\r
105                 //                              }\r
106                 //                      );\r
107                 //              }else{\r
108                 //                      console.log('not 200')\r
109                 //                      return new Response(400, {}, {errors: errors});\r
110                 //              }\r
111                 //      })\r
112                 //      .catch(err => {\r
113                 //              return new Response(200, {});\r
114                 //      });\r
115         }\r
116         // async get (id, params) {\r
117         //      console.log("bpmn-upload: get")\r
118         //      let errors = {};\r
119         //      // Get List of Definition keys from Camunda\r
120 \r
121         //      // let options = {\r
122         //      //      url: this.options.app.get('camundaApi').url + 'otf/tcu/testDefinition/v1/processDefinitionKey/' + id,\r
123         //      //      headers: {\r
124         //      //              'Authorization': 'Basic ' + new Buffer(this.options.app.get('serviceApi').aafId + ':' + this.options.app.get('serviceApi').aafPassword).toString('base64')\r
125         //      //      },\r
126         //      //      rejectUnauthorized: false\r
127         //      // }\r
128 \r
129         //      // return await new Promise((resolve, reject) => {\r
130         //      //      request.post(options, (err, res, body) => {\r
131         //      //              if(err){\r
132         //      //                      reject(err);\r
133         //      //              }\r
134         //      //              resolve(res);\r
135         //      //      });\r
136         //      // }).then(\r
137         //      //      result => {\r
138         //      //              console.log(result);\r
139         //      //              if (result.statusCode === 200) {\r
140         //      //                      //check to make sure they have access\r
141         //      //                      params.query.$limit = '-1';\r
142         //      //                      params.query.processDefinitionKey = id;\r
143         //      //                      return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(params).then(\r
144         //      //                              res => {\r
145         //      //                                      return new Response(200, {}, res);\r
146         //      //                              },\r
147         //      //                              err => {\r
148         //      //                                      return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
149         //      //                              }\r
150         //      //                      );\r
151         //      //              }else if(result.statusCode == 404){\r
152         //      //                      return new Response(400, {}, {errors: errors});\r
153         //      //              }else{\r
154         //      //                      return new Response(result.statusCode, {}, {errors: errors});\r
155         //      //              }\r
156         //      //      }\r
157         //      // ).catch(\r
158         //      //      err => {\r
159         //      //              console.log("Err: " + err)\r
160         //      //              //return new Response(200, {});\r
161         //      //              let newParams = Object.assign({}, params);\r
162         //      //              newParams.query.$limit = -1;\r
163         //      //              newParams.query.processDefinitionKey = id;\r
164         //      //              //console.log(params);\r
165         //      //              return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(newParams).then(\r
166         //      //                      res => {\r
167         //      //                              //return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
168         //      //                              return new Response(200, {}, res);\r
169         //      //                      },\r
170         //      //                      err => {\r
171         //      //                              return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
172         //      //                      }\r
173         //      //              );\r
174         //      //      }\r
175         //      // );\r
176 \r
177         //      return await axios.get(\r
178         //              this.options.app.get('camundaApi').url + 'otf/tcu/testDefinition/v1/processDefinitionKey/' + id,\r
179         //              {\r
180         //                      headers: {\r
181         //                              Authorization: 'Basic ' + new Buffer(this.options.app.get('serviceApi').aafId + ':' + this.options.app.get('serviceApi').aafPassword).toString('base64')\r
182         //                      }\r
183         //              })\r
184         //              .then(result => {\r
185         //                      console.log(result);\r
186         //                      if (result.status === 200) {\r
187         //                              console.log('in here')\r
188         //                              //check to make sure they have access\r
189         //                              params.query.$limit = '-1';\r
190         //                              params.query.processDefinitionKey = id;\r
191         //                              return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(params).then(\r
192         //                                      res => {\r
193         //                                              return new Response(200, {}, res);\r
194         //                                      }\r
195         //                              ).catch(err => {\r
196         //                                      console.log('err')\r
197         //                                      return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
198         //                              });\r
199         //                      }else if(result.status === 404){\r
200         //                              console.log('or here')\r
201         //                              return new Response(400, {}, {errors: errors});\r
202         //                      }else{\r
203         //                              return new Response(result.status, {}, {errors: errors});\r
204         //                      }\r
205         //              })\r
206         //              .catch(err => {\r
207         //                      console.log("Err: " + err)\r
208         //                      //return new Response(200, {});\r
209         //                      let newParams = Object.assign({}, params);\r
210         //                      newParams.query.$limit = -1;\r
211         //                      newParams.query.processDefinitionKey = id;\r
212         //                      //console.log(params);\r
213         //                      return this.options.app.services[this.options.app.get('base-path') + 'test-definitions'].find(newParams).then(\r
214         //                              res => {\r
215         //                                      //return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
216         //                                      return new Response(200, {}, res);\r
217         //                              }\r
218         //                      ).catch(err => {\r
219         //                              console.log('err 2')\r
220         //                              return new Response(400, {}, {errors: {processDefinitionKey: 'You do not have access to this process definition key'}})\r
221         //                      });\r
222         //              });\r
223         // }\r
224 \r
225         async create (data, params) {\r
226                 let bpmn = new Bpmn(this.options.app, data, params);\r
227                 return await bpmn.validate();\r
228         }\r
229 \r
230         //validates then saves bpmn file and returns file meta data\r
231         async update (id, data, params) {\r
232                 let bpmn = new Bpmn(this.options.app, data, params);\r
233                 let res = await bpmn.validate();\r
234                 if(res.statusCode != 200){\r
235                         return res;\r
236                 }\r
237                 \r
238                 let b = new Buffer(res.body.bpmnXml);\r
239                 let r = new Readable();\r
240                 r.push(b);\r
241                 r.push(null);\r
242                 //save new bpmn file and return\r
243                 let formData = {\r
244                         'file': {\r
245                                 value: r.read(),\r
246                                 options: {\r
247                                         filename: res.body.processDefinitionKey + '.bpmn'\r
248                                 }\r
249                         }\r
250                 };\r
251                 let options = {\r
252                         url: this.options.app.get('otf').url + this.options.app.get('base-path') + 'file-transfer',\r
253                         headers: {\r
254                                 'Authorization': params.headers.Authorization,\r
255                                 'Content-Type': "multipart/form-data"\r
256                         },\r
257                         rejectUnauthorized: false,\r
258                         formData: formData\r
259                 }\r
260 \r
261                 return await new Promise((resolve, reject) => {\r
262                         request.post(options, (err, res, body) => {\r
263                                 if(err){\r
264                                         reject(err);\r
265                                 }\r
266                                 resolve(body);\r
267                         });\r
268                 }).then(\r
269                         result => {\r
270                                 return result;\r
271                         }\r
272                 ).catch(\r
273                         err => {\r
274                                 return err;\r
275                         }\r
276                 );\r
277 \r
278         }\r
279 \r
280         async patch (id, data, params) {\r
281                 return data;\r
282         }\r
283 \r
284         async remove (id, params) {\r
285                 return { id };\r
286         }\r
287 \r
288         async parseAndUpload (data, params, method) {\r
289 \r
290         }\r
291 }\r
292 \r
293 module.exports = function (options) {\r
294         return new Service(options);\r
295 };\r
296 \r
297 module.exports.Service = Service;\r