Skip to content

Commit ce80553

Browse files
committed
move all args to common
1 parent 4cc1da9 commit ce80553

File tree

61 files changed

+664
-625
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

61 files changed

+664
-625
lines changed
Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
package org.tron.common.logsfilter;
2+
3+
import java.util.HashSet;
4+
import java.util.List;
5+
import java.util.Objects;
6+
import java.util.Set;
7+
import java.util.stream.Collectors;
8+
import lombok.Getter;
9+
import lombok.Setter;
10+
import lombok.extern.slf4j.Slf4j;
11+
import org.apache.commons.lang3.StringUtils;
12+
import org.tron.common.logsfilter.trigger.ContractEventTrigger;
13+
import org.tron.common.logsfilter.trigger.ContractLogTrigger;
14+
import org.tron.common.logsfilter.trigger.ContractTrigger;
15+
16+
@Slf4j
17+
public class FilterQuery {
18+
19+
public static final int EARLIEST_BLOCK_NUM = 0;
20+
public static final int LATEST_BLOCK_NUM = -1;
21+
public static final String EARLIEST = "earliest";
22+
public static final String LATEST = "latest";
23+
@Getter
24+
@Setter
25+
private long fromBlock;
26+
@Getter
27+
@Setter
28+
private long toBlock;
29+
@Getter
30+
@Setter
31+
private List<String> contractAddressList;
32+
@Getter
33+
@Setter
34+
private List<String> contractTopicList;
35+
36+
public static long parseFromBlockNumber(String blockNum) {
37+
long number = 0;
38+
if (StringUtils.isEmpty(blockNum) || FilterQuery.EARLIEST.equalsIgnoreCase(blockNum)) {
39+
number = FilterQuery.EARLIEST_BLOCK_NUM;
40+
} else {
41+
try {
42+
number = Long.parseLong(blockNum);
43+
} catch (Exception e) {
44+
logger.error("invalid filter: fromBlockNumber: {}", blockNum);
45+
throw e;
46+
}
47+
}
48+
return number;
49+
}
50+
51+
public static long parseToBlockNumber(String blockNum) {
52+
long number = 0;
53+
if (StringUtils.isEmpty(blockNum) || FilterQuery.LATEST.equalsIgnoreCase(blockNum)) {
54+
number = FilterQuery.LATEST_BLOCK_NUM;
55+
} else {
56+
try {
57+
number = Long.parseLong(blockNum);
58+
} catch (Exception e) {
59+
logger.error("invalid filter: toBlockNumber: {}", blockNum);
60+
throw e;
61+
}
62+
}
63+
return number;
64+
}
65+
66+
@Override
67+
public String toString() {
68+
return new StringBuilder().append("fromBlock: ")
69+
.append(fromBlock)
70+
.append(", toBlock: ")
71+
.append(toBlock)
72+
.append(", contractAddress: ")
73+
.append(contractAddressList)
74+
.append(", contractTopics: ")
75+
.append(contractTopicList).toString();
76+
}
77+
}

0 commit comments

Comments
 (0)