chrome/test/data/push_messaging/push_test.js

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 'use strict';
   6
   7 var resultQueue = new ResultQueue();
   8 var pushSubscription = null;
   9
  10 // Sends data back to the test. This must be in response to an earlier
  11 // request, but it's ok to respond asynchronously. The request blocks until
  12 // the response is sent.
  13 function sendResultToTest(result) {
  14   console.log('sendResultToTest: ' + result);
  15   if (window.domAutomationController) {
  16     domAutomationController.send('' + result);
  17   }
  18 }
  19
  20 function sendErrorToTest(error) {
  21   sendResultToTest(error.name + ' - ' + error.message);
  22 }
  23
  24 // Queue storing asynchronous results received from the Service Worker. Results
  25 // are sent to the test when requested.
  26 function ResultQueue() {
  27   // Invariant: this.queue.length == 0 || this.pendingGets == 0
  28   this.queue = [];
  29   this.pendingGets = 0;
  30 }
  31
  32 // Adds a data item to the queue. Will be sent to the test if there are
  33 // pendingGets.
  34 ResultQueue.prototype.push = function(data) {
  35   if (this.pendingGets > 0) {
  36     this.pendingGets--;
  37     sendResultToTest(data);
  38   } else {
  39     this.queue.unshift(data);
  40   }
  41 };
  42
  43 // Called by native. Sends the next data item to the test if it is available.
  44 // Otherwise increments pendingGets so it will be delivered when received.
  45 ResultQueue.prototype.pop = function() {
  46   if (this.queue.length) {
  47     sendResultToTest(this.queue.pop());
  48   } else {
  49     this.pendingGets++;
  50   }
  51 };
  52
  53 // Called by native. Immediately sends the next data item to the test if it is
  54 // available, otherwise sends null.
  55 ResultQueue.prototype.popImmediately = function() {
  56   sendResultToTest(this.queue.length ? this.queue.pop() : null);
  57 };
  58
  59 // Notification permission has been coalesced with Push permission. After
  60 // this is granted, Push API subscription can succeed.
  61 function requestNotificationPermission() {
  62   Notification.requestPermission(function(permission) {
  63     sendResultToTest('permission status - ' + permission);
  64   });
  65 }
  66
  67 function registerServiceWorker() {
  68   // The base dir used to resolve service_worker.js and the scope depends on
  69   // whether this script is included from an html file in ./, subscope1/, or
  70   // subscope2/.
  71   navigator.serviceWorker.register('service_worker.js', {scope: './'}).then(
  72       function(swRegistration) {
  73         sendResultToTest('ok - service worker registered');
  74       }, sendErrorToTest);
  75 }
  76
  77 function unregisterServiceWorker() {
  78   navigator.serviceWorker.getRegistration().then(function(swRegistration) {
  79     swRegistration.unregister().then(function(result) {
  80       sendResultToTest('service worker unregistration status: ' + result);
  81     })
  82   }).catch(sendErrorToTest);
  83 }
  84
  85 function removeManifest() {
  86   var element = document.querySelector('link[rel="manifest"]');
  87   if (element) {
  88     element.parentNode.removeChild(element);
  89     sendResultToTest('manifest removed');
  90   } else {
  91     sendResultToTest('unable to find manifest element');
  92   }
  93 }
  94
  95 function subscribePush() {
  96   navigator.serviceWorker.ready.then(function(swRegistration) {
  97     return swRegistration.pushManager.subscribe()
  98         .then(function(subscription) {
  99           pushSubscription = subscription;
 100           sendResultToTest(
 101               subscription.endpoint + ' - ' + subscription.subscriptionId);
 102         });
 103   }).catch(sendErrorToTest);
 104 }
 105
 106 function permissionState() {
 107   navigator.serviceWorker.ready.then(function(swRegistration) {
 108     return swRegistration.pushManager.permissionState()
 109         .then(function(permission) {
 110           sendResultToTest('permission status - ' + permission);
 111         });
 112   }).catch(sendErrorToTest);
 113 }
 114
 115 function isControlled() {
 116   if (navigator.serviceWorker.controller) {
 117     sendResultToTest('true - is controlled');
 118   } else {
 119     sendResultToTest('false - is not controlled');
 120   }
 121 }
 122
 123 function unsubscribePush() {
 124   if (!pushSubscription) {
 125     sendResultToTest('unsubscribe error: no subscription');
 126     return;
 127   }
 128
 129   pushSubscription.unsubscribe().then(function(result) {
 130     sendResultToTest('unsubscribe result: ' + result);
 131   }, function(error) {
 132     sendResultToTest('unsubscribe error: ' + error.name + ': ' + error.message);
 133   });
 134 }
 135
 136 function hasSubscription() {
 137   navigator.serviceWorker.ready.then(function(swRegistration) {
 138     return swRegistration.pushManager.getSubscription();
 139   }).then(function(subscription) {
 140     sendResultToTest(subscription ? 'true - subscribed'
 141                                   : 'false - not subscribed');
 142   }).catch(sendErrorToTest);
 143 }
 144
 145 addEventListener('message', function(event) {
 146   var message = JSON.parse(event.data);
 147   if (message.type == 'push')
 148     resultQueue.push(message.data);
 149 }, false);