Skip to content

Commit 0fca5db

Browse files
committed
events controller added
1 parent be0b516 commit 0fca5db

File tree

3 files changed

+52
-2
lines changed

3 files changed

+52
-2
lines changed
Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
const TransferService = require('../services/TransferService');
2+
const config = require("../config/app-config");
3+
4+
const PARSER_API_KEY = config.get("PARSER_API_KEY");
5+
6+
7+
const addEvent = async (req, res) => {
8+
const {
9+
senderAddress,
10+
transitAddress,
11+
txStatus,
12+
txHash,
13+
eventName,
14+
gasPrice,
15+
transferStatus,
16+
parserApiKey
17+
} = req.params;
18+
19+
if (parserApiKey !== PARSER_API_KEY) {
20+
throw new Error("Wrong api key");
21+
}
22+
23+
const transferFilterParams = {
24+
senderAddress,
25+
transitAddress,
26+
};
27+
28+
const event = {
29+
txStatus,
30+
txHash,
31+
eventName,
32+
gasPrice
33+
};
34+
35+
await TransferService.addEvent({transferStatus, event, transferFilterParams });
36+
res.json({success: true });
37+
}
38+
39+
40+
module.exports = {
41+
addEvent,
42+
}

src/routes/routes.js

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,5 +29,13 @@ module.exports = {
2929
controller: "ReceiverController",
3030
method: 'getTransfer'
3131
}
32-
}
32+
},
33+
'/transfer-events/add': {
34+
'get': {
35+
controller: "TransferEventsController",
36+
method: 'addEvent'
37+
}
38+
},
39+
40+
3341
}

src/services/EventsParserService.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ const subscribeForMinedWithdrawEvents = () => {
147147

148148

149149
const start = () => {
150-
subscribeForPendingEvents();
150+
// subscribeForPendingEvents();
151151
subscribeForMinedDepositEvents();
152152
subscribeForMinedCancelEvents();
153153
subscribeForMinedWithdrawEvents();

0 commit comments

Comments
 (0)