A fix the result output to README.md file.

Author: daveads

analyze.js

@@ -1,5 +1,4 @@
 #!/usr/bin/env node
-
 const { execSync } = require('child_process');
 const fs = require('fs');
 const path = require('path');
@@ -16,6 +15,7 @@ function extractMetric(file, metric) {
 }
 
 function average(values) {
+  if (values.length === 0) return 0;
   const sum = values.reduce((a, b) => parseFloat(a) + parseFloat(b), 0);
   return sum / values.length;
 }
@@ -42,10 +42,12 @@ servers.forEach((server, idx) => {
   const latencyVals = [];
   for (let j = 0; j < 3; j++) {
     const fileIdx = startIdx + j;
-    const reqSec = extractMetric(resultFiles[fileIdx], "Requests/sec");
-    const latency = extractMetric(resultFiles[fileIdx], "Latency");
-    if (reqSec !== null) reqSecVals.push(reqSec);
-    if (latency !== null) latencyVals.push(latency);
+    if (fileIdx < resultFiles.length) {
+      const reqSec = extractMetric(resultFiles[fileIdx], "Requests/sec");
+      const latency = extractMetric(resultFiles[fileIdx], "Latency");
+      if (reqSec !== null) reqSecVals.push(reqSec);
+      if (latency !== null) latencyVals.push(latency);
+    }
   }
   avgReqSecs[server] = average(reqSecVals);
   avgLatencies[server] = average(latencyVals);
@@ -54,25 +56,43 @@ servers.forEach((server, idx) => {
 const reqSecData = "/tmp/reqSec.dat";
 const latencyData = "/tmp/latency.dat";
 
-fs.writeFileSync(reqSecData, "Server Value\n" + servers.map(server => `${server} ${avgReqSecs[server]}`).join('\n'));
-fs.writeFileSync(latencyData, "Server Value\n" + servers.map(server => `${server} ${avgLatencies[server]}`).join('\n'));
+try {
+  fs.writeFileSync(reqSecData, "Server Value\n" + servers.map(server => `${server} ${avgReqSecs[server]}`).join('\n'));
+  fs.writeFileSync(latencyData, "Server Value\n" + servers.map(server => `${server} ${avgLatencies[server]}`).join('\n'));
+} catch (error) {
+  console.error(`Error writing data files: ${error.message}`);
+}
 
 let whichBench = 1;
-if (resultFiles[0].startsWith("bench2")) {
-  whichBench = 2;
-} else if (resultFiles[0].startsWith("bench3")) {
-  whichBench = 3;
+if (resultFiles.length > 0) {
+  if (resultFiles[0].startsWith("bench2")) {
+    whichBench = 2;
+  } else if (resultFiles[0].startsWith("bench3")) {
+    whichBench = 3;
+  }
 }
 
 const reqSecHistogramFile = `req_sec_histogram${whichBench}.png`;
 const latencyHistogramFile = `latency_histogram${whichBench}.png`;
 
 function getMaxValue(data) {
-  return Math.max(...data.split('\n').slice(1).map(line => parseFloat(line.split(' ')[1])));
+  try {
+    return Math.max(...data.split('\n').slice(1).map(line => parseFloat(line.split(' ')[1])));
+  } catch (error) {
+    console.error(`Error getting max value: ${error.message}`);
+    return 0;
+  }
 }
 
-const reqSecMax = getMaxValue(fs.readFileSync(reqSecData, 'utf-8')) * 1.2;
-const latencyMax = getMaxValue(fs.readFileSync(latencyData, 'utf-8')) * 1.2;
+let reqSecMax, latencyMax;
+try {
+  reqSecMax = getMaxValue(fs.readFileSync(reqSecData, 'utf-8')) * 1.2;
+  latencyMax = getMaxValue(fs.readFileSync(latencyData, 'utf-8')) * 1.2;
+} catch (error) {
+  console.error(`Error reading data files: ${error.message}`);
+  reqSecMax = 0;
+  latencyMax = 0;
+}
 
 const gnuplotScript = `
 set term pngcairo size 1280,720 enhanced font 'Courier,12'
@@ -94,19 +114,26 @@ plot '${latencyData}' using 2:xtic(1) title 'Latency'
 `;
 
 const gnuplotScriptFile = '/tmp/gnuplot_script.gp';
-fs.writeFileSync(gnuplotScriptFile, gnuplotScript);
+try {
+  fs.writeFileSync(gnuplotScriptFile, gnuplotScript);
+} catch (error) {
+  console.error(`Error writing gnuplot script: ${error.message}`);
+}
 
 try {
   execSync(`gnuplot ${gnuplotScriptFile}`, { stdio: 'inherit' });
   console.log('Gnuplot executed successfully');
 } catch (error) {
   console.error('Error executing gnuplot:', error.message);
-  process.exit(1);
 }
 
 const assetsDir = path.join(__dirname, "assets");
 if (!fs.existsSync(assetsDir)) {
-  fs.mkdirSync(assetsDir);
+  try {
+    fs.mkdirSync(assetsDir);
+  } catch (error) {
+    console.error(`Error creating assets directory: ${error.message}`);
+  }
 }
 
 function moveFile(source, destination) {
@@ -138,11 +165,15 @@ const lastServerReqSecs = avgReqSecs[lastServer];
 
 const resultsFile = "results.md";
 
-if (!fs.existsSync(resultsFile) || fs.readFileSync(resultsFile, 'utf8').trim() === '') {
-  fs.writeFileSync(resultsFile, `<!-- PERFORMANCE_RESULTS_START -->
+try {
+  if (!fs.existsSync(resultsFile) || fs.readFileSync(resultsFile, 'utf8').trim() === '') {
+    fs.writeFileSync(resultsFile, `<!-- PERFORMANCE_RESULTS_START -->
 
 | Query | Server | Requests/sec | Latency (ms) | Relative |
 |-------:|--------:|--------------:|--------------:|---------:|`);
+  }
+} catch (error) {
+  console.error(`Error initializing results file: ${error.message}`);
 }
 
 let resultsTable = "";
@@ -169,30 +200,43 @@ sortedServers.forEach((server) => {
   resultsTable += `\n|| [${formattedServerNames[server]}] | \`${formattedReqSecs}\` | \`${formattedLatencies}\` | \`${relativePerformance}x\` |`;
 });
 
-fs.appendFileSync(resultsFile, resultsTable);
+try {
+  fs.appendFileSync(resultsFile, resultsTable);
+} catch (error) {
+  console.error(`Error appending to results file: ${error.message}`);
+}
 
 if (whichBench === 3) {
-  fs.appendFileSync(resultsFile, "\n\n<!-- PERFORMANCE_RESULTS_END -->");
-  
-  const finalResults = fs
-    .readFileSync(resultsFile, "utf-8")
-    .replace(/(\r\n|\n|\r)/gm, "\\n");
-
-  const readmePath = "README.md";
-  let readmeContent = fs.readFileSync(readmePath, "utf-8");
-  const performanceResultsRegex =
-    /<!-- PERFORMANCE_RESULTS_START -->[\s\S]*<!-- PERFORMANCE_RESULTS_END -->/;
-  if (performanceResultsRegex.test(readmeContent)) {
-    readmeContent = readmeContent.replace(
-      performanceResultsRegex,
-      finalResults
-    );
-  } else {
-    readmeContent += `\n${finalResults}`;
+  try {
+    fs.appendFileSync(resultsFile, "\n\n<!-- PERFORMANCE_RESULTS_END -->");
+
+    const finalResults = fs
+      .readFileSync(resultsFile, "utf-8")
+      .replace(/\\/g, '');  // Remove backslashes
+
+    const readmePath = "README.md";
+    let readmeContent = fs.readFileSync(readmePath, "utf-8");
+    const performanceResultsRegex =
+      /<!-- PERFORMANCE_RESULTS_START -->[\s\S]*<!-- PERFORMANCE_RESULTS_END -->/;
+    if (performanceResultsRegex.test(readmeContent)) {
+      readmeContent = readmeContent.replace(
+        performanceResultsRegex,
+        finalResults
+      );
+    } else {
+      readmeContent += `\n${finalResults}`;
+    }
+    fs.writeFileSync(readmePath, readmeContent);
+    console.log("README.md updated successfully");
+  } catch (error) {
+    console.error(`Error updating README: ${error.message}`);
   }
-  fs.writeFileSync(readmePath, readmeContent);
 }
 
 resultFiles.forEach((file) => {
-  fs.unlinkSync(file);
-});
+  try {
+    fs.unlinkSync(file);
+  } catch (error) {
+    console.error(`Error deleting file ${file}: ${error.message}`);
+  }
+});