255d8f126d
updating stream defauls like aysnc calls, wait timeout, max idle connection and keep alive counts to ensure the stream doesn't fail. Moving everything to a config file to easy updates
2025-10-10 14:54:16 -04:00
88fce17efc
OHLC pipeline stuff
2025-10-09 13:06:22 -04:00
b4f1de9d0d
removing price inversion in the swap ellaborator since we always want to represent the vlaue of the swap in its quote curency
2025-10-09 13:00:07 -04:00
0d8df3df9c
adding renamed elaborators
2025-10-08 13:22:50 -04:00
2fc85c688b
Using timestmap from blockhash. Also renaming elaborators to be more descriptive and removing unneeded logs and code
2025-10-08 13:16:35 -04:00
47fe85b50b
Swap object stream with verified amount in and amount out
2025-10-07 20:11:01 -04:00
surbhi
6b4cad1479
Remove .mvn/jvm.config file
2025-10-06 19:25:35 -04:00
04d441d6b1
Remove SSH key files from repository
2025-10-06 19:18:33 -04:00
sjhavar
00ae425700
Add token metadata logging to swap event stream
...
- Integrated TokenElaborator to enrich swap events with token metadata
- Added comprehensive logging showing pool, token addresses, and metadata
- Increased timeout to handle rate limiting from RPC provider
- Simplified log output removing emoji formatting
2025-10-06 16:03:53 -04:00
sjhavar
e58fdc0b06
Add PoolElaborator for token address enrichment
...
- Created PoolElaborator async function to retrieve token0 and token1 addresses from Uniswap v3 pools
- Added ElaboratedSwapEvent DTO to store swap events with token addresses
- Updated SwapEventLog with getAddress() method for pool contract access
- Integrated PoolElaborator into DataStreamJob pipeline for real-time token enrichment
- Configured dynamic RPC URL retrieval from job parameters
2025-10-06 16:03:53 -04:00
tim
7449b4b4b1
BlockElaborator bugfix
2025-10-06 14:41:18 -04:00
tim
6829053d94
BlockElaborator
2025-10-06 12:33:45 -04:00
tim
3a64f5630c
UniswapV3Pool wrapper
2025-10-06 12:00:07 -04:00
tim
9f65c2e850
Merge remote-tracking branch 'origin/main'
2025-09-28 14:10:00 -04:00
tim
8c672f250e
TokenElaborator
2025-09-28 14:09:16 -04:00
267ff8baf2
Add Uniswap v3 swap event streaming
...
- Added SwapEventLog data stream to DataStreamJob
- Created SwapEventLog DTO for swap event processing
- Added JSON mapping and printing for swap events
2025-09-25 13:34:12 -04:00
tim
21f0f986d2
Token DTO
2025-09-25 13:32:06 -04:00
tim
ebce35c972
Swap DTO
2025-09-25 13:07:16 -04:00
tim
adb80ee7c9
updated to Flink 2.1.0 and added flink-cep
2025-09-25 12:42:15 -04:00
tim
bd82c431f9
added project files
2025-09-24 11:10:32 -04:00
tim
a80593b9c2
DTO's and other infra
2025-09-22 17:34:05 -04:00
tim
0cd8e1e28f
initial checkin with basic arbitrum head blocks working
2025-05-17 20:28:20 -04:00
