353 Commits

Author SHA1 Message Date
0xfnzero 85d50e4a11 Merge dev for solana-streamer-sdk 2.0.0 v2.0.0 2026-07-17 03:50:24 +08:00
0xfnzero f1c6aecb3d fix(pumpswap): preserve upgraded event fields 2026-07-17 03:04:10 +08:00
0xfnzero 85c6cc901a build: pin parser dev integration 2026-07-17 02:11:16 +08:00
0xfnzero aab0a3a143 feat(pumpswap): forward virtual quote reserve upgrade 2026-07-17 01:59:54 +08:00
0xfnzero 740838f414 Merge remote-tracking branch 'origin/main' into dev
# Conflicts:
#	Cargo.toml
#	src/streaming/common/event_processor.rs
#	src/streaming/common/metrics.rs
#	src/streaming/event_parser/common/high_performance_clock.rs
#	src/streaming/event_parser/common/types.rs
#	src/streaming/event_parser/common/utils.rs
#	src/streaming/event_parser/core/account_event_parser.rs
#	src/streaming/event_parser/core/common_event_parser.rs
#	src/streaming/event_parser/core/dispatcher.rs
#	src/streaming/event_parser/core/event_parser.rs
#	src/streaming/event_parser/core/merger_event.rs
#	src/streaming/event_parser/core/traits.rs
#	src/streaming/event_parser/protocols/bonk/parser.rs
#	src/streaming/event_parser/protocols/bonk/types.rs
#	src/streaming/event_parser/protocols/pumpfun/parser.rs
#	src/streaming/event_parser/protocols/pumpswap/events.rs
#	src/streaming/event_parser/protocols/pumpswap/parser.rs
#	src/streaming/event_parser/protocols/pumpswap/types.rs
#	src/streaming/event_parser/protocols/raydium_cpmm/types.rs
#	src/streaming/grpc/pool.rs
#	src/streaming/grpc/types.rs
#	src/streaming/shred/pool.rs
#	src/streaming/shred_stream.rs
#	src/streaming/yellowstone_grpc.rs
2026-07-17 01:42:21 +08:00
0xfnzero 9bd0577683 chore: release solana-streamer-sdk 1.5.16 v1.5.16 2026-06-20 10:48:53 +08:00
0xfnzero 1e17facb64 fix: pin yellowstone grpc proto for ci 2026-06-20 01:16:05 +08:00
0xfnzero d4c636ac1b Merge pull request #71 from mooncitydev/fix-streaming-ordered-dropped-events
fix dropped events in streaming ordered mode for multi event transactions
2026-06-20 01:10:00 +08:00
0xfnzero 5ff1c9f4bb docs: add streamer use-case overview 2026-06-20 00:58:05 +08:00
0xfnzero 5c43d11bf6 chore: use crates sol-parser-sdk 0.5.15 v1.5.15 2026-06-18 01:20:33 +08:00
0xfnzero 78376b8bc4 chore: update sol-parser-sdk DEX gate fix 2026-06-18 01:05:34 +08:00
0xfnzero 669cfb724c chore: update sol-parser-sdk inner CPI perf guard 2026-06-18 00:51:16 +08:00
0xfnzero 5811ade5ea chore: update sol-parser-sdk pumpswap cashback fix 2026-06-18 00:46:32 +08:00
moondev 94cd09b0e5 fix events being dropped in streaming ordered mode for multi event transactions
in StreamingOrdered mode the slot buffer is fed one event at a time, but every
event parsed from the same transaction carries that transaction's tx_index.
push_streaming bumps the streaming watermark to tx_index + 1 as soon as it
releases the first event, so the rest of that transaction's events have
tx_index < watermark, fall into the "already delivered" branch and get dropped
without any trace.

so any transaction that parses into more than one dex event (a swap route that
touches several pools, a create + buy, and so on) only ever delivered its first
event when order_mode was StreamingOrdered. Unordered, Ordered and MicroBatch
were not affected.

fix:
- push_streaming now takes all events of one (slot, tx_index) as a group so the
  watermark advances once per transaction instead of once per event
- the buffered drain advances the watermark per distinct tx_index, since a slot
  can now hold several events under the same index
- the ordered buffers use a stable sort so events inside one transaction keep
  the order the parser produced them in, sort_unstable could shuffle equal keys

