From c11b6735d77afb314998931d0a58dc1413486f97 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 09 May 2024 11:15:13 +0800
Subject: [PATCH] 合约监听
---
src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java | 20 +-------------------
1 files changed, 1 insertions(+), 19 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
index 2668ea5..a32c340 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
@@ -386,24 +386,6 @@
return web3j.ethLogFlowable(filter).map(new Function<Log, CoinRewardEventResponse>() {
@Override
public CoinRewardEventResponse apply(Log log) {
-// final List<String> topics = log.getTopics();
-// String encodedEventSignature = EventEncoder.encode(COINREWARD_EVENT);
-// if (topics == null || topics.size() == 0 || !topics.get(0).equals(encodedEventSignature)) {
-// return null;
-// }
-//
-// List<Type> indexedValues = new ArrayList<>();
-// List<Type> nonIndexedValues =
-// FunctionReturnDecoder.decode(log.getData(), COINREWARD_EVENT.getNonIndexedParameters());
-//
-// List<TypeReference<Type>> indexedParameters = COINREWARD_EVENT.getIndexedParameters();
-// for (int i = 0; i < indexedParameters.size(); i++) {
-// Type value =
-// FunctionReturnDecoder.decodeIndexedValue(
-// topics.get(i + 1), indexedParameters.get(i));
-// indexedValues.add(value);
-// }
-// final EventValues eventValues = new EventValues(indexedValues, nonIndexedValues);
EventValuesWithLog eventValues = extractEventParametersWithLog(COINREWARD_EVENT, log);
CoinRewardEventResponse typedResponse = new CoinRewardEventResponse();
if(eventValues!=null){
@@ -427,7 +409,7 @@
public Flowable<CoinRewardEventResponse> coinRewardEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
- filter.addSingleTopic(EventEncoder.encode(TRANSFER_EVENT));
+ filter.addSingleTopic(EventEncoder.encode(COINREWARD_EVENT));
return coinRewardEventFlowable(filter);
}
--
Gitblit v1.9.1