UNPKG

2.11 kBJavaScriptView Raw
1var request = require('request')
2
3var Requester = function() {}
4
5Requester.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
30Requester.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
56module.exports = Requester
\No newline at end of file