init

plugin/index.mjs

@@ -0,0 +1,113 @@
+import Debug from "debug";
+import fs from "fs";
+import { format as format2 } from "util";
+import WebSocket from "ws";
+
+import chalk from "chalk";
+import util from "util";
+var log = (...args) => console.log(util.format(...args));
+var format = util.format;
+var withWarning = (msg) => chalk.bgYellow.black(" WARNING ") + " " + msg;
+var warn = (...args) => log(withWarning(util.format(...args)));
+var cyan = chalk.cyan;
+var blue = chalk.blueBright;
+var red = chalk.red;
+var green = chalk.greenBright;
+var gray = chalk.gray;
+var white = chalk.white;
+var magenta = chalk.magenta;
+var bold = chalk.bold;
+var dim = chalk.dim;
+
+var Event = ((Event2) => {
+  Event2["RUN_CANCELLED"] = "run:cancelled";
+  Event2["RUN_RESULT"] = "run:result";
+  Event2["TEST_AFTER_RUN"] = "test:after:run";
+  Event2["TEST_BEFORE_RUN"] = "test:before:run";
+  Event2["AFTER_SCREENSHOT"] = "after:screenshot";
+  Event2["AFTER_SPEC"] = "after:spec";
+  return Event2;
+})(Event || {});
+var allEvents = Object.values(Event);
+
+
+var _debug = Debug("cc:plugin");
+async function cloudPlugin(on, config) {
+  function debug(...args) {
+    if (config.env.cc_debug_enabled) {
+      _debug(format2(...args));
+    }
+  }
+  if (!config.env.cc_marker) {
+    warn(
+      `Cc plugin is not installed properly - missing required variables in ${dim(
+        "cypress.env"
+      )}. Please refer to: self`
+    );
+  }
+  let ws = null;
+  function sendToWS(message) {
+    if (ws) {
+      ws.send(JSON.stringify(message));
+    }
+  }
+  if (config.env.cc_ws) {
+    debug("setting port to %s", config.env.cc_ws);
+    await new Promise((resolve) => {
+      ws = new WebSocket(`ws://localhost:${config.env.cc_ws}`);
+      ws.on("open", () => {
+        resolve(null);
+      });
+    });
+  }
+  on("after:screenshot", (details) => {
+    sendToWS({
+      type: "after:screenshot",
+      payload: details
+    });
+  });
+  on("task", {
+    "cc:test:after:run": (test) => {
+      debug("cc:test:after:run task received %o", test);
+      sendToWS({
+        type: "test:after:run",
+        payload: test
+      });
+      return null;
+    },
+    "cc:test:before:run": (test) => {
+      debug("cc:test:before:run task received %o", test);
+      sendToWS({
+        type: "test:before:run",
+        payload: test
+      });
+      return null;
+    }
+  });
+  on("before:spec", (spec) => {
+    debug("before:spec task received %o", spec);
+    sendToWS({ type: "before:spec", payload: { spec } });
+  });
+  on("after:spec", (spec, results) => {
+    debug("after:spec task received %o", spec);
+    sendToWS({
+      type: "after:spec",
+      payload: {
+        spec,
+        results
+      }
+    });
+  });
+  debug("cc plugin loaded");
+  if (config.env.cc_temp_file) {
+    debug("dumping config to '%s'", config.env.cc_temp_file);
+    fs.writeFileSync(config.env.cc_temp_file, JSON.stringify(config));
+    debug("config is availabe at '%s'", config.env.cc_temp_file);
+  }
+  return config;
+}
+var plugin_default = cloudPlugin;
+export {
+  cloudPlugin,
+  plugin_default as default
+};