remove cap of 20 kowledge assets

Author: Bojan131

apps/agent/.gitignore

@@ -54,3 +54,4 @@ ragas-results.json
 logs
 storage
 docker-compose.knowledge-manager.yml
+DKG_Node_Publisher_Tests.xml

packages/plugin-dkg-publisher/src/mcp/tools.ts

@@ -123,9 +123,10 @@ export function registerMcpTools(mcp: any, serviceContainer: ServiceContainer |
     "knowledge-asset-list-recent",
     {
       title: "List Recent Knowledge Assets",
-      description: "Show, list, or display recent knowledge assets. Use when user asks 'show me recent assets', 'what was published', 'last X assets', etc. Can filter by status (published, failed, publishing, queued). Always returns up to 20 most recent assets (capped at 20).",
+      description: "Show, list, or display recent knowledge assets. Use when user asks 'show me recent assets', 'what was published', 'last X assets', 'publishes 200-500', etc. Can filter by status (published, failed, publishing, queued). Supports pagination with offset for large queries.",
       inputSchema: {
-        limit: z.number().min(1).max(20).default(5).optional().describe("Number of assets to return (1-20, default: 5)"),
+        limit: z.number().min(1).default(20).optional().describe("Number of assets to return (default: 20)"),
+        offset: z.number().min(0).default(0).optional().describe("Number of assets to skip (for pagination, default: 0)"),
         status: z.enum(["published", "failed", "publishing", "queued"]).optional().describe("Filter by status (optional)"),
       },
     },
@@ -135,26 +136,31 @@ export function registerMcpTools(mcp: any, serviceContainer: ServiceContainer |
       }
 
       const assetService = serviceContainer.get<AssetService>("assetService");
+      
       const assetsList = await assetService.getRecentAssets(
-        input.limit || 5,
+        input.limit,
         input.status,
+        input.offset,
       );
 
       if (assetsList.length === 0) {
         const statusFilter = input.status ? ` with status '${input.status}'` : '';
+        const rangeText = input.offset > 0 ? ` (range ${input.offset + 1}-${input.offset + input.limit})` : '';
         return {
           content: [
             {
               type: "text",
-              text: `No assets found${statusFilter}.\n\nNo knowledge assets have been published yet.`,
+              text: `No assets found${statusFilter}${rangeText}.\n\nNo knowledge assets in this range.`,
             },
           ],
         };
       }
 
-      const requestedLimit = input.limit || 5;
       const statusFilter = input.status ? ` ${input.status}` : '';
-      let resultText = `**Last ${assetsList.length}${statusFilter} Assets** (showing most recent, max ${requestedLimit})\n\n`;
+      const rangeStart = input.offset + 1;
+      const rangeEnd = input.offset + assetsList.length;
+      const rangeText = input.offset > 0 ? ` (${rangeStart}-${rangeEnd})` : '';
+      let resultText = `**${assetsList.length}${statusFilter} Assets${rangeText}**\n\n`;
 
       const db = serviceContainer.get<Database>("db");
 
@@ -210,10 +216,11 @@ export function registerMcpTools(mcp: any, serviceContainer: ServiceContainer |
     "knowledge-asset-query-by-status",
     {
       title: "Find Knowledge Assets by Status",
-      description: "Find, show, list, or query knowledge assets by publishing status. Use when user asks 'show me all published', 'failed assets', 'what's publishing', etc. Supports statuses: published (successfully published), failed (publishing failed), publishing (currently being published), queued (waiting to publish). Always returns up to 20 most recent assets matching the status (capped at 20).",
+      description: "Find, show, list, or query knowledge assets by publishing status. Use when user asks 'show me all published', 'failed assets', 'what's publishing', 'publishes 100-200', etc. Supports statuses: published (successfully published), failed (publishing failed), publishing (currently being published), queued (waiting to publish). Supports pagination with offset for large queries.",
       inputSchema: {
         status: z.enum(["published", "failed", "publishing", "queued"]).describe("The status to filter by"),
-        limit: z.number().min(1).max(20).default(10).optional().describe("Maximum number of results (1-20, default: 10)"),
+        limit: z.number().min(1).default(20).optional().describe("Maximum number of results (default: 20)"),
+        offset: z.number().min(0).default(0).optional().describe("Number of assets to skip (for pagination, default: 0)"),
       },
     },
     async (input: any, req: any) => {
@@ -222,25 +229,30 @@ export function registerMcpTools(mcp: any, serviceContainer: ServiceContainer |
       }
 
       const assetService = serviceContainer.get<AssetService>("assetService");
+      
       const assetsList = await assetService.getAssetsByStatusForDisplay(
         input.status,
-        input.limit || 10,
+        input.limit,
+        input.offset,
       );
 
       if (assetsList.length === 0) {
+        const rangeText = input.offset > 0 ? ` (range ${input.offset + 1}-${input.offset + input.limit})` : '';
         return {
           content: [
             {
               type: "text",
-              text: `No assets found with status: ${input.status}\n\n` +
-                   `No ${input.status} knowledge assets found.`,
+              text: `No assets found with status: ${input.status}${rangeText}\n\n` +
+                   `No ${input.status} knowledge assets in this range.`,
             },
           ],
         };
       }
 
-      const requestedLimit = input.limit || 10;
-      let resultText = `**Last ${assetsList.length} ${input.status.toUpperCase()} Assets** (showing most recent, max ${requestedLimit})\n\n`;
+      const rangeStart = input.offset + 1;
+      const rangeEnd = input.offset + assetsList.length;
+      const rangeText = input.offset > 0 ? ` (${rangeStart}-${rangeEnd})` : '';
+      let resultText = `**${assetsList.length} ${input.status.toUpperCase()} Assets${rangeText}**\n\n`;
 
       const db = serviceContainer.get<Database>("db");
 

packages/plugin-dkg-publisher/src/services/AssetService.ts

@@ -596,24 +596,25 @@ export class AssetService extends EventEmitter {
    * Get recent assets for display (all users, no filtering by userId)
    */
   async getRecentAssets(
-    limit: number = 5,
+    limit: number = 20,
     statusFilter?: "published" | "failed" | "publishing" | "queued",
+    offset: number = 0,
   ): Promise<AssetStatus[]> {
-    const cappedLimit = Math.min(limit, 20); // Cap at 20
-
     let query = this.db
       .select()
       .from(assets)
       .orderBy(desc(assets.createdAt))
-      .limit(cappedLimit);
+      .limit(limit)
+      .offset(offset);
 
     if (statusFilter) {
       const results = await this.db
         .select()
         .from(assets)
         .where(eq(assets.status, statusFilter))
         .orderBy(desc(assets.createdAt))
-        .limit(cappedLimit);
+        .limit(limit)
+        .offset(offset);
 
       return results.map((asset) => ({
         id: asset.id,
@@ -646,14 +647,16 @@ export class AssetService extends EventEmitter {
    */
   async getAssetsByStatusForDisplay(
     status: "published" | "failed" | "publishing" | "queued",
-    limit: number = 10,
+    limit: number = 20,
+    offset: number = 0,
   ): Promise<AssetStatus[]> {
     const results = await this.db
       .select()
       .from(assets)
       .where(eq(assets.status, status))
       .orderBy(desc(assets.createdAt))
-      .limit(Math.min(limit, 20)); // Cap at 20
+      .limit(limit)
+      .offset(offset);
 
     return results.map((asset) => ({
       id: asset.id,