测试环境新版

KKSU

2024-04-28 ce1c98b9930028492801ac0ad138a18e7d59edac

 src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java

@@ -386,25 +386,25 @@
        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);
//                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){
                    typedResponse.adr = (String) eventValues.getNonIndexedValues().get(0).getValue();