Merge pull request #3977 from 0xbbjoker/0xbbjoker/fix-postgres-url-persistence

fix: store postgres connection URL properly in global config

Author: lalalune

packages/cli/src/commands/create.ts

@@ -79,6 +79,99 @@ async function installDependencies(targetDir: string) {
   }
 }
 
+/**
+ * Stores Postgres URL in the global .env file
+ * @param url The Postgres URL to store
+ */
+async function storePostgresUrl(url: string): Promise<void> {
+  if (!url) return;
+
+  try {
+    const homeDir = os.homedir();
+    const globalEnvPath = path.join(homeDir, '.eliza', '.env');
+
+    await fs.writeFile(globalEnvPath, `POSTGRES_URL=${url}\n`, { flag: 'a' });
+    logger.success('Postgres URL saved to configuration');
+  } catch (error) {
+    logger.warn('Error saving database configuration:', error);
+  }
+}
+
+/**
+ * Validates a Postgres URL format
+ * @param url The URL to validate
+ * @returns True if the URL appears valid
+ */
+function isValidPostgresUrl(url: string): boolean {
+  if (!url) return false;
+
+  // Basic pattern: postgresql://user:password@host:port/dbname
+  const basicPattern = /^postgresql:\/\/[^:]+:[^@]+@[^:]+:\d+\/\w+$/;
+
+  // More permissive pattern (allows missing password, different formats)
+  const permissivePattern = /^postgresql:\/\/.*@.*:\d+\/.*$/;
+
+  return basicPattern.test(url) || permissivePattern.test(url);
+}
+
+/**
+ * Prompts the user for a Postgres URL, validates it, and stores it
+ * @returns The configured Postgres URL or null if user skips
+ */
+async function promptAndStorePostgresUrl(): Promise<string | null> {
+  let isValidUrl = false;
+  let userUrl = '';
+
+  while (!isValidUrl) {
+    // Prompt for postgres url with simpler message
+    const reply = await prompts({
+      type: 'text',
+      name: 'postgresUrl',
+      message: 'Enter your Postgres URL:',
+      validate: (value) => value.trim() !== '' || 'Postgres URL cannot be empty',
+    });
+
+    // Handle cancellation
+    if (!reply.postgresUrl) {
+      const { continueAnyway } = await prompts({
+        type: 'confirm',
+        name: 'continueAnyway',
+        message: 'Continue without configuring Postgres?',
+        initial: false,
+      });
+
+      if (continueAnyway) return null;
+      continue;
+    }
+
+    userUrl = reply.postgresUrl;
+
+    // Validate URL format
+    if (!isValidPostgresUrl(userUrl)) {
+      logger.warn("The URL format doesn't appear to be valid.");
+      logger.info('Expected format: postgresql://user:password@host:port/dbname');
+
+      const { useAnyway } = await prompts({
+        type: 'confirm',
+        name: 'useAnyway',
+        message: 'Use this URL anyway? (Choose Yes if you have a custom setup)',
+        initial: false,
+      });
+
+      if (!useAnyway) continue;
+    }
+
+    isValidUrl = true;
+  }
+
+  if (userUrl) {
+    await storePostgresUrl(userUrl);
+    return userUrl;
+  }
+
+  return null;
+}
+
 /**
  * Initialize a new project or plugin.
  *
@@ -288,13 +381,7 @@ export const create = new Command()
       }
 
       if (database === 'postgres' && !postgresUrl) {
-        // prompt for postgres url
-        const reply = await prompts({
-          type: 'text',
-          name: 'postgresUrl',
-          message: 'Enter your postgres url',
-        });
-        postgresUrl = reply.postgresUrl;
+        postgresUrl = await promptAndStorePostgresUrl();
       }
 
       // Set up src directory