This commit is contained in:
Dunemask 2022-07-12 22:07:44 +00:00
parent 766610d14c
commit fd71714fc0
11 changed files with 56 additions and 50 deletions

View file

@ -1,4 +1,4 @@
export default function failingTest(){
export default function failingTest() {
console.log("This came from a failing test!");
return {status:1};
}
return { status: 1 };
}

View file

@ -1,4 +1,4 @@
export default function primaryTest(){
export default function primaryTest() {
console.log("This came from a primary test!");
return {status:0, pipelineData:"SomeData"};
}
return { status: 0, pipelineData: "SomeData" };
}

View file

@ -9,21 +9,29 @@ const endLiveCount = 5;
const reportingUrl = `${process.env.QUALITEER_URL}/api/dev/rabbit/TestResults`;
// Pull args
const args = process.argv.slice(2);
const test = (args.find((v)=>v.includes("test=")) ?? "").replace("test=","");
const pipelineData = (args.find((v)=>v.includes("pipelineData=")) ?? "").replace("pipelineData=","");
const pipelineTriggers = (args.find((v)=>v.includes("pipelineTriggers=")) ?? "").replace("pipelineTriggers=","");
const pipelineDashboardSocket = (args.find((v)=>v.includes("pipelineDashboardSocket=")) ?? "").replace("pipelineDashboardSocket=","") || undefined;
const test = (args.find((v) => v.includes("test=")) ?? "").replace("test=", "");
const pipelineData = (
args.find((v) => v.includes("pipelineData=")) ?? ""
).replace("pipelineData=", "");
const pipelineTriggers = (
args.find((v) => v.includes("pipelineTriggers=")) ?? ""
).replace("pipelineTriggers=", "");
const pipelineDashboardSocket =
(args.find((v) => v.includes("pipelineDashboardSocket=")) ?? "").replace(
"pipelineDashboardSocket=",
""
) || undefined;
const logNow = () => console.log(Date.now());
const liveIndicator = () => {
for (var i = 0; i < endLiveCount; i++) setTimeout(logNow, i * 1000);
}
};
const runTests = () => {
switch (test) {
case "primary":
return primary();
case "secondary":
case "secondary":
return secondary(pipelineData);
case "single":
return single();
@ -32,16 +40,19 @@ const runTests = () => {
default:
return single();
}
}
};
// Run
liveIndicator();
setTimeout(()=>{
const status = runTests();
const testResult = {...status, name:test, pipelineTriggers: pipelineTriggers ? pipelineTriggers : undefined, pipelineDashboardSocket}
axios.post(reportingUrl, {testResult}).catch((e)=>{console.log(e.response.status)});
},endLiveCount * 1000);
setTimeout(() => {
const status = runTests();
const testResult = {
...status,
name: test,
pipelineTriggers: pipelineTriggers ? pipelineTriggers : undefined,
pipelineDashboardSocket,
};
axios.post(reportingUrl, { testResult }).catch((e) => {
console.log(e.response.status);
});
}, endLiveCount * 1000);

View file

@ -1,4 +1,4 @@
export default function secondaryTest(pipelineData){
export default function secondaryTest(pipelineData) {
console.log("This came from a secondary test!");
return {status: + (pipelineData !== "SomeData")};
}
return { status: +(pipelineData !== "SomeData") };
}

View file

@ -1,4 +1,4 @@
export default function singleTest(){
export default function singleTest() {
console.log("This came from a single test!");
return {status:0};
}
return { status: 0 };
}

View file

@ -19,7 +19,6 @@ const job = {
image: "node",
};
const launchJob = () => primary.newPipelineJob(job, null, () =>
console.log("Primary Job Concluded")
);
const launchJob = () =>
primary.newPipelineJob(job, null, () => console.log("Primary Job Concluded"));
launchJob();