APP-3602 pipe logs to fix buffer limit

Author: abe-winter

dist/index.js

@@ -26177,7 +26177,7 @@ const os = __nccwpck_require__(612);
 const https = __nccwpck_require__(2286);
 const stream = __nccwpck_require__(6402);
 const util = __nccwpck_require__(7261);
-const { spawnSync, SpawnSyncReturns } = __nccwpck_require__(7718); // eslint-disable-line no-unused-vars
+const { spawnSync, SpawnSyncReturns, spawn, ChildProcessWithoutNullStreams } = __nccwpck_require__(7718); // eslint-disable-line no-unused-vars
 const { getInput } = __nccwpck_require__(2186);
 
 const platforms = ['linux', 'darwin'];
@@ -26239,6 +26239,27 @@ function checkSpawnSync(result) {
     }
 }
 
+/**
+ * forward output from child process, crash on error
+ * @param {ChildProcessWithoutNullStreams} child
+ */
+async function checkSpawn(child) {
+    child.stdout.pipe(process.stdout);
+    child.stderr.pipe(process.stderr);
+    await new Promise(function (resolve, reject) {
+        child.on('close', function (code, signal) {
+            if (signal != null) {
+                reject(new Error(`terminated with signal ${signal}`));
+            }
+            if (code == 0) {
+                resolve();
+            } else {
+                reject(new Error(`exited with code ${code}`));
+            }
+        });
+    });
+}
+
 /**
  * get build-id from start command
  * @param {Buffer} stdout stdout of 'start' command
@@ -26279,7 +26300,7 @@ function parseBuildId(stdout) {
     checkSpawnSync(spawnRet);
     const buildId = parseBuildId(spawnRet.stdout);
     console.log('waiting for build');
-    checkSpawnSync(spawnSync(cliPath, ['module', 'build', 'logs', '--id', buildId, '--wait']));
+    await checkSpawn(spawn(cliPath, ['module', 'build', 'logs', '--id', buildId, '--wait']));
 })();
 
 })();

src/index.js

@@ -3,7 +3,7 @@ const os = require('node:os');
 const https = require('node:https');
 const stream = require('node:stream/promises');
 const util = require('node:util');
-const { spawnSync, SpawnSyncReturns } = require('node:child_process'); // eslint-disable-line no-unused-vars
+const { spawnSync, SpawnSyncReturns, spawn, ChildProcessWithoutNullStreams } = require('node:child_process'); // eslint-disable-line no-unused-vars
 const { getInput } = require('@actions/core');
 
 const platforms = ['linux', 'darwin'];
@@ -65,6 +65,27 @@ function checkSpawnSync(result) {
     }
 }
 
+/**
+ * forward output from child process, crash on error
+ * @param {ChildProcessWithoutNullStreams} child
+ */
+async function checkSpawn(child) {
+    child.stdout.pipe(process.stdout);
+    child.stderr.pipe(process.stderr);
+    await new Promise(function (resolve, reject) {
+        child.on('close', function (code, signal) {
+            if (signal != null) {
+                reject(new Error(`terminated with signal ${signal}`));
+            }
+            if (code == 0) {
+                resolve();
+            } else {
+                reject(new Error(`exited with code ${code}`));
+            }
+        });
+    });
+}
+
 /**
  * get build-id from start command
  * @param {Buffer} stdout stdout of 'start' command
@@ -105,5 +126,5 @@ function parseBuildId(stdout) {
     checkSpawnSync(spawnRet);
     const buildId = parseBuildId(spawnRet.stdout);
     console.log('waiting for build');
-    checkSpawnSync(spawnSync(cliPath, ['module', 'build', 'logs', '--id', buildId, '--wait']));
+    await checkSpawn(spawn(cliPath, ['module', 'build', 'logs', '--id', buildId, '--wait']));
 })();