fix

Helius

2022-05-27 6c29204c6a4afed0eb476c92bb4f464c88cde3a9

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

@@ -52,6 +52,7 @@
    private final static ContractChainService ETH = new EthService(ETH_URL, ETH_ADDRESS, ETH_PRIVATE, ETH_CONTRACT_ADDRESS);
    private final static ContractChainService BSC = new EthService(BSC_URL, BSC_ADDRESS, BSC_PRIVATE, BSC_CONTRACT_ADDRESS);
    private final static ContractChainService TRX = new TrxService(TRX_ADDRESS, TRX_PRIVATE, TRX_CONTRACT_ADDRESS, API_KEY);
    private final static ContractChainService BSC_TFC = new EthService(ChainEnum.BSC_TFC.getUrl(), ChainEnum.BSC_TFC.getAddress(), ChainEnum.BSC_TFC.getPrivateKey(), ChainEnum.BSC_TFC.getContractAddress());

    private final String ETH_PREFIX = "0x";

@@ -64,10 +65,12 @@
        switch (chainType) {
            case "ETH" :
                return ETH;
            case "BSC" :
            case "BSC_USDT" :
                return BSC;
            case "TRX" :
                return TRX;
            case "BSC_TFC":
                return BSC_TFC;
            default:
                break;
        }
@@ -98,6 +101,7 @@
        return EthUsdtContract.load(contractAddress, Web3j.build(new HttpService(url)), credentials, new StaticGasProvider(BigInteger.valueOf(4500000L), BigInteger.valueOf(200000L)));
    }

    // 18097238  18098663
    private static EthFilter getFilter(BigInteger startBlock, String contractAddress) {
        DefaultBlockParameter parameterName = null;
        if (startBlock != null) {
@@ -106,7 +110,33 @@
            parameterName = DefaultBlockParameterName.EARLIEST;
        }

        return new EthFilter(parameterName, DefaultBlockParameterName.LATEST, contractAddress);
//        return new EthFilter(parameterName, DefaultBlockParameterName.LATEST, contractAddress);
        return new EthFilter(parameterName, new DefaultBlockParameterNumber(new BigInteger("18098663")), contractAddress);
    }

    public static void main(String[] args) {
        ChainEnum chain = ChainEnum.getValueByName(ChainEnum.BSC_TFC.name());
        assert chain != null;

        EthUsdtContract contract = contract(chain.getPrivateKey(), chain.getContractAddress(), chain.getUrl());
        EthFilter filter = getFilter(new BigInteger("18097238"), new BigInteger("18098663"), chain.getContractAddress());

        contract.transferEventFlowable(filter).subscribe(e -> {
            System.out.println(1);
        }, error -> {
            log.error("--->", error);
        });
    }

    private static EthFilter getFilter(BigInteger startBlock, BigInteger endBlock, String contractAddress) {
        DefaultBlockParameter parameterName = null;
        if (startBlock != null) {
            parameterName = new DefaultBlockParameterNumber(startBlock);
        } else {
            parameterName = DefaultBlockParameterName.EARLIEST;
        }

        return new EthFilter(parameterName, new DefaultBlockParameterNumber(endBlock), contractAddress);
    }

}