114 lines
2.9 KiB
JavaScript
114 lines
2.9 KiB
JavaScript
|
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
|
||
|
|
};
|