fix: enhance database connection handling in SqlDriver to ensure directory existence

Author: hotlong

packages/metadata/src/plugin.ts

@@ -105,25 +105,39 @@ export class MetadataPlugin implements Plugin {
         });
 
         // Bridge database driver from kernel service registry to MetadataManager.
-        // DriverPlugin registers drivers as 'driver.{name}' services during init().
-        // This runs AFTER filesystem loading so that system metadata populated via
-        // register() above is stored in-memory only, without being persisted to the
-        // database (which would create noisy DB state/history on every cold boot).
+        // Uses ObjectQL engine's datasource mapping to resolve the correct driver
+        // for sys_metadata (respects namespace → datasource routing).
         try {
-            const services = ctx.getServices();
-            for (const [serviceName, service] of services) {
-                if (serviceName.startsWith('driver.') && service) {
-                    ctx.logger.info('[MetadataPlugin] Bridging driver to MetadataManager for database-backed persistence', {
-                        driverService: serviceName,
+            const ql = ctx.getService<any>('objectql');
+            if (ql) {
+                const tableName = this.manager['config']?.tableName ?? 'sys_metadata';
+                const driver = ql.getDriverForObject?.(tableName);
+                if (driver) {
+                    ctx.logger.info('[MetadataPlugin] Bridging driver to MetadataManager via ObjectQL routing', {
+                        tableName,
+                        driver: driver.name,
                     });
-                    this.manager.setDatabaseDriver(service);
-                    break; // Use the first discovered driver — typically only one driver is registered per deployment
+                    this.manager.setDatabaseDriver(driver);
+                } else {
+                    ctx.logger.debug('[MetadataPlugin] ObjectQL could not resolve driver for metadata table', { tableName });
                 }
             }
-        } catch (e: any) {
-            ctx.logger.debug('[MetadataPlugin] No driver service found — database metadata persistence not available', {
-                error: e.message,
-            });
+        } catch {
+            // ObjectQL not available — fall back to first available driver service
+            try {
+                const services = ctx.getServices();
+                for (const [serviceName, service] of services) {
+                    if (serviceName.startsWith('driver.') && service) {
+                        ctx.logger.info('[MetadataPlugin] Bridging driver to MetadataManager (fallback: first driver)', {
+                            driverService: serviceName,
+                        });
+                        this.manager.setDatabaseDriver(service);
+                        break;
+                    }
+                }
+            } catch (e: any) {
+                ctx.logger.debug('[MetadataPlugin] No driver service found', { error: e.message });
+            }
         }
 
         // Bridge realtime service from kernel service registry to MetadataManager.

packages/plugins/driver-sql/src/sql-driver.ts

@@ -148,7 +148,9 @@ export class SqlDriver implements IDataDriver {
   // ===================================
 
   async connect(): Promise<void> {
-    return Promise.resolve();
+    // Ensure the database directory exists before any query can trigger
+    // better-sqlite3 to open the file (e.g. loadMetaFromDb on startup).
+    await this.ensureDatabaseExists();
   }
 
   async checkHealth(): Promise<boolean> {
@@ -1006,8 +1008,21 @@ export class SqlDriver implements IDataDriver {
   // ── Database helpers ────────────────────────────────────────────────────────
 
   protected async ensureDatabaseExists() {
-    // SQLite auto-creates database files — no need to check
-    if (this.isSqlite) return;
+    // SQLite auto-creates database files but NOT parent directories.
+    // Ensure the directory exists so better-sqlite3 can create the file.
+    if (this.isSqlite) {
+      const conn = (this.config as any).connection;
+      const filename = typeof conn === 'string' ? conn : conn?.filename;
+      if (filename && filename !== ':memory:' && !filename.startsWith(':')) {
+        const { dirname } = await import('node:path');
+        const { mkdir } = await import('node:fs/promises');
+        const dir = dirname(filename);
+        if (dir && dir !== '.') {
+          await mkdir(dir, { recursive: true });
+        }
+      }
+      return;
+    }
 
     // Only PostgreSQL and MySQL support programmatic database creation
     if (!this.isPostgres && !this.isMysql) return;

packages/services/service-feed/src/objects/feed-item.object.ts

@@ -11,7 +11,8 @@ import { ObjectSchema, Field } from '@objectstack/spec/data';
  * Belongs to `service-feed` package per "protocol + service ownership" pattern.
  */
 export const FeedItem = ObjectSchema.create({
-  name: 'sys_feed_item',
+  namespace: 'sys',
+  name: 'feed_item',
   label: 'Feed Item',
   pluralLabel: 'Feed Items',
   icon: 'message-square',

packages/services/service-feed/src/objects/feed-reaction.object.ts

@@ -11,7 +11,8 @@ import { ObjectSchema, Field } from '@objectstack/spec/data';
  * Belongs to `service-feed` package per "protocol + service ownership" pattern.
  */
 export const FeedReaction = ObjectSchema.create({
-  name: 'sys_feed_reaction',
+  namespace: 'sys',
+  name: 'feed_reaction',
   label: 'Feed Reaction',
   pluralLabel: 'Feed Reactions',
   icon: 'smile',

packages/services/service-feed/src/objects/record-subscription.object.ts

@@ -11,7 +11,8 @@ import { ObjectSchema, Field } from '@objectstack/spec/data';
  * Belongs to `service-feed` package per "protocol + service ownership" pattern.
  */
 export const RecordSubscription = ObjectSchema.create({
-  name: 'sys_record_subscription',
+  namespace: 'sys',
+  name: 'record_subscription',
   label: 'Record Subscription',
   pluralLabel: 'Record Subscriptions',
   icon: 'bell',