Catch errors from Browsertime so errors are thrown on the queue. (#3170)
This commit is contained in:
Peter Hedenskog
GitHub
parent
9693415f8f
commit
8951539273
|
|
@ -127,339 +127,352 @@ module.exports = {
|
|||
case 'url': {
|
||||
let url = message.url;
|
||||
let group = message.group;
|
||||
// manually set the resultBaseDir
|
||||
// it's used in BT when we record a video
|
||||
options.resultDir = await this.storageManager.getBaseDir();
|
||||
const consoleLogAggregator = new ConsoleLogAggregator(options);
|
||||
const result = await analyzer.analyzeUrl(
|
||||
url,
|
||||
this.scriptOrMultiple,
|
||||
this.pluginScripts,
|
||||
this.pluginAsyncScripts,
|
||||
options
|
||||
);
|
||||
try {
|
||||
// manually set the resultBaseDir
|
||||
// it's used in BT when we record a video
|
||||
options.resultDir = await this.storageManager.getBaseDir();
|
||||
const consoleLogAggregator = new ConsoleLogAggregator(options);
|
||||
const result = await analyzer.analyzeUrl(
|
||||
url,
|
||||
this.scriptOrMultiple,
|
||||
this.pluginScripts,
|
||||
this.pluginAsyncScripts,
|
||||
options
|
||||
);
|
||||
|
||||
log.verbose('Result from Browsertime for %s with %:2j', url, result);
|
||||
// We need to check for alias first, since when we send the HAR (incliude all runs)
|
||||
// need to know if alias exists, else we will end up with things like
|
||||
// https://github.com/sitespeedio/sitespeed.io/issues/2341
|
||||
for (let resultIndex = 0; resultIndex < result.length; resultIndex++) {
|
||||
// Browsertime supports alias for URLS in a script
|
||||
const alias = result[resultIndex].info.alias;
|
||||
if (alias) {
|
||||
log.verbose('Result from Browsertime for %s with %:2j', url, result);
|
||||
// We need to check for alias first, since when we send the HAR (incliude all runs)
|
||||
// need to know if alias exists, else we will end up with things like
|
||||
// https://github.com/sitespeedio/sitespeed.io/issues/2341
|
||||
for (
|
||||
let resultIndex = 0;
|
||||
resultIndex < result.length;
|
||||
resultIndex++
|
||||
) {
|
||||
// Browsertime supports alias for URLS in a script
|
||||
const alias = result[resultIndex].info.alias;
|
||||
if (alias) {
|
||||
if (this.scriptOrMultiple) {
|
||||
url = result[resultIndex].info.url;
|
||||
group = urlParser.parse(url).hostname;
|
||||
}
|
||||
queue.postMessage(
|
||||
make('browsertime.alias', alias, {
|
||||
url,
|
||||
group
|
||||
})
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
const errorStats = new Stats();
|
||||
let axeAggregatorPerURL;
|
||||
for (
|
||||
let resultIndex = 0;
|
||||
resultIndex < result.length;
|
||||
resultIndex++
|
||||
) {
|
||||
axeAggregatorPerURL = new AxeAggregator(this.options);
|
||||
// If we use scripts or multiple, use the URL from the tested page
|
||||
// so that we can handle click on links etc
|
||||
// see https://github.com/sitespeedio/sitespeed.io/issues/2260
|
||||
// we could change the plugins but since they do not work with
|
||||
// multiple/scripting lets do it like this for now
|
||||
if (this.scriptOrMultiple) {
|
||||
url = result[resultIndex].info.url;
|
||||
group = urlParser.parse(url).hostname;
|
||||
}
|
||||
queue.postMessage(
|
||||
make('browsertime.alias', alias, {
|
||||
url,
|
||||
group
|
||||
})
|
||||
);
|
||||
}
|
||||
}
|
||||
let runIndex = 0;
|
||||
for (let run of result[resultIndex].browserScripts) {
|
||||
// Kind of ugly way to add visualMetrics to a run
|
||||
// it's outside of browserScripts today
|
||||
// we could instead pass browsertime.visualMetrics maybe
|
||||
if (result[resultIndex].visualMetrics) {
|
||||
run.visualMetrics = result[resultIndex].visualMetrics[runIndex];
|
||||
}
|
||||
|
||||
const errorStats = new Stats();
|
||||
let axeAggregatorPerURL;
|
||||
for (let resultIndex = 0; resultIndex < result.length; resultIndex++) {
|
||||
axeAggregatorPerURL = new AxeAggregator(this.options);
|
||||
// If we use scripts or multiple, use the URL from the tested page
|
||||
// so that we can handle click on links etc
|
||||
// see https://github.com/sitespeedio/sitespeed.io/issues/2260
|
||||
// we could change the plugins but since they do not work with
|
||||
// multiple/scripting lets do it like this for now
|
||||
if (this.scriptOrMultiple) {
|
||||
url = result[resultIndex].info.url;
|
||||
group = urlParser.parse(url).hostname;
|
||||
}
|
||||
let runIndex = 0;
|
||||
for (let run of result[resultIndex].browserScripts) {
|
||||
// Kind of ugly way to add visualMetrics to a run
|
||||
// it's outside of browserScripts today
|
||||
// we could instead pass browsertime.visualMetrics maybe
|
||||
if (result[resultIndex].visualMetrics) {
|
||||
run.visualMetrics = result[resultIndex].visualMetrics[runIndex];
|
||||
}
|
||||
let harIndex = runIndex * result.length;
|
||||
harIndex += resultIndex;
|
||||
if (result.har) {
|
||||
// Let the plugins now what browser we are using at the moment
|
||||
queue.postMessage(
|
||||
make('browsertime.browser', {
|
||||
browser: result.har.log.browser
|
||||
})
|
||||
);
|
||||
// Add meta data to be used when we compare multiple HARs
|
||||
// the meta field is added in Browsertime
|
||||
if (result.har.log.pages[harIndex]) {
|
||||
const _meta = result.har.log.pages[harIndex]._meta;
|
||||
|
||||
let harIndex = runIndex * result.length;
|
||||
harIndex += resultIndex;
|
||||
if (result.har) {
|
||||
// Let the plugins now what browser we are using at the moment
|
||||
queue.postMessage(
|
||||
make('browsertime.browser', {
|
||||
browser: result.har.log.browser
|
||||
})
|
||||
);
|
||||
// Add meta data to be used when we compare multiple HARs
|
||||
// the meta field is added in Browsertime
|
||||
if (result.har.log.pages[harIndex]) {
|
||||
const _meta = result.har.log.pages[harIndex]._meta;
|
||||
|
||||
// add the definiton for first party/third party
|
||||
if (this.firstParty) {
|
||||
_meta.firstParty = this.firstParty;
|
||||
}
|
||||
if (this.resultUrls.hasBaseUrl()) {
|
||||
const base = this.resultUrls.absoluteSummaryPagePath(url);
|
||||
_meta.screenshot = `${base}data/screenshots/${runIndex +
|
||||
1}/afterPageCompleteCheck.${this.screenshotType}`;
|
||||
_meta.result = `${base}${runIndex + 1}.html`;
|
||||
if (options.video) {
|
||||
_meta.video = `${base}data/video/${runIndex + 1}.mp4`;
|
||||
_meta.filmstrip = await filmstrip.getFilmstrip(
|
||||
run,
|
||||
`${runIndex + 1}`,
|
||||
`${
|
||||
options.resultDir
|
||||
}/${this.resultUrls.relativeSummaryPageUrl(url)}`,
|
||||
this.allOptions,
|
||||
`${base}data/filmstrip/${runIndex + 1}/`
|
||||
);
|
||||
// add the definiton for first party/third party
|
||||
if (this.firstParty) {
|
||||
_meta.firstParty = this.firstParty;
|
||||
}
|
||||
if (this.resultUrls.hasBaseUrl()) {
|
||||
const base = this.resultUrls.absoluteSummaryPagePath(url);
|
||||
_meta.screenshot = `${base}data/screenshots/${runIndex +
|
||||
1}/afterPageCompleteCheck.${this.screenshotType}`;
|
||||
_meta.result = `${base}${runIndex + 1}.html`;
|
||||
if (options.video) {
|
||||
_meta.video = `${base}data/video/${runIndex + 1}.mp4`;
|
||||
_meta.filmstrip = await filmstrip.getFilmstrip(
|
||||
run,
|
||||
`${runIndex + 1}`,
|
||||
`${
|
||||
options.resultDir
|
||||
}/${this.resultUrls.relativeSummaryPageUrl(url)}`,
|
||||
this.allOptions,
|
||||
`${base}data/filmstrip/${runIndex + 1}/`
|
||||
);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
log.error(
|
||||
'Could not find the right index %s for har for url %s ',
|
||||
harIndex,
|
||||
url
|
||||
);
|
||||
}
|
||||
} else {
|
||||
log.error(
|
||||
'Could not find the right index %s for har for url %s ',
|
||||
harIndex,
|
||||
url
|
||||
);
|
||||
run.har = api.pickAPage(result.har, harIndex);
|
||||
}
|
||||
run.har = api.pickAPage(result.har, harIndex);
|
||||
}
|
||||
|
||||
// Hack to get axe data. In the future we can make this more generic
|
||||
if (result[resultIndex].extras.length > 0) {
|
||||
if (result[resultIndex].extras[runIndex].axe) {
|
||||
const order = ['critical', 'serious', 'moderate', 'minor'];
|
||||
result[resultIndex].extras[runIndex].axe.violations.sort(
|
||||
(a, b) => order.indexOf(a.impact) > order.indexOf(b.impact)
|
||||
);
|
||||
// Hack to get axe data. In the future we can make this more generic
|
||||
if (result[resultIndex].extras.length > 0) {
|
||||
if (result[resultIndex].extras[runIndex].axe) {
|
||||
const order = ['critical', 'serious', 'moderate', 'minor'];
|
||||
result[resultIndex].extras[runIndex].axe.violations.sort(
|
||||
(a, b) => order.indexOf(a.impact) > order.indexOf(b.impact)
|
||||
);
|
||||
|
||||
axeAggregatorPerURL.addStats(
|
||||
result[resultIndex].extras[runIndex].axe
|
||||
);
|
||||
axeAggregatorPerURL.addStats(
|
||||
result[resultIndex].extras[runIndex].axe
|
||||
);
|
||||
|
||||
this.axeAggregatorTotal.addStats(
|
||||
result[resultIndex].extras[runIndex].axe
|
||||
);
|
||||
this.axeAggregatorTotal.addStats(
|
||||
result[resultIndex].extras[runIndex].axe
|
||||
);
|
||||
|
||||
queue.postMessage(
|
||||
make('axe.run', result[resultIndex].extras[runIndex].axe, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
// Another hack: Browsertime automatically creates statistics for alla data in extras
|
||||
// but we don't really need that for AXE.
|
||||
delete result[resultIndex].extras[runIndex].axe;
|
||||
delete result[resultIndex].statistics.extras.axe;
|
||||
}
|
||||
}
|
||||
if (result[resultIndex].cpu) {
|
||||
run.cpu = result[resultIndex].cpu[runIndex];
|
||||
}
|
||||
|
||||
if (result[resultIndex].extras) {
|
||||
run.extras = result[resultIndex].extras[runIndex];
|
||||
}
|
||||
|
||||
if (
|
||||
result[resultIndex].cdp &&
|
||||
result[resultIndex].cdp.performance
|
||||
) {
|
||||
run.cdp = {
|
||||
performance: result[resultIndex].cdp.performance[runIndex]
|
||||
};
|
||||
}
|
||||
|
||||
if (result[resultIndex].fullyLoaded) {
|
||||
run.fullyLoaded = result[resultIndex].fullyLoaded[runIndex];
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.title) {
|
||||
run.title = result[resultIndex].info.title;
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.description) {
|
||||
run.description = result[resultIndex].info.description;
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.android) {
|
||||
run.android = result[resultIndex].info.android;
|
||||
run.android.batteryTemperature =
|
||||
result[resultIndex].android.batteryTemperature[runIndex];
|
||||
}
|
||||
|
||||
run.timestamp = dayjs(
|
||||
result[resultIndex].timestamps[runIndex]
|
||||
).format(TIME_FORMAT);
|
||||
|
||||
run.errors = result[resultIndex].errors[runIndex];
|
||||
|
||||
run.screenshots = result[resultIndex].files.screenshot[runIndex];
|
||||
|
||||
// calculate errors
|
||||
for (let error of result[resultIndex].errors) {
|
||||
errorStats.push(error.length);
|
||||
}
|
||||
|
||||
queue.postMessage(
|
||||
make('browsertime.run', run, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
|
||||
if (
|
||||
options.chrome &&
|
||||
options.chrome.collectConsoleLog &&
|
||||
options.browser === 'chrome'
|
||||
) {
|
||||
try {
|
||||
const consoleData = await consoleLogAggregator.addStats(
|
||||
runIndex + 1,
|
||||
result[resultIndex].files.consoleLog[runIndex]
|
||||
);
|
||||
|
||||
queue.postMessage(
|
||||
make('browsertime.console', consoleData, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
} catch (e) {
|
||||
// This could happen if the run failed somehow
|
||||
log.error('Could not fetch the console log');
|
||||
}
|
||||
}
|
||||
|
||||
// In Browsertime 2.x the tracelog was part of the result but since 3.x
|
||||
// it is stored to disk. If you want it passed around in the queue, just add
|
||||
// --postChromeTrace
|
||||
if (
|
||||
options.chrome &&
|
||||
options.chrome.timeline &&
|
||||
this.postChromeTrace
|
||||
) {
|
||||
const traceData = await getGzippedFileAsJson(
|
||||
options.resultDir,
|
||||
`trace-${runIndex + 1}.json.gz`
|
||||
);
|
||||
queue.postMessage(
|
||||
make('browsertime.chrometrace', traceData, {
|
||||
url,
|
||||
group,
|
||||
name: `trace-${runIndex + 1}.json`, // backward compatible to 2.x
|
||||
runIndex
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
// If the coach is turned on, collect the coach result
|
||||
if (options.coach) {
|
||||
const coachAdvice = run.coach.coachAdvice;
|
||||
// check if the coach has error(s)
|
||||
if (!isEmpty(coachAdvice.errors)) {
|
||||
log.error(
|
||||
'%s generated the following errors in the coach %:2j',
|
||||
url,
|
||||
coachAdvice.errors
|
||||
);
|
||||
queue.postMessage(
|
||||
make(
|
||||
'error',
|
||||
'The coach got the following errors: ' +
|
||||
JSON.stringify(coachAdvice.errors),
|
||||
{
|
||||
queue.postMessage(
|
||||
make('axe.run', result[resultIndex].extras[runIndex].axe, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
}
|
||||
)
|
||||
);
|
||||
})
|
||||
);
|
||||
// Another hack: Browsertime automatically creates statistics for alla data in extras
|
||||
// but we don't really need that for AXE.
|
||||
delete result[resultIndex].extras[runIndex].axe;
|
||||
delete result[resultIndex].statistics.extras.axe;
|
||||
}
|
||||
}
|
||||
if (result[resultIndex].cpu) {
|
||||
run.cpu = result[resultIndex].cpu[runIndex];
|
||||
}
|
||||
|
||||
let advice = coachAdvice;
|
||||
// If we run without HAR
|
||||
if (result.har) {
|
||||
// make sure to get the right run in the HAR
|
||||
const myHar = api.pickAPage(result.har, harIndex);
|
||||
const harResult = await api.analyseHar(myHar);
|
||||
advice = api.merge(coachAdvice, harResult);
|
||||
if (result[resultIndex].extras) {
|
||||
run.extras = result[resultIndex].extras[runIndex];
|
||||
}
|
||||
|
||||
if (
|
||||
result[resultIndex].cdp &&
|
||||
result[resultIndex].cdp.performance
|
||||
) {
|
||||
run.cdp = {
|
||||
performance: result[resultIndex].cdp.performance[runIndex]
|
||||
};
|
||||
}
|
||||
|
||||
if (result[resultIndex].fullyLoaded) {
|
||||
run.fullyLoaded = result[resultIndex].fullyLoaded[runIndex];
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.title) {
|
||||
run.title = result[resultIndex].info.title;
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.description) {
|
||||
run.description = result[resultIndex].info.description;
|
||||
}
|
||||
|
||||
if (result[resultIndex].info.android) {
|
||||
run.android = result[resultIndex].info.android;
|
||||
run.android.batteryTemperature =
|
||||
result[resultIndex].android.batteryTemperature[runIndex];
|
||||
}
|
||||
|
||||
run.timestamp = dayjs(
|
||||
result[resultIndex].timestamps[runIndex]
|
||||
).format(TIME_FORMAT);
|
||||
|
||||
run.errors = result[resultIndex].errors[runIndex];
|
||||
|
||||
run.screenshots = result[resultIndex].files.screenshot[runIndex];
|
||||
|
||||
// calculate errors
|
||||
for (let error of result[resultIndex].errors) {
|
||||
errorStats.push(error.length);
|
||||
}
|
||||
|
||||
queue.postMessage(
|
||||
make('coach.run', advice, {
|
||||
make('browsertime.run', run, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
|
||||
if (
|
||||
options.chrome &&
|
||||
options.chrome.collectConsoleLog &&
|
||||
options.browser === 'chrome'
|
||||
) {
|
||||
try {
|
||||
const consoleData = await consoleLogAggregator.addStats(
|
||||
runIndex + 1,
|
||||
result[resultIndex].files.consoleLog[runIndex]
|
||||
);
|
||||
|
||||
queue.postMessage(
|
||||
make('browsertime.console', consoleData, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
} catch (e) {
|
||||
// This could happen if the run failed somehow
|
||||
log.error('Could not fetch the console log');
|
||||
}
|
||||
}
|
||||
|
||||
// In Browsertime 2.x the tracelog was part of the result but since 3.x
|
||||
// it is stored to disk. If you want it passed around in the queue, just add
|
||||
// --postChromeTrace
|
||||
if (
|
||||
options.chrome &&
|
||||
options.chrome.timeline &&
|
||||
this.postChromeTrace
|
||||
) {
|
||||
const traceData = await getGzippedFileAsJson(
|
||||
options.resultDir,
|
||||
`trace-${runIndex + 1}.json.gz`
|
||||
);
|
||||
queue.postMessage(
|
||||
make('browsertime.chrometrace', traceData, {
|
||||
url,
|
||||
group,
|
||||
name: `trace-${runIndex + 1}.json`, // backward compatible to 2.x
|
||||
runIndex
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
// If the coach is turned on, collect the coach result
|
||||
if (options.coach) {
|
||||
const coachAdvice = run.coach.coachAdvice;
|
||||
// check if the coach has error(s)
|
||||
if (!isEmpty(coachAdvice.errors)) {
|
||||
log.error(
|
||||
'%s generated the following errors in the coach %:2j',
|
||||
url,
|
||||
coachAdvice.errors
|
||||
);
|
||||
queue.postMessage(
|
||||
make(
|
||||
'error',
|
||||
'The coach got the following errors: ' +
|
||||
JSON.stringify(coachAdvice.errors),
|
||||
{
|
||||
url,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
}
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
let advice = coachAdvice;
|
||||
// If we run without HAR
|
||||
if (result.har) {
|
||||
// make sure to get the right run in the HAR
|
||||
const myHar = api.pickAPage(result.har, harIndex);
|
||||
const harResult = await api.analyseHar(myHar);
|
||||
advice = api.merge(coachAdvice, harResult);
|
||||
}
|
||||
queue.postMessage(
|
||||
make('coach.run', advice, {
|
||||
url,
|
||||
group,
|
||||
runIndex,
|
||||
iteration: runIndex + 1
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
aggregator.addToAggregate(run, group);
|
||||
runIndex++;
|
||||
}
|
||||
|
||||
aggregator.addToAggregate(run, group);
|
||||
runIndex++;
|
||||
}
|
||||
// Let take the first runs timestamp and use that as the summary timestamp
|
||||
result.timestamp = dayjs(result[resultIndex].timestamps[0]).format(
|
||||
TIME_FORMAT
|
||||
);
|
||||
|
||||
// Let take the first runs timestamp and use that as the summary timestamp
|
||||
result.timestamp = dayjs(result[resultIndex].timestamps[0]).format(
|
||||
TIME_FORMAT
|
||||
);
|
||||
if (options.chrome && options.chrome.collectConsoleLog) {
|
||||
result[
|
||||
resultIndex
|
||||
].statistics.console = consoleLogAggregator.summarizeStats();
|
||||
}
|
||||
|
||||
if (options.chrome && options.chrome.collectConsoleLog) {
|
||||
result[
|
||||
resultIndex
|
||||
].statistics.console = consoleLogAggregator.summarizeStats();
|
||||
}
|
||||
result[resultIndex].statistics.errors = statsHelpers.summarizeStats(
|
||||
errorStats
|
||||
);
|
||||
|
||||
result[resultIndex].statistics.errors = statsHelpers.summarizeStats(
|
||||
errorStats
|
||||
);
|
||||
|
||||
// Post the result on the queue so other plugins can use it
|
||||
queue.postMessage(
|
||||
make('browsertime.pageSummary', result[resultIndex], {
|
||||
url,
|
||||
group,
|
||||
runTime: result.timestamp
|
||||
})
|
||||
);
|
||||
// Post the HAR on the queue so other plugins can use it
|
||||
if (result.har) {
|
||||
// Post the result on the queue so other plugins can use it
|
||||
queue.postMessage(
|
||||
make('browsertime.har', result.har, {
|
||||
make('browsertime.pageSummary', result[resultIndex], {
|
||||
url,
|
||||
group
|
||||
group,
|
||||
runTime: result.timestamp
|
||||
})
|
||||
);
|
||||
}
|
||||
// Post the HAR on the queue so other plugins can use it
|
||||
if (result.har) {
|
||||
queue.postMessage(
|
||||
make('browsertime.har', result.har, {
|
||||
url,
|
||||
group
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
// Post the result on the queue so other plugins can use it
|
||||
if (this.useAxe) {
|
||||
queue.postMessage(
|
||||
make('axe.pageSummary', axeAggregatorPerURL.summarizeStats(), {
|
||||
url,
|
||||
group
|
||||
})
|
||||
);
|
||||
}
|
||||
// Post the result on the queue so other plugins can use it
|
||||
if (this.useAxe) {
|
||||
queue.postMessage(
|
||||
make('axe.pageSummary', axeAggregatorPerURL.summarizeStats(), {
|
||||
url,
|
||||
group
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
// Check for errors. Browsertime errors is an array of all iterations
|
||||
// [[],[],[]] where one iteration can have multiple errors
|
||||
for (let errorsForOneIteration of result[resultIndex].errors) {
|
||||
for (let error of errorsForOneIteration) {
|
||||
queue.postMessage(make('error', error, merge({ url })));
|
||||
// Check for errors. Browsertime errors is an array of all iterations
|
||||
// [[],[],[]] where one iteration can have multiple errors
|
||||
for (let errorsForOneIteration of result[resultIndex].errors) {
|
||||
for (let error of errorsForOneIteration) {
|
||||
queue.postMessage(make('error', error, merge({ url })));
|
||||
}
|
||||
}
|
||||
}
|
||||
break;
|
||||
} catch (error) {
|
||||
queue.postMessage(make('error', error, merge({ url })));
|
||||
break;
|
||||
}
|
||||
break;
|
||||
}
|
||||
// It's time to summarize the metrics for all pages and runs
|
||||
// and post the summary on the queue
|
||||
|
|
|
|||
Loading…
Reference in New Issue