[EmmanuelOchaje]

Summary

Four enhancements to DripStream and DripFactory contracts:

• contracts/stream/src/errors.rs: add ZeroRateStreamNotAllowed error variant #792: Zero-rate stream validation
• contracts/stream/src/ttl.rs: add bump_stream_instance function for low-cost keeper maintenance #791: Keeper-driven low-cost TTL maintenance function
• contracts/stream/src/lib.rs: allow sender to update stream title or reference tag post-creation #790: Sender-controlled post-creation stream metadata
• contracts/factory/src/tests.rs: test factory behavior under high stream creation concurrency #789: High-concurrency factory stress tests

Changes

1. ZeroRateStreamNotAllowed Error (#792)

File: contracts/stream/src/errors.rs

Added new error variant ZeroRateStreamNotAllowed = 22 to explicitly reject stream creation with rate_per_second <= 0. Improves error specificity over generic InvalidAmount.

2. bump_stream_instance Keeper Function (#791)

File: contracts/stream/src/ttl.rs

Added low-cost public function bump_stream_instance(env: &Env, stream_id: &str) -> Result<(), Error> that:

• Extends instance TTL when remaining < threshold
• Allows keepers to maintain archived streams with minimal gas cost
• Prevents long-pause scenarios where streams become unresumable
• Validates stream existence before bumping

3. Stream Title & Reference Tag (#790)

Files: contracts/stream/src/storage.rs, contracts/stream/src/lib.rs

Added sender-modifiable post-creation metadata:

• set_stream_title(env, caller, title) — update descriptive name
• set_reference_tag(env, caller, tag) — link to external systems (invoice, order ID)
• stream_title(env) -> Option<String> — read title
• reference_tag(env) -> Option<String> — read tag

Storage keys: DataKey::StreamTitle and DataKey::ReferenceTag

4. High-Concurrency Factory Tests (#789)

File: contracts/factory/src/tests.rs

Added two new tests:

high_stream_creation_concurrency()

• Creates 50 streams rapidly with unique senders/recipients
• Verifies no stream_id collisions
• Spot-checks index queryability
• Stresses factory storage and deployment pipeline

concurrent_stream_creation_maintains_factory_invariants()

• Creates 50 streams (5 per sender, 10 senders)
• Tests sender-indexed lookups under concurrent load
• Verifies event counts reflect all creations
• Ensures no cross-contamination between senders

Both tests ensure factory behavior remains correct under stream creation load.

Technical Notes

• All sender-protected operations (set_stream_title, set_reference_tag) require caller auth and prevent calls on cancelled streams
• TTL bumping uses existing env.storage().instance().extend_ttl() mechanics
• Metadata keys follow existing DataKey enum pattern
• Factory tests extend existing Setup harness for consistency

Closes #792
Closes #791
Closes #790
Closes #789

[drips-wave]

@EmmanuelOchaje Great news! 🎉 Based on an automated assessment of this PR, the linked Wave issue(s) no longer count against your application limits.

You can now already apply to more issues while waiting for a review of this PR. Keep up the great work! 🚀

Learn more about application limits