feat: add IndexedDB functions for message retrieval by rowId (#2709)

Author: manfe

src/api/layers/retriever.layer.ts

@@ -15,20 +15,19 @@
  * along with WPPConnect.  If not, see <https://www.gnu.org/licenses/>.
  */
 
+import { ChatListOptions } from '@wppconnect/wa-js/dist/chat';
 import { Page } from 'puppeteer';
 import { CreateConfig } from '../../config/create-config';
 import { SessionToken } from '../../token-store';
 import { evaluateAndReturn } from '../helpers';
 import {
   Chat,
-  Contact,
   ContactStatus,
   ProfilePicThumbObj,
   WhatsappProfile,
   Wid,
 } from '../model';
 import { SenderLayer } from './sender.layer';
-import { ChatListOptions } from '@wppconnect/wa-js/dist/chat';
 
 export class RetrieverLayer extends SenderLayer {
   constructor(public page: Page, session?: string, options?: CreateConfig) {
@@ -627,4 +626,44 @@ export class RetrieverLayer extends SenderLayer {
       phoneOrLid
     );
   }
+
+  /**
+   * Get messages from IndexedDB 'model-storage' database starting from a specific rowId
+   *
+   * This function queries the IndexedDB database directly using the rowId index,
+   * retrieving messages with rowId greater than the specified value.
+   * It's useful for pagination or fetching messages in chronological order.
+   *
+   * @example
+   * ```javascript
+   * // Get 1000 messages after rowId 999960610
+   * const messages = await client.getMessagesFromRowId({ minRowId: 999960610 });
+   *
+   * // Get 500 messages after rowId 999960610
+   * const messages = await client.getMessagesFromRowId({
+   *   minRowId: 999960610,
+   *   limit: 500
+   * });
+   *
+   * // Get all available messages after rowId (use with caution)
+   * const messages = await client.getMessagesFromRowId({
+   *   minRowId: 999960610,
+   *   limit: -1
+   * });
+   * ```
+   * @category Chat
+   * @param options Options for fetching messages
+   * @returns Promise that resolves to an array of message objects from IndexedDB
+   */
+  public async getMessagesFromRowId(options: {
+    minRowId: number;
+    limit?: number;
+  }): Promise<any[]> {
+    return await evaluateAndReturn(
+      this.page,
+      // TODO: Change to WPP.indexdb.getMessagesFromRowId when version is released with this function
+      (options) => (WPP as any).indexdb.getMessagesFromRowId(options),
+      options
+    );
+  }
 }