fixed export metaschema handler

Author: Zetazzz

functions/export-metaschema/handler.ts

@@ -1,7 +1,7 @@
 import type { PgpmFunctionContext, PgpmFunctionHandler } from '@constructive-io/fn-pgpm-runtime';
 import { DEFAULT_DATABASE_NAME } from '@constructive-io/fn-core';
 import { exportMigrations } from '@pgpmjs/core';
-import { getPgPool } from 'pg-cache';
+import { getPgPool, pgCache } from 'pg-cache';
 import { resolve } from 'path';
 
 type ExportMetaschemaParams = {
@@ -13,6 +13,8 @@ type ExportMetaschemaParams = {
   schema_names?: string[];
   outdir?: string;
   skipSchemaRenaming?: boolean;
+  username?: string;
+  repoName?: string;
 };
 
 const handler: PgpmFunctionHandler<ExportMetaschemaParams> = async (
@@ -48,6 +50,24 @@ const handler: PgpmFunctionHandler<ExportMetaschemaParams> = async (
   const databaseName = targetRow.name;
   const database_ids = [targetRow.id];
 
+  // Check that sql_actions exist for this database before exporting
+  const actionsResult = await pgPool.query(
+    'SELECT count(*)::int AS cnt FROM db_migrate.sql_actions WHERE database_id = $1',
+    [database_ids[0]]
+  );
+  const actionCount = actionsResult.rows[0]?.cnt ?? 0;
+
+  if (actionCount === 0) {
+    log.info('[export-metaschema] No sql_actions found, nothing to export', {
+      databaseName,
+      database_id: database_ids[0]
+    });
+    return {
+      complete: false,
+      reason: `No sql_actions found for database '${databaseName}' (${database_ids[0]}). The database may have been deployed from pre-built packages.`
+    };
+  }
+
   // Discover schemas if not provided
   let schema_names = params.schema_names;
   if (!schema_names?.length) {
@@ -65,13 +85,17 @@ const handler: PgpmFunctionHandler<ExportMetaschemaParams> = async (
   const author = params.author || 'Constructive <developers@constructive.io>';
   const extensionName = params.extensionName || databaseName;
   const metaExtensionName = params.metaExtensionName || `${databaseName}-service`;
+  // Default username/repoName to avoid interactive prompts from scaffoldTemplate
+  const username = params.username || 'constructive-io';
+  const repoName = params.repoName || extensionName;
 
   log.info('[export-metaschema] Starting export', {
     dbname,
     databaseName,
     database_ids,
     extensionName,
-    schema_names
+    schema_names,
+    actionCount
   });
 
   project.ensureWorkspace();
@@ -92,12 +116,18 @@ const handler: PgpmFunctionHandler<ExportMetaschemaParams> = async (
     schema_names,
     extensionName,
     metaExtensionName,
+    username,
+    repoName,
     skipSchemaRenaming: params.skipSchemaRenaming
   });
 
-  log.info('[export-metaschema] Export complete');
+  // exportMigrationsToDisk calls pgPool.end() which kills the cached pool.
+  // Evict the dead pool from pg-cache so the next request gets a fresh one.
+  pgCache.delete(dbname);
+
+  log.info('[export-metaschema] Export complete', { outdir });
 
-  return { complete: true };
+  return { complete: true, outdir, extensionName, metaExtensionName, actionCount };
 };
 
 export default handler;