Reload97 / sate24-to-otomax

1

"use strict";

1

"use strict";

2

3

var request = require('request');

3

var request = require('request');

4

var crypto = require('crypto');

4

var crypto = require('crypto');

5

var url = require('url');

5

var url = require('url');

6

var http = require('http');

6

var http = require('http');

7

8

var resendDelay = require('sate24/resend-delay');

8

var resendDelay = require('sate24/resend-delay');

9

var taskHistory = require('sate24/task-history');

9

var taskHistory = require('sate24/task-history');

10

var antiSameDayDupe = require('sate24/anti-same-day-dupe');

10

var antiSameDayDupe = require('sate24/anti-same-day-dupe');

11

12

var config;

12

var config;

13

var aaa;

13

var aaa;

14

var logger;

14

var logger;

15

16

17

function start(options) {

17

function start(options) {

18

if (!options) {

18

if (!options) {

19

console.log('Undefined options, terminating....');

19

console.log('Undefined options, terminating....');

20

process.exit(1);

20

process.exit(1);

21

}

21

}

22

23

if (options.config) {

23

if (options.config) {

24

config = options.config;

24

config = options.config;

25

} else {

25

} else {

26

console.log('Undefined options.config, terminating....')

26

console.log('Undefined options.config, terminating....')

27

process.exit(1);

27

process.exit(1);

28

}

28

}

29

30

if (options.aaa) {

30

if (options.aaa) {

31

aaa = options.aaa;

31

aaa = options.aaa;

32

} else {

32

} else {

33

console.log('Undefined options.aaa, terminating....')

33

console.log('Undefined options.aaa, terminating....')

34

process.exit(1);

34

process.exit(1);

35

}

35

}

36

37

if (options && options.logger) {

37

if (options && options.logger) {

38

logger = options.logger;

38

logger = options.logger;

39

} else {

39

} else {

40

console.log('Undefined options.logger, terminating....')

40

console.log('Undefined options.logger, terminating....')

41

process.exit(1);

41

process.exit(1);

42

}

42

}

43

44

resendDelay.init({

44

resendDelay.init({

45

config: config,

45

config: config,

46

topupRequest: topupRequest,

46

topupRequest: topupRequest,

47

logger: logger

47

logger: logger

48

});

48

});

49

50

taskHistory.init(options);

50

taskHistory.init(options);

51

antiSameDayDupe.init(options);

51

antiSameDayDupe.init(options);

52

53

createReverseHttpServer();

53

createReverseHttpServer();

54

}

54

}

55

56

function callbackReport(requestId, rc, message) {

56

function callbackReport(requestId, rc, message) {

57

if (rc != '68') {

57

if (rc != '68') {

58

resendDelay.cancel(requestId);

58

resendDelay.cancel(requestId);

59

} else {

59

} else {

60

taskHistory.get(requestId, function(err, archivedTask) {

60

taskHistory.get(requestId, function(err, archivedTask) {

61

if (archivedTask) {

61

if (archivedTask) {

62

logger.verbose('DEBUG', {archivedTask: archivedTask});

62

logger.verbose('DEBUG', {archivedTask: archivedTask});

63

resendDelay.register(archivedTask);

63

resendDelay.register(archivedTask);

64

}

64

}

65

});

65

});

66

}

66

}

67

68

options.aaa.callbackReportWithPushToMongoDb(requestId, rc, message);

68

aaa.callbackReportWithPushToMongoDb(requestId, rc, message);

69

}

69

}

70

71

function topupRequest(task) {

71

function topupRequest(task) {

72

if (!aaa.isTodayTrx(task)) {

72

if (!aaa.isTodayTrx(task)) {

73

logger.warn('Maaf, transaksi beda hari tidak dapat dilakukan');

73

logger.warn('Maaf, transaksi beda hari tidak dapat dilakukan');

74

callbackReport(task.requestId, '68', 'Maaf, transaksi beda hari tidak dapat dilakukan');

74

callbackReport(task.requestId, '68', 'Maaf, transaksi beda hari tidak dapat dilakukan');

75

resendDelay.cancel(task);

75

resendDelay.cancel(task);

76

return;

76

return;

77

}

77

}

78

79

aaa.insertTaskToMongoDb(task);

79

aaa.insertTaskToMongoDb(task);

80

antiSameDayDupe.check(task, _topupRequest, onSameDayDupe, _topupRequest);

80

antiSameDayDupe.check(task, _topupRequest, onSameDayDupe, _topupRequest);

81

}

81

}

82

83

function _topupRequest(task) {

83

function _topupRequest(task) {

84

taskHistory.put(task, function() {

84

taskHistory.put(task, function() {

85

requestToPartner(task);;

85

requestToPartner(task);;

86

});

86

});

87

}

87

}

88

89

