Merge pull request #407 from ambermartin681/feat/386-request-deduplication

feat: implement request deduplication with getDedupStats and dedupe o…

Author: Kingsman-99

src/client.ts

@@ -1321,25 +1321,36 @@ export class StellarSplitClient {
    */
   async getInvoice(
     invoiceId: string,
+    opts?: { retry?: PerMethodRetryOptions; dedupe?: boolean }
     opts?: { retry?: PerMethodRetryOptions; traceId?: string; timeout?: number }
   ): Promise<Invoice> {
     return this._withCache("getInvoice", [invoiceId], async () => {
       const fetcher = this._batcher
         ? () => this._batcher!.getInvoice(invoiceId)
         : () => this._fetchInvoice(invoiceId, opts?.traceId);
 
+      const useDedupe = opts?.dedupe !== false;
       const effectiveRetry = opts?.retry ?? (this._retryOptions ? {} : undefined);
       if (this._retryOptions && effectiveRetry !== undefined) {
         return await executeWithRetry(
-          () => this._dedup.dedupe(invoiceId, fetcher),
+          () => useDedupe ? this._dedup.dedupe(invoiceId, fetcher) : fetcher(),
           this._retryOptions,
           opts?.retry
         );
       }
-      return await this._dedup.dedupe(invoiceId, fetcher);
+      return useDedupe ? this._dedup.dedupe(invoiceId, fetcher) : fetcher();
     });
   }
 
+  /**
+   * Returns deduplication statistics for observability.
+   * @returns { deduped: number, total: number } — deduped is how many calls were short-circuited.
+   */
+  getDedupStats(): { deduped: number; total: number } {
+    return this._dedup.getDedupStats();
+  }
+
+  private async _fetchInvoice(invoiceId: string): Promise<Invoice> {
   private async _fetchInvoice(invoiceId: string, traceId?: string): Promise<Invoice> {
     const startTime = Date.now();
     const req = { method: "getInvoice", params: [invoiceId], headers: traceId ? { "X-Trace-Id": traceId } : undefined };

src/dedup.ts

@@ -19,4 +19,8 @@ export class Deduplicator<T> {
     const total = this._hits + this._misses;
     return total === 0 ? 0 : this._hits / total;
   }
+
+  getDedupStats(): { deduped: number; total: number } {
+    return { deduped: this._hits, total: this._hits + this._misses };
+  }
 }