2012-11-13 20:22:09 -08:00
|
|
|
/* Any copyright is dedicated to the Public Domain.
|
|
|
|
* http://creativecommons.org/publicdomain/zero/1.0/ */
|
|
|
|
|
|
|
|
"use strict";
|
|
|
|
|
|
|
|
const {classes: Cc, interfaces: Ci, utils: Cu} = Components;
|
|
|
|
|
|
|
|
Cu.import("resource://services-common/observers.js");
|
|
|
|
Cu.import("resource://services-common/preferences.js");
|
2013-02-01 11:43:15 -08:00
|
|
|
Cu.import("resource://gre/modules/commonjs/sdk/core/promise.js");
|
2012-11-13 20:22:09 -08:00
|
|
|
Cu.import("resource://gre/modules/services/healthreport/healthreporter.jsm");
|
2013-01-11 13:45:22 -08:00
|
|
|
Cu.import("resource://gre/modules/services/datareporting/policy.jsm");
|
2013-01-06 12:13:27 -08:00
|
|
|
Cu.import("resource://gre/modules/Services.jsm");
|
|
|
|
Cu.import("resource://gre/modules/Task.jsm");
|
2012-11-13 20:22:09 -08:00
|
|
|
Cu.import("resource://testing-common/services-common/bagheeraserver.js");
|
|
|
|
Cu.import("resource://testing-common/services/metrics/mocks.jsm");
|
2013-01-06 16:24:50 -08:00
|
|
|
Cu.import("resource://testing-common/services/healthreport/utils.jsm");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
|
|
|
|
|
|
|
const SERVER_HOSTNAME = "localhost";
|
|
|
|
const SERVER_PORT = 8080;
|
|
|
|
const SERVER_URI = "http://" + SERVER_HOSTNAME + ":" + SERVER_PORT;
|
2013-01-06 12:13:27 -08:00
|
|
|
const MILLISECONDS_PER_DAY = 24 * 60 * 60 * 1000;
|
2012-11-13 20:22:09 -08:00
|
|
|
|
|
|
|
|
|
|
|
function defineNow(policy, now) {
|
|
|
|
print("Adjusting fake system clock to " + now);
|
|
|
|
Object.defineProperty(policy, "now", {
|
|
|
|
value: function customNow() {
|
|
|
|
return now;
|
|
|
|
},
|
|
|
|
writable: true,
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
2013-01-06 16:24:50 -08:00
|
|
|
function getJustReporter(name, uri=SERVER_URI, inspected=false) {
|
2012-11-13 20:22:09 -08:00
|
|
|
let branch = "healthreport.testing. " + name + ".";
|
|
|
|
|
2013-01-11 13:45:22 -08:00
|
|
|
let prefs = new Preferences(branch + "healthreport.");
|
2012-11-13 20:22:09 -08:00
|
|
|
prefs.set("documentServerURI", uri);
|
2013-01-06 12:13:27 -08:00
|
|
|
prefs.set("dbName", name);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-01-11 13:45:22 -08:00
|
|
|
let reporter;
|
|
|
|
|
|
|
|
let policyPrefs = new Preferences(branch + "policy.");
|
|
|
|
let policy = new DataReportingPolicy(policyPrefs, prefs, {
|
|
|
|
onRequestDataUpload: function (request) {
|
|
|
|
reporter.requestDataUpload(request);
|
|
|
|
},
|
|
|
|
|
|
|
|
onNotifyDataPolicy: function (request) { },
|
|
|
|
|
|
|
|
onRequestRemoteDelete: function (request) {
|
|
|
|
reporter.deleteRemoteData(request);
|
|
|
|
},
|
|
|
|
});
|
|
|
|
|
2013-01-06 16:24:50 -08:00
|
|
|
let type = inspected ? InspectedHealthReporter : HealthReporter;
|
2013-01-11 13:45:22 -08:00
|
|
|
reporter = new type(branch + "healthreport.", policy);
|
|
|
|
|
|
|
|
return reporter;
|
2013-01-06 16:24:50 -08:00
|
|
|
}
|
|
|
|
|
|
|
|
function getReporter(name, uri, inspected) {
|
|
|
|
let reporter = getJustReporter(name, uri, inspected);
|
2013-01-06 12:13:27 -08:00
|
|
|
return reporter.onInit();
|
2012-11-13 20:22:09 -08:00
|
|
|
}
|
|
|
|
|
|
|
|
function getReporterAndServer(name, namespace="test") {
|
2013-01-06 12:13:27 -08:00
|
|
|
return Task.spawn(function get() {
|
|
|
|
let reporter = yield getReporter(name, SERVER_URI);
|
|
|
|
reporter.serverNamespace = namespace;
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
let server = new BagheeraServer(SERVER_URI);
|
|
|
|
server.createNamespace(namespace);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
server.start(SERVER_PORT);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
throw new Task.Result([reporter, server]);
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
function shutdownServer(server) {
|
|
|
|
let deferred = Promise.defer();
|
|
|
|
server.stop(deferred.resolve.bind(deferred));
|
|
|
|
|
|
|
|
return deferred.promise;
|
2012-11-13 20:22:09 -08:00
|
|
|
}
|
|
|
|
|
|
|
|
function run_test() {
|
2013-03-05 10:31:12 -08:00
|
|
|
makeFakeAppDir().then(run_next_test, do_throw);
|
2012-11-13 20:22:09 -08:00
|
|
|
}
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_constructor() {
|
|
|
|
let reporter = yield getReporter("constructor");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
|
|
|
try {
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_eq(reporter.lastPingDate.getTime(), 0);
|
|
|
|
do_check_null(reporter.lastSubmitID);
|
|
|
|
|
|
|
|
reporter.lastSubmitID = "foo";
|
|
|
|
do_check_eq(reporter.lastSubmitID, "foo");
|
|
|
|
reporter.lastSubmitID = null;
|
|
|
|
do_check_null(reporter.lastSubmitID);
|
|
|
|
|
|
|
|
let failed = false;
|
|
|
|
try {
|
|
|
|
new HealthReporter("foo.bar");
|
|
|
|
} catch (ex) {
|
|
|
|
failed = true;
|
|
|
|
do_check_true(ex.message.startsWith("Branch must end"));
|
|
|
|
} finally {
|
|
|
|
do_check_true(failed);
|
|
|
|
failed = false;
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
} finally {
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter._shutdown();
|
2012-11-13 20:22:09 -08:00
|
|
|
}
|
|
|
|
});
|
|
|
|
|
2013-01-06 16:24:50 -08:00
|
|
|
add_task(function test_shutdown_normal() {
|
|
|
|
let reporter = yield getReporter("shutdown_normal");
|
|
|
|
|
|
|
|
// We can't send "quit-application" notification because the xpcshell runner
|
|
|
|
// will shut down!
|
|
|
|
reporter._initiateShutdown();
|
|
|
|
reporter._waitForShutdown();
|
|
|
|
});
|
|
|
|
|
|
|
|
add_task(function test_shutdown_storage_in_progress() {
|
|
|
|
let reporter = yield getJustReporter("shutdown_storage_in_progress", SERVER_URI, true);
|
|
|
|
|
|
|
|
reporter.onStorageCreated = function () {
|
|
|
|
print("Faking shutdown during storage initialization.");
|
|
|
|
reporter._initiateShutdown();
|
|
|
|
};
|
|
|
|
|
|
|
|
reporter._waitForShutdown();
|
2013-03-07 05:06:46 -08:00
|
|
|
do_check_eq(reporter.providerManagerShutdownCount, 0);
|
2013-01-06 16:24:50 -08:00
|
|
|
do_check_eq(reporter.storageCloseCount, 1);
|
|
|
|
});
|
|
|
|
|
2013-03-07 05:06:46 -08:00
|
|
|
// Ensure that a shutdown triggered while provider manager is initializing
|
|
|
|
// results in shutdown and storage closure.
|
|
|
|
add_task(function test_shutdown_provider_manager_in_progress() {
|
|
|
|
let reporter = yield getJustReporter("shutdown_provider_manager_in_progress",
|
|
|
|
SERVER_URI, true);
|
2013-01-06 16:24:50 -08:00
|
|
|
|
2013-03-07 05:06:46 -08:00
|
|
|
reporter.onProviderManagerInitialized = function () {
|
|
|
|
print("Faking shutdown during provider manager initialization.");
|
2013-01-06 16:24:50 -08:00
|
|
|
reporter._initiateShutdown();
|
|
|
|
};
|
|
|
|
|
|
|
|
// This will hang if shutdown logic is busted.
|
|
|
|
reporter._waitForShutdown();
|
2013-03-07 05:06:46 -08:00
|
|
|
do_check_eq(reporter.providerManagerShutdownCount, 1);
|
2013-02-27 16:52:29 -08:00
|
|
|
do_check_eq(reporter.storageCloseCount, 1);
|
|
|
|
});
|
|
|
|
|
2013-03-07 05:06:46 -08:00
|
|
|
// Simulates an error during provider manager initialization and verifies we shut down.
|
|
|
|
add_task(function test_shutdown_when_provider_manager_errors() {
|
|
|
|
let reporter = yield getJustReporter("shutdown_when_provider_manager_errors",
|
|
|
|
SERVER_URI, true);
|
2013-02-27 16:52:29 -08:00
|
|
|
|
2013-03-07 05:06:46 -08:00
|
|
|
reporter.onInitializeProviderManagerFinished = function () {
|
2013-02-27 16:52:29 -08:00
|
|
|
print("Throwing fake error.");
|
2013-03-07 05:06:46 -08:00
|
|
|
throw new Error("Fake error during provider manager initialization.");
|
2013-02-27 16:52:29 -08:00
|
|
|
};
|
|
|
|
|
|
|
|
// This will hang if shutdown logic is busted.
|
|
|
|
reporter._waitForShutdown();
|
2013-03-07 05:06:46 -08:00
|
|
|
do_check_eq(reporter.providerManagerShutdownCount, 1);
|
2013-01-06 16:24:50 -08:00
|
|
|
do_check_eq(reporter.storageCloseCount, 1);
|
|
|
|
});
|
|
|
|
|
2013-02-18 13:05:07 -08:00
|
|
|
// Pull-only providers are only initialized at collect time.
|
|
|
|
add_task(function test_pull_only_providers() {
|
2013-01-31 08:58:19 -08:00
|
|
|
const category = "healthreporter-constant-only";
|
|
|
|
|
|
|
|
let cm = Cc["@mozilla.org/categorymanager;1"]
|
|
|
|
.getService(Ci.nsICategoryManager);
|
|
|
|
cm.addCategoryEntry(category, "DummyProvider",
|
|
|
|
"resource://testing-common/services/metrics/mocks.jsm",
|
|
|
|
false, true);
|
|
|
|
cm.addCategoryEntry(category, "DummyConstantProvider",
|
|
|
|
"resource://testing-common/services/metrics/mocks.jsm",
|
|
|
|
false, true);
|
|
|
|
|
|
|
|
let reporter = yield getReporter("constant_only_providers");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
do_check_eq(reporter._providerManager._providers.size, 0);
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvidersFromCategoryManager(category);
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_eq(reporter._providerManager._providers.size, 1);
|
|
|
|
do_check_true(reporter._storage.hasProvider("DummyProvider"));
|
|
|
|
do_check_false(reporter._storage.hasProvider("DummyConstantProvider"));
|
|
|
|
do_check_neq(reporter.getProvider("DummyProvider"), null);
|
|
|
|
do_check_null(reporter.getProvider("DummyConstantProvider"));
|
|
|
|
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.ensurePullOnlyProvidersRegistered();
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter.collectMeasurements();
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.ensurePullOnlyProvidersUnregistered();
|
2013-03-07 05:06:58 -08:00
|
|
|
|
|
|
|
do_check_eq(reporter._providerManager._providers.size, 1);
|
|
|
|
do_check_true(reporter._storage.hasProvider("DummyConstantProvider"));
|
|
|
|
|
|
|
|
let mID = reporter._storage.measurementID("DummyConstantProvider", "DummyMeasurement", 1);
|
|
|
|
let values = yield reporter._storage.getMeasurementValues(mID);
|
|
|
|
do_check_true(values.singular.size > 0);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2013-01-31 08:58:19 -08:00
|
|
|
});
|
|
|
|
|
2013-02-05 09:59:15 -08:00
|
|
|
add_task(function test_collect_daily() {
|
|
|
|
let reporter = yield getReporter("collect_daily");
|
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let now = new Date();
|
|
|
|
let provider = new DummyProvider();
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvider(provider);
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter.collectMeasurements();
|
2013-02-05 09:59:15 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_eq(provider.collectConstantCount, 1);
|
|
|
|
do_check_eq(provider.collectDailyCount, 1);
|
2013-02-05 09:59:15 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter.collectMeasurements();
|
|
|
|
do_check_eq(provider.collectConstantCount, 1);
|
|
|
|
do_check_eq(provider.collectDailyCount, 1);
|
2013-02-05 09:59:15 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter.collectMeasurements();
|
|
|
|
do_check_eq(provider.collectDailyCount, 1); // Too soon.
|
2013-02-05 09:59:15 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter._lastDailyDate = now.getTime() - MILLISECONDS_PER_DAY - 1;
|
|
|
|
yield reporter.collectMeasurements();
|
|
|
|
do_check_eq(provider.collectDailyCount, 2);
|
2013-02-05 09:59:15 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter._lastDailyDate = null;
|
|
|
|
yield reporter.collectMeasurements();
|
|
|
|
do_check_eq(provider.collectDailyCount, 3);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2013-02-05 09:59:15 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_json_payload_simple() {
|
|
|
|
let reporter = yield getReporter("json_payload_simple");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let now = new Date();
|
|
|
|
let payload = yield reporter.getJSONPayload();
|
|
|
|
do_check_eq(typeof payload, "string");
|
|
|
|
let original = JSON.parse(payload);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_eq(original.version, 1);
|
|
|
|
do_check_eq(original.thisPingDate, reporter._formatDate(now));
|
|
|
|
do_check_eq(Object.keys(original.data.last).length, 0);
|
|
|
|
do_check_eq(Object.keys(original.data.days).length, 0);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter.lastPingDate = new Date(now.getTime() - 24 * 60 * 60 * 1000 - 10);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
original = JSON.parse(yield reporter.getJSONPayload());
|
|
|
|
do_check_eq(original.lastPingDate, reporter._formatDate(reporter.lastPingDate));
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
// This could fail if we cross UTC day boundaries at the exact instance the
|
|
|
|
// test is executed. Let's tempt fate.
|
|
|
|
do_check_eq(original.thisPingDate, reporter._formatDate(now));
|
2013-02-05 20:31:48 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
payload = yield reporter.getJSONPayload(true);
|
|
|
|
do_check_eq(typeof payload, "object");
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_json_payload_dummy_provider() {
|
|
|
|
let reporter = yield getReporter("json_payload_dummy_provider");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvider(new DummyProvider());
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter.collectMeasurements();
|
|
|
|
let payload = yield reporter.getJSONPayload();
|
|
|
|
print(payload);
|
|
|
|
let o = JSON.parse(payload);
|
|
|
|
|
|
|
|
let name = "DummyProvider.DummyMeasurement";
|
|
|
|
do_check_eq(Object.keys(o.data.last).length, 1);
|
|
|
|
do_check_true(name in o.data.last);
|
|
|
|
do_check_eq(o.data.last[name]._v, 1);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-02-05 20:31:48 -08:00
|
|
|
add_task(function test_collect_and_obtain_json_payload() {
|
|
|
|
let reporter = yield getReporter("collect_and_obtain_json_payload");
|
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvider(new DummyProvider());
|
2013-03-07 05:06:58 -08:00
|
|
|
let payload = yield reporter.collectAndObtainJSONPayload();
|
|
|
|
do_check_eq(typeof payload, "string");
|
2013-02-05 20:31:48 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let o = JSON.parse(payload);
|
|
|
|
do_check_true("DummyProvider.DummyMeasurement" in o.data.last);
|
2013-02-05 20:31:48 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
payload = yield reporter.collectAndObtainJSONPayload(true);
|
|
|
|
do_check_eq(typeof payload, "object");
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2013-02-05 20:31:48 -08:00
|
|
|
});
|
|
|
|
|
2013-02-06 19:26:26 -08:00
|
|
|
// Ensure constant-only providers make their way into the JSON payload.
|
|
|
|
add_task(function test_constant_only_providers_in_json_payload() {
|
|
|
|
const category = "healthreporter-constant-only-in-payload";
|
|
|
|
|
|
|
|
let cm = Cc["@mozilla.org/categorymanager;1"]
|
|
|
|
.getService(Ci.nsICategoryManager);
|
|
|
|
cm.addCategoryEntry(category, "DummyProvider",
|
|
|
|
"resource://testing-common/services/metrics/mocks.jsm",
|
|
|
|
false, true);
|
|
|
|
cm.addCategoryEntry(category, "DummyConstantProvider",
|
|
|
|
"resource://testing-common/services/metrics/mocks.jsm",
|
|
|
|
false, true);
|
|
|
|
|
|
|
|
let reporter = yield getReporter("constant_only_providers_in_json_payload");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvidersFromCategoryManager(category);
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let payload = yield reporter.collectAndObtainJSONPayload();
|
|
|
|
let o = JSON.parse(payload);
|
|
|
|
do_check_true("DummyProvider.DummyMeasurement" in o.data.last);
|
|
|
|
do_check_true("DummyConstantProvider.DummyMeasurement" in o.data.last);
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let providers = reporter._providerManager.providers;
|
|
|
|
do_check_eq(providers.length, 1);
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
// Do it again for good measure.
|
|
|
|
payload = yield reporter.collectAndObtainJSONPayload();
|
|
|
|
o = JSON.parse(payload);
|
|
|
|
do_check_true("DummyProvider.DummyMeasurement" in o.data.last);
|
|
|
|
do_check_true("DummyConstantProvider.DummyMeasurement" in o.data.last);
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:46 -08:00
|
|
|
providers = reporter._providerManager.providers;
|
2013-02-06 19:26:26 -08:00
|
|
|
do_check_eq(providers.length, 1);
|
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
// Ensure throwing getJSONPayload is handled properly.
|
|
|
|
Object.defineProperty(reporter, "_getJSONPayload", {
|
|
|
|
value: function () {
|
|
|
|
throw new Error("Silly error.");
|
|
|
|
},
|
|
|
|
});
|
|
|
|
|
|
|
|
let deferred = Promise.defer();
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter.collectAndObtainJSONPayload().then(do_throw, function onError() {
|
|
|
|
providers = reporter._providerManager.providers;
|
|
|
|
do_check_eq(providers.length, 1);
|
|
|
|
deferred.resolve();
|
|
|
|
});
|
|
|
|
|
|
|
|
yield deferred.promise;
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2013-02-06 19:26:26 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_json_payload_multiple_days() {
|
|
|
|
let reporter = yield getReporter("json_payload_multiple_days");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let provider = new DummyProvider();
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvider(provider);
|
2013-03-07 05:06:58 -08:00
|
|
|
|
|
|
|
let now = new Date();
|
|
|
|
let m = provider.getMeasurement("DummyMeasurement", 1);
|
|
|
|
for (let i = 0; i < 200; i++) {
|
|
|
|
let date = new Date(now.getTime() - i * MILLISECONDS_PER_DAY);
|
|
|
|
yield m.incrementDailyCounter("daily-counter", date);
|
|
|
|
yield m.addDailyDiscreteNumeric("daily-discrete-numeric", i, date);
|
|
|
|
yield m.addDailyDiscreteNumeric("daily-discrete-numeric", i + 100, date);
|
|
|
|
yield m.addDailyDiscreteText("daily-discrete-text", "" + i, date);
|
|
|
|
yield m.addDailyDiscreteText("daily-discrete-text", "" + (i + 50), date);
|
|
|
|
yield m.setDailyLastNumeric("daily-last-numeric", date.getTime(), date);
|
|
|
|
}
|
|
|
|
|
|
|
|
let payload = yield reporter.getJSONPayload();
|
|
|
|
print(payload);
|
|
|
|
let o = JSON.parse(payload);
|
|
|
|
|
|
|
|
do_check_eq(Object.keys(o.data.days).length, 180);
|
|
|
|
let today = reporter._formatDate(now);
|
|
|
|
do_check_true(today in o.data.days);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2013-01-06 12:13:27 -08:00
|
|
|
});
|
|
|
|
|
|
|
|
add_task(function test_idle_daily() {
|
|
|
|
let reporter = yield getReporter("idle_daily");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let provider = new DummyProvider();
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProvider(provider);
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let now = new Date();
|
|
|
|
let m = provider.getMeasurement("DummyMeasurement", 1);
|
|
|
|
for (let i = 0; i < 200; i++) {
|
|
|
|
let date = new Date(now.getTime() - i * MILLISECONDS_PER_DAY);
|
|
|
|
yield m.incrementDailyCounter("daily-counter", date);
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let values = yield m.getValues();
|
|
|
|
do_check_eq(values.days.size, 200);
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
Services.obs.notifyObservers(null, "idle-daily", null);
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
values = yield m.getValues();
|
|
|
|
do_check_eq(values.days.size, 180);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_data_submission_transport_failure() {
|
|
|
|
let reporter = yield getReporter("data_submission_transport_failure");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
reporter.serverURI = "http://localhost:8080/";
|
|
|
|
reporter.serverNamespace = "test00";
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let deferred = Promise.defer();
|
|
|
|
let request = new DataSubmissionRequest(deferred, new Date(Date.now + 30000));
|
|
|
|
reporter.requestDataUpload(request);
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
yield deferred.promise;
|
|
|
|
do_check_eq(request.state, request.SUBMISSION_FAILURE_SOFT);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_data_submission_success() {
|
|
|
|
let [reporter, server] = yield getReporterAndServer("data_submission_success");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
2013-03-11 14:12:24 -07:00
|
|
|
yield reporter._providerManager.registerProviderFromType(DummyProvider);
|
|
|
|
yield reporter._providerManager.registerProviderFromType(DummyConstantProvider);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_eq(reporter.lastPingDate.getTime(), 0);
|
|
|
|
do_check_false(reporter.haveRemoteData());
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let deferred = Promise.defer();
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
let request = new DataSubmissionRequest(deferred, new Date());
|
|
|
|
reporter.requestDataUpload(request);
|
|
|
|
yield deferred.promise;
|
|
|
|
do_check_eq(request.state, request.SUBMISSION_SUCCESS);
|
|
|
|
do_check_true(reporter.lastPingDate.getTime() > 0);
|
|
|
|
do_check_true(reporter.haveRemoteData());
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
// Ensure data from providers made it to payload.
|
|
|
|
let o = yield reporter.getLastPayload();
|
|
|
|
do_check_true("DummyProvider.DummyMeasurement" in o.data.last);
|
|
|
|
do_check_true("DummyConstantProvider.DummyMeasurement" in o.data.last);
|
2013-02-06 19:26:26 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
reporter._shutdown();
|
|
|
|
} finally {
|
|
|
|
yield shutdownServer(server);
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_recurring_daily_pings() {
|
|
|
|
let [reporter, server] = yield getReporterAndServer("recurring_daily_pings");
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
2013-03-11 14:12:24 -07:00
|
|
|
reporter._providerManager.registerProvider(new DummyProvider());
|
2013-03-07 05:06:58 -08:00
|
|
|
|
|
|
|
let policy = reporter._policy;
|
|
|
|
|
|
|
|
defineNow(policy, policy._futureDate(-24 * 60 * 68 * 1000));
|
|
|
|
policy.recordUserAcceptance();
|
|
|
|
defineNow(policy, policy.nextDataSubmissionDate);
|
|
|
|
let promise = policy.checkStateAndTrigger();
|
|
|
|
do_check_neq(promise, null);
|
|
|
|
yield promise;
|
|
|
|
|
|
|
|
let lastID = reporter.lastSubmitID;
|
|
|
|
do_check_neq(lastID, null);
|
|
|
|
do_check_true(server.hasDocument(reporter.serverNamespace, lastID));
|
|
|
|
|
|
|
|
// Skip forward to next scheduled submission time.
|
|
|
|
defineNow(policy, policy.nextDataSubmissionDate);
|
|
|
|
promise = policy.checkStateAndTrigger();
|
|
|
|
do_check_neq(promise, null);
|
|
|
|
yield promise;
|
|
|
|
do_check_neq(reporter.lastSubmitID, lastID);
|
|
|
|
do_check_true(server.hasDocument(reporter.serverNamespace, reporter.lastSubmitID));
|
|
|
|
do_check_false(server.hasDocument(reporter.serverNamespace, lastID));
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
yield shutdownServer(server);
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_request_remote_data_deletion() {
|
|
|
|
let [reporter, server] = yield getReporterAndServer("request_remote_data_deletion");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let policy = reporter._policy;
|
|
|
|
defineNow(policy, policy._futureDate(-24 * 60 * 60 * 1000));
|
|
|
|
policy.recordUserAcceptance();
|
|
|
|
defineNow(policy, policy.nextDataSubmissionDate);
|
|
|
|
yield policy.checkStateAndTrigger();
|
|
|
|
let id = reporter.lastSubmitID;
|
|
|
|
do_check_neq(id, null);
|
|
|
|
do_check_true(server.hasDocument(reporter.serverNamespace, id));
|
|
|
|
|
|
|
|
defineNow(policy, policy._futureDate(10 * 1000));
|
|
|
|
|
|
|
|
let promise = reporter.requestDeleteRemoteData();
|
|
|
|
do_check_neq(promise, null);
|
|
|
|
yield promise;
|
|
|
|
do_check_null(reporter.lastSubmitID);
|
|
|
|
do_check_false(reporter.haveRemoteData());
|
|
|
|
do_check_false(server.hasDocument(reporter.serverNamespace, id));
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
yield shutdownServer(server);
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_policy_accept_reject() {
|
|
|
|
let [reporter, server] = yield getReporterAndServer("policy_accept_reject");
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let policy = reporter._policy;
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
do_check_false(policy.dataSubmissionPolicyAccepted);
|
|
|
|
do_check_false(reporter.willUploadData);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
policy.recordUserAcceptance();
|
|
|
|
do_check_true(policy.dataSubmissionPolicyAccepted);
|
|
|
|
do_check_true(reporter.willUploadData);
|
2012-11-13 20:22:09 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
policy.recordUserRejection();
|
|
|
|
do_check_false(policy.dataSubmissionPolicyAccepted);
|
|
|
|
do_check_false(reporter.willUploadData);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
yield shutdownServer(server);
|
|
|
|
}
|
2012-11-13 20:22:09 -08:00
|
|
|
});
|
|
|
|
|
2013-01-06 12:13:27 -08:00
|
|
|
add_task(function test_upload_save_payload() {
|
|
|
|
let [reporter, server] = yield getReporterAndServer("upload_save_payload");
|
2012-11-16 10:05:19 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
try {
|
|
|
|
let deferred = Promise.defer();
|
|
|
|
let request = new DataSubmissionRequest(deferred, new Date(), false);
|
2013-01-06 12:13:27 -08:00
|
|
|
|
2013-03-07 05:06:58 -08:00
|
|
|
yield reporter._uploadData(request);
|
|
|
|
let json = yield reporter.getLastPayload();
|
|
|
|
do_check_true("thisPingDate" in json);
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
yield shutdownServer(server);
|
|
|
|
}
|
2012-11-16 10:05:19 -08:00
|
|
|
});
|
|
|
|
|
2013-03-05 10:31:12 -08:00
|
|
|
add_task(function test_error_message_scrubbing() {
|
|
|
|
let reporter = yield getReporter("error_message_scrubbing");
|
|
|
|
|
|
|
|
try {
|
|
|
|
let profile = Services.dirsvc.get("ProfD", Ci.nsIFile).path;
|
|
|
|
reporter._recordError("Foo " + profile);
|
|
|
|
|
|
|
|
do_check_eq(reporter._errors.length, 1);
|
|
|
|
do_check_eq(reporter._errors[0], "Foo <ProfilePath>");
|
|
|
|
|
|
|
|
reporter._errors = [];
|
|
|
|
|
|
|
|
let appdata = Services.dirsvc.get("UAppData", Ci.nsIFile);
|
|
|
|
let uri = Services.io.newFileURI(appdata);
|
|
|
|
|
|
|
|
reporter._recordError("Foo " + uri.spec);
|
|
|
|
do_check_eq(reporter._errors[0], "Foo <AppDataURI>");
|
|
|
|
} finally {
|
|
|
|
reporter._shutdown();
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|