Skip to content

Commit ff44e09

Browse files
committed
solve the sonar problem
1 parent 70a7979 commit ff44e09

File tree

5 files changed

+69
-39
lines changed

5 files changed

+69
-39
lines changed

framework/src/main/java/org/tron/core/services/event/BlockEventGet.java

Lines changed: 34 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,6 @@ public BlockEvent getBlockEvent(long blockNum) throws Exception {
5959
blockEvent.setBlockId(block.getBlockId());
6060
blockEvent.setParentId(block.getParentBlockId());
6161
blockEvent.setSolidId(manager.getChainBaseManager().getBlockIdByNum(solidNum));
62-
blockEvent.setBlockTime(block.getTimeStamp());
6362
if (instance.isBlockLogTriggerEnable()) {
6463
blockEvent.setBlockLogTriggerCapsule(getBlockLogTrigger(block, solidNum));
6564
}
@@ -145,11 +144,45 @@ private List<ContractTrigger> parseLogs(Protocol.Transaction tx,
145144

146145
Map<String, String> addrMap = new HashMap<>();
147146
Map<String, SmartContractOuterClass.SmartContract.ABI> abiMap = new HashMap<>();
147+
parseLogs(logs, originAddress, addrMap, abiMap);
148148

149+
int index = 1;
149150
for (Protocol.TransactionInfo.Log log : logs) {
150151

151152
byte[] contractAddress = TransactionTrace
152153
.convertToTronAddress(log.getAddress().toByteArray());
154+
String strContractAddress =
155+
ArrayUtils.isEmpty(contractAddress) ? "" : StringUtil.encode58Check(contractAddress);
156+
SmartContractOuterClass.SmartContract.ABI abi = abiMap.get(strContractAddress);
157+
ContractTrigger event = new ContractTrigger();
158+
String creatorAddr = addrMap.get(strContractAddress);
159+
String txId = Hex.toHexString(txInfo.getId().toByteArray());
160+
event.setUniqueId(txId + "_" + index);
161+
event.setTransactionId(txId);
162+
event.setContractAddress(strContractAddress);
163+
event.setOriginAddress(originAddress);
164+
event.setCallerAddress("");
165+
event.setCreatorAddress(StringUtils.isEmpty(creatorAddr) ? "" : creatorAddr);
166+
event.setBlockNumber(txInfo.getBlockNumber());
167+
event.setTimeStamp(txInfo.getBlockTimeStamp());
168+
event.setLogInfo(buildLogInfo(log));
169+
event.setAbi(abi);
170+
171+
list.add(event);
172+
index++;
173+
}
174+
175+
return list;
176+
}
177+
178+
private void parseLogs(List<Protocol.TransactionInfo.Log> logs,
179+
String originAddress,
180+
Map<String, String> addrMap, Map<String,
181+
SmartContractOuterClass.SmartContract.ABI> abiMap) {
182+
for (Protocol.TransactionInfo.Log log : logs) {
183+
184+
byte[] contractAddress = TransactionTrace
185+
.convertToTronAddress(log.getAddress().toByteArray());
153186
String strContractAddr =
154187
ArrayUtils.isEmpty(contractAddress) ? "" : StringUtil.encode58Check(contractAddress);
155188
if (addrMap.get(strContractAddr) != null) {
@@ -175,34 +208,6 @@ private List<ContractTrigger> parseLogs(Protocol.Transaction tx,
175208
addrMap.put(strContractAddr, creatorAddr);
176209
abiMap.put(strContractAddr, abi);
177210
}
178-
179-
int index = 1;
180-
for (Protocol.TransactionInfo.Log log : logs) {
181-
182-
byte[] contractAddress = TransactionTrace
183-
.convertToTronAddress(log.getAddress().toByteArray());
184-
String strContractAddress =
185-
ArrayUtils.isEmpty(contractAddress) ? "" : StringUtil.encode58Check(contractAddress);
186-
SmartContractOuterClass.SmartContract.ABI abi = abiMap.get(strContractAddress);
187-
ContractTrigger event = new ContractTrigger();
188-
String creatorAddr = addrMap.get(strContractAddress);
189-
String txId = Hex.toHexString(txInfo.getId().toByteArray());
190-
event.setUniqueId(txId + "_" + index);
191-
event.setTransactionId(txId);
192-
event.setContractAddress(strContractAddress);
193-
event.setOriginAddress(originAddress);
194-
event.setCallerAddress("");
195-
event.setCreatorAddress(StringUtils.isEmpty(creatorAddr) ? "" : creatorAddr);
196-
event.setBlockNumber(txInfo.getBlockNumber());
197-
event.setTimeStamp(txInfo.getBlockTimeStamp());
198-
event.setLogInfo(buildLogInfo(log));
199-
event.setAbi(abi);
200-
201-
list.add(event);
202-
index++;
203-
}
204-
205-
return list;
206211
}
207212

208213
private LogInfo buildLogInfo(Protocol.TransactionInfo.Log log) {

framework/src/main/java/org/tron/core/services/event/HistoryEventService.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,11 @@ private void syncEvent() {
6161
Thread.sleep(30);
6262
}
6363
initEventService(manager.getChainBaseManager().getBlockIdByNum(endNum));
64-
} catch (Exception e) {
65-
logger.error("Sync event failed.", e);
64+
} catch (InterruptedException e1) {
65+
logger.warn("Sync event interrupted.");
66+
Thread.currentThread().interrupt();
67+
} catch (Exception e2) {
68+
logger.error("Sync event failed.", e2);
6669
}
6770
}
6871

framework/src/main/java/org/tron/core/services/event/bo/BlockEvent.java

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,34 @@
11
package org.tron.core.services.event.bo;
22

33
import java.util.List;
4-
import lombok.Data;
4+
import lombok.Getter;
5+
import lombok.Setter;
56
import org.tron.common.logsfilter.capsule.BlockLogTriggerCapsule;
67
import org.tron.common.logsfilter.capsule.SolidityTriggerCapsule;
78
import org.tron.common.logsfilter.capsule.TransactionLogTriggerCapsule;
89
import org.tron.core.capsule.BlockCapsule;
910

10-
@Data
1111
public class BlockEvent {
12+
@Getter
13+
@Setter
1214
private BlockCapsule.BlockId blockId;
15+
@Getter
16+
@Setter
1317
private BlockCapsule.BlockId parentId;
18+
@Getter
19+
@Setter
1420
private BlockCapsule.BlockId solidId;
15-
private long blockTime;
16-
21+
@Getter
22+
@Setter
1723
private BlockLogTriggerCapsule blockLogTriggerCapsule;
24+
@Getter
25+
@Setter
1826
private List<TransactionLogTriggerCapsule> transactionLogTriggerCapsules;
27+
@Getter
28+
@Setter
1929
private SolidityTriggerCapsule solidityTriggerCapsule;
30+
@Getter
31+
@Setter
2032
private SmartContractTrigger smartContractTrigger;
2133

2234
public BlockEvent() {}

framework/src/main/java/org/tron/core/services/event/bo/Event.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,14 @@
11
package org.tron.core.services.event.bo;
22

3-
import lombok.Data;
3+
import lombok.Getter;
4+
import lombok.Setter;
45

5-
@Data
66
public class Event {
7+
@Getter
8+
@Setter
79
private boolean isRemove;
10+
@Getter
11+
@Setter
812
private BlockEvent blockEvent;
913

1014
public Event(BlockEvent blockEvent, boolean isRemove) {

framework/src/main/java/org/tron/core/services/event/bo/SmartContractTrigger.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,19 @@
22

33
import java.util.ArrayList;
44
import java.util.List;
5-
import lombok.Data;
5+
import lombok.Getter;
6+
import lombok.Setter;
67
import org.tron.common.logsfilter.trigger.ContractEventTrigger;
78
import org.tron.common.logsfilter.trigger.ContractLogTrigger;
89

9-
@Data
1010
public class SmartContractTrigger {
11+
@Getter
12+
@Setter
1113
private List<ContractLogTrigger> contractLogTriggers = new ArrayList<>();
14+
@Getter
15+
@Setter
1216
private List<ContractEventTrigger> contractEventTriggers = new ArrayList<>();
17+
@Getter
18+
@Setter
1319
private List<ContractLogTrigger> redundancies = new ArrayList<>();
1420
}

0 commit comments

Comments
 (0)