1 | var request = require('request')
|
2 |
|
3 | var Requester = function() {}
|
4 |
|
5 | Requester.prototype.get = function(object, queue) {
|
6 | request.get({
|
7 | url: object.request.url,
|
8 | headers: {
|
9 | authorization: `Bearer ${object.request.adminclass}`,
|
10 | 'x-shopid': object.request.shopID || 'null'
|
11 | }
|
12 | }, function(err, res, body) {
|
13 | if(err) queue.stop({func: '@get', lCode: '-E1', msg: `Hiba történt a lekérés futtatása közben (URL: ${object.request.url})!`, type:'request-error'})
|
14 | else {
|
15 | try {
|
16 | body = JSON.parse(body)
|
17 | if(body.type != 'success') queue.stop(body)
|
18 | else {
|
19 | object[object.request.soi] = body.document || null
|
20 | delete object.request
|
21 | queue.next()
|
22 | }
|
23 | } catch(e) {
|
24 | queue.stop({func: '@get', lCode: '-E2', msg: `Hiba történt a válasz feldolgozása közben (URL: ${object.request.url})!`, type:'parse-error'})
|
25 | }
|
26 | }
|
27 | })
|
28 | }
|
29 |
|
30 | Requester.prototype.post = function(object, queue) {
|
31 | request.post({
|
32 | url: object.request.url,
|
33 | headers: {
|
34 | authorization: `Bearer ${object.request.adminclass}`,
|
35 | 'x-shopid': object.request.shopID || 'null'
|
36 | },
|
37 | form: object.request.body
|
38 | }, function(err, res, body) {
|
39 | if(err) queue.stop({func: '@post', lCode: '-E1', msg: `Hiba történt a lekérés futtatása közben (URL: ${object.request.url})!`, type:'request-error'})
|
40 | else {
|
41 | try {
|
42 | body = JSON.parse(body)
|
43 | if(body.type != 'success') queue.stop(body)
|
44 | else {
|
45 | object[object.request.soi] = body.document || null
|
46 | delete object.request
|
47 | queue.next()
|
48 | }
|
49 | } catch(e) {
|
50 | queue.stop({func: '@post', lCode: '-E2', msg: `Hiba történt a válasz feldolgozása közben (URL: ${object.request.url})!`, type:'parse-error'})
|
51 | }
|
52 | }
|
53 | })
|
54 | }
|
55 |
|
56 | module.exports = Requester |
\ | No newline at end of file |