chore(sds): allow specifying lookback time range for store query

Author: danisharora099

packages/sdk/src/query_on_connect/query_on_connect.ts

@@ -26,6 +26,13 @@ export interface QueryOnConnectOptions {
    * @default [[DEFAULT_FORCE_QUERY_THRESHOLD_MS]]
    */
   forceQueryThresholdMs?: number;
+  /**
+   * Maximum time range to look back when performing a store query on connect.
+   * This value is capped server-side to 24h per single request; larger ranges
+   * will be chunked by the SDK Store layer.
+   * @default [[MAX_TIME_RANGE_QUERY_MS]] (24 hours)
+   */
+  maxTimeRangeQueryMs?: number;
 }
 
 export enum QueryOnConnectEvent {
@@ -51,6 +58,7 @@ export class QueryOnConnect<
   private lastSuccessfulQuery: number;
   private lastTimeOffline: number;
   private readonly forceQueryThresholdMs: number;
+  private readonly maxTimeRangeQueryMs: number;
 
   public constructor(
     public decoders: IDecoder<T>[],
@@ -67,6 +75,8 @@ export class QueryOnConnect<
     this.lastTimeOffline = 0;
     this.forceQueryThresholdMs =
       options?.forceQueryThresholdMs ?? DEFAULT_FORCE_QUERY_THRESHOLD_MS;
+    this.maxTimeRangeQueryMs =
+      options?.maxTimeRangeQueryMs ?? MAX_TIME_RANGE_QUERY_MS;
   }
 
   public start(): void {
@@ -140,7 +150,7 @@ export class QueryOnConnect<
     return calculateTimeRange(
       Date.now(),
       this.lastSuccessfulQuery,
-      MAX_TIME_RANGE_QUERY_MS
+      this.maxTimeRangeQueryMs
     );
   }
 

packages/sdk/src/reliable_channel/reliable_channel.ts

@@ -111,6 +111,14 @@ export type ReliableChannelOptions = MessageChannelOptions & {
    * @default 1000 (1 second)
    */
   processTaskMinElapseMs?: number;
+  /**
+   * Maximum lookback window for the initial store query performed by
+   * QueryOnConnect when a store peer connects.
+   * This is capped to 24h per request server-side; longer windows will be
+   * chunked by the Store SDK.
+   * @default 24h
+   */
+  initialQueryLookbackMs?: number;
 };
 
 /**
@@ -190,7 +198,12 @@ export class ReliableChannel<
           [this.decoder],
           peerManagerEvents,
           node.events,
-          this._retrieve.bind(this)
+          this._retrieve.bind(this),
+          {
+            maxTimeRangeQueryMs: options?.initialQueryLookbackMs,
+            // Keep existing default unless user overrides
+            forceQueryThresholdMs: undefined
+          }
         );
       }
     }