Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2016 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 | |
| 9 // Sends data back to the test. This must be in response to an earlier | |
| 10 // request, but it's ok to respond asynchronously. The request blocks until | |
| 11 // the response is sent. | |
| 12 function sendResultToTest(result) { | |
| 13 console.log('sendResultToTest: ' + result); | |
| 14 if (window.domAutomationController) { | |
| 15 domAutomationController.send('' + result); | |
| 16 } | |
| 17 } | |
| 18 | |
| 19 function sendErrorToTest(error) { | |
| 20 sendResultToTest(error.name + ' - ' + error.message); | |
| 21 } | |
| 22 | |
| 23 // Queue storing asynchronous results received from the Service Worker. Results | |
| 24 // are sent to the test when requested. | |
| 25 function ResultQueue() { | |
|
Peter Beverloo
2016/09/27 15:57:47
Could we share this code with the push messaging t
harkness
2016/09/28 12:29:21
Done.
| |
| 26 // Invariant: this.queue.length == 0 || this.pendingGets == 0 | |
| 27 this.queue = []; | |
| 28 this.pendingGets = 0; | |
| 29 } | |
| 30 | |
| 31 // Adds a data item to the queue. Will be sent to the test if there are | |
| 32 // pendingGets. | |
| 33 ResultQueue.prototype.push = function(data) { | |
| 34 if (this.pendingGets > 0) { | |
| 35 this.pendingGets--; | |
| 36 sendResultToTest(data); | |
| 37 } else { | |
| 38 this.queue.unshift(data); | |
| 39 } | |
| 40 }; | |
| 41 | |
| 42 // Called by native. Sends the next data item to the test if it is available. | |
| 43 // Otherwise increments pendingGets so it will be delivered when received. | |
| 44 ResultQueue.prototype.pop = function() { | |
| 45 if (this.queue.length) { | |
| 46 sendResultToTest(this.queue.pop()); | |
| 47 } else { | |
| 48 this.pendingGets++; | |
| 49 } | |
| 50 }; | |
| 51 | |
| 52 // Called by native. Immediately sends the next data item to the test if it is | |
| 53 // available, otherwise sends null. | |
| 54 ResultQueue.prototype.popImmediately = function() { | |
| 55 sendResultToTest(this.queue.length ? this.queue.pop() : null); | |
| 56 }; | |
| 57 | |
| 58 function registerServiceWorker() { | |
| 59 // The base dir used to resolve service_worker.js. | |
| 60 navigator.serviceWorker.register('service_worker.js', {scope: './'}).then( | |
| 61 function(swRegistration) { | |
| 62 sendResultToTest('ok - service worker registered'); | |
| 63 }, sendErrorToTest); | |
| 64 } | |
| 65 | |
| 66 // Query for the budget and return the current total. | |
| 67 function documentGetBudget() { | |
| 68 navigator.budget.getBudget().then(function(budget) { | |
| 69 sendResultToTest("ok - budget returned value of " + budget[0].budgetAt); | |
| 70 }, function() { | |
| 71 sendResultToTest("failed - unable to get budget values"); | |
| 72 }); | |
| 73 } | |
| 74 | |
| 75 // Request a reservation for a silent push. | |
| 76 function documentReserveBudget() { | |
| 77 navigator.budget.reserve('silent-push').then(function(reserved) { | |
| 78 if (reserved) | |
| 79 sendResultToTest("ok - reserved budget"); | |
| 80 else | |
| 81 sendResultToTest("failed - not able to reserve budget"); | |
| 82 }, function() { | |
| 83 sendResultToTest("failed - error while trying to reserve budget"); | |
| 84 }); | |
| 85 } | |
| 86 | |
| 87 function workerGetBudget() { | |
| 88 navigator.serviceWorker.controller.postMessage({command: 'workerGet'}); | |
| 89 } | |
| 90 | |
| 91 function workerReserveBudget() { | |
| 92 navigator.serviceWorker.controller.postMessage({command: 'workerReserve'}); | |
| 93 } | |
| 94 | |
| 95 function isControlled() { | |
| 96 if (navigator.serviceWorker.controller) { | |
| 97 sendResultToTest('true - is controlled'); | |
| 98 } else { | |
| 99 sendResultToTest('false - is not controlled'); | |
| 100 } | |
| 101 } | |
| 102 | |
| 103 navigator.serviceWorker.addEventListener('message', function(event) { | |
| 104 var message = JSON.parse(event.data); | |
| 105 if (message.type == 'push') | |
| 106 resultQueue.push(message.data); | |
| 107 else | |
| 108 sendResultToTest(message.data); | |
| 109 }, false); | |
| OLD | NEW |