feat: add optional packageId parameter to getMetaItems and getMetaItem methods for filtering

Author: hotlong

packages/objectql/src/protocol.ts

@@ -185,19 +185,22 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
         };
     }
 
-    async getMetaItems(request: { type: string }) {
-        let items = SchemaRegistry.listItems(request.type);
+    async getMetaItems(request: { type: string; packageId?: string }) {
+        const { packageId } = request;
+        let items = SchemaRegistry.listItems(request.type, packageId);
         // Normalize singular/plural: REST uses singular ('app') but registry may store as plural ('apps')
         if (items.length === 0) {
             const alt = request.type.endsWith('s') ? request.type.slice(0, -1) : request.type + 's';
-            items = SchemaRegistry.listItems(alt);
+            items = SchemaRegistry.listItems(alt, packageId);
         }
 
         // Fallback to database if registry is empty for this type
         if (items.length === 0) {
             try {
+                const whereClause: any = { type: request.type, state: 'active' };
+                if (packageId) whereClause._packageId = packageId;
                 const allRecords = await this.engine.find('sys_metadata', {
-                    where: { type: request.type, state: 'active' }
+                    where: whereClause
                 });
                 if (allRecords && allRecords.length > 0) {
                     items = allRecords.map((record: any) => {
@@ -235,7 +238,7 @@ export class ObjectStackProtocolImplementation implements ObjectStackProtocol {
         };
     }
 
-    async getMetaItem(request: { type: string, name: string }) {
+    async getMetaItem(request: { type: string, name: string, packageId?: string }) {
         let item = SchemaRegistry.getItem(request.type, request.name);
         // Normalize singular/plural
         if (item === undefined) {

packages/rest/src/rest-server.ts

@@ -306,7 +306,8 @@ export class RestServer {
                 path: `${metaPath}/:type`,
                 handler: async (req: any, res: any) => {
                     try {
-                        const items = await this.protocol.getMetaItems({ type: req.params.type });
+                        const packageId = req.query?.package || undefined;
+                        const items = await this.protocol.getMetaItems({ type: req.params.type, packageId });
                         res.json(items);
                     } catch (error: any) {
                         res.status(404).json({ error: error.message });
@@ -365,7 +366,8 @@ export class RestServer {
                             res.json(result.data);
                         } else {
                             // Non-cached version
-                            const item = await this.protocol.getMetaItem({ type: req.params.type, name: req.params.name });
+                            const packageId = req.query?.package || undefined;
+                            const item = await this.protocol.getMetaItem({ type: req.params.type, name: req.params.name, packageId });
                             res.json(item);
                         }
                     } catch (error: any) {

packages/spec/src/api/protocol.zod.ts

@@ -155,6 +155,7 @@ export const GetMetaTypesResponseSchema = z.object({
  */
 export const GetMetaItemsRequestSchema = z.object({
   type: z.string().describe('Metadata type name (e.g., "object", "plugin")'),
+  packageId: z.string().optional().describe('Optional package ID to filter items by'),
 });
 
 /**
@@ -172,6 +173,7 @@ export const GetMetaItemsResponseSchema = z.object({
 export const GetMetaItemRequestSchema = z.object({
   type: z.string().describe('Metadata type name'),
   name: z.string().describe('Item name (snake_case identifier)'),
+  packageId: z.string().optional().describe('Optional package ID to filter items by'),
 });
 
 /**