function requestToPartner(task) {

89

function requestToPartner(task) {

90

let requestOptions = createRequestOptions(task);

90

let requestOptions = createRequestOptions(task);

91

92

logger.info('Requesting to partner', {task: task, request_options: requestOptions});

92

logger.info('Requesting to partner', {task: task, request_options: requestOptions});

93

94

request(requestOptions, function(error, response, body) {

94

request(requestOptions, function(error, response, body) {

95

if (error) {

95

if (error) {

96

logger.warn('Error requesting to partner', {task: task, error: error});

96

logger.warn('Error requesting to partner', {task: task, error: error});

97

callbackReport(task.requestId, '68', 'Error requesting to partner. ' + error);

97

callbackReport(task.requestId, '68', 'Error requesting to partner. ' + error);

98

return;

98

return;

99

}

99

}

100

101

if (response.statusCode != 200) {

101

if (response.statusCode != 200) {

102

logger.warn('HTTP status code is not 200', {task: task, http_status_code: response.statusCode});

102

logger.warn('HTTP status code is not 200', {task: task, http_status_code: response.statusCode});

103

callbackReport(task.requestId, '40', 'HTTP status code ' + response.statusCode);

103

callbackReport(task.requestId, '40', 'HTTP status code ' + response.statusCode);

104

return;

104

return;

105

}

105

}

106

107

logger.verbose('Got response from partner', {task: task, body: body});

107

logger.verbose('Got response from partner', {task: task, body: body});

108

109

parseMessage(task, body);

109

parseMessage(task, body);

110

});

110

});

111

}

111

}

112

113

function parseMessage(task, message) {

113

function parseMessage(task, message) {

114

let rc = '68';

114

let rc = '68';

115

116

if (message.indexOf('SUKSES') >= 0) {

116

if (message.indexOf('SUKSES') >= 0) {

117

rc = '00';

117

rc = '00';

118

}

118

}

119

else if (message.indexOf('GAGAL') >= 0) {

119

else if (message.indexOf('GAGAL') >= 0) {

120

rc = '40';

120

rc = '40';

121

}

121

}

122

else if (message.indexOf('Invalid Signature') >= 0) {

122

else if (message.indexOf('Invalid Signature') >= 0) {

123

rc = '40';

123

rc = '40';

124

}

124

}

125

126

callbackReport(task.requestId, rc, message);

126

callbackReport(task.requestId, rc, message);

127

}

127

}

128

129

function generateSign(userid, remoteProduct, destination, requestId, pin, password) {

129

function generateSign(userid, remoteProduct, destination, requestId, pin, password) {

130

let plain = ["OtomaX", userid, remoteProduct, destination, requestId, pin, password].join("|");

130

let plain = ["OtomaX", userid, remoteProduct, destination, requestId, pin, password].join("|");

131

//let sha1 = crypto.createHash('sha1').update(plain).digest().toString('hex');

131

//let sha1 = crypto.createHash('sha1').update(plain).digest().toString('hex');

132

//let buffer = new Buffer(sha1);

132

//let buffer = new Buffer(sha1);

133

let buffer = crypto.createHash('sha1').update(plain).digest();

133

let buffer = crypto.createHash('sha1').update(plain).digest();

134

135

return buffer.toString('base64').replace(/\//g, '_');

135

return buffer.toString('base64').replace(/\//g, '_');

136

}

136

}

137

138

function createRequestOptions(task) {

138

function createRequestOptions(task) {

139

return {

139

return {

140

url: config.h2h_out.partner,

140

url: config.h2h_out.partner,

141

qs: {

141

qs: {

142

memberID: config.h2h_out.userid,

142

memberID: config.h2h_out.userid,

143

product: task.remoteProduct,

143

product: task.remoteProduct,

144

dest: task.destination,

144

dest: task.destination,

145

refID: task.requestId,

145

refID: task.requestId,

146

sign: generateSign(

146

sign: generateSign(

147

config.h2h_out.userid,

147

config.h2h_out.userid,

148

task.remoteProduct,

148

task.remoteProduct,

149

task.destination,

149

task.destination,

150

task.requestId,

150

task.requestId,

151

config.h2h_out.pin,

151

config.h2h_out.pin,

152

config.h2h_out.password

152

config.h2h_out.password

153

)

153

)

154

}

154

}

155

};

155

};

156

}

156

}

157

158

function onSameDayDupe(task) {

158

function onSameDayDupe(task) {

159

callbackReport(task.requestId, '55', 'Transaksi duplikat dalam satu hari yang sama');

159

callbackReport(task.requestId, '55', 'Transaksi duplikat dalam satu hari yang sama');

160

}

160

}

161

162

function createReverseHttpServer() {

162

function createReverseHttpServer() {

163

var httpServer = http.createServer(function(request, response) {

163

var httpServer = http.createServer(function(request, response) {

164

let qs = url.parse(request.url, true).query;

164

let qs = url.parse(request.url, true).query;

165

logger.verbose('Hit on Reverse HTTP server', {url: request.url, qs: qs});

165

logger.verbose('Hit on Reverse HTTP server', {url: request.url, qs: qs});

166

});

166

});

167

168

httpServer.listen(config.h2h_out.listen_port, function() {

168

httpServer.listen(config.h2h_out.listen_port, function() {

169

logger.info('Reverse Report HTTP Server listen on %d', config.h2h_out.listen_port);

169

logger.info('Reverse Report HTTP Server listen on %d', config.h2h_out.listen_port);

170

});

170

});

171

}

171

}

172

173

exports.start = start;

173

exports.start = start;

174

exports.topupRequest = topupRequest;

174

exports.topupRequest = topupRequest;

175

exports.generateSign = generateSign;

175

exports.generateSign = generateSign;

176

GITLAB

Reload97 / sate24-to-otomax

typo variabel aaa fix