stream

Author	SHA1	Message	Date
surbhi	6b4cad1479	Remove .mvn/jvm.config file	2025-10-06 19:25:35 -04:00
surbhi	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
Surbhi Jhavar	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

16 Commits