blob: 2573daf2c4851e3a1d7d16c3090cd372934ff45c [file] [log] [blame]
#!/usr/local/bin/node
const fs = require('fs');
const parseArguments = require('./js/parse-arguments.js').parseArguments;
const RemoteAPI = require('./js/remote.js').RemoteAPI;
const MeasurementSetAnalyzer = require('./js/measurement-set-analyzer.js').MeasurementSetAnalyzer;
const AnalysisResultsNotifier = require('./js/analysis-results-notifier.js').AnalysisResultsNotifier;
const Subprocess = require('./js/subprocess.js').Subprocess;
require('./js/v3-models.js');
global.PrivilegedAPI = require('./js/privileged-api.js').PrivilegedAPI;
function main(argv)
{
const options = parseArguments(argv, [
{name: '--server-config-json', required: true},
{name: '--notification-config-json', required: true},
{name: '--analysis-range-in-days', type: parseFloat, default: 10},
{name: '--seconds-to-sleep', type: parseFloat, default: 1200},
{name: '--max-retry-factor', type: parseFloat, default: 3},
]);
if (!options)
return;
analysisLoop(options);
}
async function analysisLoop(options)
{
const secondsToSleep = options['--seconds-to-sleep'];
try {
const serverConfig = JSON.parse(fs.readFileSync(options['--server-config-json'], 'utf-8'));
const analysisRangeInDays = options['--analysis-range-in-days'];
global.RemoteAPI = new RemoteAPI(serverConfig.server);
PrivilegedAPI.configure(serverConfig.worker.name, serverConfig.worker.password);
const manifest = await Manifest.fetch();
const measurementSetList = MeasurementSetAnalyzer.measurementSetListForAnalysis(manifest);
const endTime = Date.now();
const startTime = endTime - analysisRangeInDays * 24 * 3600 * 1000;
const analyzer = new MeasurementSetAnalyzer(measurementSetList, startTime, endTime, console);
console.log(`Start analyzing last ${analysisRangeInDays} days measurement sets.`);
await analyzer.analyzeOnce();
} catch (error) {
console.error(`Failed to analyze measurement sets due to ${error}`);
}
const maxRetryFactor = options['--max-retry-factor'];
const testGroupsMayNeedMoreRequests = await TestGroup.fetchAllThatMayNeedMoreRequests();
try {
for (const testGroup of testGroupsMayNeedMoreRequests) {
const retryCount = await testGroup.scheduleMoreRequestsOrClearFlag(maxRetryFactor);
if (!retryCount)
continue;
const analysisTask = await testGroup.fetchTask();
console.log(`Added ${retryCount} build request(s) to "${testGroup.name()}" of analysis task: ${analysisTask.id()} - "${analysisTask.name()}"`);
}
} catch (error) {
console.error(error);
if (typeof(error.stack) == 'string') {
for (let line of error.stack.split('\n'))
console.error(line);
}
}
try {
const notificationConfig = JSON.parse(fs.readFileSync(options['--notification-config-json'], 'utf-8'));
const testGroupsNeedNotification = await TestGroup.fetchAllWithNotificationReady();
const notificationRemoteAPI = new RemoteAPI(notificationConfig.notificationServerConfig);
const notificationMessageConfig = notificationConfig.notificationMessageConfig;
const notifier = new AnalysisResultsNotifier(notificationMessageConfig.messageTemplate, notificationMessageConfig.finalizeScript,
notificationMessageConfig.messageConstructionRules, notificationRemoteAPI, notificationConfig.notificationServerConfig.path, new Subprocess);
await notifier.sendNotificationsForTestGroups(testGroupsNeedNotification);
} catch (error) {
console.error(`Failed to send notification for test groups due to ${error}`);
}
console.log(`Sleeping for ${secondsToSleep} seconds.`);
setTimeout(() => analysisLoop(options), secondsToSleep * 1000);
}
main(process.argv);