added tests for the multi event transaction case and for releasing buffered out
of order multi event transactions.
2026-06-16 00:28:15 +09:00
0xfnzero 0a879cac05 chore: update sol-parser-sdk quote case fix 2026-06-13 00:51:57 +08:00
0xfnzero f916e2ab59 chore: update sol-parser-sdk account field tests 2026-06-13 00:32:21 +08:00
0xfnzero 8aa1df3115 test: sync PumpFun quote signature cases 2026-06-13 00:22:40 +08:00
0xfnzero e78e37da6b chore: update sol-parser-sdk quote mint fix 2026-06-13 00:08:54 +08:00
0xfnzero 04d7f7b520 test: sync PumpFun quote case examples 2026-06-12 23:55:30 +08:00
0xfnzero e3249703a5 fix: add PumpFun quote case parser example 2026-06-12 22:22:40 +08:00
0xfnzero ad166ae62e fix: expose PumpFun create quote accounts v1.5.14 2026-06-12 01:08:33 +08:00
0xfnzero 7131fb3aa1 Release solana-streamer-sdk 1.5.13 v1.5.13 2026-06-09 18:57:08 +08:00
0xfnzero e263caa75d fix pumpfun wsol quote normalization v1.5.12 2026-06-08 03:13:04 +08:00
0xfnzero aa065e7cae Release solana-streamer-sdk 1.5.11 v1.5.11 2026-06-07 02:30:28 +08:00
0xfnzero 89bf36148f Release solana-streamer-sdk 1.5.10 v1.5.10 2026-06-07 02:00:14 +08:00
0xfnzero 28ffd0f566 Release solana-streamer-sdk 1.5.9 v1.5.9 2026-06-05 00:27:02 +08:00
0xfnzero 6582b310c3 Release solana-streamer-sdk 1.5.8 v1.5.8 2026-06-03 02:38:10 +08:00
0xfnzero 590801db7c Add PumpFun trade filter and create ix_name support v1.5.7 2026-06-03 01:07:45 +08:00
0xfnzero 9e93d2c5d1 Release solana-streamer-sdk 1.5.6 v1.5.6 2026-06-02 03:28:42 +08:00
0xfnzero 83c5476ff3 Release v1.5.5 parser SDK sync v1.5.5 2026-06-01 20:20:01 +08:00
0xfnzero 5a282bd84d Release solana-streamer-sdk v1.5.4 v1.5.4 2026-05-28 04:58:18 +08:00
0xfnzero 4cb22592e8 Release solana-streamer-sdk v1.5.3 v1.5.3 2026-05-28 03:44:42 +08:00
0xfnzero 02c8a6d168 Release solana-streamer 1.5.2 v1.5.2 2026-05-26 21:23:27 +08:00
0xfnzero 8b967f58d6 Release solana-streamer-sdk 1.5.1 v1.5.1 2026-05-26 07:22:21 +08:00
0xfnzero 8972d83492 Release streamer with parser SDK 0.5 v1.5.0 2026-05-26 00:19:07 +08:00
0xfnzero 6149ae2987 Integrate CLMM accounts and optimize ordered buffers v1.4.14 2026-05-26 00:03:22 +08:00
0xfnzero 983aedf27c Integrate Raydium CLMM upgraded parser events v1.4.13 2026-05-25 23:06:44 +08:00
0xfnzero 0875ec1a9d Use sol-parser-sdk 0.4.17 v1.4.12 2026-05-25 19:18:54 +08:00
0xfnzero eb1324d402 Use crates.io sol-parser-sdk dependency 2026-05-25 03:54:25 +08:00
0xfnzero 108b9a616f Release solana-streamer-sdk v1.4.11 v1.4.11 2026-05-25 03:38:28 +08:00
0xfnzero aaa10a69f7 Release parser SDK bridge updates v1.4.10 2026-05-25 01:48:41 +08:00
0xfnzero 45ab6eb061 Fix grpc subscription cleanup and API compatibility 2026-05-25 00:41:25 +08:00
0xfnzero 3cd3517d3e Merge pull request #70 from 0xfnzero/fix-grpc-reconnect-bad-protobuf
# Conflicts:
#	src/streaming/grpc/pool.rs
2026-05-25 00:35:22 +08:00
0xfnzero 41187ff84f Update parser dependency and release 1.4.9 v1.4.9 2026-05-21 17:48:52 +08:00
0xfnzero 79ffd856e0 Update sol-parser-sdk dependency to v0.4.13 2026-05-21 02:13:41 +08:00
0xfnzero 1beb07befa Release solana-streamer-sdk v1.4.8
Update sol-parser-sdk dependency to v0.4.12.
v1.4.8
2026-05-20 19:43:41 +08:00
mooncitydev 3c7bf52e01 fix grpc reconnect after stream death and skip bad protobuf updates
clear active_subscription when the yellowstone stream task exits or subscribe fails, so callers are not stuck on "already subscribed" after a disconnect.

replace unwrap/expect in grpc pool parsing with validation and skip malformed account or transaction updates instead of panicking the whole stream.
2026-05-19 04:26:51 -07:00
0xfnzero 5494fd5fb3 Release solana-streamer-sdk v1.4.7 v1.4.7 2026-05-19 00:27:06 +08:00
0xfnzero ea0f9b9145 Release solana-streamer-sdk v1.4.6 v1.4.6 2026-05-18 01:53:25 +08:00
0xfnzero b60838a840 Propagate PumpFun instruction amount fields v1.4.5 2026-05-17 21:32:48 +08:00