feat: add CRM server implementation with ObjectStack integration and logging

Author: hotlong

examples/crm/package.json

@@ -11,7 +11,7 @@
   },
   "scripts": {
     "build": "objectstack compile objectstack.config.ts dist/objectstack.json",
-    "dev": "objectstack dev"
+    "start": "tsx server.ts"
   },
   "dependencies": {
     "@objectstack/spec": "^0.8.0"

examples/crm/server.ts

@@ -0,0 +1,59 @@
+
+import { ObjectKernel } from '@objectstack/core';
+import { ObjectQLPlugin } from '@objectstack/objectql';
+import { AppPlugin, DriverPlugin } from '@objectstack/runtime';
+import { HonoServerPlugin } from '@objectstack/plugin-hono-server';
+import { InMemoryDriver } from '@objectstack/driver-memory';
+import config from './objectstack.config';
+import { pino } from 'pino';
+
+async function startServer() {
+  const logger = pino({
+    level: 'info',
+    transport: {
+      target: 'pino-pretty',
+      options: {
+        colorize: true
+      }
+    }
+  });
+
+  logger.info('Starting CRM Server...');
+
+  try {
+    // Initialize Kernel
+    const kernel = new ObjectKernel({
+      logger,
+    });
+
+    // 1. Core Engine (ObjectQL)
+    const qlPlugin = new ObjectQLPlugin();
+    kernel.use(qlPlugin);
+
+    // 2. Data Driver (Memory)
+    const memoryDriver = new InMemoryDriver();
+    const driverPlugin = new DriverPlugin(memoryDriver);
+    kernel.use(driverPlugin);
+
+    // 3. Application (crm_app from config)
+    // The config export from defineStack is treated as an App Bundle or Manifest
+    const appPlugin = new AppPlugin(config);
+    kernel.use(appPlugin);
+
+    // 4. HTTP Server
+    const serverPlugin = new HonoServerPlugin({ port: 3000 });
+    kernel.use(serverPlugin);
+
+    // Bootstrap
+    await kernel.bootstrap();
+    
+    logger.info('✅ CRM Server is running on http://localhost:3000');
+    logger.info('   GraphQL: http://localhost:3000/graphql');
+
+  } catch (error) {
+    logger.error(error, 'Failed to start server');
+    process.exit(1);
+  }
+}
+
+startServer();

package.json

@@ -18,6 +18,7 @@
   "scripts": {
     "dev": "pnpm --filter @object-ui/console dev",
     "dev:console": "pnpm --filter @object-ui/console dev",
+    "dev:crm": "pnpm --filter @object-ui/example-crm start",
     "build": "turbo run build",
     "pretest": "turbo run build --filter=@object-ui/types --filter=@object-ui/core --filter=@object-ui/react --filter=@object-ui/components --filter=@object-ui/fields --filter=@object-ui/layout --filter=@object-ui/plugin-kanban --filter=@object-ui/plugin-charts --filter=@object-ui/plugin-form --filter=@object-ui/plugin-grid --filter=@object-ui/plugin-dashboard",
     "test": "turbo run test",
@@ -114,8 +115,9 @@
     }
   },
   "dependencies": {
+    "@objectstack/plugin-hono-server": "^0.8.0",
     "coverage-v8": "0.0.1-security",
-    "pino": "^10.3.0",
+    "pino": "^8.21.0",
     "pino-pretty": "^13.1.3"
   },
   "msw": {

packages/plugin-form/src/ObjectForm.msw.test.tsx

@@ -19,10 +19,10 @@ const BASE_URL = process.env.OBJECTSTACK_API_URL || 'http://test-api.com';
 const mockSchema = ContactObject;
 
 const mockRecord = {
-  _id: 'rec_123',
-  name: 'Alice Smith',
+  _id: '1',
+  name: 'Alice Johnson',
   email: 'alice@example.com',
-  status: 'Customer'
+  status: 'Active'
 };
 
 // --- MSW Setup ---
@@ -57,7 +57,7 @@ const handlers = [
   // Mock Record Fetch: GET /api/v1/data/:object/:id
   http.get(`${BASE_URL}/api/v1/data/:object/:id`, ({ params }) => {
     const { object, id } = params;
-    if (object === 'contact' && id === 'rec_123') {
+    if (object === 'contact' && id === '1') {
       return HttpResponse.json(mockRecord);
     }
     return new HttpResponse(null, { status: 404 });
@@ -111,7 +111,7 @@ describe('ObjectForm with ObjectStack/MSW', () => {
           type: 'object-form',
           objectName: 'contact',
           mode: 'edit',
-          recordId: 'rec_123'
+          recordId: '1'
         }}
         dataSource={dataSource}
       />
@@ -120,7 +120,7 @@ describe('ObjectForm with ObjectStack/MSW', () => {
     // Initial load of schema logic + data fetch
     await waitFor(() => {
       // Changed from 'Full Name' to 'Name'
-      expect(screen.getByRole('textbox', { name: /Name/i })).toHaveValue('Alice Smith');
+      expect(screen.getByRole('textbox', { name: /Name/i })).toHaveValue('Alice Johnson');
     }, { timeout: 2000 }); // Give slight buffer for network mock
 
     // Changed from 'Email Address' to 'Email'