feat: enhance Hono and MSW plugins with improved exports and new ObjectStackServer class for better API interaction

Author: hotlong

packages/adapters/hono/package.json

@@ -4,6 +4,13 @@
   "license": "Apache-2.0",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
+  "exports": {
+    ".": {
+      "types": "./dist/index.d.ts",
+      "import": "./dist/index.js",
+      "require": "./dist/index.js"
+    }
+  },
   "scripts": {
     "build": "tsc"
   },

packages/plugins/plugin-hono-server/src/hono-plugin.ts

@@ -120,14 +120,3 @@ export class HonoServerPlugin implements Plugin {
         console.log('[HonoServerPlugin] Server stopped');
     }
 }
-
-
-    /**
-     * Destroy phase - Stop server
-     */
-    async destroy() {
-        this.server.close();
-        // Note: Can't use ctx.logger here since we're in destroy
-        console.log('[HonoServerPlugin] Server stopped');
-    }
-}

packages/plugins/plugin-msw/package.json

@@ -13,9 +13,10 @@
     "@objectstack/runtime": "^1.0.1"
   },
   "dependencies": {
+    "@objectstack/core": "^1.0.1",
+    "@objectstack/objectql": "workspace:*",
     "@objectstack/spec": "workspace:*",
     "@objectstack/types": "workspace:*",
-    "@objectstack/objectql": "workspace:*",
     "msw": "^2.0.0"
   },
   "devDependencies": {

packages/plugins/plugin-msw/src/msw-plugin.ts

@@ -9,7 +9,7 @@ import {
 } from '@objectstack/runtime';
 // import { ObjectStackProtocolImplementation } from '@objectstack/objectql';
 import { ObjectStackProtocol } from '@objectstack/spec/api';
-// import { IDataEngine } from '@objectstack/core';
+import { IDataEngine } from '@objectstack/core';
 
 // Helper for parsing query parameters
 function parseQueryParams(url: URL): Record<string, any> {
@@ -314,3 +314,46 @@ export class MSWPlugin implements Plugin {
         return this.handlers;
     }
 }
+
+/**
+ * Static helper for interacting with ObjectStack protocol in MSW handlers
+ */
+export class ObjectStackServer {
+    private static protocol: ObjectStackProtocol;
+
+    static init(protocol: ObjectStackProtocol) {
+        this.protocol = protocol;
+    }
+
+    private static getProtocol(): ObjectStackProtocol {
+        if (!this.protocol) {
+            throw new Error('ObjectStackServer not initialized. Call ObjectStackServer.init(protocol) first.');
+        }
+        return this.protocol;
+    }
+
+    static async findData(objectName: string, query?: any) {
+        const body = await this.getProtocol().findData({ object: objectName, query });
+        return { data: body, status: 200 };
+    }
+
+    static async getData(objectName: string, id: string) {
+        const body = await this.getProtocol().getData({ object: objectName, id });
+        return { data: body, status: 200 };
+    }
+
+    static async createData(objectName: string, data: any) {
+        const body = await this.getProtocol().createData({ object: objectName, data });
+        return { data: body, status: 201 };
+    }
+
+    static async updateData(objectName: string, id: string, data: any) {
+        const body = await this.getProtocol().updateData({ object: objectName, id, data });
+        return { data: body, status: 200 };
+    }
+
+    static async deleteData(objectName: string, id: string) {
+        const body = await this.getProtocol().deleteData({ object: objectName, id });
+        return { data: body, status: 200 };
+    }
+}