11/**
2- * StreamsModule  all DripStream + DripFactory operations.
2+ * StreamsModule - all DripStream + DripFactory operations.
33 */
44
55import { SorobanRpc , nativeToScVal , xdr , Address , Transaction } from '@stellar/stellar-sdk' ;
@@ -33,7 +33,7 @@ import {
3333import { FactoryModule } from './factory.js' ;
3434import { ConduitError , RateLimitError , StreamErrorCode } from './errors.js' ;
3535
36- // ── Deprecation warnings ─────────────────────────────────────────────────
36+ // Deprecation warnings
3737
3838/**
3939 * Tracks which v1-deprecated methods have already warned this session, so
@@ -109,7 +109,7 @@ export class StreamsModule {
109109 /**
110110 * Resolve the caller address, handling both sync and async getPublicKey().
111111 * Unlike _signerPublicKey(), this can be used when the wallet adapter
112- * returns a promise  but it MUST only be called from async contexts.
112+ * returns a promise - but it MUST only be called from async contexts.
113113 */
114114 private async _resolveCallerAddress ( ) : Promise < string > {
115115 if ( this . activeWallet ) {
@@ -218,7 +218,7 @@ export class StreamsModule {
218218 return parseStreamInfo ( id , addr , val ) ;
219219 }
220220
221- /** Get withdrawable balance  read-only, no transaction. */
221+ /** Get withdrawable balance - read-only, no transaction. */
222222 async withdrawable ( streamId : bigint | string ) : Promise < bigint > {
223223 const id = BigInt ( streamId ) ;
224224 const addr = await this . _resolveAddr ( id ) ;
@@ -376,7 +376,7 @@ export class StreamsModule {
376376 return pageFromFilteredIds ( await this . _factory . streamsByRecipient ( recipient , offset , limit ) ) ;
377377 }
378378
379- // Neither sender nor recipient  return empty page
379+ // Neither sender nor recipient - return empty page
380380 return { streams : [ ] , hasNextPage : false , totalCount : 0n , offset, limit } ;
381381 }
382382
@@ -391,7 +391,7 @@ export class StreamsModule {
391391 return subscribeToStream ( this . config . rpcUrl ! , address , handlers ) ;
392392 }
393393
394- /** Synchronous subscribe  resolves address lazily on first poll tick. */
394+ /** Synchronous subscribe - resolves address lazily on first poll tick. */
395395 subscribe ( streamId : bigint | string , handlers : StreamEventHandlers ) : Subscription {
396396 let inner : Subscription | null = null ;
397397 let stopped = false ;
@@ -417,7 +417,7 @@ export class StreamsModule {
417417 } ;
418418 }
419419
420- // ââ€â‚¬Ã¢â€â‚¬ Private helpers ââ€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬
420+ // Private helpers
421421
422422 private _ensureCanMutate ( ) : void {
423423 if ( ! this . activeWallet && ! this . config . signer && ! this . config . keypair ) {
@@ -535,7 +535,7 @@ export class StreamsModule {
535535 }
536536}
537537
538- // ââ€â‚¬Ã¢â€â‚¬ Parsing ââ€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬Ã¢â€â‚¬
538+ // Parsing
539539
540540function parseStreamInfo ( id : bigint , address : string , val : xdr . ScVal ) : StreamInfo {
541541 const entries = val . map ( ) ?? [ ] ;
0 commit comments