michael@0: /* Any copyright is dedicated to the Public Domain.
michael@0:    http://creativecommons.org/publicdomain/zero/1.0/ */
michael@0: 
michael@0: Cu.import("resource://services-sync/service.js");
michael@0: Cu.import("resource://services-sync/status.js");
michael@0: Cu.import("resource://services-sync/util.js");
michael@0: 
michael@0: Cu.import("resource://testing-common/services/sync/fakeservices.js");
michael@0: Cu.import("resource://testing-common/services/sync/utils.js");
michael@0: 
michael@0: function baseHandler(eolCode, request, response, statusCode, status, body) {
michael@0:   let alertBody = {
michael@0:     code: eolCode,
michael@0:     message: "Service is EOLed.",
michael@0:     url: "http://getfirefox.com",
michael@0:   };
michael@0:   response.setHeader("X-Weave-Timestamp", "" + new_timestamp(), false);
michael@0:   response.setHeader("X-Weave-Alert", "" + JSON.stringify(alertBody), false);
michael@0:   response.setStatusLine(request.httpVersion, statusCode, status);
michael@0:   response.bodyOutputStream.write(body, body.length);
michael@0: }
michael@0: 
michael@0: function handler513(request, response) {
michael@0:   let statusCode = 513;
michael@0:   let status = "Upgrade Required";
michael@0:   let body = "{}";
michael@0:   baseHandler("hard-eol", request, response, statusCode, status, body);
michael@0: }
michael@0: 
michael@0: function handler200(eolCode) {
michael@0:   return function (request, response) {
michael@0:     let statusCode = 200;
michael@0:     let status = "OK";
michael@0:     let body = "{\"meta\": 123456789010}";
michael@0:     baseHandler(eolCode, request, response, statusCode, status, body);
michael@0:   };
michael@0: }
michael@0: 
michael@0: function sync_httpd_setup(infoHandler) {
michael@0:   let handlers = {
michael@0:     "/1.1/johndoe/info/collections": infoHandler,
michael@0:   };
michael@0:   return httpd_setup(handlers);
michael@0: }
michael@0: 
michael@0: function setUp(server) {
michael@0:   yield configureIdentity({username: "johndoe"});
michael@0:   Service.serverURL = server.baseURI + "/";
michael@0:   Service.clusterURL = server.baseURI + "/";
michael@0:   new FakeCryptoService();
michael@0: }
michael@0: 
michael@0: function run_test() {
michael@0:   run_next_test();
michael@0: }
michael@0: 
michael@0: function do_check_soft_eol(eh, start) {
michael@0:   // We subtract 1000 because the stored value is in second precision.
michael@0:   do_check_true(eh.earliestNextAlert >= (start + eh.MINIMUM_ALERT_INTERVAL_MSEC - 1000));
michael@0:   do_check_eq("soft-eol", eh.currentAlertMode);
michael@0: }
michael@0: function do_check_hard_eol(eh, start) {
michael@0:   // We subtract 1000 because the stored value is in second precision.
michael@0:   do_check_true(eh.earliestNextAlert >= (start + eh.MINIMUM_ALERT_INTERVAL_MSEC - 1000));
michael@0:   do_check_eq("hard-eol", eh.currentAlertMode);
michael@0:   do_check_true(Status.eol);
michael@0: }
michael@0: 
michael@0: add_identity_test(this, function test_200_hard() {
michael@0:   let eh = Service.errorHandler;
michael@0:   let start = Date.now();
michael@0:   let server = sync_httpd_setup(handler200("hard-eol"));
michael@0:   yield setUp(server);
michael@0: 
michael@0:   let deferred = Promise.defer();
michael@0:   let obs = function (subject, topic, data) {
michael@0:     Svc.Obs.remove("weave:eol", obs);
michael@0:     do_check_eq("hard-eol", subject.code);
michael@0:     do_check_hard_eol(eh, start);
michael@0:     do_check_eq(Service.scheduler.eolInterval, Service.scheduler.syncInterval);
michael@0:     eh.clearServerAlerts();
michael@0:     server.stop(deferred.resolve);
michael@0:   };
michael@0: 
michael@0:   Svc.Obs.add("weave:eol", obs);
michael@0:   Service._fetchInfo();
michael@0:   Service.scheduler.adjustSyncInterval();   // As if we failed or succeeded in syncing.
michael@0:   yield deferred.promise;
michael@0: });
michael@0: 
michael@0: add_identity_test(this, function test_513_hard() {
michael@0:   let eh = Service.errorHandler;
michael@0:   let start = Date.now();
michael@0:   let server = sync_httpd_setup(handler513);
michael@0:   yield setUp(server);
michael@0: 
michael@0:   let deferred = Promise.defer();
michael@0:   let obs = function (subject, topic, data) {
michael@0:     Svc.Obs.remove("weave:eol", obs);
michael@0:     do_check_eq("hard-eol", subject.code);
michael@0:     do_check_hard_eol(eh, start);
michael@0:     do_check_eq(Service.scheduler.eolInterval, Service.scheduler.syncInterval);
michael@0:     eh.clearServerAlerts();
michael@0:     server.stop(deferred.resolve);
michael@0:   };
michael@0: 
michael@0:   Svc.Obs.add("weave:eol", obs);
michael@0:   try {
michael@0:     Service._fetchInfo();
michael@0:     Service.scheduler.adjustSyncInterval();   // As if we failed or succeeded in syncing.
michael@0:   } catch (ex) {
michael@0:     // Because fetchInfo will fail on a 513.
michael@0:   }
michael@0:   yield deferred.promise;
michael@0: });
michael@0: 
michael@0: add_identity_test(this, function test_200_soft() {
michael@0:   let eh = Service.errorHandler;
michael@0:   let start = Date.now();
michael@0:   let server = sync_httpd_setup(handler200("soft-eol"));
michael@0:   yield setUp(server);
michael@0: 
michael@0:   let deferred = Promise.defer();
michael@0:   let obs = function (subject, topic, data) {
michael@0:     Svc.Obs.remove("weave:eol", obs);
michael@0:     do_check_eq("soft-eol", subject.code);
michael@0:     do_check_soft_eol(eh, start);
michael@0:     do_check_eq(Service.scheduler.singleDeviceInterval, Service.scheduler.syncInterval);
michael@0:     eh.clearServerAlerts();
michael@0:     server.stop(deferred.resolve);
michael@0:   };
michael@0: 
michael@0:   Svc.Obs.add("weave:eol", obs);
michael@0:   Service._fetchInfo();
michael@0:   Service.scheduler.adjustSyncInterval();   // As if we failed or succeeded in syncing.
michael@0:   yield deferred.promise;
michael@0: });