Wire stream event handlers to persistence

[pragmaticAweds]

Context

The streams package now has Stream, WithdrawalAction, and CancelAction entities plus handlers for created, funded, withdrawal, and cancel events. Several handlers still only validate/log events and return success, so indexed stream events do not fully update persistent state yet.

Scope

• Add a streams repository/service for Stream, WithdrawalAction, and CancelAction writes
• Persist stream creation from StreamCreated events
• Apply funded events to stream totals or funding state as defined by the schema
• Persist withdrawal actions and update withdrawn totals idempotently
• Persist cancel actions and mark streams canceled idempotently
• Add tests that prove duplicate event processing does not double-count amounts

Out of Scope

• Defining new Soroban event shapes
• Distribution domain persistence
• GraphQL API resolvers
• Broad poller refactors outside handler persistence wiring

Acceptance Criteria

• Stream handlers write durable database state through a repository/service
• Handler tests cover create, fund, withdraw, cancel, duplicate replay, and missing stream cases
• Numeric token amounts are handled without floating-point precision loss
• Existing TODOs for stream handler persistence are removed or replaced with narrower follow-up notes
• bun run indexer:type-check passes
• bun run indexer:test passes
• bun run indexer:lint passes

Dependencies

• Define Streams database schema #32
• Create indexed events idempotency table #25
• Implement indexed event repository #27

Suggested Files or Packages

• indexer/streams/src/db/
• indexer/streams/src/handlers/
• indexer/common/src/db/repository.ts

[Tobi-8]

@Tobi-8 has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

please maintainer , assign me to this issue. I have looked through your description, and i have had experience in this type of issue.
kindly assign

ℹ️ Repo Maintainers: To accept this application, review their application or assign @Tobi-8 to this issue.

[attyolu]

@attyolu has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

Good evening Maintainer. I would love to work on this issue quickly. Please assign to me. Thank you

ℹ️ Repo Maintainers: To accept this application, review their application or assign @attyolu to this issue.

[6akola]

@6akola has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

Please, I would love to work on this issue.
Thank you.

ℹ️ Repo Maintainers: To accept this application, review their application or assign @6akola to this issue.

[Okorie2000-code]

@Okorie2000-code has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

Hi maintainer, can i work on this ? i can submit a clean PR before the deadline.

ℹ️ Repo Maintainers: To accept this application, review their application or assign @Okorie2000-code to this issue.

[GreatShinro]

@GreatShinro has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

Hi, can I work on this please?

ℹ️ Repo Maintainers: To accept this application, review their application or assign @GreatShinro to this issue.

[intelliDean]

@intelliDean has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

I'd like to work on this issue

ℹ️ Repo Maintainers: To accept this application, review their application or assign @intelliDean to this issue.

[newmattock]

@newmattock has applied to work on this issue as part of the Stellar Wave Program's 6th wave.

I'd love to work on this issue.

ℹ️ Repo Maintainers: To accept this application, review their application or assign @newmattock to this issue.

[drips-wave]

Congratulations, @GreatShinro! 🎉 Your application was accepted by the repo's maintainers, and the issue is due on June 30, 2026.

🧑‍💻 @GreatShinro: Please resolve the issue such that the repo's maintainers have enough time to review your contribution before the due date. You'll earn Points for completing the issue on-time, which will make you eligible for a share of the Stellar Wave Program's reward pool.

Warning

When opening a PR, please link it to this issue to ensure it gets tracked accurately. Points are awarded when this issue is marked as completed by the maintainer.

🤠 Repo maintainers: Please keep an eye on the contributor's progress and review their work before the due date. You can manage this issue, including adjusting its complexity and points, here.

🌊 Happy Wave 🌊