fix(mysql): only unreference connections in a Bun environment as it has problems with Node for some reason

.changeset/sharp-houses-smell.md

@@ -0,0 +1,5 @@
+---
+'@emigrate/mysql': patch
+---
+
+Only unreference connections in a Bun environment as it crashes Node for some reason, without even throwing an error that is

packages/mysql/package.json

@@ -43,7 +43,9 @@
     "mysql2": "3.6.5"
   },
   "devDependencies": {
-    "@emigrate/tsconfig": "workspace:*"
+    "@emigrate/tsconfig": "workspace:*",
+    "@types/bun": "1.0.5",
+    "bun-types": "1.0.26"
   },
   "volta": {
     "extends": "../../package.json"

packages/mysql/src/index.ts

@@ -171,11 +171,13 @@ export const createMysqlStorage = ({ table = defaultTable, connection }: MysqlSt
     async initializeStorage() {
       const pool = getPool(connection);
 
-      pool.on('connection', (connection) => {
-        // @ts-expect-error stream is not in the types but it's there
-        // eslint-disable-next-line @typescript-eslint/no-unsafe-call
-        connection.stream.unref();
-      });
+      if (process.isBun) {
+        pool.on('connection', (connection) => {
+          // @ts-expect-error stream is not in the types but it's there
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-call
+          connection.stream.unref();
+        });
+      }
 
       await pool.query('SELECT 1');
 
@@ -274,9 +276,11 @@ export const createMysqlLoader = ({ connection }: MysqlLoaderOptions): LoaderPlu
         const contents = await fs.readFile(migration.filePath, 'utf8');
         const conn = await getConnection(connection);
 
-        // @ts-expect-error the connection is not in the types but it's there
-        // eslint-disable-next-line @typescript-eslint/no-unsafe-call
-        conn.connection.stream.unref();
+        if (process.isBun) {
+          // @ts-expect-error the connection is not in the types but it's there
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-call
+          conn.connection.stream.unref();
+        }
 
         try {
           await conn.query(contents);

pnpm-lock.yaml

@@ -130,6 +130,12 @@ importers:
       '@emigrate/tsconfig':
         specifier: workspace:*
         version: link:../tsconfig
+      '@types/bun':
+        specifier: 1.0.5
+        version: 1.0.5
+      bun-types:
+        specifier: 1.0.26
+        version: 1.0.26
 
   packages/plugin-generate-js:
     dependencies: