Claude fixes exiting test program

bin/pos-cli-logs.js

@@ -88,7 +88,7 @@ program
       if (message == null) message = '';
       if (typeof(message) != 'string') message = JSON.stringify(message);
 
-      const text = `[${created_at.replace('T', ' ')}] - ${error_type}: ${message.replace(/\n$/, '')}`;
+      const text = `[${created_at.replace('T', ' ')}] - ${error_type}: ${message.replace(/\r?\n$/, '')}`;
       const options = { exit: false, hideTimestamp: true };
 
       if (isError(message)) {

lib/apiRequest.js

@@ -18,14 +18,18 @@ const buildFormData = (formData) => {
   return form;
 };
 
-const apiRequest = async ({ method = 'GET', uri, body, headers = {}, formData, json = true, forever }) => {
+const apiRequest = async ({ method = 'GET', uri, body, headers = {}, formData, json = true, forever, signal }) => {
   logger.Debug(`[${method}] ${uri}`);
 
   const fetchOptions = {
     method,
     headers: { ...headers }
   };
 
+  if (signal) {
+    fetchOptions.signal = signal;
+  }
+
   if (formData) {
     const form = buildFormData(formData);
     fetchOptions.body = form;

lib/proxy.js

@@ -92,8 +92,8 @@ class Gateway {
     return apiRequest({ uri: `${this.api_url}/logs`, headers: this.defaultHeaders });
   }
 
-  logs(json) {
-    return apiRequest({ uri: `${this.api_url}/logs?last_id=${json.lastId}`, json: true, forever: true, headers: this.defaultHeaders });
+  logs(json, { signal } = {}) {
+    return apiRequest({ uri: `${this.api_url}/logs?last_id=${json.lastId}`, json: true, forever: true, headers: this.defaultHeaders, signal });
   }
 
   logsv2(params) {

lib/test-runner/formatters.js

@@ -13,7 +13,7 @@ const formatTestLog = (logRow, isTestLog) => {
   const message = logRow.message || '';
   const logType = logRow.error_type || '';
   const fullMessage = typeof message === 'string' ? message : JSON.stringify(message);
-  const cleanMessage = fullMessage.replace(/\n$/, '');
+  const cleanMessage = fullMessage.replace(/\r?\n$/, '');
 
   const hasTestPath = /app\/lib\/test\/|modules\/.*\/test\/|\.liquid/.test(cleanMessage);
 

lib/test-runner/logStream.js

@@ -19,11 +19,12 @@ class TestLogStream extends EventEmitter {
     this.lastId = 0;
     this.intervalId = null;
     this.timeoutId = null;
+    this.abortController = null;
   }
 
   isValidTestSummaryJson(message) {
     try {
-      const obj = JSON.parse(message);
+      const obj = JSON.parse(message.trim());
 
       const hasTestsArray = Array.isArray(obj.tests);
       const hasSuccessField = typeof obj.success === 'boolean';
@@ -37,6 +38,7 @@ class TestLogStream extends EventEmitter {
   }
 
   start() {
+    this.abortController = new AbortController();
     this.intervalId = setInterval(() => this.fetchLogs(), POLL_INTERVAL_MS);
     this.timeoutId = setTimeout(() => {
       this.emit('timeout');
@@ -47,6 +49,10 @@ class TestLogStream extends EventEmitter {
   }
 
   stop() {
+    if (this.abortController) {
+      this.abortController.abort();
+      this.abortController = null;
+    }
     if (this.intervalId) {
       clearInterval(this.intervalId);
       this.intervalId = null;
@@ -58,8 +64,10 @@ class TestLogStream extends EventEmitter {
   }
 
   async fetchLogs() {
+    if (!this.abortController) return;
+
     try {
-      const response = await this.gateway.logs({ lastId: this.lastId || 0 });
+      const response = await this.gateway.logs({ lastId: this.lastId || 0 }, { signal: this.abortController.signal });
       const logs = response && response.logs;
       if (!logs) return;
 
@@ -73,6 +81,7 @@ class TestLogStream extends EventEmitter {
         this.processLogMessage(row);
       }
     } catch (error) {
+      if (error.name === 'AbortError') return;
       logger.Debug(`Error fetching logs: ${error.message}`);
     }
   }
@@ -83,7 +92,7 @@ class TestLogStream extends EventEmitter {
     const fullMessage = typeof message === 'string' ? message : JSON.stringify(message);
     const summaryType = this.testName ? `${this.testName} SUMMARY` : null;
 
-    const cleanMessage = fullMessage.replace(/\n$/, '');
+    const cleanMessage = fullMessage.replace(/\r?\n$/, '');
     const hasTestPath = /app\/lib\/test\/|modules\/.*\/test\/|\.liquid/.test(cleanMessage);
 
     if (this.testName) {
@@ -136,7 +145,7 @@ class TestLogStream extends EventEmitter {
 
   parseJsonSummary(message) {
     try {
-      const summary = JSON.parse(message);
+      const summary = JSON.parse(message.trim());
       return transformTestResponse(summary);
     } catch (error) {
       logger.Debug(`[DEBUG] Failed to parse JSON summary: ${error.message}`);