Release 2.1.6

Author: jellesiderius

package-lock.json

@@ -1,6 +1,6 @@
 {
     "name": "mage-db-sync",
-    "version": "2.1.5",
+    "version": "2.1.6",
     "description": "Database synchronizer for Magento, based on Magerun",
     "license": "MIT",
     "author": {

package.json

@@ -13,7 +13,13 @@ class MainController {
     protected services: ServiceContainer;
     public list = new Listr(
         [],
-        {concurrent: false}
+        {
+            concurrent: false,
+            exitOnError: true,
+            rendererOptions: {
+                collapseErrors: false
+            }
+        }
     );
     public ssh = new NodeSSH();
     public sshSecondDatabase = new NodeSSH();

src/controllers/MainController.ts

@@ -36,10 +36,18 @@ class StartController extends MainController {
             process.exit(0);
         } catch (e) {
             const error = e as Error;
+            const logger = this.services.getLogger();
+
+            // Log error for debugging
+            logger.error('Operation failed', error);
+
+            // Display user-friendly error message
+            console.log('\n');
             UI.error(`Operation failed: ${error.message}`);
 
-            if (error.stack) {
-                console.log('\n' + error.stack);
+            if (error.stack && process.env.DEBUG) {
+                console.log('\nStack trace:');
+                console.log(error.stack);
             }
 
             // Try to close SSH connections on error (might already be closed)
@@ -49,6 +57,8 @@ class StartController extends MainController {
                 // Ignore cleanup errors during error handling
             }
 
+            // Force exit with error code
+            process.exitCode = 1;
             process.exit(1);
         }
     };

src/controllers/StartController.ts

@@ -6,6 +6,7 @@ import { Listr } from 'listr2';
 import { consoleCommand, localhostMagentoRootExec } from '../utils/Console';
 import { ServiceContainer } from '../core/ServiceContainer';
 import { ConfigPathResolver } from '../utils/ConfigPathResolver';
+import { UI } from '../utils/UI';
 
 interface CheckResult {
     success: boolean;
@@ -186,6 +187,28 @@ class ChecksTask {
             config.settings.import === 'yes' ||
             (config.settings.wordpressImport === 'yes' && config.settings.currentFolderhasWordpress)
         ) {
+            // Check if DDEV is running when isDdevActive is true
+            if (config.settings.isDdevActive) {
+                this.checkTasks.push({
+                    title: 'Checking DDEV project status',
+                    task: async (ctx: any, task: any): Promise<boolean> => {
+                        task.output = 'Verifying DDEV is running...';
+                        const commandService = this.services.getCommand();
+                        const isRunning = await commandService.isDdevActive();
+
+                        if (!isRunning) {
+                            throw UI.createError(
+                                `DDEV project is not running in this directory\n` +
+                                `[TIP] Start your DDEV project with: ddev start`
+                            );
+                        }
+
+                        task.output = 'DDEV project is running';
+                        return true;
+                    }
+                });
+            }
+
             // Check Magerun 2 version (requires command execution)
             this.checkTasks.push({
                 title: 'Checking Magerun2 version',

src/tasks/ChecksTask.ts

@@ -96,11 +96,25 @@ class DownloadTask {
         try {
             await SSHConnectionPool.getConnection(host, sshConfig, async () => {
                 await ssh.connect(sshConfig);
+
+                // Add error handler to prevent unhandled ECONNRESET errors
+                if (ssh && ssh.connection) {
+                    const logger = this.services.getLogger();
+                    ssh.connection.on('error', (err: Error) => {
+                        // Catch and log connection errors to prevent process crash
+                        if (err.message && err.message.includes('ECONNRESET')) {
+                            logger.debug('SSH connection reset', { host });
+                        } else {
+                            logger.error('SSH connection error', err, { host });
+                        }
+                    });
+                }
+
                 return ssh;
             });
         } catch (error) {
             const err = error as Error;
-            throw new Error(
+            throw UI.createError(
                 `Failed to connect to ${host}\n` +
                 `[TIP] Check your SSH credentials and key format\n` +
                 `Error: ${err.message}`
@@ -255,7 +269,7 @@ class DownloadTask {
                                     database: config.serverVariables.databaseName
                                 });
                             } catch (_e) {
-                                throw new Error(
+                                throw UI.createError(
                                     `Could not retrieve database name from server.\n` +
                                     `Magerun output: ${output}\n` +
                                     `[TIP] Check if Magerun can connect to the database on the server`
@@ -264,7 +278,7 @@ class DownloadTask {
                         }
 
                         if (!config.serverVariables.databaseName) {
-                            throw new Error(
+                            throw UI.createError(
                                 `Database name could not be determined.\n` +
                                 `[TIP] Check server Magento configuration and database connectivity`
                             );
@@ -507,7 +521,7 @@ class DownloadTask {
                         clearInterval(sizeCheckInterval);
 
                         if (result.code && result.code !== 0) {
-                            throw new Error(
+                            throw UI.createError(
                                 `Database dump failed\n[TIP] Check database permissions and disk space\nError: ${result.stderr}`
                             );
                         }
@@ -628,7 +642,7 @@ class DownloadTask {
                         rsync.on('exit', function (code: any) {
                             if (code !== 0) {
                                 reject(
-                                    new Error(
+                                    UI.createError(
                                         `Download failed with code ${code}\n[TIP] Check SSH connection and file permissions`
                                     )
                                 );
@@ -711,13 +725,13 @@ class DownloadTask {
                             });
                         }
                     }).catch((error: any) => {
-                        throw new Error(
+                        throw UI.createError(
                             `Could not read wp-config.php from server\n[TIP] Make sure WordPress is installed in wp/, blog/, or wordpress/ folder\nError: ${error.message}`
                         );
                     });
 
                     if (!config.wordpressConfig.database) {
-                        throw new Error(
+                        throw UI.createError(
                             `Could not parse WordPress database configuration from wp-config.php\n[TIP] Check if wp-config.php is properly formatted`
                         );
                     }
@@ -766,7 +780,7 @@ class DownloadTask {
 
                     await ssh.execCommand(dumpCommand).then(function (result: any) {
                         if (result.code && result.code !== 0) {
-                            throw new Error(
+                            throw UI.createError(
                                 `WordPress database dump failed\n[TIP] Check WordPress database credentials and permissions\nError: ${result.stderr}`
                             );
                         }

src/tasks/DownloadTask.ts

@@ -104,6 +104,14 @@ export class SSHConnectionPool {
             .filter(conn => conn && conn !== null && typeof conn.dispose === 'function')
             .map(conn => {
                 try {
+                    // Add error handler before disposal to catch ECONNRESET
+                    if (conn.connection && typeof conn.connection.on === 'function') {
+                        conn.connection.removeAllListeners('error');
+                        conn.connection.on('error', () => {
+                            // Silently ignore errors during disposal
+                        });
+                    }
+
                     const disposeResult = conn.dispose();
                     return disposeResult && typeof disposeResult.catch === 'function'
                         ? disposeResult.catch(() => {})

src/utils/Performance.ts

@@ -60,11 +60,28 @@ export class UI {
         console.log(chalk.green('[OK]') + ' ' + chalk.white(message));
     }
 
+    /**
+     * Format error message with colored [TIP] sections
+     */
+    static formatErrorMessage(message: string): string {
+        // Replace [TIP] with colored version (magenta/purple)
+        return message.replace(/\[TIP\]/g, chalk.magenta.bold('[TIP]'));
+    }
+
+    /**
+     * Create an Error with formatted message (colored [TIP])
+     * Use this when throwing errors that contain [TIP] sections
+     */
+    static createError(message: string): Error {
+        return new Error(this.formatErrorMessage(message));
+    }
+
     /**
      * Show error message
      */
     static error(message: string): void {
-        console.log(chalk.red('[ERROR]') + ' ' + chalk.white(message));
+        const formattedMessage = this.formatErrorMessage(message);
+        console.log(chalk.red('[ERROR]') + ' ' + chalk.white(formattedMessage));
     }
 
     /**