Komodo / komodo-gw-komodo-httpgex

Blame view

lib/callback/dumper.js 1.88 KB
edit raw normal view history
d4661aa84   Adhidarma Hadiwinoto   Ready to test pre... 
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
 
  const MODULE_NAME = 'CALLBACK.DUMPER';
  
  const fs = require('fs');
  const fsPromise = require('fs').promises;
  const path = require('path');
  const config = require('komodo-sdk/config');
  const logger = require('komodo-sdk/logger');
  const moment = require('moment');
  
  const baseDumpDir = 'dump';
  const callbackDumpDir = path.join(baseDumpDir, 'callback');
  
  if (!fs.existsSync(baseDumpDir)) {
      logger.verbose(`${MODULE_NAME} D7E3D88E: Creating base dump dir`);
      fs.mkdirSync(baseDumpDir);
  }
  
  if (!fs.existsSync(callbackDumpDir)) {
      logger.verbose(`${MODULE_NAME} 002EC4A8: Creating callback dump dir`);
      fs.mkdirSync(callbackDumpDir);
  }
  
  module.exports = async (req, res, next) => {
      if (
          !config
          || !config.partner
          || !config.partner.callback
          || !config.partner.callback.dump_request
      ) {
          next();
          return;
      }
  
      const { xid } = res.locals;
  
      const data = `--------
  XID: ${xid}
385d8ff59   Adhidarma Hadiwinoto   PREPAID topup tested 
38
 
  PID: ${process.pid}
d4661aa84   Adhidarma Hadiwinoto   Ready to test pre... 
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
  DATE: ${moment().format('YYYY-MM-DD HH:mm:ss.SSS')}
  REMOTE-ADDR: ${req.ip}
  USER-AGENT: ${req.get('user-agent')}
  METHOD: ${req.method}
  URL: ${req.url}
  
  QUERY-STRING:
  ${JSON.stringify(req.query, null, 2)}
  
  REQ-CONTENT-TYPE: ${req.get('content-type')}
  REQ-BODY-TYPEOF: ${typeof req.body}
  REQ-BODY: 
  ${(req.body && typeof req.body === 'object' && JSON.stringify(req.body, null, 2)) || req.body}
  `;
  
      const dumpDir = path.join(
          callbackDumpDir,
          moment().format('YYYY-MM-DD'),
      );
  
      try {
          await fsPromise.stat(dumpDir);
fd3157376   Adhidarma Hadiwinoto   Perbaikan dumper ... 
61
 
      } catch (e) {
d4661aa84   Adhidarma Hadiwinoto   Ready to test pre... 
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
          await fsPromise.mkdir(dumpDir, { recursive: true });
      }
  
      await fsPromise.writeFile(
          path.join(
              dumpDir,
              [
                  moment().format('YYMMDD_HHmmss_SSS'),
                  xid,
              ].join('_'),
          ),
          data,
      );
  
      await fsPromise.writeFile(
6621ca5cd   Adhidarma Hadiwinoto   Last dump filename 
77
 
          path.join(callbackDumpDir, 'last'),
d4661aa84   Adhidarma Hadiwinoto   Ready to test pre... 
78
79
80
81
82
 
          data,
      );
  
      next();
  };