Commit 4f830c4851d7812598bc2af8d75a7981f2088ad9
1 parent
d327b0abba
Exists in
master
change config reference
Showing 1 changed file with 1 additions and 1 deletions Inline Diff
lib/actions/buy-to-sds.js
1 | const MODULE_NAME = 'ACTIONS.BUY-TO-SDS'; | 1 | const MODULE_NAME = 'ACTIONS.BUY-TO-SDS'; |
2 | 2 | ||
3 | const logger = require('tektrans-logger'); | 3 | const logger = require('tektrans-logger'); |
4 | const axios = require('axios').default; | 4 | const axios = require('axios').default; |
5 | 5 | ||
6 | const config = require('../config'); | 6 | const config = require('../config'); |
7 | 7 | ||
8 | const client = axios.create({ | 8 | const client = axios.create({ |
9 | baseURL: config.sds_ss.url, | 9 | baseURL: config.sds_ss.url, |
10 | timeout: config.sds_ss.request_timeout_ms, | 10 | timeout: config.sds_ss.request_timeout_ms, |
11 | }); | 11 | }); |
12 | 12 | ||
13 | /** | 13 | /** |
14 | * request buy to sds | 14 | * request buy to sds |
15 | * | 15 | * |
16 | * @param {string} xid | 16 | * @param {string} xid |
17 | * @param {string} requestId | 17 | * @param {string} requestId |
18 | * @param {string} destination | 18 | * @param {string} destination |
19 | * @param {string} productName | 19 | * @param {string} productName |
20 | * @param {number} quantity | 20 | * @param {number} quantity |
21 | * @param {string} reverseUrl | 21 | * @param {string} reverseUrl |
22 | */ | 22 | */ |
23 | module.exports = async ( | 23 | module.exports = async ( |
24 | xid, | 24 | xid, |
25 | requestId, | 25 | requestId, |
26 | destination, | 26 | destination, |
27 | productName, | 27 | productName, |
28 | quantity, | 28 | quantity, |
29 | reverseUrl, | 29 | reverseUrl, |
30 | ) => { | 30 | ) => { |
31 | logger.verbose(`${MODULE_NAME} 4AD4DF41: buy to sds`, { | 31 | logger.verbose(`${MODULE_NAME} 4AD4DF41: buy to sds`, { |
32 | requestId, destination, productName, xid, | 32 | requestId, destination, productName, xid, |
33 | }); | 33 | }); |
34 | 34 | ||
35 | const params = { | 35 | const params = { |
36 | request_id: requestId, | 36 | request_id: requestId, |
37 | username: config.sds_ss.username, | 37 | username: config.sds_ss.username, |
38 | password: config.komodo_http_get_x.password, | 38 | password: config.sds_ss.password, |
39 | number: destination, | 39 | number: destination, |
40 | product: productName, | 40 | product: productName, |
41 | amount: quantity, | 41 | amount: quantity, |
42 | reverse_url: reverseUrl, | 42 | reverse_url: reverseUrl, |
43 | }; | 43 | }; |
44 | 44 | ||
45 | try { | 45 | try { |
46 | const response = await client.get('/request', { | 46 | const response = await client.get('/request', { |
47 | params, | 47 | params, |
48 | }); | 48 | }); |
49 | if (!response) { | 49 | if (!response) { |
50 | throw new Error(`${MODULE_NAME} 6CE3E06E: Empty response sds`); | 50 | throw new Error(`${MODULE_NAME} 6CE3E06E: Empty response sds`); |
51 | } | 51 | } |
52 | if (!response.data) { | 52 | if (!response.data) { |
53 | throw new Error(`${MODULE_NAME} F236476F: Empty response sds`); | 53 | throw new Error(`${MODULE_NAME} F236476F: Empty response sds`); |
54 | } | 54 | } |
55 | 55 | ||
56 | return response.data; | 56 | return response.data; |
57 | } catch (err) { | 57 | } catch (err) { |
58 | logger.warn(`${MODULE_NAME} 48BAA6B7: Exception`, { | 58 | logger.warn(`${MODULE_NAME} 48BAA6B7: Exception`, { |
59 | xid, | 59 | xid, |
60 | requestId, | 60 | requestId, |
61 | destination, | 61 | destination, |
62 | productName, | 62 | productName, |
63 | quantity, | 63 | quantity, |
64 | message: err.message, | 64 | message: err.message, |
65 | }); | 65 | }); |
66 | throw err; | 66 | throw err; |
67 | } | 67 | } |
68 | }; | 68 | }; |
69 | 69 |