use new perfSend

Author: W-A-James

.evergreen/config.yml

@@ -257,9 +257,22 @@ tasks:
         vars:
           WARMUP: 1000
           ITERATIONS: 1000
-      - command: perf.send
+      - command: subprocess.exec
         params:
-          file: src/test/bench/etc/resultsCollectedMeans.json
+          working_dir: src
+          binary: node 
+          env:
+            project: ${project}
+            revision_order_id: ${order}
+            execution: ${execution}
+            requester: ${requester}
+            task_id: ${task_id}
+            task_name: ${task_name}
+            build_variant: ${build_variant}
+            version_id: ${version_id}
+          args:
+            - .evergreen/perfSend.mjs
+            - src/test/bench/etc/resultsCollectedMeans.json
   - name: run-custom-benchmarks
     commands:
       - func: fetch source

.evergreen/perfSend.mjs

@@ -0,0 +1,56 @@
+#! node
+'use strict';
+
+import * as fs from 'fs/promises';
+// STAGING
+const API_PATH = "https://performance-monitoring-service-rest.server-tig.staging.corp.mongodb.com/raw_perf_results"
+
+const resultFile = process.argv[2];
+if (resultFile == undefined) {
+  throw new Error("Must specify result file");
+}
+
+// Get expansions
+const {
+  execution,
+  requester,
+  project,
+  task_id,
+  task_name,
+  revision_order_id: order,
+  build_variant: variant,
+  version_id: version
+} = process.env;
+
+
+fs.readFile(resultFile, { encoding: 'utf8' })
+  .then(
+    results => {
+      const body = {
+        id: {
+          project,
+          version,
+          variant,
+          order,
+          task_name,
+          task_id,
+          execution,
+          mainline: requester === 'commit'
+        },
+        results: JSON.parse(results)
+      };
+      return fetch(API_PATH, {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json"
+        },
+        body: JSON.stringify(body)
+      })
+    }
+  )
+  .then(resp => {
+    console.log(resp);
+    if (resp.status !== 200) {
+      throw new Error('Got non 200 status code')
+    }
+  });

package-lock.json

@@ -24,11 +24,10 @@ function logBenchmark(event) {
   console.log(String(event.target));
 }
 
-function processBenchmarkResult(bench, tags, metadata) {
+function processBenchmarkResult(bench, metadata) {
   return {
     info: { test_name: bench.name },
-    metrics: [{ name: 'ops_per_sec', value: bench.hz, metadata }],
-    tags
+    metrics: [{ name: 'ops_per_sec', value: bench.hz, metadata }]
   };
 }
 
@@ -53,7 +52,7 @@ async function completeSuite() {
     for (const { suite, suiteConfig } of collectedSuites) {
       const { tags } = suiteConfig;
       for (const bench of Array.from(suite)) {
-        const result = processBenchmarkResult(bench, tags, metadata);
+        const result = processBenchmarkResult(bench, { ...metadata, tags });
         result.metrics.push({
           name: 'normalized_throughput',
           value: bench.hz / cpuBaselineResult,

test/bench/custom/main.mjs

@@ -85,7 +85,7 @@ const DOCUMENT_ROOT = path.resolve(`${__dirname}/../documents`);
     const rv = { ...result };
     rv.metrics = rv.metrics.filter(metric => metric.type === 'MEAN');
     rv.metrics = rv.metrics.map(m => {
-      return { ...m, metadata };
+      return { ...m, metadata: { ...m.metadata, improvement_direction: 'up' } };
     });
     rv.metrics.push({
       name: 'normalized_throughput',

test/bench/etc/run_granular_benchmarks.js

@@ -116,19 +116,18 @@ suite.run().then(async () => {
     }, 0) / results.length;
 
   for (const r of results) {
-    r.metrics[0].metadata = metadata;
+    r.metrics[0].metadata = { ...r.metrics[0].metadata, ...metadata };
     r.metrics.push({
       name: 'normalized_throughput',
       value: r.metrics[0].value / cpuBaselineResult,
-      metadata
+      metadata: { ...r.metrics[0].metadata }
     });
   }
 
   // Add to results
   results.push({
     info: {
       test_name: 'BSONBench',
-      tags: [],
       args: {}
     },
     metrics: [
@@ -144,7 +143,6 @@ suite.run().then(async () => {
   results.push({
     info: {
       test_name: 'cpuBaseline',
-      tags: [],
       args: {}
     },
     metrics: [{ name: 'mean_megabytes_per_second', value: cpuBaselineResult, metadata }]