dump-req-res.js
2.08 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
const MODULE_NAME = 'DUMP-REQ-RES';
const querystring = require('querystring');
const fs = require('fs');
const path = require('path');
const fsPromise = require('fs').promises;
const moment = require('moment');
const config = require('komodo-sdk/config');
const logger = require('tektrans-logger');
const baseDumpDir = 'dump';
const requestDumpDir = path.join(baseDumpDir, 'request');
if (!fs.existsSync(baseDumpDir)) {
logger.verbose(`${MODULE_NAME} 51105314: Creating base dump dir`);
fs.mkdirSync(baseDumpDir);
}
if (!fs.existsSync(requestDumpDir)) {
logger.verbose(`${MODULE_NAME} 8A52891B: Creating request dump dir`);
fs.mkdirSync(requestDumpDir);
}
module.exports = async (
xid, task, httpMethod, endpointUrl, params, responseBody, responseStatus, isAdvice,
) => {
if (
!config
|| !config.partner
|| !config.partner.dump_request
) {
return;
}
const data = `--------
XID: ${xid}
PID: ${process.pid}
DATE: ${moment().format('YYYY-MM-DD HH:mm:ss.SSS')}
TASK:
${JSON.stringify(task, null, 2)}
IS-ADVICE: ${!!isAdvice}
HTTP-METHOD: ${httpMethod}
URL: ${endpointUrl}
PARAMS:
${
params && (
(typeof params === 'string' && params)
|| JSON.stringify(params, null, 2)
)
}
${
(httpMethod === 'GET' && `FULL URL: ${endpointUrl}?${querystring.stringify(params)}`)
|| (httpMethod === 'POST' && `FORM DATA: ${new URLSearchParams(params).toString()}`)
|| ''
}
RESPONSE-STATUS: ${responseStatus}
RESPONSE-BODY:
${
responseBody && (
(typeof responseBody === 'string' && responseBody)
|| JSON.stringify(responseBody, null, 2)
)
}
`;
const dumpDir = path.join(
requestDumpDir,
moment().format('YYYY-MM-DD'),
);
try {
await fsPromise.stat(dumpDir);
} catch {
await fsPromise.mkdir(dumpDir, { recursive: true });
}
await fsPromise.appendFile(
path.join(
dumpDir,
`trx_${task.trx_id}`,
),
data,
);
await fsPromise.writeFile(
path.join(requestDumpDir, 'last'),
data,
);
};