dexorder/stream
2
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

BlockElaborator bugfix

Browse Source
This commit is contained in:
tim
2025-10-06 14:41:18 -04:00
parent 6829053d94
commit 7449b4b4b1
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/stream/io/BlockElaborator.java
View File

@@ -8,8 +8,6 @@ import org.slf4j.LoggerFactory;
import org.web3j.protocol.Web3j;
import org.web3j.protocol.core.DefaultBlockParameterNumber;
import org.web3j.protocol.core.methods.response.EthBlock;
import org.web3j.tx.ReadonlyTransactionManager;
import org.web3j.tx.gas.DefaultGasProvider;
import stream.dto.BlockHash;
import stream.dto.BlockId;
import stream.dto.BlockNumber;
@@ -28,8 +26,6 @@ public class BlockElaborator extends RichAsyncFunction<BlockId, EthBlock> {
public void open(OpenContext openContext) throws Exception {
Map<String, String> params = getRuntimeContext().getGlobalJobParameters();
w3 = Web3Client.get(params);
gasProvider = new DefaultGasProvider();
transactionManager = new ReadonlyTransactionManager(w3, "0x1234000000000000000000000000000000001234");
}
@Override
@@ -39,7 +35,7 @@ public class BlockElaborator extends RichAsyncFunction<BlockId, EthBlock> {
return getBlock(blockId);
} catch (Exception e) {
log.error("Failed to get block {} on chain {}", blockId, e);
throw new RuntimeException("Error processing token: " + address, e);
throw new RuntimeException("Error processing block " + blockId, e);
}
}).thenAccept(result -> resultFuture.complete(Collections.singleton(result)));
}