Launch Week Day 5: Introducing Reachability for PHP.Learn More →
@firebase/messaging
Advanced tools
@firebase/messaging - npm Package Compare versions
@@ -46,4 +46,7 @@ import TokenDetailsModel from '../models/token-details-model'; | ||
| requestPermission(): void; | ||
| getPushSubscription_(registration: any, publicVapidKey: any): Promise<PushSubscription>; | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| */ | ||
| getPushSubscription(swRegistration: ServiceWorkerRegistration, publicVapidKey: Uint8Array): Promise<PushSubscription>; | ||
| /** | ||
| * @export | ||
@@ -50,0 +53,0 @@ * @param {!ServiceWorkerRegistration} registration |
@@ -125,3 +125,3 @@ /** | ||
| publicVapidKey = publicKey; | ||
| return _this.getPushSubscription_(swReg, publicVapidKey); | ||
| return _this.getPushSubscription(swReg, publicVapidKey); | ||
| }) | ||
@@ -164,3 +164,3 @@ .then(function (pushSubscription) { | ||
| publicVapidKey = publicKey; | ||
| return _this.getPushSubscription_(swReg, publicVapidKey); | ||
| return _this.getPushSubscription(swReg, publicVapidKey); | ||
| }) | ||
@@ -230,4 +230,15 @@ .then(function (pushSubscription) { | ||
| }; | ||
| ControllerInterface.prototype.getPushSubscription_ = function (registration, publicVapidKey) { | ||
| throw this.errorFactory_.create(errors_1.default.codes.AVAILABLE_IN_WINDOW); | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| */ | ||
| ControllerInterface.prototype.getPushSubscription = function (swRegistration, publicVapidKey) { | ||
| return swRegistration.pushManager.getSubscription().then(function (subscription) { | ||
| if (subscription) { | ||
| return subscription; | ||
| } | ||
| return swRegistration.pushManager.subscribe({ | ||
| userVisibleOnly: true, | ||
| applicationServerKey: publicVapidKey | ||
| }); | ||
| }); | ||
| }; | ||
@@ -234,0 +245,0 @@ /** |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/controllers/controller-interface.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;AAEb,uCAA8C;AAC9C,2CAAsC;AACtC,qEAA8D;AAC9D,qEAA8D;AAC9D,6EAAwE;AACxE,iDAA2C;AAC3C,4EAAoE;AAEpE,IAAM,qBAAqB,GAAG,mBAAmB,CAAC;AAClD,oDAAoD;AACvC,QAAA,uBAAuB,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,IAAI,CAAC,CAAC,SAAS;AAEzE;IASE;;;OAGG;IACH,6BAAY,GAAG;QAAf,iBAmBC;QAlBC,IAAI,CAAC,aAAa,GAAG,IAAI,mBAAY,CAAC,WAAW,EAAE,WAAW,EAAE,gBAAM,CAAC,GAAG,CAAC,CAAC;QAE5E,EAAE,CAAC,CACD,CAAC,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC;YACnC,OAAO,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,KAAK,QAChD,CAAC,CAAC,CAAC;YACD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,aAAa,CAAC,CAAC;QAC9D,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,CAAC;QAE7D,IAAI,CAAC,kBAAkB,GAAG,IAAI,6BAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,kBAAkB,GAAG,IAAI,6BAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,SAAS,GAAG,IAAI,mBAAQ,EAAE,CAAC;QAEhC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,QAAQ,GAAG,EAAE,CAAC;QACnB,IAAI,CAAC,QAAQ,CAAC,MAAM,GAAG,cAAM,OAAA,KAAI,CAAC,MAAM,EAAE,EAAb,CAAa,CAAC;IAC7C,CAAC;IAED;;OAEG;IACH,sCAAQ,GAAR;QAAA,iBAyBC;QAxBC,yBAAyB;QACzB,IAAM,iBAAiB,GAAG,IAAI,CAAC,0BAA0B,EAAE,CAAC;QAC5D,EAAE,CAAC,CAAC,iBAAiB,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;YAC1D,EAAE,CAAC,CAAC,iBAAiB,KAAK,iCAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gBACzD,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,qBAAqB,CAAC,CAC9D,CAAC;YACJ,CAAC;YAED,4CAA4C;YAC5C,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAgC,CAAC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,GAAG;YACP,KAAK,GAAG,GAAG,CAAC;YACZ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,0BAA0B,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;QACzE,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;YACvD,CAAC;YACD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACjC,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;;;OAQG;IACK,iDAAmB,GAA3B,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAoBC;QAhBC,MAAM,CAAC,IAAI,CAAC,iBAAiB,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC,UAAA,OAAO;YACtD,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;gBACZ,IAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBACvB,EAAE,CAAC,CAAC,GAAG,GAAG,YAAY,CAAC,YAAY,CAAC,GAAG,+BAAuB,CAAC,CAAC,CAAC;oBAC/D,MAAM,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;gBAC/C,CAAC;YACH,CAAC;YAAC,IAAI,CAAC,CAAC;gBACN,+DAA+D;gBAC/D,wBAAwB;gBACxB,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;oBACrD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;gBACjC,CAAC,CAAC,CAAC;YACL,CAAC;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACK,+CAAiB,GAAzB,UAA0B,YAAoB;QAC5C,qCAAqC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE,CAAC,IAAI,CAAC,UAAA,SAAS;YAC7C,EAAE,CAAC,CAAC,gCAAmB,CAAC,SAAS,CAAC,KAAK,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC;gBAChE,MAAM,CAAC,KAAK,CAAC;YACf,CAAC;YACD,MAAM,CAAC,IAAI,CAAC;QACd,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,yCAAW,GAAnB,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAgDC;QA5CC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAAoB,CAAC;QACzB,IAAI,YAA8B,CAAC;QACnC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,oBAAoB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAC1D,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,KAAI,CAAC,kBAAkB,EACvB,YAAY,CAAC,UAAU,CAAC,EACxB,YAAY,CAAC,YAAY,CAAC,EAC1B,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;gBACrD,MAAM,GAAG,CAAC;YACZ,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,KAAK;YACT,YAAY,GAAG,KAAK,CAAC;YACrB,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY;gBACtB,UAAU,EAAE,YAAY,CAAC,YAAY,CAAC;aACvC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC;QACtB,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,yCAAW,GAAnB,UAAoB,KAAgC;QAApD,iBAsCC;QArCC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAA8B,CAAC;QACnC,IAAI,YAAoB,CAAC;QACzB,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,oBAAoB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAC1D,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,QAAQ,CAC5B,KAAI,CAAC,kBAAkB,EACvB,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,eAAe;YACnB,YAAY,GAAG,eAAe,CAAC;YAC/B,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY,CAAC,OAAO,CAAC;gBAC/B,UAAU,EAAE,YAAY,CAAC,SAAS,CAAC;aACpC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;QAC/B,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;OAMG;IACH,yCAAW,GAAX,UAAY,KAAa;QAAzB,iBAuBC;QAtBC,MAAM,CAAC,IAAI,CAAC,kBAAkB;aAC3B,WAAW,CAAC,KAAK,CAAC;aAClB,IAAI,CAAC,UAAA,OAAO;YACX,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,OAAO,CAAC,aAAa,CAAC,EACtB,OAAO,CAAC,UAAU,CAAC,EACnB,OAAO,CAAC,YAAY,CAAC,CACtB,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,EAAE;iBAC7B,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC;gBACpD,CAAC;YACH,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,EAAE,CAAC;gBACpC,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,gEAAgE;IAChE,EAAE;IAEF,+CAAiB,GAAjB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,kDAAoB,GAApB,UACE,YAAY,EACZ,cAAc;QAEd,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,8CAAgB,GAAhB,UAAiB,YAAY;QAC3B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,+CAAiB,GAAjB,UAAkB,YAAY;QAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;OAMG;IACH,uCAAS,GAAT,UAAU,cAAc,EAAE,QAAQ,EAAE,YAAY;QAC9C,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;;;;OASG;IACH,4CAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,6DAA6D;IAC7D,EAAE;IAEF;;;OAGG;IACH,yDAA2B,GAA3B,UAA4B,QAAQ;QAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAChE,CAAC;IAED,EAAE;IACF,2EAA2E;IAC3E,qDAAqD;IACrD,EAAE;IAEF;;;OAGG;IACH,oCAAM,GAAN;QACE,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC;YACjB,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;YACvC,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;SACxC,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,wDAA0B,GAA1B;QACE,MAAM,CAAE,YAAoB,CAAC,UAAU,CAAC;IAC1C,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED;;;OAGG;IACH,yCAAW,GAAX;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IACH,0BAAC;AAAD,CA1VA,AA0VC,IAAA","file":"controller-interface.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { ErrorFactory } from '@firebase/util';\nimport Errors from '../models/errors';\nimport TokenDetailsModel from '../models/token-details-model';\nimport VapidDetailsModel from '../models/vapid-details-model';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport IIDModel from '../models/iid-model';\nimport arrayBufferToBase64 from '../helpers/array-buffer-to-base64';\n\nconst SENDER_ID_OPTION_NAME = 'messagingSenderId';\n// Database cache should be invalidated once a week.\nexport const TOKEN_EXPIRATION_MILLIS = 7 * 24 * 60 * 60 * 1000; // 7 days\n\nexport default class ControllerInterface {\n public app;\n public INTERNAL;\n protected errorFactory_;\n private messagingSenderId_: string;\n private tokenDetailsModel_: TokenDetailsModel;\n private vapidDetailsModel_: VapidDetailsModel;\n private iidModel_: IIDModel;\n\n /**\n * An interface of the Messaging Service API\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n this.errorFactory_ = new ErrorFactory('messaging', 'Messaging', Errors.map);\n\n if (\n !app.options[SENDER_ID_OPTION_NAME] ||\n typeof app.options[SENDER_ID_OPTION_NAME] !== 'string'\n ) {\n throw this.errorFactory_.create(Errors.codes.BAD_SENDER_ID);\n }\n\n this.messagingSenderId_ = app.options[SENDER_ID_OPTION_NAME];\n\n this.tokenDetailsModel_ = new TokenDetailsModel();\n this.vapidDetailsModel_ = new VapidDetailsModel();\n this.iidModel_ = new IIDModel();\n\n this.app = app;\n this.INTERNAL = {};\n this.INTERNAL.delete = () => this.delete();\n }\n\n /**\n * @export\n */\n getToken(): Promise<string | null> {\n // Check with permissions\n const currentPermission = this.getNotificationPermission_();\n if (currentPermission !== NOTIFICATION_PERMISSION.granted) {\n if (currentPermission === NOTIFICATION_PERMISSION.denied) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.NOTIFICATIONS_BLOCKED)\n );\n }\n\n // We must wait for permission to be granted\n return Promise.resolve(null);\n }\n let swReg: ServiceWorkerRegistration;\n return this.getSWRegistration_()\n .then(reg => {\n swReg = reg;\n return this.tokenDetailsModel_.getTokenDetailsFromSWScope(swReg.scope);\n })\n .then(tokenDetails => {\n if (tokenDetails) {\n return this.manageExistingToken(tokenDetails, swReg);\n }\n return this.getNewToken(swReg);\n });\n }\n\n /**\n * manageExistingToken is triggered if there's an existing FCM token in the\n * database and it can take 3 different actions:\n * 1) Retrieve the existing FCM token from the database.\n * 2) If VAPID details have changed: Delete the existing token and create a\n * new one with the new VAPID key.\n * 3) If the database cache is invalidated: Send a request to FCM to update\n * the token, and to check if the token is still valid on FCM-side.\n */\n private manageExistingToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n return this.isTokenStillValid(tokenDetails).then(isValid => {\n if (isValid) {\n const now = Date.now();\n if (now < tokenDetails['createTime'] + TOKEN_EXPIRATION_MILLIS) {\n return tokenDetails['fcmToken'];\n } else {\n return this.updateToken(tokenDetails, swReg);\n }\n } else {\n // If the VAPID details are updated, delete the existing token,\n // and create a new one.\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n return this.getNewToken(swReg);\n });\n }\n });\n }\n\n /*\n * Checks if the tokenDetails match the details provided in the clients.\n */\n private isTokenStillValid(tokenDetails: Object): Promise<Boolean> {\n // TODO Validate rest of the details.\n return this.getPublicVapidKey_().then(publicKey => {\n if (arrayBufferToBase64(publicKey) !== tokenDetails['vapidKey']) {\n return false;\n }\n return true;\n });\n }\n\n private updateToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n let publicVapidKey: Uint8Array;\n let updatedToken: string;\n let subscription: PushSubscription;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription_(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.updateToken(\n this.messagingSenderId_,\n tokenDetails['fcmToken'],\n tokenDetails['fcmPushSet'],\n subscription,\n publicVapidKey\n );\n })\n .catch(err => {\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n throw err;\n });\n })\n .then(token => {\n updatedToken = token;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: updatedToken,\n fcmPushSet: tokenDetails['fcmPushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return updatedToken;\n });\n }\n\n private getNewToken(swReg: ServiceWorkerRegistration): Promise<string> {\n let publicVapidKey: Uint8Array;\n let subscription: PushSubscription;\n let tokenDetails: Object;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription_(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.getToken(\n this.messagingSenderId_,\n subscription,\n publicVapidKey\n );\n })\n .then(iidTokenDetails => {\n tokenDetails = iidTokenDetails;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: tokenDetails['token'],\n fcmPushSet: tokenDetails['pushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return tokenDetails['token'];\n });\n }\n\n /**\n * This method deletes tokens that the token manager looks after,\n * unsubscribes the token from FCM and then unregisters the push\n * subscription if it exists. It returns a promise that indicates\n * whether or not the unsubscribe request was processed successfully.\n * @export\n */\n deleteToken(token: string): Promise<Boolean> {\n return this.tokenDetailsModel_\n .deleteToken(token)\n .then(details => {\n return this.iidModel_.deleteToken(\n details['fcmSenderId'],\n details['fcmToken'],\n details['fcmPushSet']\n );\n })\n .then(() => {\n return this.getSWRegistration_()\n .then(registration => {\n if (registration) {\n return registration.pushManager.getSubscription();\n }\n })\n .then(subscription => {\n if (subscription) {\n return subscription.unsubscribe();\n }\n });\n });\n }\n\n getSWRegistration_(): Promise<ServiceWorkerRegistration> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n getPublicVapidKey_(): Promise<Uint8Array> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n //\n // The following methods should only be available in the window.\n //\n\n requestPermission() {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n getPushSubscription_(\n registration,\n publicVapidKey\n ): Promise<PushSubscription> {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!ServiceWorkerRegistration} registration\n */\n useServiceWorker(registration) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!string} b64PublicKey\n */\n usePublicVapidKey(b64PublicKey) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver\n * @param {function(!Error)=} optError\n * @param {function()=} optCompleted\n * @return {!function()}\n */\n onMessage(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n //\n // The following methods are used by the service worker only.\n //\n\n /**\n * @export\n * @param {function(Object)} callback\n */\n setBackgroundMessageHandler(callback) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_SW);\n }\n\n //\n // The following methods are used by the service themselves and not exposed\n // publicly or not expected to be used by developers.\n //\n\n /**\n * This method is required to adhere to the Firebase interface.\n * It closes any currently open indexdb database connections.\n */\n delete() {\n return Promise.all([\n this.tokenDetailsModel_.closeDatabase(),\n this.vapidDetailsModel_.closeDatabase()\n ]);\n }\n\n /**\n * Returns the current Notification Permission state.\n * @private\n * @return {string} The currenct permission state.\n */\n getNotificationPermission_() {\n return (Notification as any).permission;\n }\n\n getTokenDetailsModel(): TokenDetailsModel {\n return this.tokenDetailsModel_;\n }\n\n getVapidDetailsModel(): VapidDetailsModel {\n return this.vapidDetailsModel_;\n }\n\n /**\n * @protected\n * @returns {IIDModel}\n */\n getIIDModel() {\n return this.iidModel_;\n }\n}\n"]} | ||
| {"version":3,"sources":["../src/controllers/controller-interface.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;AAEb,uCAA8C;AAC9C,2CAAsC;AACtC,qEAA8D;AAC9D,qEAA8D;AAC9D,6EAAwE;AACxE,iDAA2C;AAC3C,4EAAoE;AAEpE,IAAM,qBAAqB,GAAG,mBAAmB,CAAC;AAClD,oDAAoD;AACvC,QAAA,uBAAuB,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,IAAI,CAAC,CAAC,SAAS;AAEzE;IASE;;;OAGG;IACH,6BAAY,GAAG;QAAf,iBAmBC;QAlBC,IAAI,CAAC,aAAa,GAAG,IAAI,mBAAY,CAAC,WAAW,EAAE,WAAW,EAAE,gBAAM,CAAC,GAAG,CAAC,CAAC;QAE5E,EAAE,CAAC,CACD,CAAC,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC;YACnC,OAAO,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,KAAK,QAChD,CAAC,CAAC,CAAC;YACD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,aAAa,CAAC,CAAC;QAC9D,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,CAAC;QAE7D,IAAI,CAAC,kBAAkB,GAAG,IAAI,6BAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,kBAAkB,GAAG,IAAI,6BAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,SAAS,GAAG,IAAI,mBAAQ,EAAE,CAAC;QAEhC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,QAAQ,GAAG,EAAE,CAAC;QACnB,IAAI,CAAC,QAAQ,CAAC,MAAM,GAAG,cAAM,OAAA,KAAI,CAAC,MAAM,EAAE,EAAb,CAAa,CAAC;IAC7C,CAAC;IAED;;OAEG;IACH,sCAAQ,GAAR;QAAA,iBAyBC;QAxBC,yBAAyB;QACzB,IAAM,iBAAiB,GAAG,IAAI,CAAC,0BAA0B,EAAE,CAAC;QAC5D,EAAE,CAAC,CAAC,iBAAiB,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;YAC1D,EAAE,CAAC,CAAC,iBAAiB,KAAK,iCAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gBACzD,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,qBAAqB,CAAC,CAC9D,CAAC;YACJ,CAAC;YAED,4CAA4C;YAC5C,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAgC,CAAC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,GAAG;YACP,KAAK,GAAG,GAAG,CAAC;YACZ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,0BAA0B,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;QACzE,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;YACvD,CAAC;YACD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACjC,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;;;OAQG;IACK,iDAAmB,GAA3B,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAoBC;QAhBC,MAAM,CAAC,IAAI,CAAC,iBAAiB,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC,UAAA,OAAO;YACtD,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;gBACZ,IAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBACvB,EAAE,CAAC,CAAC,GAAG,GAAG,YAAY,CAAC,YAAY,CAAC,GAAG,+BAAuB,CAAC,CAAC,CAAC;oBAC/D,MAAM,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;gBAC/C,CAAC;YACH,CAAC;YAAC,IAAI,CAAC,CAAC;gBACN,+DAA+D;gBAC/D,wBAAwB;gBACxB,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;oBACrD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;gBACjC,CAAC,CAAC,CAAC;YACL,CAAC;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACK,+CAAiB,GAAzB,UAA0B,YAAoB;QAC5C,qCAAqC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE,CAAC,IAAI,CAAC,UAAA,SAAS;YAC7C,EAAE,CAAC,CAAC,gCAAmB,CAAC,SAAS,CAAC,KAAK,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC;gBAChE,MAAM,CAAC,KAAK,CAAC;YACf,CAAC;YACD,MAAM,CAAC,IAAI,CAAC;QACd,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,yCAAW,GAAnB,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAgDC;QA5CC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAAoB,CAAC;QACzB,IAAI,YAA8B,CAAC;QACnC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QACzD,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,KAAI,CAAC,kBAAkB,EACvB,YAAY,CAAC,UAAU,CAAC,EACxB,YAAY,CAAC,YAAY,CAAC,EAC1B,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;gBACrD,MAAM,GAAG,CAAC;YACZ,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,KAAK;YACT,YAAY,GAAG,KAAK,CAAC;YACrB,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY;gBACtB,UAAU,EAAE,YAAY,CAAC,YAAY,CAAC;aACvC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC;QACtB,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,yCAAW,GAAnB,UAAoB,KAAgC;QAApD,iBAsCC;QArCC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAA8B,CAAC;QACnC,IAAI,YAAoB,CAAC;QACzB,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QACzD,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,QAAQ,CAC5B,KAAI,CAAC,kBAAkB,EACvB,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,eAAe;YACnB,YAAY,GAAG,eAAe,CAAC;YAC/B,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY,CAAC,OAAO,CAAC;gBAC/B,UAAU,EAAE,YAAY,CAAC,SAAS,CAAC;aACpC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;QAC/B,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;OAMG;IACH,yCAAW,GAAX,UAAY,KAAa;QAAzB,iBAuBC;QAtBC,MAAM,CAAC,IAAI,CAAC,kBAAkB;aAC3B,WAAW,CAAC,KAAK,CAAC;aAClB,IAAI,CAAC,UAAA,OAAO;YACX,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,OAAO,CAAC,aAAa,CAAC,EACtB,OAAO,CAAC,UAAU,CAAC,EACnB,OAAO,CAAC,YAAY,CAAC,CACtB,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,EAAE;iBAC7B,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC;gBACpD,CAAC;YACH,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,EAAE,CAAC;gBACpC,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,gEAAgE;IAChE,EAAE;IAEF,+CAAiB,GAAjB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;OAEG;IACH,iDAAmB,GAAnB,UACE,cAAyC,EACzC,cAA0B;QAE1B,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC,IAAI,CAAC,UAAA,YAAY;YACnE,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC;YAED,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,SAAS,CAAC;gBAC1C,eAAe,EAAE,IAAI;gBACrB,oBAAoB,EAAE,cAAc;aACrC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,8CAAgB,GAAhB,UAAiB,YAAY;QAC3B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,+CAAiB,GAAjB,UAAkB,YAAY;QAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;OAMG;IACH,uCAAS,GAAT,UAAU,cAAc,EAAE,QAAQ,EAAE,YAAY;QAC9C,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;;;;OASG;IACH,4CAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,6DAA6D;IAC7D,EAAE;IAEF;;;OAGG;IACH,yDAA2B,GAA3B,UAA4B,QAAQ;QAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAChE,CAAC;IAED,EAAE;IACF,2EAA2E;IAC3E,qDAAqD;IACrD,EAAE;IAEF;;;OAGG;IACH,oCAAM,GAAN;QACE,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC;YACjB,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;YACvC,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;SACxC,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,wDAA0B,GAA1B;QACE,MAAM,CAAE,YAAoB,CAAC,UAAU,CAAC;IAC1C,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED;;;OAGG;IACH,yCAAW,GAAX;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IACH,0BAAC;AAAD,CAtWA,AAsWC,IAAA","file":"controller-interface.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { ErrorFactory } from '@firebase/util';\nimport Errors from '../models/errors';\nimport TokenDetailsModel from '../models/token-details-model';\nimport VapidDetailsModel from '../models/vapid-details-model';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport IIDModel from '../models/iid-model';\nimport arrayBufferToBase64 from '../helpers/array-buffer-to-base64';\n\nconst SENDER_ID_OPTION_NAME = 'messagingSenderId';\n// Database cache should be invalidated once a week.\nexport const TOKEN_EXPIRATION_MILLIS = 7 * 24 * 60 * 60 * 1000; // 7 days\n\nexport default class ControllerInterface {\n public app;\n public INTERNAL;\n protected errorFactory_;\n private messagingSenderId_: string;\n private tokenDetailsModel_: TokenDetailsModel;\n private vapidDetailsModel_: VapidDetailsModel;\n private iidModel_: IIDModel;\n\n /**\n * An interface of the Messaging Service API\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n this.errorFactory_ = new ErrorFactory('messaging', 'Messaging', Errors.map);\n\n if (\n !app.options[SENDER_ID_OPTION_NAME] ||\n typeof app.options[SENDER_ID_OPTION_NAME] !== 'string'\n ) {\n throw this.errorFactory_.create(Errors.codes.BAD_SENDER_ID);\n }\n\n this.messagingSenderId_ = app.options[SENDER_ID_OPTION_NAME];\n\n this.tokenDetailsModel_ = new TokenDetailsModel();\n this.vapidDetailsModel_ = new VapidDetailsModel();\n this.iidModel_ = new IIDModel();\n\n this.app = app;\n this.INTERNAL = {};\n this.INTERNAL.delete = () => this.delete();\n }\n\n /**\n * @export\n */\n getToken(): Promise<string | null> {\n // Check with permissions\n const currentPermission = this.getNotificationPermission_();\n if (currentPermission !== NOTIFICATION_PERMISSION.granted) {\n if (currentPermission === NOTIFICATION_PERMISSION.denied) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.NOTIFICATIONS_BLOCKED)\n );\n }\n\n // We must wait for permission to be granted\n return Promise.resolve(null);\n }\n let swReg: ServiceWorkerRegistration;\n return this.getSWRegistration_()\n .then(reg => {\n swReg = reg;\n return this.tokenDetailsModel_.getTokenDetailsFromSWScope(swReg.scope);\n })\n .then(tokenDetails => {\n if (tokenDetails) {\n return this.manageExistingToken(tokenDetails, swReg);\n }\n return this.getNewToken(swReg);\n });\n }\n\n /**\n * manageExistingToken is triggered if there's an existing FCM token in the\n * database and it can take 3 different actions:\n * 1) Retrieve the existing FCM token from the database.\n * 2) If VAPID details have changed: Delete the existing token and create a\n * new one with the new VAPID key.\n * 3) If the database cache is invalidated: Send a request to FCM to update\n * the token, and to check if the token is still valid on FCM-side.\n */\n private manageExistingToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n return this.isTokenStillValid(tokenDetails).then(isValid => {\n if (isValid) {\n const now = Date.now();\n if (now < tokenDetails['createTime'] + TOKEN_EXPIRATION_MILLIS) {\n return tokenDetails['fcmToken'];\n } else {\n return this.updateToken(tokenDetails, swReg);\n }\n } else {\n // If the VAPID details are updated, delete the existing token,\n // and create a new one.\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n return this.getNewToken(swReg);\n });\n }\n });\n }\n\n /*\n * Checks if the tokenDetails match the details provided in the clients.\n */\n private isTokenStillValid(tokenDetails: Object): Promise<Boolean> {\n // TODO Validate rest of the details.\n return this.getPublicVapidKey_().then(publicKey => {\n if (arrayBufferToBase64(publicKey) !== tokenDetails['vapidKey']) {\n return false;\n }\n return true;\n });\n }\n\n private updateToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n let publicVapidKey: Uint8Array;\n let updatedToken: string;\n let subscription: PushSubscription;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.updateToken(\n this.messagingSenderId_,\n tokenDetails['fcmToken'],\n tokenDetails['fcmPushSet'],\n subscription,\n publicVapidKey\n );\n })\n .catch(err => {\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n throw err;\n });\n })\n .then(token => {\n updatedToken = token;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: updatedToken,\n fcmPushSet: tokenDetails['fcmPushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return updatedToken;\n });\n }\n\n private getNewToken(swReg: ServiceWorkerRegistration): Promise<string> {\n let publicVapidKey: Uint8Array;\n let subscription: PushSubscription;\n let tokenDetails: Object;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.getToken(\n this.messagingSenderId_,\n subscription,\n publicVapidKey\n );\n })\n .then(iidTokenDetails => {\n tokenDetails = iidTokenDetails;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: tokenDetails['token'],\n fcmPushSet: tokenDetails['pushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return tokenDetails['token'];\n });\n }\n\n /**\n * This method deletes tokens that the token manager looks after,\n * unsubscribes the token from FCM and then unregisters the push\n * subscription if it exists. It returns a promise that indicates\n * whether or not the unsubscribe request was processed successfully.\n * @export\n */\n deleteToken(token: string): Promise<Boolean> {\n return this.tokenDetailsModel_\n .deleteToken(token)\n .then(details => {\n return this.iidModel_.deleteToken(\n details['fcmSenderId'],\n details['fcmToken'],\n details['fcmPushSet']\n );\n })\n .then(() => {\n return this.getSWRegistration_()\n .then(registration => {\n if (registration) {\n return registration.pushManager.getSubscription();\n }\n })\n .then(subscription => {\n if (subscription) {\n return subscription.unsubscribe();\n }\n });\n });\n }\n\n getSWRegistration_(): Promise<ServiceWorkerRegistration> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n getPublicVapidKey_(): Promise<Uint8Array> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n //\n // The following methods should only be available in the window.\n //\n\n requestPermission() {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * Gets a PushSubscription for the current user.\n */\n getPushSubscription(\n swRegistration: ServiceWorkerRegistration,\n publicVapidKey: Uint8Array\n ): Promise<PushSubscription> {\n return swRegistration.pushManager.getSubscription().then(subscription => {\n if (subscription) {\n return subscription;\n }\n\n return swRegistration.pushManager.subscribe({\n userVisibleOnly: true,\n applicationServerKey: publicVapidKey\n });\n });\n }\n\n /**\n * @export\n * @param {!ServiceWorkerRegistration} registration\n */\n useServiceWorker(registration) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!string} b64PublicKey\n */\n usePublicVapidKey(b64PublicKey) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver\n * @param {function(!Error)=} optError\n * @param {function()=} optCompleted\n * @return {!function()}\n */\n onMessage(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n //\n // The following methods are used by the service worker only.\n //\n\n /**\n * @export\n * @param {function(Object)} callback\n */\n setBackgroundMessageHandler(callback) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_SW);\n }\n\n //\n // The following methods are used by the service themselves and not exposed\n // publicly or not expected to be used by developers.\n //\n\n /**\n * This method is required to adhere to the Firebase interface.\n * It closes any currently open indexdb database connections.\n */\n delete() {\n return Promise.all([\n this.tokenDetailsModel_.closeDatabase(),\n this.vapidDetailsModel_.closeDatabase()\n ]);\n }\n\n /**\n * Returns the current Notification Permission state.\n * @private\n * @return {string} The currenct permission state.\n */\n getNotificationPermission_() {\n return (Notification as any).permission;\n }\n\n getTokenDetailsModel(): TokenDetailsModel {\n return this.tokenDetailsModel_;\n }\n\n getVapidDetailsModel(): VapidDetailsModel {\n return this.vapidDetailsModel_;\n }\n\n /**\n * @protected\n * @returns {IIDModel}\n */\n getIIDModel() {\n return this.iidModel_;\n }\n}\n"]} |
@@ -102,9 +102,2 @@ import { FirebaseMessaging } from '@firebase/messaging-types'; | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| * @private | ||
| * @param {ServiceWorkerRegistration} registration | ||
| * @return {Promise<PushSubscription>} | ||
| */ | ||
| getPushSubscription_(swRegistration: any, publicVapidKey: any): any; | ||
| /** | ||
| * This method will set up a message listener to handle | ||
@@ -111,0 +104,0 @@ * events from the service worker that should trigger |
@@ -322,22 +322,2 @@ /** | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| * @private | ||
| * @param {ServiceWorkerRegistration} registration | ||
| * @return {Promise<PushSubscription>} | ||
| */ | ||
| WindowController.prototype.getPushSubscription_ = function (swRegistration, publicVapidKey) { | ||
| // Check for existing subscription first | ||
| var subscription; | ||
| var fcmTokenDetails; | ||
| return swRegistration.pushManager.getSubscription().then(function (subscription) { | ||
| if (subscription) { | ||
| return subscription; | ||
| } | ||
| return swRegistration.pushManager.subscribe({ | ||
| userVisibleOnly: true, | ||
| applicationServerKey: publicVapidKey | ||
| }); | ||
| }); | ||
| }; | ||
| /** | ||
| * This method will set up a message listener to handle | ||
@@ -344,0 +324,0 @@ * events from the service worker that should trigger |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/controllers/window-controller.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;;AAGb,+DAAyD;AACzD,2CAAsC;AACtC,qEAA8D;AAC9D,mDAA6C;AAC7C,6EAAwE;AACxE,qDAA+C;AAC/C,4EAAoE;AACpE,uCAAiD;AAIjD;IAA8C,4CAAmB;IAc/D;;;OAGG;IACH,0BAAY,GAAG;QAAf,YACE,kBAAM,GAAG,CAAC,SAsCX;QApDO,sBAAgB,GAAG,IAAI,CAAC;QACxB,gBAAU,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAC3C,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QACK,2BAAqB,GAAG,IAAI,CAAC;QAC7B,qBAAe,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAChD,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QASD;;;WAGG;QACH,KAAI,CAAC,kBAAkB,CAAC;QAExB;;;WAGG;QACH,KAAI,CAAC,qBAAqB,CAAC;QAE3B;;;WAGG;QACH,KAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B;;;WAGG;QACH,KAAI,CAAC,UAAU,GAAG,sBAAe,CAAC,UAAA,QAAQ;YACxC,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QAEH;;;WAGG;QACH,KAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC;QAClC,KAAI,CAAC,eAAe,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAC7C,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QAEH,KAAI,CAAC,uBAAuB,EAAE,CAAC;;IACjC,CAAC;IAED;;;;;;;;OAQG;IACH,mCAAQ,GAAR;QAAA,iBAWC;QAVC,8CAA8C;QAC9C,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;YACzB,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAC5D,CAAC;QACJ,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC,IAAI,CAAC;YAChC,MAAM,CAAC,iBAAM,QAAQ,YAAE,CAAC;QAC1B,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,yCAAc,GAAd;QAAA,iBAqCC;QApCC,EAAE,CAAC,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAC,CAAC;YAC/B,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;QACpC,CAAC;QAED,IAAM,WAAW,GAAsB,QAAQ,CAAC,aAAa,CAC3D,sBAAsB,CACvB,CAAC;QACF,EAAE,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;YACjB,IAAI,CAAC,qBAAqB,GAAG,OAAO,CAAC,OAAO,EAAE,CAAC;QACjD,CAAC;QAAC,IAAI,CAAC,CAAC;YACN,IAAI,CAAC,qBAAqB,GAAG,KAAK,CAAC,WAAW,CAAC,IAAI,CAAC;iBACjD,IAAI,CAAC,UAAA,QAAQ;gBACZ,MAAM,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;YACzB,CAAC,CAAC;iBACD,KAAK,CAAC;gBACL,gDAAgD;gBAChD,wEAAwE;YAC1E,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,eAAe;gBACnB,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,CAAC,CAAC;oBACrB,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,CAAC,CAAC,CAAC;oBACtC,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,KAAK,cAAc,CAAC,CAAC,CAAC;oBACxD,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,uBAAuB,CACrC,CAAC;gBACJ,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;IACpC,CAAC;IAED;;;;;OAKG;IACG,4CAAiB,GAAvB;;;;gBACE,EAAE,CAAC,CAAE,YAAoB,CAAC,UAAU,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;oBACzE,MAAM,gBAAC;gBACT,CAAC;gBAED,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;wBACjC,IAAM,sBAAsB,GAAG,UAAA,MAAM;4BACnC,EAAE,CAAC,CAAC,MAAM,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;gCAC/C,MAAM,CAAC,OAAO,EAAE,CAAC;4BACnB,CAAC;4BAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,KAAK,iCAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gCACrD,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;4BAAC,IAAI,CAAC,CAAC;gCACN,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;wBACH,CAAC,CAAC;wBAEF,wDAAwD;wBACxD,sDAAsD;wBACtD,uDAAuD;wBACvD,IAAM,iBAAiB,GAAG,YAAY,CAAC,iBAAiB,CACtD,sBAAsB,CACvB,CAAC;wBACF,EAAE,CAAC,CAAC,iBAAiB,CAAC,CAAC,CAAC;4BACtB,qDAAqD;4BACrD,iBAAiB,CAAC,IAAI,CAAC,sBAAsB,CAAC,CAAC;wBACjD,CAAC;oBACH,CAAC,CAAC,EAAC;;;KACJ;IAED;;;;;;OAMG;IACH,2CAAgB,GAAhB,UAAiB,YAAY;QAC3B,EAAE,CAAC,CAAC,CAAC,CAAC,YAAY,YAAY,yBAAyB,CAAC,CAAC,CAAC,CAAC;YACzD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,kBAAkB,KAAK,WAAW,CAAC,CAAC,CAAC;YACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,uBAAuB,CAAC,CAAC;QACxE,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;IACzC,CAAC;IAED;;;;;OAKG;IACH,4CAAiB,GAAjB,UAAkB,SAAS;QACzB,EAAE,CAAC,CAAC,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC;YAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,oBAAoB,KAAK,WAAW,CAAC,CAAC,CAAC;YACrD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,+BAA+B,CAC7C,CAAC;QACJ,CAAC;QAED,IAAM,SAAS,GAAG,gCAAmB,CAAC,SAAS,CAAC,CAAC;QAEjD,EAAE,CAAC,CAAC,SAAS,CAAC,MAAM,KAAK,EAAE,CAAC,CAAC,CAAC;YAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,4BAA4B,CAC1C,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,oBAAoB,GAAG,SAAS,CAAC;IACxC,CAAC;IAED;;;;;;;;;OASG;IACH,oCAAS,GAAT,UAAU,cAAc,EAAE,QAAS,EAAE,YAAa;QAChD,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACjE,CAAC;IAED;;;;;;;;;OASG;IACH,yCAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,CAAC,IAAI,CAAC,eAAe,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACtE,CAAC;IAED;;;;;;;;OAQG;IACH,yDAA8B,GAA9B,UAA+B,YAAY;QAA3C,iBAmCC;QAlCC,IAAM,aAAa,GACjB,YAAY,CAAC,UAAU,IAAI,YAAY,CAAC,OAAO,IAAI,YAAY,CAAC,MAAM,CAAC;QAEzE,MAAM,CAAC,IAAI,OAAO,CAA4B,UAAC,OAAO,EAAE,MAAM;YAC5D,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC;gBACnB,qDAAqD;gBACrD,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,CAAC;gBAC7D,MAAM,CAAC;YACT,CAAC;YACD,iEAAiE;YACjE,mEAAmE;YACnE,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACtB,MAAM,CAAC;YACT,CAAC;YAED,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACjE,MAAM,CAAC;YACT,CAAC;YAED,IAAI,mBAAmB,GAAG;gBACxB,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBAC/C,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACnE,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,6CAA6C;oBAC7C,MAAM,CAAC;gBACT,CAAC;gBACD,aAAa,CAAC,mBAAmB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;YACxE,CAAC,CAAC;YACF,aAAa,CAAC,gBAAgB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;OAKG;IACH,6CAAkB,GAAlB;QAAA,iBAiCC;QAhCC,EAAE,CAAC,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC,CAAC;YAC5B,MAAM,CAAC,IAAI,CAAC,8BAA8B,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC;QACtE,CAAC;QAED,kEAAkE;QAClE,wEAAwE;QACxE,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;QAE/B,MAAM,CAAC,SAAS,CAAC,aAAa;aAC3B,QAAQ,CAAC,oBAAS,CAAC,IAAI,EAAE;YACxB,KAAK,EAAE,oBAAS,CAAC,KAAK;SACvB,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,2BAA2B,EACxC;gBACE,mBAAmB,EAAE,GAAG,CAAC,OAAO;aACjC,CACF,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,MAAM,CAAC,KAAI,CAAC,8BAA8B,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC;gBAC5D,KAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;gBAEvC,oEAAoE;gBACpE,gEAAgE;gBAChE,UAAU;gBACV,YAAY,CAAC,MAAM,EAAE,CAAC;gBAEtB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;OAIG;IACH,6CAAkB,GAAlB;QACE,EAAE,CAAC,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC,CAAC;YAC9B,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC;QACpD,CAAC;QAED,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,qBAAU,CAAC,wBAAwB,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;OAKG;IACH,+CAAoB,GAApB,UAAqB,cAAc,EAAE,cAAc;QACjD,wCAAwC;QACxC,IAAI,YAAY,CAAC;QACjB,IAAI,eAAe,CAAC;QACpB,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC,IAAI,CAAC,UAAA,YAAY;YACnE,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC;YAED,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,SAAS,CAAC;gBAC1C,eAAe,EAAE,IAAI;gBACrB,oBAAoB,EAAE,cAAc;aACrC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,kDAAuB,GAAvB;QAAA,iBA8BC;QA7BC,EAAE,CAAC,CAAC,CAAC,CAAC,eAAe,IAAI,SAAS,CAAC,CAAC,CAAC,CAAC;YACpC,MAAM,CAAC;QACT,CAAC;QAED,SAAS,CAAC,aAAa,CAAC,gBAAgB,CACtC,SAAS,EACT,UAAA,KAAK;YACH,EAAE,CAAC,CAAC,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,6BAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBACrE,yBAAyB;gBACzB,MAAM,CAAC;YACT,CAAC;YAED,IAAM,iBAAiB,GAAG,KAAK,CAAC,IAAI,CAAC;YACrC,MAAM,CAAC,CAAC,iBAAiB,CAAC,6BAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBAChE,KAAK,6BAAiB,CAAC,YAAY,CAAC,iBAAiB,CAAC;gBACtD,KAAK,6BAAiB,CAAC,YAAY,CAAC,oBAAoB;oBACtD,IAAM,WAAW,GACf,iBAAiB,CAAC,6BAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;oBACnD,EAAE,CAAC,CAAC,KAAI,CAAC,gBAAgB,CAAC,CAAC,CAAC;wBAC1B,KAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;oBAC1C,CAAC;oBACD,KAAK,CAAC;gBACR;oBACE,QAAQ;oBACR,KAAK,CAAC;YACV,CAAC;QACH,CAAC,EACD,KAAK,CACN,CAAC;IACJ,CAAC;IAED;;;;OAIG;IACH,uCAAY,GAAZ;QACE,MAAM,CAAC,CACL,eAAe,IAAI,SAAS;YAC5B,aAAa,IAAI,MAAM;YACvB,cAAc,IAAI,MAAM;YACxB,OAAO,IAAI,MAAM;YACjB,yBAAyB,CAAC,SAAS,CAAC,cAAc,CAAC,kBAAkB,CAAC;YACtE,gBAAgB,CAAC,SAAS,CAAC,cAAc,CAAC,QAAQ,CAAC,CACpD,CAAC;IACJ,CAAC;IACH,uBAAC;AAAD,CAjaA,AAiaC,CAja6C,8BAAmB,GAiahE","file":"window-controller.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { FirebaseMessaging } from '@firebase/messaging-types';\nimport ControllerInterface from './controller-interface';\nimport Errors from '../models/errors';\nimport WorkerPageMessage from '../models/worker-page-message';\nimport DefaultSW from '../models/default-sw';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport FCMDetails from '../models/fcm-details';\nimport base64ToArrayBuffer from '../helpers/base64-to-array-buffer';\nimport { createSubscribe } from '@firebase/util';\n\ndeclare const firebase: any;\n\nexport default class WindowController extends ControllerInterface\n implements FirebaseMessaging {\n private registrationToUse_;\n private publicVapidKeyToUse_;\n private manifestCheckPromise_;\n private messageObserver_ = null;\n private onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n private tokenRefreshObserver_ = null;\n private onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n /**\n * A service that provides a MessagingService instance.\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n super(app);\n\n /**\n * @private\n * @type {ServiceWorkerRegistration}\n */\n this.registrationToUse_;\n\n /**\n * @private\n * @type {Promise}\n */\n this.manifestCheckPromise_;\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.messageObserver_ = null;\n\n /**\n * @private {!firebase.Subscribe} The subscribe function to the onMessage\n * observer.\n */\n this.onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.tokenRefreshObserver_ = null;\n this.onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n this.setupSWMessageListener_();\n }\n\n /**\n * This method returns an FCM token if it can be generated.\n * The return promise will reject if the browser doesn't support\n * FCM, if permission is denied for notifications or it's not\n * possible to generate a token.\n * @export\n * @return {Promise<string> | Promise<null>} Returns a promise the\n * resolves to an FCM token or null if permission isn't granted.\n */\n getToken() {\n // Check that the required API's are available\n if (!this.isSupported_()) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.UNSUPPORTED_BROWSER)\n );\n }\n\n return this.manifestCheck_().then(() => {\n return super.getToken();\n });\n }\n\n /**\n * The method checks that a manifest is defined and has the correct GCM\n * sender ID.\n * @private\n * @return {Promise} Returns a promise that resolves if the manifest matches\n * our required sender ID\n */\n manifestCheck_() {\n if (this.manifestCheckPromise_) {\n return this.manifestCheckPromise_;\n }\n\n const manifestTag = <HTMLAnchorElement>document.querySelector(\n 'link[rel=\"manifest\"]'\n );\n if (!manifestTag) {\n this.manifestCheckPromise_ = Promise.resolve();\n } else {\n this.manifestCheckPromise_ = fetch(manifestTag.href)\n .then(response => {\n return response.json();\n })\n .catch(() => {\n // If the download or parsing fails allow check.\n // We only want to error if we KNOW that the gcm_sender_id is incorrect.\n })\n .then(manifestContent => {\n if (!manifestContent) {\n return;\n }\n\n if (!manifestContent['gcm_sender_id']) {\n return;\n }\n\n if (manifestContent['gcm_sender_id'] !== '103953800507') {\n throw this.errorFactory_.create(\n Errors.codes.INCORRECT_GCM_SENDER_ID\n );\n }\n });\n }\n\n return this.manifestCheckPromise_;\n }\n\n /**\n * Request permission if it is not currently granted\n * @export\n * @returns {Promise} Resolves if the permission was granted, otherwise\n * rejects\n */\n async requestPermission() {\n if ((Notification as any).permission === NOTIFICATION_PERMISSION.granted) {\n return;\n }\n\n return new Promise((resolve, reject) => {\n const managePermissionResult = result => {\n if (result === NOTIFICATION_PERMISSION.granted) {\n return resolve();\n } else if (result === NOTIFICATION_PERMISSION.denied) {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_BLOCKED)\n );\n } else {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_DEFAULT)\n );\n }\n };\n\n // The Notification.requestPermission API was changed to\n // return a promise so now have to handle both in case\n // browsers stop support callbacks for promised version\n const permissionPromise = Notification.requestPermission(\n managePermissionResult\n );\n if (permissionPromise) {\n // Prefer the promise version as it's the future API.\n permissionPromise.then(managePermissionResult);\n }\n });\n }\n\n /**\n * This method allows a developer to override the default service worker and\n * instead use a custom service worker.\n * @export\n * @param {!ServiceWorkerRegistration} registration The service worker\n * registration that should be used to receive the push messages.\n */\n useServiceWorker(registration) {\n if (!(registration instanceof ServiceWorkerRegistration)) {\n throw this.errorFactory_.create(Errors.codes.SW_REGISTRATION_EXPECTED);\n }\n\n if (typeof this.registrationToUse_ !== 'undefined') {\n throw this.errorFactory_.create(Errors.codes.USE_SW_BEFORE_GET_TOKEN);\n }\n\n this.registrationToUse_ = registration;\n }\n\n /**\n * This method allows a developer to override the default vapid key\n * and instead use a custom VAPID public key.\n * @export\n * @param {!string} publicKey A URL safe base64 encoded string.\n */\n usePublicVapidKey(publicKey) {\n if (typeof publicKey !== 'string') {\n throw this.errorFactory_.create(Errors.codes.INVALID_PUBLIC_VAPID_KEY);\n }\n\n if (typeof this.publicVapidKeyToUse_ !== 'undefined') {\n throw this.errorFactory_.create(\n Errors.codes.USE_PUBLIC_KEY_BEFORE_GET_TOKEN\n );\n }\n\n const parsedKey = base64ToArrayBuffer(publicKey);\n\n if (parsedKey.length !== 65) {\n throw this.errorFactory_.create(\n Errors.codes.PUBLIC_KEY_DECRYPTION_FAILED\n );\n }\n\n this.publicVapidKeyToUse_ = parsedKey;\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver An observer object\n * or a function triggered on message.\n * @param {function(!Error)=} optError Optional A function triggered on\n * message error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onMessage(nextOrObserver, optError?, optCompleted?) {\n return this.onMessage_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n return this.onTokenRefresh_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * Given a registration, wait for the service worker it relates to\n * become activer\n * @private\n * @param {ServiceWorkerRegistration} registration Registration to wait\n * for service worker to become active\n * @return {Promise<!ServiceWorkerRegistration>} Wait for service worker\n * registration to become active\n */\n waitForRegistrationToActivate_(registration) {\n const serviceWorker =\n registration.installing || registration.waiting || registration.active;\n\n return new Promise<ServiceWorkerRegistration>((resolve, reject) => {\n if (!serviceWorker) {\n // This is a rare scenario but has occured in firefox\n reject(this.errorFactory_.create(Errors.codes.NO_SW_IN_REG));\n return;\n }\n // Because the Promise function is called on next tick there is a\n // small chance that the worker became active or redundant already.\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n return;\n }\n\n if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n return;\n }\n\n let stateChangeListener = () => {\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n } else if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n } else {\n // Return early and wait to next state change\n return;\n }\n serviceWorker.removeEventListener('statechange', stateChangeListener);\n };\n serviceWorker.addEventListener('statechange', stateChangeListener);\n });\n }\n\n /**\n * This will regiater the default service worker and return the registration\n * @private\n * @return {Promise<!ServiceWorkerRegistration>} The service worker\n * registration to be used for the push service.\n */\n getSWRegistration_() {\n if (this.registrationToUse_) {\n return this.waitForRegistrationToActivate_(this.registrationToUse_);\n }\n\n // Make the registration null so we know useServiceWorker will not\n // use a new service worker as registrationToUse_ is no longer undefined\n this.registrationToUse_ = null;\n\n return navigator.serviceWorker\n .register(DefaultSW.path, {\n scope: DefaultSW.scope\n })\n .catch(err => {\n throw this.errorFactory_.create(\n Errors.codes.FAILED_DEFAULT_REGISTRATION,\n {\n browserErrorMessage: err.message\n }\n );\n })\n .then(registration => {\n return this.waitForRegistrationToActivate_(registration).then(() => {\n this.registrationToUse_ = registration;\n\n // We update after activation due to an issue with Firefox v49 where\n // a race condition occassionally causes the service work to not\n // install\n registration.update();\n\n return registration;\n });\n });\n }\n\n /**\n * This will return the default VAPID key or the uint8array version of the public VAPID key\n * provided by the developer.\n * @private\n */\n getPublicVapidKey_(): Promise<Uint8Array> {\n if (this.publicVapidKeyToUse_) {\n return Promise.resolve(this.publicVapidKeyToUse_);\n }\n\n return Promise.resolve(FCMDetails.DEFAULT_PUBLIC_VAPID_KEY);\n }\n\n /**\n * Gets a PushSubscription for the current user.\n * @private\n * @param {ServiceWorkerRegistration} registration\n * @return {Promise<PushSubscription>}\n */\n getPushSubscription_(swRegistration, publicVapidKey) {\n // Check for existing subscription first\n let subscription;\n let fcmTokenDetails;\n return swRegistration.pushManager.getSubscription().then(subscription => {\n if (subscription) {\n return subscription;\n }\n\n return swRegistration.pushManager.subscribe({\n userVisibleOnly: true,\n applicationServerKey: publicVapidKey\n });\n });\n }\n\n /**\n * This method will set up a message listener to handle\n * events from the service worker that should trigger\n * events in the page.\n *\n * @private\n */\n setupSWMessageListener_() {\n if (!('serviceWorker' in navigator)) {\n return;\n }\n\n navigator.serviceWorker.addEventListener(\n 'message',\n event => {\n if (!event.data || !event.data[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n // Not a message from FCM\n return;\n }\n\n const workerPageMessage = event.data;\n switch (workerPageMessage[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n case WorkerPageMessage.TYPES_OF_MSG.PUSH_MSG_RECEIVED:\n case WorkerPageMessage.TYPES_OF_MSG.NOTIFICATION_CLICKED:\n const pushMessage =\n workerPageMessage[WorkerPageMessage.PARAMS.DATA];\n if (this.messageObserver_) {\n this.messageObserver_.next(pushMessage);\n }\n break;\n default:\n // Noop.\n break;\n }\n },\n false\n );\n }\n\n /**\n * Checks to see if the required API's are valid or not.\n * @private\n * @return {boolean} Returns true if the desired APIs are available.\n */\n isSupported_() {\n return (\n 'serviceWorker' in navigator &&\n 'PushManager' in window &&\n 'Notification' in window &&\n 'fetch' in window &&\n ServiceWorkerRegistration.prototype.hasOwnProperty('showNotification') &&\n PushSubscription.prototype.hasOwnProperty('getKey')\n );\n }\n}\n"]} | ||
| {"version":3,"sources":["../src/controllers/window-controller.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;;AAGb,+DAAyD;AACzD,2CAAsC;AACtC,qEAA8D;AAC9D,mDAA6C;AAC7C,6EAAwE;AACxE,qDAA+C;AAC/C,4EAAoE;AACpE,uCAAiD;AAIjD;IAA8C,4CAAmB;IAc/D;;;OAGG;IACH,0BAAY,GAAG;QAAf,YACE,kBAAM,GAAG,CAAC,SAsCX;QApDO,sBAAgB,GAAG,IAAI,CAAC;QACxB,gBAAU,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAC3C,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QACK,2BAAqB,GAAG,IAAI,CAAC;QAC7B,qBAAe,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAChD,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QASD;;;WAGG;QACH,KAAI,CAAC,kBAAkB,CAAC;QAExB;;;WAGG;QACH,KAAI,CAAC,qBAAqB,CAAC;QAE3B;;;WAGG;QACH,KAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B;;;WAGG;QACH,KAAI,CAAC,UAAU,GAAG,sBAAe,CAAC,UAAA,QAAQ;YACxC,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QAEH;;;WAGG;QACH,KAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC;QAClC,KAAI,CAAC,eAAe,GAAG,sBAAe,CAAC,UAAA,QAAQ;YAC7C,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QAEH,KAAI,CAAC,uBAAuB,EAAE,CAAC;;IACjC,CAAC;IAED;;;;;;;;OAQG;IACH,mCAAQ,GAAR;QAAA,iBAWC;QAVC,8CAA8C;QAC9C,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;YACzB,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAC5D,CAAC;QACJ,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC,IAAI,CAAC;YAChC,MAAM,CAAC,iBAAM,QAAQ,YAAE,CAAC;QAC1B,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,yCAAc,GAAd;QAAA,iBAqCC;QApCC,EAAE,CAAC,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAC,CAAC;YAC/B,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;QACpC,CAAC;QAED,IAAM,WAAW,GAAsB,QAAQ,CAAC,aAAa,CAC3D,sBAAsB,CACvB,CAAC;QACF,EAAE,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;YACjB,IAAI,CAAC,qBAAqB,GAAG,OAAO,CAAC,OAAO,EAAE,CAAC;QACjD,CAAC;QAAC,IAAI,CAAC,CAAC;YACN,IAAI,CAAC,qBAAqB,GAAG,KAAK,CAAC,WAAW,CAAC,IAAI,CAAC;iBACjD,IAAI,CAAC,UAAA,QAAQ;gBACZ,MAAM,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;YACzB,CAAC,CAAC;iBACD,KAAK,CAAC;gBACL,gDAAgD;gBAChD,wEAAwE;YAC1E,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,eAAe;gBACnB,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,CAAC,CAAC;oBACrB,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,CAAC,CAAC,CAAC;oBACtC,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,KAAK,cAAc,CAAC,CAAC,CAAC;oBACxD,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,uBAAuB,CACrC,CAAC;gBACJ,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;IACpC,CAAC;IAED;;;;;OAKG;IACG,4CAAiB,GAAvB;;;;gBACE,EAAE,CAAC,CAAE,YAAoB,CAAC,UAAU,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;oBACzE,MAAM,gBAAC;gBACT,CAAC;gBAED,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;wBACjC,IAAM,sBAAsB,GAAG,UAAA,MAAM;4BACnC,EAAE,CAAC,CAAC,MAAM,KAAK,iCAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;gCAC/C,MAAM,CAAC,OAAO,EAAE,CAAC;4BACnB,CAAC;4BAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,KAAK,iCAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gCACrD,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;4BAAC,IAAI,CAAC,CAAC;gCACN,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;wBACH,CAAC,CAAC;wBAEF,wDAAwD;wBACxD,sDAAsD;wBACtD,uDAAuD;wBACvD,IAAM,iBAAiB,GAAG,YAAY,CAAC,iBAAiB,CACtD,sBAAsB,CACvB,CAAC;wBACF,EAAE,CAAC,CAAC,iBAAiB,CAAC,CAAC,CAAC;4BACtB,qDAAqD;4BACrD,iBAAiB,CAAC,IAAI,CAAC,sBAAsB,CAAC,CAAC;wBACjD,CAAC;oBACH,CAAC,CAAC,EAAC;;;KACJ;IAED;;;;;;OAMG;IACH,2CAAgB,GAAhB,UAAiB,YAAY;QAC3B,EAAE,CAAC,CAAC,CAAC,CAAC,YAAY,YAAY,yBAAyB,CAAC,CAAC,CAAC,CAAC;YACzD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,kBAAkB,KAAK,WAAW,CAAC,CAAC,CAAC;YACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,uBAAuB,CAAC,CAAC;QACxE,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;IACzC,CAAC;IAED;;;;;OAKG;IACH,4CAAiB,GAAjB,UAAkB,SAAS;QACzB,EAAE,CAAC,CAAC,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC;YAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,oBAAoB,KAAK,WAAW,CAAC,CAAC,CAAC;YACrD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,+BAA+B,CAC7C,CAAC;QACJ,CAAC;QAED,IAAM,SAAS,GAAG,gCAAmB,CAAC,SAAS,CAAC,CAAC;QAEjD,EAAE,CAAC,CAAC,SAAS,CAAC,MAAM,KAAK,EAAE,CAAC,CAAC,CAAC;YAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,4BAA4B,CAC1C,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,oBAAoB,GAAG,SAAS,CAAC;IACxC,CAAC;IAED;;;;;;;;;OASG;IACH,oCAAS,GAAT,UAAU,cAAc,EAAE,QAAS,EAAE,YAAa;QAChD,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACjE,CAAC;IAED;;;;;;;;;OASG;IACH,yCAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,CAAC,IAAI,CAAC,eAAe,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACtE,CAAC;IAED;;;;;;;;OAQG;IACH,yDAA8B,GAA9B,UAA+B,YAAY;QAA3C,iBAmCC;QAlCC,IAAM,aAAa,GACjB,YAAY,CAAC,UAAU,IAAI,YAAY,CAAC,OAAO,IAAI,YAAY,CAAC,MAAM,CAAC;QAEzE,MAAM,CAAC,IAAI,OAAO,CAA4B,UAAC,OAAO,EAAE,MAAM;YAC5D,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC;gBACnB,qDAAqD;gBACrD,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,CAAC;gBAC7D,MAAM,CAAC;YACT,CAAC;YACD,iEAAiE;YACjE,mEAAmE;YACnE,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACtB,MAAM,CAAC;YACT,CAAC;YAED,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACjE,MAAM,CAAC;YACT,CAAC;YAED,IAAI,mBAAmB,GAAG;gBACxB,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBAC/C,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,gBAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACnE,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,6CAA6C;oBAC7C,MAAM,CAAC;gBACT,CAAC;gBACD,aAAa,CAAC,mBAAmB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;YACxE,CAAC,CAAC;YACF,aAAa,CAAC,gBAAgB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;OAKG;IACH,6CAAkB,GAAlB;QAAA,iBAiCC;QAhCC,EAAE,CAAC,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC,CAAC;YAC5B,MAAM,CAAC,IAAI,CAAC,8BAA8B,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC;QACtE,CAAC;QAED,kEAAkE;QAClE,wEAAwE;QACxE,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;QAE/B,MAAM,CAAC,SAAS,CAAC,aAAa;aAC3B,QAAQ,CAAC,oBAAS,CAAC,IAAI,EAAE;YACxB,KAAK,EAAE,oBAAS,CAAC,KAAK;SACvB,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,gBAAM,CAAC,KAAK,CAAC,2BAA2B,EACxC;gBACE,mBAAmB,EAAE,GAAG,CAAC,OAAO;aACjC,CACF,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,MAAM,CAAC,KAAI,CAAC,8BAA8B,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC;gBAC5D,KAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;gBAEvC,oEAAoE;gBACpE,gEAAgE;gBAChE,UAAU;gBACV,YAAY,CAAC,MAAM,EAAE,CAAC;gBAEtB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;OAIG;IACH,6CAAkB,GAAlB;QACE,EAAE,CAAC,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC,CAAC;YAC9B,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC;QACpD,CAAC;QAED,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,qBAAU,CAAC,wBAAwB,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;;OAMG;IACH,kDAAuB,GAAvB;QAAA,iBA8BC;QA7BC,EAAE,CAAC,CAAC,CAAC,CAAC,eAAe,IAAI,SAAS,CAAC,CAAC,CAAC,CAAC;YACpC,MAAM,CAAC;QACT,CAAC;QAED,SAAS,CAAC,aAAa,CAAC,gBAAgB,CACtC,SAAS,EACT,UAAA,KAAK;YACH,EAAE,CAAC,CAAC,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,6BAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBACrE,yBAAyB;gBACzB,MAAM,CAAC;YACT,CAAC;YAED,IAAM,iBAAiB,GAAG,KAAK,CAAC,IAAI,CAAC;YACrC,MAAM,CAAC,CAAC,iBAAiB,CAAC,6BAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBAChE,KAAK,6BAAiB,CAAC,YAAY,CAAC,iBAAiB,CAAC;gBACtD,KAAK,6BAAiB,CAAC,YAAY,CAAC,oBAAoB;oBACtD,IAAM,WAAW,GACf,iBAAiB,CAAC,6BAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;oBACnD,EAAE,CAAC,CAAC,KAAI,CAAC,gBAAgB,CAAC,CAAC,CAAC;wBAC1B,KAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;oBAC1C,CAAC;oBACD,KAAK,CAAC;gBACR;oBACE,QAAQ;oBACR,KAAK,CAAC;YACV,CAAC;QACH,CAAC,EACD,KAAK,CACN,CAAC;IACJ,CAAC;IAED;;;;OAIG;IACH,uCAAY,GAAZ;QACE,MAAM,CAAC,CACL,eAAe,IAAI,SAAS;YAC5B,aAAa,IAAI,MAAM;YACvB,cAAc,IAAI,MAAM;YACxB,OAAO,IAAI,MAAM;YACjB,yBAAyB,CAAC,SAAS,CAAC,cAAc,CAAC,kBAAkB,CAAC;YACtE,gBAAgB,CAAC,SAAS,CAAC,cAAc,CAAC,QAAQ,CAAC,CACpD,CAAC;IACJ,CAAC;IACH,uBAAC;AAAD,CA3YA,AA2YC,CA3Y6C,8BAAmB,GA2YhE","file":"window-controller.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { FirebaseMessaging } from '@firebase/messaging-types';\nimport ControllerInterface from './controller-interface';\nimport Errors from '../models/errors';\nimport WorkerPageMessage from '../models/worker-page-message';\nimport DefaultSW from '../models/default-sw';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport FCMDetails from '../models/fcm-details';\nimport base64ToArrayBuffer from '../helpers/base64-to-array-buffer';\nimport { createSubscribe } from '@firebase/util';\n\ndeclare const firebase: any;\n\nexport default class WindowController extends ControllerInterface\n implements FirebaseMessaging {\n private registrationToUse_;\n private publicVapidKeyToUse_;\n private manifestCheckPromise_;\n private messageObserver_ = null;\n private onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n private tokenRefreshObserver_ = null;\n private onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n /**\n * A service that provides a MessagingService instance.\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n super(app);\n\n /**\n * @private\n * @type {ServiceWorkerRegistration}\n */\n this.registrationToUse_;\n\n /**\n * @private\n * @type {Promise}\n */\n this.manifestCheckPromise_;\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.messageObserver_ = null;\n\n /**\n * @private {!firebase.Subscribe} The subscribe function to the onMessage\n * observer.\n */\n this.onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.tokenRefreshObserver_ = null;\n this.onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n this.setupSWMessageListener_();\n }\n\n /**\n * This method returns an FCM token if it can be generated.\n * The return promise will reject if the browser doesn't support\n * FCM, if permission is denied for notifications or it's not\n * possible to generate a token.\n * @export\n * @return {Promise<string> | Promise<null>} Returns a promise the\n * resolves to an FCM token or null if permission isn't granted.\n */\n getToken() {\n // Check that the required API's are available\n if (!this.isSupported_()) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.UNSUPPORTED_BROWSER)\n );\n }\n\n return this.manifestCheck_().then(() => {\n return super.getToken();\n });\n }\n\n /**\n * The method checks that a manifest is defined and has the correct GCM\n * sender ID.\n * @private\n * @return {Promise} Returns a promise that resolves if the manifest matches\n * our required sender ID\n */\n manifestCheck_() {\n if (this.manifestCheckPromise_) {\n return this.manifestCheckPromise_;\n }\n\n const manifestTag = <HTMLAnchorElement>document.querySelector(\n 'link[rel=\"manifest\"]'\n );\n if (!manifestTag) {\n this.manifestCheckPromise_ = Promise.resolve();\n } else {\n this.manifestCheckPromise_ = fetch(manifestTag.href)\n .then(response => {\n return response.json();\n })\n .catch(() => {\n // If the download or parsing fails allow check.\n // We only want to error if we KNOW that the gcm_sender_id is incorrect.\n })\n .then(manifestContent => {\n if (!manifestContent) {\n return;\n }\n\n if (!manifestContent['gcm_sender_id']) {\n return;\n }\n\n if (manifestContent['gcm_sender_id'] !== '103953800507') {\n throw this.errorFactory_.create(\n Errors.codes.INCORRECT_GCM_SENDER_ID\n );\n }\n });\n }\n\n return this.manifestCheckPromise_;\n }\n\n /**\n * Request permission if it is not currently granted\n * @export\n * @returns {Promise} Resolves if the permission was granted, otherwise\n * rejects\n */\n async requestPermission() {\n if ((Notification as any).permission === NOTIFICATION_PERMISSION.granted) {\n return;\n }\n\n return new Promise((resolve, reject) => {\n const managePermissionResult = result => {\n if (result === NOTIFICATION_PERMISSION.granted) {\n return resolve();\n } else if (result === NOTIFICATION_PERMISSION.denied) {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_BLOCKED)\n );\n } else {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_DEFAULT)\n );\n }\n };\n\n // The Notification.requestPermission API was changed to\n // return a promise so now have to handle both in case\n // browsers stop support callbacks for promised version\n const permissionPromise = Notification.requestPermission(\n managePermissionResult\n );\n if (permissionPromise) {\n // Prefer the promise version as it's the future API.\n permissionPromise.then(managePermissionResult);\n }\n });\n }\n\n /**\n * This method allows a developer to override the default service worker and\n * instead use a custom service worker.\n * @export\n * @param {!ServiceWorkerRegistration} registration The service worker\n * registration that should be used to receive the push messages.\n */\n useServiceWorker(registration) {\n if (!(registration instanceof ServiceWorkerRegistration)) {\n throw this.errorFactory_.create(Errors.codes.SW_REGISTRATION_EXPECTED);\n }\n\n if (typeof this.registrationToUse_ !== 'undefined') {\n throw this.errorFactory_.create(Errors.codes.USE_SW_BEFORE_GET_TOKEN);\n }\n\n this.registrationToUse_ = registration;\n }\n\n /**\n * This method allows a developer to override the default vapid key\n * and instead use a custom VAPID public key.\n * @export\n * @param {!string} publicKey A URL safe base64 encoded string.\n */\n usePublicVapidKey(publicKey) {\n if (typeof publicKey !== 'string') {\n throw this.errorFactory_.create(Errors.codes.INVALID_PUBLIC_VAPID_KEY);\n }\n\n if (typeof this.publicVapidKeyToUse_ !== 'undefined') {\n throw this.errorFactory_.create(\n Errors.codes.USE_PUBLIC_KEY_BEFORE_GET_TOKEN\n );\n }\n\n const parsedKey = base64ToArrayBuffer(publicKey);\n\n if (parsedKey.length !== 65) {\n throw this.errorFactory_.create(\n Errors.codes.PUBLIC_KEY_DECRYPTION_FAILED\n );\n }\n\n this.publicVapidKeyToUse_ = parsedKey;\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver An observer object\n * or a function triggered on message.\n * @param {function(!Error)=} optError Optional A function triggered on\n * message error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onMessage(nextOrObserver, optError?, optCompleted?) {\n return this.onMessage_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n return this.onTokenRefresh_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * Given a registration, wait for the service worker it relates to\n * become activer\n * @private\n * @param {ServiceWorkerRegistration} registration Registration to wait\n * for service worker to become active\n * @return {Promise<!ServiceWorkerRegistration>} Wait for service worker\n * registration to become active\n */\n waitForRegistrationToActivate_(registration) {\n const serviceWorker =\n registration.installing || registration.waiting || registration.active;\n\n return new Promise<ServiceWorkerRegistration>((resolve, reject) => {\n if (!serviceWorker) {\n // This is a rare scenario but has occured in firefox\n reject(this.errorFactory_.create(Errors.codes.NO_SW_IN_REG));\n return;\n }\n // Because the Promise function is called on next tick there is a\n // small chance that the worker became active or redundant already.\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n return;\n }\n\n if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n return;\n }\n\n let stateChangeListener = () => {\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n } else if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n } else {\n // Return early and wait to next state change\n return;\n }\n serviceWorker.removeEventListener('statechange', stateChangeListener);\n };\n serviceWorker.addEventListener('statechange', stateChangeListener);\n });\n }\n\n /**\n * This will regiater the default service worker and return the registration\n * @private\n * @return {Promise<!ServiceWorkerRegistration>} The service worker\n * registration to be used for the push service.\n */\n getSWRegistration_() {\n if (this.registrationToUse_) {\n return this.waitForRegistrationToActivate_(this.registrationToUse_);\n }\n\n // Make the registration null so we know useServiceWorker will not\n // use a new service worker as registrationToUse_ is no longer undefined\n this.registrationToUse_ = null;\n\n return navigator.serviceWorker\n .register(DefaultSW.path, {\n scope: DefaultSW.scope\n })\n .catch(err => {\n throw this.errorFactory_.create(\n Errors.codes.FAILED_DEFAULT_REGISTRATION,\n {\n browserErrorMessage: err.message\n }\n );\n })\n .then(registration => {\n return this.waitForRegistrationToActivate_(registration).then(() => {\n this.registrationToUse_ = registration;\n\n // We update after activation due to an issue with Firefox v49 where\n // a race condition occassionally causes the service work to not\n // install\n registration.update();\n\n return registration;\n });\n });\n }\n\n /**\n * This will return the default VAPID key or the uint8array version of the public VAPID key\n * provided by the developer.\n * @private\n */\n getPublicVapidKey_(): Promise<Uint8Array> {\n if (this.publicVapidKeyToUse_) {\n return Promise.resolve(this.publicVapidKeyToUse_);\n }\n\n return Promise.resolve(FCMDetails.DEFAULT_PUBLIC_VAPID_KEY);\n }\n\n /**\n * This method will set up a message listener to handle\n * events from the service worker that should trigger\n * events in the page.\n *\n * @private\n */\n setupSWMessageListener_() {\n if (!('serviceWorker' in navigator)) {\n return;\n }\n\n navigator.serviceWorker.addEventListener(\n 'message',\n event => {\n if (!event.data || !event.data[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n // Not a message from FCM\n return;\n }\n\n const workerPageMessage = event.data;\n switch (workerPageMessage[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n case WorkerPageMessage.TYPES_OF_MSG.PUSH_MSG_RECEIVED:\n case WorkerPageMessage.TYPES_OF_MSG.NOTIFICATION_CLICKED:\n const pushMessage =\n workerPageMessage[WorkerPageMessage.PARAMS.DATA];\n if (this.messageObserver_) {\n this.messageObserver_.next(pushMessage);\n }\n break;\n default:\n // Noop.\n break;\n }\n },\n false\n );\n }\n\n /**\n * Checks to see if the required API's are valid or not.\n * @private\n * @return {boolean} Returns true if the desired APIs are available.\n */\n isSupported_() {\n return (\n 'serviceWorker' in navigator &&\n 'PushManager' in window &&\n 'Notification' in window &&\n 'fetch' in window &&\n ServiceWorkerRegistration.prototype.hasOwnProperty('showNotification') &&\n PushSubscription.prototype.hasOwnProperty('getKey')\n );\n }\n}\n"]} |
@@ -46,4 +46,7 @@ import TokenDetailsModel from '../models/token-details-model'; | ||
| requestPermission(): void; | ||
| getPushSubscription_(registration: any, publicVapidKey: any): Promise<PushSubscription>; | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| */ | ||
| getPushSubscription(swRegistration: ServiceWorkerRegistration, publicVapidKey: Uint8Array): Promise<PushSubscription>; | ||
| /** | ||
| * @export | ||
@@ -50,0 +53,0 @@ * @param {!ServiceWorkerRegistration} registration |
@@ -124,3 +124,3 @@ /** | ||
| publicVapidKey = publicKey; | ||
| return _this.getPushSubscription_(swReg, publicVapidKey); | ||
| return _this.getPushSubscription(swReg, publicVapidKey); | ||
| }) | ||
@@ -163,3 +163,3 @@ .then(function (pushSubscription) { | ||
| publicVapidKey = publicKey; | ||
| return _this.getPushSubscription_(swReg, publicVapidKey); | ||
| return _this.getPushSubscription(swReg, publicVapidKey); | ||
| }) | ||
@@ -229,4 +229,15 @@ .then(function (pushSubscription) { | ||
| }; | ||
| ControllerInterface.prototype.getPushSubscription_ = function (registration, publicVapidKey) { | ||
| throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW); | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| */ | ||
| ControllerInterface.prototype.getPushSubscription = function (swRegistration, publicVapidKey) { | ||
| return swRegistration.pushManager.getSubscription().then(function (subscription) { | ||
| if (subscription) { | ||
| return subscription; | ||
| } | ||
| return swRegistration.pushManager.subscribe({ | ||
| userVisibleOnly: true, | ||
| applicationServerKey: publicVapidKey | ||
| }); | ||
| }); | ||
| }; | ||
@@ -233,0 +244,0 @@ /** |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/controllers/controller-interface.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;AAEb,OAAO,EAAE,YAAY,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,MAAM,MAAM,kBAAkB,CAAC;AACtC,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,uBAAuB,MAAM,mCAAmC,CAAC;AACxE,OAAO,QAAQ,MAAM,qBAAqB,CAAC;AAC3C,OAAO,mBAAmB,MAAM,mCAAmC,CAAC;AAEpE,IAAM,qBAAqB,GAAG,mBAAmB,CAAC;AAClD,oDAAoD;AACpD,MAAM,CAAC,IAAM,uBAAuB,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,IAAI,CAAC,CAAC,SAAS;AAEzE;IASE;;;OAGG;IACH,6BAAY,GAAG;QAAf,iBAmBC;QAlBC,IAAI,CAAC,aAAa,GAAG,IAAI,YAAY,CAAC,WAAW,EAAE,WAAW,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAE5E,EAAE,CAAC,CACD,CAAC,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC;YACnC,OAAO,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,KAAK,QAChD,CAAC,CAAC,CAAC;YACD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,aAAa,CAAC,CAAC;QAC9D,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,CAAC;QAE7D,IAAI,CAAC,kBAAkB,GAAG,IAAI,iBAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,kBAAkB,GAAG,IAAI,iBAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,SAAS,GAAG,IAAI,QAAQ,EAAE,CAAC;QAEhC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,QAAQ,GAAG,EAAE,CAAC;QACnB,IAAI,CAAC,QAAQ,CAAC,MAAM,GAAG,cAAM,OAAA,KAAI,CAAC,MAAM,EAAE,EAAb,CAAa,CAAC;IAC7C,CAAC;IAED;;OAEG;IACH,sCAAQ,GAAR;QAAA,iBAyBC;QAxBC,yBAAyB;QACzB,IAAM,iBAAiB,GAAG,IAAI,CAAC,0BAA0B,EAAE,CAAC;QAC5D,EAAE,CAAC,CAAC,iBAAiB,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;YAC1D,EAAE,CAAC,CAAC,iBAAiB,KAAK,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gBACzD,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,qBAAqB,CAAC,CAC9D,CAAC;YACJ,CAAC;YAED,4CAA4C;YAC5C,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAgC,CAAC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,GAAG;YACP,KAAK,GAAG,GAAG,CAAC;YACZ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,0BAA0B,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;QACzE,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;YACvD,CAAC;YACD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACjC,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;;;OAQG;IACK,iDAAmB,GAA3B,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAoBC;QAhBC,MAAM,CAAC,IAAI,CAAC,iBAAiB,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC,UAAA,OAAO;YACtD,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;gBACZ,IAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBACvB,EAAE,CAAC,CAAC,GAAG,GAAG,YAAY,CAAC,YAAY,CAAC,GAAG,uBAAuB,CAAC,CAAC,CAAC;oBAC/D,MAAM,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;gBAC/C,CAAC;YACH,CAAC;YAAC,IAAI,CAAC,CAAC;gBACN,+DAA+D;gBAC/D,wBAAwB;gBACxB,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;oBACrD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;gBACjC,CAAC,CAAC,CAAC;YACL,CAAC;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACK,+CAAiB,GAAzB,UAA0B,YAAoB;QAC5C,qCAAqC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE,CAAC,IAAI,CAAC,UAAA,SAAS;YAC7C,EAAE,CAAC,CAAC,mBAAmB,CAAC,SAAS,CAAC,KAAK,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC;gBAChE,MAAM,CAAC,KAAK,CAAC;YACf,CAAC;YACD,MAAM,CAAC,IAAI,CAAC;QACd,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,yCAAW,GAAnB,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAgDC;QA5CC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAAoB,CAAC;QACzB,IAAI,YAA8B,CAAC;QACnC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,oBAAoB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAC1D,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,KAAI,CAAC,kBAAkB,EACvB,YAAY,CAAC,UAAU,CAAC,EACxB,YAAY,CAAC,YAAY,CAAC,EAC1B,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;gBACrD,MAAM,GAAG,CAAC;YACZ,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,KAAK;YACT,YAAY,GAAG,KAAK,CAAC;YACrB,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY;gBACtB,UAAU,EAAE,YAAY,CAAC,YAAY,CAAC;aACvC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC;QACtB,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,yCAAW,GAAnB,UAAoB,KAAgC;QAApD,iBAsCC;QArCC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAA8B,CAAC;QACnC,IAAI,YAAoB,CAAC;QACzB,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,oBAAoB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAC1D,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,QAAQ,CAC5B,KAAI,CAAC,kBAAkB,EACvB,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,eAAe;YACnB,YAAY,GAAG,eAAe,CAAC;YAC/B,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY,CAAC,OAAO,CAAC;gBAC/B,UAAU,EAAE,YAAY,CAAC,SAAS,CAAC;aACpC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;QAC/B,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;OAMG;IACH,yCAAW,GAAX,UAAY,KAAa;QAAzB,iBAuBC;QAtBC,MAAM,CAAC,IAAI,CAAC,kBAAkB;aAC3B,WAAW,CAAC,KAAK,CAAC;aAClB,IAAI,CAAC,UAAA,OAAO;YACX,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,OAAO,CAAC,aAAa,CAAC,EACtB,OAAO,CAAC,UAAU,CAAC,EACnB,OAAO,CAAC,YAAY,CAAC,CACtB,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,EAAE;iBAC7B,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC;gBACpD,CAAC;YACH,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,EAAE,CAAC;gBACpC,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,gEAAgE;IAChE,EAAE;IAEF,+CAAiB,GAAjB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,kDAAoB,GAApB,UACE,YAAY,EACZ,cAAc;QAEd,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,8CAAgB,GAAhB,UAAiB,YAAY;QAC3B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,+CAAiB,GAAjB,UAAkB,YAAY;QAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;OAMG;IACH,uCAAS,GAAT,UAAU,cAAc,EAAE,QAAQ,EAAE,YAAY;QAC9C,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;;;;OASG;IACH,4CAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,6DAA6D;IAC7D,EAAE;IAEF;;;OAGG;IACH,yDAA2B,GAA3B,UAA4B,QAAQ;QAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAChE,CAAC;IAED,EAAE;IACF,2EAA2E;IAC3E,qDAAqD;IACrD,EAAE;IAEF;;;OAGG;IACH,oCAAM,GAAN;QACE,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC;YACjB,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;YACvC,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;SACxC,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,wDAA0B,GAA1B;QACE,MAAM,CAAE,YAAoB,CAAC,UAAU,CAAC;IAC1C,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED;;;OAGG;IACH,yCAAW,GAAX;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IACH,0BAAC;AAAD,CA1VA,AA0VC,IAAA","file":"controller-interface.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { ErrorFactory } from '@firebase/util';\nimport Errors from '../models/errors';\nimport TokenDetailsModel from '../models/token-details-model';\nimport VapidDetailsModel from '../models/vapid-details-model';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport IIDModel from '../models/iid-model';\nimport arrayBufferToBase64 from '../helpers/array-buffer-to-base64';\n\nconst SENDER_ID_OPTION_NAME = 'messagingSenderId';\n// Database cache should be invalidated once a week.\nexport const TOKEN_EXPIRATION_MILLIS = 7 * 24 * 60 * 60 * 1000; // 7 days\n\nexport default class ControllerInterface {\n public app;\n public INTERNAL;\n protected errorFactory_;\n private messagingSenderId_: string;\n private tokenDetailsModel_: TokenDetailsModel;\n private vapidDetailsModel_: VapidDetailsModel;\n private iidModel_: IIDModel;\n\n /**\n * An interface of the Messaging Service API\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n this.errorFactory_ = new ErrorFactory('messaging', 'Messaging', Errors.map);\n\n if (\n !app.options[SENDER_ID_OPTION_NAME] ||\n typeof app.options[SENDER_ID_OPTION_NAME] !== 'string'\n ) {\n throw this.errorFactory_.create(Errors.codes.BAD_SENDER_ID);\n }\n\n this.messagingSenderId_ = app.options[SENDER_ID_OPTION_NAME];\n\n this.tokenDetailsModel_ = new TokenDetailsModel();\n this.vapidDetailsModel_ = new VapidDetailsModel();\n this.iidModel_ = new IIDModel();\n\n this.app = app;\n this.INTERNAL = {};\n this.INTERNAL.delete = () => this.delete();\n }\n\n /**\n * @export\n */\n getToken(): Promise<string | null> {\n // Check with permissions\n const currentPermission = this.getNotificationPermission_();\n if (currentPermission !== NOTIFICATION_PERMISSION.granted) {\n if (currentPermission === NOTIFICATION_PERMISSION.denied) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.NOTIFICATIONS_BLOCKED)\n );\n }\n\n // We must wait for permission to be granted\n return Promise.resolve(null);\n }\n let swReg: ServiceWorkerRegistration;\n return this.getSWRegistration_()\n .then(reg => {\n swReg = reg;\n return this.tokenDetailsModel_.getTokenDetailsFromSWScope(swReg.scope);\n })\n .then(tokenDetails => {\n if (tokenDetails) {\n return this.manageExistingToken(tokenDetails, swReg);\n }\n return this.getNewToken(swReg);\n });\n }\n\n /**\n * manageExistingToken is triggered if there's an existing FCM token in the\n * database and it can take 3 different actions:\n * 1) Retrieve the existing FCM token from the database.\n * 2) If VAPID details have changed: Delete the existing token and create a\n * new one with the new VAPID key.\n * 3) If the database cache is invalidated: Send a request to FCM to update\n * the token, and to check if the token is still valid on FCM-side.\n */\n private manageExistingToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n return this.isTokenStillValid(tokenDetails).then(isValid => {\n if (isValid) {\n const now = Date.now();\n if (now < tokenDetails['createTime'] + TOKEN_EXPIRATION_MILLIS) {\n return tokenDetails['fcmToken'];\n } else {\n return this.updateToken(tokenDetails, swReg);\n }\n } else {\n // If the VAPID details are updated, delete the existing token,\n // and create a new one.\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n return this.getNewToken(swReg);\n });\n }\n });\n }\n\n /*\n * Checks if the tokenDetails match the details provided in the clients.\n */\n private isTokenStillValid(tokenDetails: Object): Promise<Boolean> {\n // TODO Validate rest of the details.\n return this.getPublicVapidKey_().then(publicKey => {\n if (arrayBufferToBase64(publicKey) !== tokenDetails['vapidKey']) {\n return false;\n }\n return true;\n });\n }\n\n private updateToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n let publicVapidKey: Uint8Array;\n let updatedToken: string;\n let subscription: PushSubscription;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription_(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.updateToken(\n this.messagingSenderId_,\n tokenDetails['fcmToken'],\n tokenDetails['fcmPushSet'],\n subscription,\n publicVapidKey\n );\n })\n .catch(err => {\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n throw err;\n });\n })\n .then(token => {\n updatedToken = token;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: updatedToken,\n fcmPushSet: tokenDetails['fcmPushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return updatedToken;\n });\n }\n\n private getNewToken(swReg: ServiceWorkerRegistration): Promise<string> {\n let publicVapidKey: Uint8Array;\n let subscription: PushSubscription;\n let tokenDetails: Object;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription_(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.getToken(\n this.messagingSenderId_,\n subscription,\n publicVapidKey\n );\n })\n .then(iidTokenDetails => {\n tokenDetails = iidTokenDetails;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: tokenDetails['token'],\n fcmPushSet: tokenDetails['pushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return tokenDetails['token'];\n });\n }\n\n /**\n * This method deletes tokens that the token manager looks after,\n * unsubscribes the token from FCM and then unregisters the push\n * subscription if it exists. It returns a promise that indicates\n * whether or not the unsubscribe request was processed successfully.\n * @export\n */\n deleteToken(token: string): Promise<Boolean> {\n return this.tokenDetailsModel_\n .deleteToken(token)\n .then(details => {\n return this.iidModel_.deleteToken(\n details['fcmSenderId'],\n details['fcmToken'],\n details['fcmPushSet']\n );\n })\n .then(() => {\n return this.getSWRegistration_()\n .then(registration => {\n if (registration) {\n return registration.pushManager.getSubscription();\n }\n })\n .then(subscription => {\n if (subscription) {\n return subscription.unsubscribe();\n }\n });\n });\n }\n\n getSWRegistration_(): Promise<ServiceWorkerRegistration> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n getPublicVapidKey_(): Promise<Uint8Array> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n //\n // The following methods should only be available in the window.\n //\n\n requestPermission() {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n getPushSubscription_(\n registration,\n publicVapidKey\n ): Promise<PushSubscription> {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!ServiceWorkerRegistration} registration\n */\n useServiceWorker(registration) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!string} b64PublicKey\n */\n usePublicVapidKey(b64PublicKey) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver\n * @param {function(!Error)=} optError\n * @param {function()=} optCompleted\n * @return {!function()}\n */\n onMessage(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n //\n // The following methods are used by the service worker only.\n //\n\n /**\n * @export\n * @param {function(Object)} callback\n */\n setBackgroundMessageHandler(callback) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_SW);\n }\n\n //\n // The following methods are used by the service themselves and not exposed\n // publicly or not expected to be used by developers.\n //\n\n /**\n * This method is required to adhere to the Firebase interface.\n * It closes any currently open indexdb database connections.\n */\n delete() {\n return Promise.all([\n this.tokenDetailsModel_.closeDatabase(),\n this.vapidDetailsModel_.closeDatabase()\n ]);\n }\n\n /**\n * Returns the current Notification Permission state.\n * @private\n * @return {string} The currenct permission state.\n */\n getNotificationPermission_() {\n return (Notification as any).permission;\n }\n\n getTokenDetailsModel(): TokenDetailsModel {\n return this.tokenDetailsModel_;\n }\n\n getVapidDetailsModel(): VapidDetailsModel {\n return this.vapidDetailsModel_;\n }\n\n /**\n * @protected\n * @returns {IIDModel}\n */\n getIIDModel() {\n return this.iidModel_;\n }\n}\n"]} | ||
| {"version":3,"sources":["../src/controllers/controller-interface.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;AAEb,OAAO,EAAE,YAAY,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,MAAM,MAAM,kBAAkB,CAAC;AACtC,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,uBAAuB,MAAM,mCAAmC,CAAC;AACxE,OAAO,QAAQ,MAAM,qBAAqB,CAAC;AAC3C,OAAO,mBAAmB,MAAM,mCAAmC,CAAC;AAEpE,IAAM,qBAAqB,GAAG,mBAAmB,CAAC;AAClD,oDAAoD;AACpD,MAAM,CAAC,IAAM,uBAAuB,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,IAAI,CAAC,CAAC,SAAS;AAEzE;IASE;;;OAGG;IACH,6BAAY,GAAG;QAAf,iBAmBC;QAlBC,IAAI,CAAC,aAAa,GAAG,IAAI,YAAY,CAAC,WAAW,EAAE,WAAW,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAE5E,EAAE,CAAC,CACD,CAAC,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC;YACnC,OAAO,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,KAAK,QAChD,CAAC,CAAC,CAAC;YACD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,aAAa,CAAC,CAAC;QAC9D,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,GAAG,CAAC,OAAO,CAAC,qBAAqB,CAAC,CAAC;QAE7D,IAAI,CAAC,kBAAkB,GAAG,IAAI,iBAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,kBAAkB,GAAG,IAAI,iBAAiB,EAAE,CAAC;QAClD,IAAI,CAAC,SAAS,GAAG,IAAI,QAAQ,EAAE,CAAC;QAEhC,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,QAAQ,GAAG,EAAE,CAAC;QACnB,IAAI,CAAC,QAAQ,CAAC,MAAM,GAAG,cAAM,OAAA,KAAI,CAAC,MAAM,EAAE,EAAb,CAAa,CAAC;IAC7C,CAAC;IAED;;OAEG;IACH,sCAAQ,GAAR;QAAA,iBAyBC;QAxBC,yBAAyB;QACzB,IAAM,iBAAiB,GAAG,IAAI,CAAC,0BAA0B,EAAE,CAAC;QAC5D,EAAE,CAAC,CAAC,iBAAiB,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;YAC1D,EAAE,CAAC,CAAC,iBAAiB,KAAK,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gBACzD,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,qBAAqB,CAAC,CAC9D,CAAC;YACJ,CAAC;YAED,4CAA4C;YAC5C,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAgC,CAAC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,GAAG;YACP,KAAK,GAAG,GAAG,CAAC;YACZ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,0BAA0B,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;QACzE,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;YACvD,CAAC;YACD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACjC,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;;;OAQG;IACK,iDAAmB,GAA3B,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAoBC;QAhBC,MAAM,CAAC,IAAI,CAAC,iBAAiB,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC,UAAA,OAAO;YACtD,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;gBACZ,IAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBACvB,EAAE,CAAC,CAAC,GAAG,GAAG,YAAY,CAAC,YAAY,CAAC,GAAG,uBAAuB,CAAC,CAAC,CAAC;oBAC/D,MAAM,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,EAAE,KAAK,CAAC,CAAC;gBAC/C,CAAC;YACH,CAAC;YAAC,IAAI,CAAC,CAAC;gBACN,+DAA+D;gBAC/D,wBAAwB;gBACxB,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;oBACrD,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;gBACjC,CAAC,CAAC,CAAC;YACL,CAAC;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACK,+CAAiB,GAAzB,UAA0B,YAAoB;QAC5C,qCAAqC;QACrC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE,CAAC,IAAI,CAAC,UAAA,SAAS;YAC7C,EAAE,CAAC,CAAC,mBAAmB,CAAC,SAAS,CAAC,KAAK,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC;gBAChE,MAAM,CAAC,KAAK,CAAC;YACf,CAAC;YACD,MAAM,CAAC,IAAI,CAAC;QACd,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,yCAAW,GAAnB,UACE,YAAoB,EACpB,KAAgC;QAFlC,iBAgDC;QA5CC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAAoB,CAAC;QACzB,IAAI,YAA8B,CAAC;QACnC,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QACzD,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,KAAI,CAAC,kBAAkB,EACvB,YAAY,CAAC,UAAU,CAAC,EACxB,YAAY,CAAC,YAAY,CAAC,EAC1B,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,CAAC,KAAI,CAAC,WAAW,CAAC,YAAY,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC;gBACrD,MAAM,GAAG,CAAC;YACZ,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,KAAK;YACT,YAAY,GAAG,KAAK,CAAC;YACrB,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY;gBACtB,UAAU,EAAE,YAAY,CAAC,YAAY,CAAC;aACvC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC;QACtB,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,yCAAW,GAAnB,UAAoB,KAAgC;QAApD,iBAsCC;QArCC,IAAI,cAA0B,CAAC;QAC/B,IAAI,YAA8B,CAAC;QACnC,IAAI,YAAoB,CAAC;QACzB,MAAM,CAAC,IAAI,CAAC,kBAAkB,EAAE;aAC7B,IAAI,CAAC,UAAA,SAAS;YACb,cAAc,GAAG,SAAS,CAAC;YAC3B,MAAM,CAAC,KAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QACzD,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,gBAAgB;YACpB,YAAY,GAAG,gBAAgB,CAAC;YAChC,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,QAAQ,CAC5B,KAAI,CAAC,kBAAkB,EACvB,YAAY,EACZ,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,eAAe;YACnB,YAAY,GAAG,eAAe,CAAC;YAC/B,IAAM,UAAU,GAAG;gBACjB,OAAO,EAAE,KAAK,CAAC,KAAK;gBACpB,QAAQ,EAAE,cAAc;gBACxB,YAAY,EAAE,YAAY;gBAC1B,WAAW,EAAE,KAAI,CAAC,kBAAkB;gBACpC,QAAQ,EAAE,YAAY,CAAC,OAAO,CAAC;gBAC/B,UAAU,EAAE,YAAY,CAAC,SAAS,CAAC;aACpC,CAAC;YACF,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;QAC9D,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,CAAC,gBAAgB,CAC7C,KAAK,CAAC,KAAK,EACX,cAAc,CACf,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;QAC/B,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;;;OAMG;IACH,yCAAW,GAAX,UAAY,KAAa;QAAzB,iBAuBC;QAtBC,MAAM,CAAC,IAAI,CAAC,kBAAkB;aAC3B,WAAW,CAAC,KAAK,CAAC;aAClB,IAAI,CAAC,UAAA,OAAO;YACX,MAAM,CAAC,KAAI,CAAC,SAAS,CAAC,WAAW,CAC/B,OAAO,CAAC,aAAa,CAAC,EACtB,OAAO,CAAC,UAAU,CAAC,EACnB,OAAO,CAAC,YAAY,CAAC,CACtB,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC;YACJ,MAAM,CAAC,KAAI,CAAC,kBAAkB,EAAE;iBAC7B,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC;gBACpD,CAAC;YACH,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,YAAY;gBAChB,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;oBACjB,MAAM,CAAC,YAAY,CAAC,WAAW,EAAE,CAAC;gBACpC,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,gDAAkB,GAAlB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,gEAAgE;IAChE,EAAE;IAEF,+CAAiB,GAAjB;QACE,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;OAEG;IACH,iDAAmB,GAAnB,UACE,cAAyC,EACzC,cAA0B;QAE1B,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC,IAAI,CAAC,UAAA,YAAY;YACnE,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC;YAED,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,SAAS,CAAC;gBAC1C,eAAe,EAAE,IAAI;gBACrB,oBAAoB,EAAE,cAAc;aACrC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,8CAAgB,GAAhB,UAAiB,YAAY;QAC3B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;OAGG;IACH,+CAAiB,GAAjB,UAAkB,YAAY;QAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;OAMG;IACH,uCAAS,GAAT,UAAU,cAAc,EAAE,QAAQ,EAAE,YAAY;QAC9C,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED;;;;;;;;;OASG;IACH,4CAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAAC;IACpE,CAAC;IAED,EAAE;IACF,6DAA6D;IAC7D,EAAE;IAEF;;;OAGG;IACH,yDAA2B,GAA3B,UAA4B,QAAQ;QAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAChE,CAAC;IAED,EAAE;IACF,2EAA2E;IAC3E,qDAAqD;IACrD,EAAE;IAEF;;;OAGG;IACH,oCAAM,GAAN;QACE,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC;YACjB,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;YACvC,IAAI,CAAC,kBAAkB,CAAC,aAAa,EAAE;SACxC,CAAC,CAAC;IACL,CAAC;IAED;;;;OAIG;IACH,wDAA0B,GAA1B;QACE,MAAM,CAAE,YAAoB,CAAC,UAAU,CAAC;IAC1C,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED,kDAAoB,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC;IACjC,CAAC;IAED;;;OAGG;IACH,yCAAW,GAAX;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IACH,0BAAC;AAAD,CAtWA,AAsWC,IAAA","file":"controller-interface.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { ErrorFactory } from '@firebase/util';\nimport Errors from '../models/errors';\nimport TokenDetailsModel from '../models/token-details-model';\nimport VapidDetailsModel from '../models/vapid-details-model';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport IIDModel from '../models/iid-model';\nimport arrayBufferToBase64 from '../helpers/array-buffer-to-base64';\n\nconst SENDER_ID_OPTION_NAME = 'messagingSenderId';\n// Database cache should be invalidated once a week.\nexport const TOKEN_EXPIRATION_MILLIS = 7 * 24 * 60 * 60 * 1000; // 7 days\n\nexport default class ControllerInterface {\n public app;\n public INTERNAL;\n protected errorFactory_;\n private messagingSenderId_: string;\n private tokenDetailsModel_: TokenDetailsModel;\n private vapidDetailsModel_: VapidDetailsModel;\n private iidModel_: IIDModel;\n\n /**\n * An interface of the Messaging Service API\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n this.errorFactory_ = new ErrorFactory('messaging', 'Messaging', Errors.map);\n\n if (\n !app.options[SENDER_ID_OPTION_NAME] ||\n typeof app.options[SENDER_ID_OPTION_NAME] !== 'string'\n ) {\n throw this.errorFactory_.create(Errors.codes.BAD_SENDER_ID);\n }\n\n this.messagingSenderId_ = app.options[SENDER_ID_OPTION_NAME];\n\n this.tokenDetailsModel_ = new TokenDetailsModel();\n this.vapidDetailsModel_ = new VapidDetailsModel();\n this.iidModel_ = new IIDModel();\n\n this.app = app;\n this.INTERNAL = {};\n this.INTERNAL.delete = () => this.delete();\n }\n\n /**\n * @export\n */\n getToken(): Promise<string | null> {\n // Check with permissions\n const currentPermission = this.getNotificationPermission_();\n if (currentPermission !== NOTIFICATION_PERMISSION.granted) {\n if (currentPermission === NOTIFICATION_PERMISSION.denied) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.NOTIFICATIONS_BLOCKED)\n );\n }\n\n // We must wait for permission to be granted\n return Promise.resolve(null);\n }\n let swReg: ServiceWorkerRegistration;\n return this.getSWRegistration_()\n .then(reg => {\n swReg = reg;\n return this.tokenDetailsModel_.getTokenDetailsFromSWScope(swReg.scope);\n })\n .then(tokenDetails => {\n if (tokenDetails) {\n return this.manageExistingToken(tokenDetails, swReg);\n }\n return this.getNewToken(swReg);\n });\n }\n\n /**\n * manageExistingToken is triggered if there's an existing FCM token in the\n * database and it can take 3 different actions:\n * 1) Retrieve the existing FCM token from the database.\n * 2) If VAPID details have changed: Delete the existing token and create a\n * new one with the new VAPID key.\n * 3) If the database cache is invalidated: Send a request to FCM to update\n * the token, and to check if the token is still valid on FCM-side.\n */\n private manageExistingToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n return this.isTokenStillValid(tokenDetails).then(isValid => {\n if (isValid) {\n const now = Date.now();\n if (now < tokenDetails['createTime'] + TOKEN_EXPIRATION_MILLIS) {\n return tokenDetails['fcmToken'];\n } else {\n return this.updateToken(tokenDetails, swReg);\n }\n } else {\n // If the VAPID details are updated, delete the existing token,\n // and create a new one.\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n return this.getNewToken(swReg);\n });\n }\n });\n }\n\n /*\n * Checks if the tokenDetails match the details provided in the clients.\n */\n private isTokenStillValid(tokenDetails: Object): Promise<Boolean> {\n // TODO Validate rest of the details.\n return this.getPublicVapidKey_().then(publicKey => {\n if (arrayBufferToBase64(publicKey) !== tokenDetails['vapidKey']) {\n return false;\n }\n return true;\n });\n }\n\n private updateToken(\n tokenDetails: Object,\n swReg: ServiceWorkerRegistration\n ): Promise<string> {\n let publicVapidKey: Uint8Array;\n let updatedToken: string;\n let subscription: PushSubscription;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.updateToken(\n this.messagingSenderId_,\n tokenDetails['fcmToken'],\n tokenDetails['fcmPushSet'],\n subscription,\n publicVapidKey\n );\n })\n .catch(err => {\n return this.deleteToken(tokenDetails['fcmToken']).then(() => {\n throw err;\n });\n })\n .then(token => {\n updatedToken = token;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: updatedToken,\n fcmPushSet: tokenDetails['fcmPushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return updatedToken;\n });\n }\n\n private getNewToken(swReg: ServiceWorkerRegistration): Promise<string> {\n let publicVapidKey: Uint8Array;\n let subscription: PushSubscription;\n let tokenDetails: Object;\n return this.getPublicVapidKey_()\n .then(publicKey => {\n publicVapidKey = publicKey;\n return this.getPushSubscription(swReg, publicVapidKey);\n })\n .then(pushSubscription => {\n subscription = pushSubscription;\n return this.iidModel_.getToken(\n this.messagingSenderId_,\n subscription,\n publicVapidKey\n );\n })\n .then(iidTokenDetails => {\n tokenDetails = iidTokenDetails;\n const allDetails = {\n swScope: swReg.scope,\n vapidKey: publicVapidKey,\n subscription: subscription,\n fcmSenderId: this.messagingSenderId_,\n fcmToken: tokenDetails['token'],\n fcmPushSet: tokenDetails['pushSet']\n };\n return this.tokenDetailsModel_.saveTokenDetails(allDetails);\n })\n .then(() => {\n return this.vapidDetailsModel_.saveVapidDetails(\n swReg.scope,\n publicVapidKey\n );\n })\n .then(() => {\n return tokenDetails['token'];\n });\n }\n\n /**\n * This method deletes tokens that the token manager looks after,\n * unsubscribes the token from FCM and then unregisters the push\n * subscription if it exists. It returns a promise that indicates\n * whether or not the unsubscribe request was processed successfully.\n * @export\n */\n deleteToken(token: string): Promise<Boolean> {\n return this.tokenDetailsModel_\n .deleteToken(token)\n .then(details => {\n return this.iidModel_.deleteToken(\n details['fcmSenderId'],\n details['fcmToken'],\n details['fcmPushSet']\n );\n })\n .then(() => {\n return this.getSWRegistration_()\n .then(registration => {\n if (registration) {\n return registration.pushManager.getSubscription();\n }\n })\n .then(subscription => {\n if (subscription) {\n return subscription.unsubscribe();\n }\n });\n });\n }\n\n getSWRegistration_(): Promise<ServiceWorkerRegistration> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n getPublicVapidKey_(): Promise<Uint8Array> {\n throw this.errorFactory_.create(Errors.codes.SHOULD_BE_INHERITED);\n }\n\n //\n // The following methods should only be available in the window.\n //\n\n requestPermission() {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * Gets a PushSubscription for the current user.\n */\n getPushSubscription(\n swRegistration: ServiceWorkerRegistration,\n publicVapidKey: Uint8Array\n ): Promise<PushSubscription> {\n return swRegistration.pushManager.getSubscription().then(subscription => {\n if (subscription) {\n return subscription;\n }\n\n return swRegistration.pushManager.subscribe({\n userVisibleOnly: true,\n applicationServerKey: publicVapidKey\n });\n });\n }\n\n /**\n * @export\n * @param {!ServiceWorkerRegistration} registration\n */\n useServiceWorker(registration) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!string} b64PublicKey\n */\n usePublicVapidKey(b64PublicKey) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver\n * @param {function(!Error)=} optError\n * @param {function()=} optCompleted\n * @return {!function()}\n */\n onMessage(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_WINDOW);\n }\n\n //\n // The following methods are used by the service worker only.\n //\n\n /**\n * @export\n * @param {function(Object)} callback\n */\n setBackgroundMessageHandler(callback) {\n throw this.errorFactory_.create(Errors.codes.AVAILABLE_IN_SW);\n }\n\n //\n // The following methods are used by the service themselves and not exposed\n // publicly or not expected to be used by developers.\n //\n\n /**\n * This method is required to adhere to the Firebase interface.\n * It closes any currently open indexdb database connections.\n */\n delete() {\n return Promise.all([\n this.tokenDetailsModel_.closeDatabase(),\n this.vapidDetailsModel_.closeDatabase()\n ]);\n }\n\n /**\n * Returns the current Notification Permission state.\n * @private\n * @return {string} The currenct permission state.\n */\n getNotificationPermission_() {\n return (Notification as any).permission;\n }\n\n getTokenDetailsModel(): TokenDetailsModel {\n return this.tokenDetailsModel_;\n }\n\n getVapidDetailsModel(): VapidDetailsModel {\n return this.vapidDetailsModel_;\n }\n\n /**\n * @protected\n * @returns {IIDModel}\n */\n getIIDModel() {\n return this.iidModel_;\n }\n}\n"]} |
@@ -102,9 +102,2 @@ import { FirebaseMessaging } from '@firebase/messaging-types'; | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| * @private | ||
| * @param {ServiceWorkerRegistration} registration | ||
| * @return {Promise<PushSubscription>} | ||
| */ | ||
| getPushSubscription_(swRegistration: any, publicVapidKey: any): any; | ||
| /** | ||
| * This method will set up a message listener to handle | ||
@@ -111,0 +104,0 @@ * events from the service worker that should trigger |
@@ -321,22 +321,2 @@ /** | ||
| /** | ||
| * Gets a PushSubscription for the current user. | ||
| * @private | ||
| * @param {ServiceWorkerRegistration} registration | ||
| * @return {Promise<PushSubscription>} | ||
| */ | ||
| WindowController.prototype.getPushSubscription_ = function (swRegistration, publicVapidKey) { | ||
| // Check for existing subscription first | ||
| var subscription; | ||
| var fcmTokenDetails; | ||
| return swRegistration.pushManager.getSubscription().then(function (subscription) { | ||
| if (subscription) { | ||
| return subscription; | ||
| } | ||
| return swRegistration.pushManager.subscribe({ | ||
| userVisibleOnly: true, | ||
| applicationServerKey: publicVapidKey | ||
| }); | ||
| }); | ||
| }; | ||
| /** | ||
| * This method will set up a message listener to handle | ||
@@ -343,0 +323,0 @@ * events from the service worker that should trigger |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/controllers/window-controller.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;AAGb,OAAO,mBAAmB,MAAM,wBAAwB,CAAC;AACzD,OAAO,MAAM,MAAM,kBAAkB,CAAC;AACtC,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,SAAS,MAAM,sBAAsB,CAAC;AAC7C,OAAO,uBAAuB,MAAM,mCAAmC,CAAC;AACxE,OAAO,UAAU,MAAM,uBAAuB,CAAC;AAC/C,OAAO,mBAAmB,MAAM,mCAAmC,CAAC;AACpE,OAAO,EAAE,eAAe,EAAE,MAAM,gBAAgB,CAAC;AAIjD;IAA8C,4CAAmB;IAc/D;;;OAGG;IACH,0BAAY,GAAG;QAAf,YACE,kBAAM,GAAG,CAAC,SAsCX;QApDO,sBAAgB,GAAG,IAAI,CAAC;QACxB,gBAAU,GAAG,eAAe,CAAC,UAAA,QAAQ;YAC3C,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QACK,2BAAqB,GAAG,IAAI,CAAC;QAC7B,qBAAe,GAAG,eAAe,CAAC,UAAA,QAAQ;YAChD,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QASD;;;WAGG;QACH,KAAI,CAAC,kBAAkB,CAAC;QAExB;;;WAGG;QACH,KAAI,CAAC,qBAAqB,CAAC;QAE3B;;;WAGG;QACH,KAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B;;;WAGG;QACH,KAAI,CAAC,UAAU,GAAG,eAAe,CAAC,UAAA,QAAQ;YACxC,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QAEH;;;WAGG;QACH,KAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC;QAClC,KAAI,CAAC,eAAe,GAAG,eAAe,CAAC,UAAA,QAAQ;YAC7C,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QAEH,KAAI,CAAC,uBAAuB,EAAE,CAAC;;IACjC,CAAC;IAED;;;;;;;;OAQG;IACH,mCAAQ,GAAR;QAAA,iBAWC;QAVC,8CAA8C;QAC9C,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;YACzB,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAC5D,CAAC;QACJ,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC,IAAI,CAAC;YAChC,MAAM,CAAC,iBAAM,QAAQ,YAAE,CAAC;QAC1B,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,yCAAc,GAAd;QAAA,iBAqCC;QApCC,EAAE,CAAC,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAC,CAAC;YAC/B,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;QACpC,CAAC;QAED,IAAM,WAAW,GAAsB,QAAQ,CAAC,aAAa,CAC3D,sBAAsB,CACvB,CAAC;QACF,EAAE,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;YACjB,IAAI,CAAC,qBAAqB,GAAG,OAAO,CAAC,OAAO,EAAE,CAAC;QACjD,CAAC;QAAC,IAAI,CAAC,CAAC;YACN,IAAI,CAAC,qBAAqB,GAAG,KAAK,CAAC,WAAW,CAAC,IAAI,CAAC;iBACjD,IAAI,CAAC,UAAA,QAAQ;gBACZ,MAAM,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;YACzB,CAAC,CAAC;iBACD,KAAK,CAAC;gBACL,gDAAgD;gBAChD,wEAAwE;YAC1E,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,eAAe;gBACnB,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,CAAC,CAAC;oBACrB,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,CAAC,CAAC,CAAC;oBACtC,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,KAAK,cAAc,CAAC,CAAC,CAAC;oBACxD,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,uBAAuB,CACrC,CAAC;gBACJ,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;IACpC,CAAC;IAED;;;;;OAKG;IACG,4CAAiB,GAAvB;;;;gBACE,EAAE,CAAC,CAAE,YAAoB,CAAC,UAAU,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;oBACzE,MAAM,gBAAC;gBACT,CAAC;gBAED,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;wBACjC,IAAM,sBAAsB,GAAG,UAAA,MAAM;4BACnC,EAAE,CAAC,CAAC,MAAM,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;gCAC/C,MAAM,CAAC,OAAO,EAAE,CAAC;4BACnB,CAAC;4BAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,KAAK,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gCACrD,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;4BAAC,IAAI,CAAC,CAAC;gCACN,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;wBACH,CAAC,CAAC;wBAEF,wDAAwD;wBACxD,sDAAsD;wBACtD,uDAAuD;wBACvD,IAAM,iBAAiB,GAAG,YAAY,CAAC,iBAAiB,CACtD,sBAAsB,CACvB,CAAC;wBACF,EAAE,CAAC,CAAC,iBAAiB,CAAC,CAAC,CAAC;4BACtB,qDAAqD;4BACrD,iBAAiB,CAAC,IAAI,CAAC,sBAAsB,CAAC,CAAC;wBACjD,CAAC;oBACH,CAAC,CAAC,EAAC;;;KACJ;IAED;;;;;;OAMG;IACH,2CAAgB,GAAhB,UAAiB,YAAY;QAC3B,EAAE,CAAC,CAAC,CAAC,CAAC,YAAY,YAAY,yBAAyB,CAAC,CAAC,CAAC,CAAC;YACzD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,kBAAkB,KAAK,WAAW,CAAC,CAAC,CAAC;YACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,uBAAuB,CAAC,CAAC;QACxE,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;IACzC,CAAC;IAED;;;;;OAKG;IACH,4CAAiB,GAAjB,UAAkB,SAAS;QACzB,EAAE,CAAC,CAAC,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC;YAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,oBAAoB,KAAK,WAAW,CAAC,CAAC,CAAC;YACrD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,+BAA+B,CAC7C,CAAC;QACJ,CAAC;QAED,IAAM,SAAS,GAAG,mBAAmB,CAAC,SAAS,CAAC,CAAC;QAEjD,EAAE,CAAC,CAAC,SAAS,CAAC,MAAM,KAAK,EAAE,CAAC,CAAC,CAAC;YAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,4BAA4B,CAC1C,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,oBAAoB,GAAG,SAAS,CAAC;IACxC,CAAC;IAED;;;;;;;;;OASG;IACH,oCAAS,GAAT,UAAU,cAAc,EAAE,QAAS,EAAE,YAAa;QAChD,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACjE,CAAC;IAED;;;;;;;;;OASG;IACH,yCAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,CAAC,IAAI,CAAC,eAAe,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACtE,CAAC;IAED;;;;;;;;OAQG;IACH,yDAA8B,GAA9B,UAA+B,YAAY;QAA3C,iBAmCC;QAlCC,IAAM,aAAa,GACjB,YAAY,CAAC,UAAU,IAAI,YAAY,CAAC,OAAO,IAAI,YAAY,CAAC,MAAM,CAAC;QAEzE,MAAM,CAAC,IAAI,OAAO,CAA4B,UAAC,OAAO,EAAE,MAAM;YAC5D,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC;gBACnB,qDAAqD;gBACrD,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,CAAC;gBAC7D,MAAM,CAAC;YACT,CAAC;YACD,iEAAiE;YACjE,mEAAmE;YACnE,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACtB,MAAM,CAAC;YACT,CAAC;YAED,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACjE,MAAM,CAAC;YACT,CAAC;YAED,IAAI,mBAAmB,GAAG;gBACxB,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBAC/C,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACnE,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,6CAA6C;oBAC7C,MAAM,CAAC;gBACT,CAAC;gBACD,aAAa,CAAC,mBAAmB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;YACxE,CAAC,CAAC;YACF,aAAa,CAAC,gBAAgB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;OAKG;IACH,6CAAkB,GAAlB;QAAA,iBAiCC;QAhCC,EAAE,CAAC,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC,CAAC;YAC5B,MAAM,CAAC,IAAI,CAAC,8BAA8B,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC;QACtE,CAAC;QAED,kEAAkE;QAClE,wEAAwE;QACxE,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;QAE/B,MAAM,CAAC,SAAS,CAAC,aAAa;aAC3B,QAAQ,CAAC,SAAS,CAAC,IAAI,EAAE;YACxB,KAAK,EAAE,SAAS,CAAC,KAAK;SACvB,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,2BAA2B,EACxC;gBACE,mBAAmB,EAAE,GAAG,CAAC,OAAO;aACjC,CACF,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,MAAM,CAAC,KAAI,CAAC,8BAA8B,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC;gBAC5D,KAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;gBAEvC,oEAAoE;gBACpE,gEAAgE;gBAChE,UAAU;gBACV,YAAY,CAAC,MAAM,EAAE,CAAC;gBAEtB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;OAIG;IACH,6CAAkB,GAAlB;QACE,EAAE,CAAC,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC,CAAC;YAC9B,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC;QACpD,CAAC;QAED,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,wBAAwB,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;OAKG;IACH,+CAAoB,GAApB,UAAqB,cAAc,EAAE,cAAc;QACjD,wCAAwC;QACxC,IAAI,YAAY,CAAC;QACjB,IAAI,eAAe,CAAC;QACpB,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,eAAe,EAAE,CAAC,IAAI,CAAC,UAAA,YAAY;YACnE,EAAE,CAAC,CAAC,YAAY,CAAC,CAAC,CAAC;gBACjB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC;YAED,MAAM,CAAC,cAAc,CAAC,WAAW,CAAC,SAAS,CAAC;gBAC1C,eAAe,EAAE,IAAI;gBACrB,oBAAoB,EAAE,cAAc;aACrC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,kDAAuB,GAAvB;QAAA,iBA8BC;QA7BC,EAAE,CAAC,CAAC,CAAC,CAAC,eAAe,IAAI,SAAS,CAAC,CAAC,CAAC,CAAC;YACpC,MAAM,CAAC;QACT,CAAC;QAED,SAAS,CAAC,aAAa,CAAC,gBAAgB,CACtC,SAAS,EACT,UAAA,KAAK;YACH,EAAE,CAAC,CAAC,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,iBAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBACrE,yBAAyB;gBACzB,MAAM,CAAC;YACT,CAAC;YAED,IAAM,iBAAiB,GAAG,KAAK,CAAC,IAAI,CAAC;YACrC,MAAM,CAAC,CAAC,iBAAiB,CAAC,iBAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBAChE,KAAK,iBAAiB,CAAC,YAAY,CAAC,iBAAiB,CAAC;gBACtD,KAAK,iBAAiB,CAAC,YAAY,CAAC,oBAAoB;oBACtD,IAAM,WAAW,GACf,iBAAiB,CAAC,iBAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;oBACnD,EAAE,CAAC,CAAC,KAAI,CAAC,gBAAgB,CAAC,CAAC,CAAC;wBAC1B,KAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;oBAC1C,CAAC;oBACD,KAAK,CAAC;gBACR;oBACE,QAAQ;oBACR,KAAK,CAAC;YACV,CAAC;QACH,CAAC,EACD,KAAK,CACN,CAAC;IACJ,CAAC;IAED;;;;OAIG;IACH,uCAAY,GAAZ;QACE,MAAM,CAAC,CACL,eAAe,IAAI,SAAS;YAC5B,aAAa,IAAI,MAAM;YACvB,cAAc,IAAI,MAAM;YACxB,OAAO,IAAI,MAAM;YACjB,yBAAyB,CAAC,SAAS,CAAC,cAAc,CAAC,kBAAkB,CAAC;YACtE,gBAAgB,CAAC,SAAS,CAAC,cAAc,CAAC,QAAQ,CAAC,CACpD,CAAC;IACJ,CAAC;IACH,uBAAC;AAAD,CAjaA,AAiaC,CAja6C,mBAAmB,GAiahE","file":"window-controller.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { FirebaseMessaging } from '@firebase/messaging-types';\nimport ControllerInterface from './controller-interface';\nimport Errors from '../models/errors';\nimport WorkerPageMessage from '../models/worker-page-message';\nimport DefaultSW from '../models/default-sw';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport FCMDetails from '../models/fcm-details';\nimport base64ToArrayBuffer from '../helpers/base64-to-array-buffer';\nimport { createSubscribe } from '@firebase/util';\n\ndeclare const firebase: any;\n\nexport default class WindowController extends ControllerInterface\n implements FirebaseMessaging {\n private registrationToUse_;\n private publicVapidKeyToUse_;\n private manifestCheckPromise_;\n private messageObserver_ = null;\n private onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n private tokenRefreshObserver_ = null;\n private onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n /**\n * A service that provides a MessagingService instance.\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n super(app);\n\n /**\n * @private\n * @type {ServiceWorkerRegistration}\n */\n this.registrationToUse_;\n\n /**\n * @private\n * @type {Promise}\n */\n this.manifestCheckPromise_;\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.messageObserver_ = null;\n\n /**\n * @private {!firebase.Subscribe} The subscribe function to the onMessage\n * observer.\n */\n this.onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.tokenRefreshObserver_ = null;\n this.onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n this.setupSWMessageListener_();\n }\n\n /**\n * This method returns an FCM token if it can be generated.\n * The return promise will reject if the browser doesn't support\n * FCM, if permission is denied for notifications or it's not\n * possible to generate a token.\n * @export\n * @return {Promise<string> | Promise<null>} Returns a promise the\n * resolves to an FCM token or null if permission isn't granted.\n */\n getToken() {\n // Check that the required API's are available\n if (!this.isSupported_()) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.UNSUPPORTED_BROWSER)\n );\n }\n\n return this.manifestCheck_().then(() => {\n return super.getToken();\n });\n }\n\n /**\n * The method checks that a manifest is defined and has the correct GCM\n * sender ID.\n * @private\n * @return {Promise} Returns a promise that resolves if the manifest matches\n * our required sender ID\n */\n manifestCheck_() {\n if (this.manifestCheckPromise_) {\n return this.manifestCheckPromise_;\n }\n\n const manifestTag = <HTMLAnchorElement>document.querySelector(\n 'link[rel=\"manifest\"]'\n );\n if (!manifestTag) {\n this.manifestCheckPromise_ = Promise.resolve();\n } else {\n this.manifestCheckPromise_ = fetch(manifestTag.href)\n .then(response => {\n return response.json();\n })\n .catch(() => {\n // If the download or parsing fails allow check.\n // We only want to error if we KNOW that the gcm_sender_id is incorrect.\n })\n .then(manifestContent => {\n if (!manifestContent) {\n return;\n }\n\n if (!manifestContent['gcm_sender_id']) {\n return;\n }\n\n if (manifestContent['gcm_sender_id'] !== '103953800507') {\n throw this.errorFactory_.create(\n Errors.codes.INCORRECT_GCM_SENDER_ID\n );\n }\n });\n }\n\n return this.manifestCheckPromise_;\n }\n\n /**\n * Request permission if it is not currently granted\n * @export\n * @returns {Promise} Resolves if the permission was granted, otherwise\n * rejects\n */\n async requestPermission() {\n if ((Notification as any).permission === NOTIFICATION_PERMISSION.granted) {\n return;\n }\n\n return new Promise((resolve, reject) => {\n const managePermissionResult = result => {\n if (result === NOTIFICATION_PERMISSION.granted) {\n return resolve();\n } else if (result === NOTIFICATION_PERMISSION.denied) {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_BLOCKED)\n );\n } else {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_DEFAULT)\n );\n }\n };\n\n // The Notification.requestPermission API was changed to\n // return a promise so now have to handle both in case\n // browsers stop support callbacks for promised version\n const permissionPromise = Notification.requestPermission(\n managePermissionResult\n );\n if (permissionPromise) {\n // Prefer the promise version as it's the future API.\n permissionPromise.then(managePermissionResult);\n }\n });\n }\n\n /**\n * This method allows a developer to override the default service worker and\n * instead use a custom service worker.\n * @export\n * @param {!ServiceWorkerRegistration} registration The service worker\n * registration that should be used to receive the push messages.\n */\n useServiceWorker(registration) {\n if (!(registration instanceof ServiceWorkerRegistration)) {\n throw this.errorFactory_.create(Errors.codes.SW_REGISTRATION_EXPECTED);\n }\n\n if (typeof this.registrationToUse_ !== 'undefined') {\n throw this.errorFactory_.create(Errors.codes.USE_SW_BEFORE_GET_TOKEN);\n }\n\n this.registrationToUse_ = registration;\n }\n\n /**\n * This method allows a developer to override the default vapid key\n * and instead use a custom VAPID public key.\n * @export\n * @param {!string} publicKey A URL safe base64 encoded string.\n */\n usePublicVapidKey(publicKey) {\n if (typeof publicKey !== 'string') {\n throw this.errorFactory_.create(Errors.codes.INVALID_PUBLIC_VAPID_KEY);\n }\n\n if (typeof this.publicVapidKeyToUse_ !== 'undefined') {\n throw this.errorFactory_.create(\n Errors.codes.USE_PUBLIC_KEY_BEFORE_GET_TOKEN\n );\n }\n\n const parsedKey = base64ToArrayBuffer(publicKey);\n\n if (parsedKey.length !== 65) {\n throw this.errorFactory_.create(\n Errors.codes.PUBLIC_KEY_DECRYPTION_FAILED\n );\n }\n\n this.publicVapidKeyToUse_ = parsedKey;\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver An observer object\n * or a function triggered on message.\n * @param {function(!Error)=} optError Optional A function triggered on\n * message error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onMessage(nextOrObserver, optError?, optCompleted?) {\n return this.onMessage_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n return this.onTokenRefresh_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * Given a registration, wait for the service worker it relates to\n * become activer\n * @private\n * @param {ServiceWorkerRegistration} registration Registration to wait\n * for service worker to become active\n * @return {Promise<!ServiceWorkerRegistration>} Wait for service worker\n * registration to become active\n */\n waitForRegistrationToActivate_(registration) {\n const serviceWorker =\n registration.installing || registration.waiting || registration.active;\n\n return new Promise<ServiceWorkerRegistration>((resolve, reject) => {\n if (!serviceWorker) {\n // This is a rare scenario but has occured in firefox\n reject(this.errorFactory_.create(Errors.codes.NO_SW_IN_REG));\n return;\n }\n // Because the Promise function is called on next tick there is a\n // small chance that the worker became active or redundant already.\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n return;\n }\n\n if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n return;\n }\n\n let stateChangeListener = () => {\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n } else if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n } else {\n // Return early and wait to next state change\n return;\n }\n serviceWorker.removeEventListener('statechange', stateChangeListener);\n };\n serviceWorker.addEventListener('statechange', stateChangeListener);\n });\n }\n\n /**\n * This will regiater the default service worker and return the registration\n * @private\n * @return {Promise<!ServiceWorkerRegistration>} The service worker\n * registration to be used for the push service.\n */\n getSWRegistration_() {\n if (this.registrationToUse_) {\n return this.waitForRegistrationToActivate_(this.registrationToUse_);\n }\n\n // Make the registration null so we know useServiceWorker will not\n // use a new service worker as registrationToUse_ is no longer undefined\n this.registrationToUse_ = null;\n\n return navigator.serviceWorker\n .register(DefaultSW.path, {\n scope: DefaultSW.scope\n })\n .catch(err => {\n throw this.errorFactory_.create(\n Errors.codes.FAILED_DEFAULT_REGISTRATION,\n {\n browserErrorMessage: err.message\n }\n );\n })\n .then(registration => {\n return this.waitForRegistrationToActivate_(registration).then(() => {\n this.registrationToUse_ = registration;\n\n // We update after activation due to an issue with Firefox v49 where\n // a race condition occassionally causes the service work to not\n // install\n registration.update();\n\n return registration;\n });\n });\n }\n\n /**\n * This will return the default VAPID key or the uint8array version of the public VAPID key\n * provided by the developer.\n * @private\n */\n getPublicVapidKey_(): Promise<Uint8Array> {\n if (this.publicVapidKeyToUse_) {\n return Promise.resolve(this.publicVapidKeyToUse_);\n }\n\n return Promise.resolve(FCMDetails.DEFAULT_PUBLIC_VAPID_KEY);\n }\n\n /**\n * Gets a PushSubscription for the current user.\n * @private\n * @param {ServiceWorkerRegistration} registration\n * @return {Promise<PushSubscription>}\n */\n getPushSubscription_(swRegistration, publicVapidKey) {\n // Check for existing subscription first\n let subscription;\n let fcmTokenDetails;\n return swRegistration.pushManager.getSubscription().then(subscription => {\n if (subscription) {\n return subscription;\n }\n\n return swRegistration.pushManager.subscribe({\n userVisibleOnly: true,\n applicationServerKey: publicVapidKey\n });\n });\n }\n\n /**\n * This method will set up a message listener to handle\n * events from the service worker that should trigger\n * events in the page.\n *\n * @private\n */\n setupSWMessageListener_() {\n if (!('serviceWorker' in navigator)) {\n return;\n }\n\n navigator.serviceWorker.addEventListener(\n 'message',\n event => {\n if (!event.data || !event.data[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n // Not a message from FCM\n return;\n }\n\n const workerPageMessage = event.data;\n switch (workerPageMessage[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n case WorkerPageMessage.TYPES_OF_MSG.PUSH_MSG_RECEIVED:\n case WorkerPageMessage.TYPES_OF_MSG.NOTIFICATION_CLICKED:\n const pushMessage =\n workerPageMessage[WorkerPageMessage.PARAMS.DATA];\n if (this.messageObserver_) {\n this.messageObserver_.next(pushMessage);\n }\n break;\n default:\n // Noop.\n break;\n }\n },\n false\n );\n }\n\n /**\n * Checks to see if the required API's are valid or not.\n * @private\n * @return {boolean} Returns true if the desired APIs are available.\n */\n isSupported_() {\n return (\n 'serviceWorker' in navigator &&\n 'PushManager' in window &&\n 'Notification' in window &&\n 'fetch' in window &&\n ServiceWorkerRegistration.prototype.hasOwnProperty('showNotification') &&\n PushSubscription.prototype.hasOwnProperty('getKey')\n );\n }\n}\n"]} | ||
| {"version":3,"sources":["../src/controllers/window-controller.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;GAcG;AACH,YAAY,CAAC;;AAGb,OAAO,mBAAmB,MAAM,wBAAwB,CAAC;AACzD,OAAO,MAAM,MAAM,kBAAkB,CAAC;AACtC,OAAO,iBAAiB,MAAM,+BAA+B,CAAC;AAC9D,OAAO,SAAS,MAAM,sBAAsB,CAAC;AAC7C,OAAO,uBAAuB,MAAM,mCAAmC,CAAC;AACxE,OAAO,UAAU,MAAM,uBAAuB,CAAC;AAC/C,OAAO,mBAAmB,MAAM,mCAAmC,CAAC;AACpE,OAAO,EAAE,eAAe,EAAE,MAAM,gBAAgB,CAAC;AAIjD;IAA8C,4CAAmB;IAc/D;;;OAGG;IACH,0BAAY,GAAG;QAAf,YACE,kBAAM,GAAG,CAAC,SAsCX;QApDO,sBAAgB,GAAG,IAAI,CAAC;QACxB,gBAAU,GAAG,eAAe,CAAC,UAAA,QAAQ;YAC3C,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QACK,2BAAqB,GAAG,IAAI,CAAC;QAC7B,qBAAe,GAAG,eAAe,CAAC,UAAA,QAAQ;YAChD,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QASD;;;WAGG;QACH,KAAI,CAAC,kBAAkB,CAAC;QAExB;;;WAGG;QACH,KAAI,CAAC,qBAAqB,CAAC;QAE3B;;;WAGG;QACH,KAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B;;;WAGG;QACH,KAAI,CAAC,UAAU,GAAG,eAAe,CAAC,UAAA,QAAQ;YACxC,KAAI,CAAC,gBAAgB,GAAG,QAAQ,CAAC;QACnC,CAAC,CAAC,CAAC;QAEH;;;WAGG;QACH,KAAI,CAAC,qBAAqB,GAAG,IAAI,CAAC;QAClC,KAAI,CAAC,eAAe,GAAG,eAAe,CAAC,UAAA,QAAQ;YAC7C,KAAI,CAAC,qBAAqB,GAAG,QAAQ,CAAC;QACxC,CAAC,CAAC,CAAC;QAEH,KAAI,CAAC,uBAAuB,EAAE,CAAC;;IACjC,CAAC;IAED;;;;;;;;OAQG;IACH,mCAAQ,GAAR;QAAA,iBAWC;QAVC,8CAA8C;QAC9C,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;YACzB,MAAM,CAAC,OAAO,CAAC,MAAM,CACnB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,CAAC,CAC5D,CAAC;QACJ,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC,IAAI,CAAC;YAChC,MAAM,CAAC,iBAAM,QAAQ,YAAE,CAAC;QAC1B,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;OAMG;IACH,yCAAc,GAAd;QAAA,iBAqCC;QApCC,EAAE,CAAC,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAC,CAAC;YAC/B,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;QACpC,CAAC;QAED,IAAM,WAAW,GAAsB,QAAQ,CAAC,aAAa,CAC3D,sBAAsB,CACvB,CAAC;QACF,EAAE,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;YACjB,IAAI,CAAC,qBAAqB,GAAG,OAAO,CAAC,OAAO,EAAE,CAAC;QACjD,CAAC;QAAC,IAAI,CAAC,CAAC;YACN,IAAI,CAAC,qBAAqB,GAAG,KAAK,CAAC,WAAW,CAAC,IAAI,CAAC;iBACjD,IAAI,CAAC,UAAA,QAAQ;gBACZ,MAAM,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;YACzB,CAAC,CAAC;iBACD,KAAK,CAAC;gBACL,gDAAgD;gBAChD,wEAAwE;YAC1E,CAAC,CAAC;iBACD,IAAI,CAAC,UAAA,eAAe;gBACnB,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,CAAC,CAAC;oBACrB,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,CAAC,CAAC,CAAC;oBACtC,MAAM,CAAC;gBACT,CAAC;gBAED,EAAE,CAAC,CAAC,eAAe,CAAC,eAAe,CAAC,KAAK,cAAc,CAAC,CAAC,CAAC;oBACxD,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,uBAAuB,CACrC,CAAC;gBACJ,CAAC;YACH,CAAC,CAAC,CAAC;QACP,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,qBAAqB,CAAC;IACpC,CAAC;IAED;;;;;OAKG;IACG,4CAAiB,GAAvB;;;;gBACE,EAAE,CAAC,CAAE,YAAoB,CAAC,UAAU,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;oBACzE,MAAM,gBAAC;gBACT,CAAC;gBAED,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;wBACjC,IAAM,sBAAsB,GAAG,UAAA,MAAM;4BACnC,EAAE,CAAC,CAAC,MAAM,KAAK,uBAAuB,CAAC,OAAO,CAAC,CAAC,CAAC;gCAC/C,MAAM,CAAC,OAAO,EAAE,CAAC;4BACnB,CAAC;4BAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,KAAK,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;gCACrD,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;4BAAC,IAAI,CAAC,CAAC;gCACN,MAAM,CAAC,MAAM,CACX,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAC3D,CAAC;4BACJ,CAAC;wBACH,CAAC,CAAC;wBAEF,wDAAwD;wBACxD,sDAAsD;wBACtD,uDAAuD;wBACvD,IAAM,iBAAiB,GAAG,YAAY,CAAC,iBAAiB,CACtD,sBAAsB,CACvB,CAAC;wBACF,EAAE,CAAC,CAAC,iBAAiB,CAAC,CAAC,CAAC;4BACtB,qDAAqD;4BACrD,iBAAiB,CAAC,IAAI,CAAC,sBAAsB,CAAC,CAAC;wBACjD,CAAC;oBACH,CAAC,CAAC,EAAC;;;KACJ;IAED;;;;;;OAMG;IACH,2CAAgB,GAAhB,UAAiB,YAAY;QAC3B,EAAE,CAAC,CAAC,CAAC,CAAC,YAAY,YAAY,yBAAyB,CAAC,CAAC,CAAC,CAAC;YACzD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,kBAAkB,KAAK,WAAW,CAAC,CAAC,CAAC;YACnD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,uBAAuB,CAAC,CAAC;QACxE,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;IACzC,CAAC;IAED;;;;;OAKG;IACH,4CAAiB,GAAjB,UAAkB,SAAS;QACzB,EAAE,CAAC,CAAC,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC;YAClC,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;QACzE,CAAC;QAED,EAAE,CAAC,CAAC,OAAO,IAAI,CAAC,oBAAoB,KAAK,WAAW,CAAC,CAAC,CAAC;YACrD,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,+BAA+B,CAC7C,CAAC;QACJ,CAAC;QAED,IAAM,SAAS,GAAG,mBAAmB,CAAC,SAAS,CAAC,CAAC;QAEjD,EAAE,CAAC,CAAC,SAAS,CAAC,MAAM,KAAK,EAAE,CAAC,CAAC,CAAC;YAC5B,MAAM,IAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,4BAA4B,CAC1C,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,oBAAoB,GAAG,SAAS,CAAC;IACxC,CAAC;IAED;;;;;;;;;OASG;IACH,oCAAS,GAAT,UAAU,cAAc,EAAE,QAAS,EAAE,YAAa;QAChD,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACjE,CAAC;IAED;;;;;;;;;OASG;IACH,yCAAc,GAAd,UAAe,cAAc,EAAE,QAAQ,EAAE,YAAY;QACnD,MAAM,CAAC,IAAI,CAAC,eAAe,CAAC,cAAc,EAAE,QAAQ,EAAE,YAAY,CAAC,CAAC;IACtE,CAAC;IAED;;;;;;;;OAQG;IACH,yDAA8B,GAA9B,UAA+B,YAAY;QAA3C,iBAmCC;QAlCC,IAAM,aAAa,GACjB,YAAY,CAAC,UAAU,IAAI,YAAY,CAAC,OAAO,IAAI,YAAY,CAAC,MAAM,CAAC;QAEzE,MAAM,CAAC,IAAI,OAAO,CAA4B,UAAC,OAAO,EAAE,MAAM;YAC5D,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC;gBACnB,qDAAqD;gBACrD,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,CAAC;gBAC7D,MAAM,CAAC;YACT,CAAC;YACD,iEAAiE;YACjE,mEAAmE;YACnE,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACtB,MAAM,CAAC;YACT,CAAC;YAED,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;gBACxC,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACjE,MAAM,CAAC;YACT,CAAC;YAED,IAAI,mBAAmB,GAAG;gBACxB,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBACxC,OAAO,CAAC,YAAY,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,EAAE,CAAC,CAAC,aAAa,CAAC,KAAK,KAAK,WAAW,CAAC,CAAC,CAAC;oBAC/C,MAAM,CAAC,KAAI,CAAC,aAAa,CAAC,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC,CAAC;gBACnE,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACN,6CAA6C;oBAC7C,MAAM,CAAC;gBACT,CAAC;gBACD,aAAa,CAAC,mBAAmB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;YACxE,CAAC,CAAC;YACF,aAAa,CAAC,gBAAgB,CAAC,aAAa,EAAE,mBAAmB,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;OAKG;IACH,6CAAkB,GAAlB;QAAA,iBAiCC;QAhCC,EAAE,CAAC,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC,CAAC;YAC5B,MAAM,CAAC,IAAI,CAAC,8BAA8B,CAAC,IAAI,CAAC,kBAAkB,CAAC,CAAC;QACtE,CAAC;QAED,kEAAkE;QAClE,wEAAwE;QACxE,IAAI,CAAC,kBAAkB,GAAG,IAAI,CAAC;QAE/B,MAAM,CAAC,SAAS,CAAC,aAAa;aAC3B,QAAQ,CAAC,SAAS,CAAC,IAAI,EAAE;YACxB,KAAK,EAAE,SAAS,CAAC,KAAK;SACvB,CAAC;aACD,KAAK,CAAC,UAAA,GAAG;YACR,MAAM,KAAI,CAAC,aAAa,CAAC,MAAM,CAC7B,MAAM,CAAC,KAAK,CAAC,2BAA2B,EACxC;gBACE,mBAAmB,EAAE,GAAG,CAAC,OAAO;aACjC,CACF,CAAC;QACJ,CAAC,CAAC;aACD,IAAI,CAAC,UAAA,YAAY;YAChB,MAAM,CAAC,KAAI,CAAC,8BAA8B,CAAC,YAAY,CAAC,CAAC,IAAI,CAAC;gBAC5D,KAAI,CAAC,kBAAkB,GAAG,YAAY,CAAC;gBAEvC,oEAAoE;gBACpE,gEAAgE;gBAChE,UAAU;gBACV,YAAY,CAAC,MAAM,EAAE,CAAC;gBAEtB,MAAM,CAAC,YAAY,CAAC;YACtB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;;;OAIG;IACH,6CAAkB,GAAlB;QACE,EAAE,CAAC,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC,CAAC;YAC9B,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,oBAAoB,CAAC,CAAC;QACpD,CAAC;QAED,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,wBAAwB,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;;OAMG;IACH,kDAAuB,GAAvB;QAAA,iBA8BC;QA7BC,EAAE,CAAC,CAAC,CAAC,CAAC,eAAe,IAAI,SAAS,CAAC,CAAC,CAAC,CAAC;YACpC,MAAM,CAAC;QACT,CAAC;QAED,SAAS,CAAC,aAAa,CAAC,gBAAgB,CACtC,SAAS,EACT,UAAA,KAAK;YACH,EAAE,CAAC,CAAC,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,iBAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBACrE,yBAAyB;gBACzB,MAAM,CAAC;YACT,CAAC;YAED,IAAM,iBAAiB,GAAG,KAAK,CAAC,IAAI,CAAC;YACrC,MAAM,CAAC,CAAC,iBAAiB,CAAC,iBAAiB,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;gBAChE,KAAK,iBAAiB,CAAC,YAAY,CAAC,iBAAiB,CAAC;gBACtD,KAAK,iBAAiB,CAAC,YAAY,CAAC,oBAAoB;oBACtD,IAAM,WAAW,GACf,iBAAiB,CAAC,iBAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;oBACnD,EAAE,CAAC,CAAC,KAAI,CAAC,gBAAgB,CAAC,CAAC,CAAC;wBAC1B,KAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;oBAC1C,CAAC;oBACD,KAAK,CAAC;gBACR;oBACE,QAAQ;oBACR,KAAK,CAAC;YACV,CAAC;QACH,CAAC,EACD,KAAK,CACN,CAAC;IACJ,CAAC;IAED;;;;OAIG;IACH,uCAAY,GAAZ;QACE,MAAM,CAAC,CACL,eAAe,IAAI,SAAS;YAC5B,aAAa,IAAI,MAAM;YACvB,cAAc,IAAI,MAAM;YACxB,OAAO,IAAI,MAAM;YACjB,yBAAyB,CAAC,SAAS,CAAC,cAAc,CAAC,kBAAkB,CAAC;YACtE,gBAAgB,CAAC,SAAS,CAAC,cAAc,CAAC,QAAQ,CAAC,CACpD,CAAC;IACJ,CAAC;IACH,uBAAC;AAAD,CA3YA,AA2YC,CA3Y6C,mBAAmB,GA2YhE","file":"window-controller.js","sourcesContent":["/**\n * Copyright 2017 Google Inc.\n *\n * Licensed under the Apache License, Version 2.0 (the \"License\");\n * you may not use this file except in compliance with the License.\n * You may obtain a copy of the License at\n *\n * http://www.apache.org/licenses/LICENSE-2.0\n *\n * Unless required by applicable law or agreed to in writing, software\n * distributed under the License is distributed on an \"AS IS\" BASIS,\n * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n * See the License for the specific language governing permissions and\n * limitations under the License.\n */\n'use strict';\n\nimport { FirebaseMessaging } from '@firebase/messaging-types';\nimport ControllerInterface from './controller-interface';\nimport Errors from '../models/errors';\nimport WorkerPageMessage from '../models/worker-page-message';\nimport DefaultSW from '../models/default-sw';\nimport NOTIFICATION_PERMISSION from '../models/notification-permission';\nimport FCMDetails from '../models/fcm-details';\nimport base64ToArrayBuffer from '../helpers/base64-to-array-buffer';\nimport { createSubscribe } from '@firebase/util';\n\ndeclare const firebase: any;\n\nexport default class WindowController extends ControllerInterface\n implements FirebaseMessaging {\n private registrationToUse_;\n private publicVapidKeyToUse_;\n private manifestCheckPromise_;\n private messageObserver_ = null;\n private onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n private tokenRefreshObserver_ = null;\n private onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n /**\n * A service that provides a MessagingService instance.\n * @param {!firebase.app.App} app\n */\n constructor(app) {\n super(app);\n\n /**\n * @private\n * @type {ServiceWorkerRegistration}\n */\n this.registrationToUse_;\n\n /**\n * @private\n * @type {Promise}\n */\n this.manifestCheckPromise_;\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.messageObserver_ = null;\n\n /**\n * @private {!firebase.Subscribe} The subscribe function to the onMessage\n * observer.\n */\n this.onMessage_ = createSubscribe(observer => {\n this.messageObserver_ = observer;\n });\n\n /**\n * @private\n * @type {firebase.Observer}\n */\n this.tokenRefreshObserver_ = null;\n this.onTokenRefresh_ = createSubscribe(observer => {\n this.tokenRefreshObserver_ = observer;\n });\n\n this.setupSWMessageListener_();\n }\n\n /**\n * This method returns an FCM token if it can be generated.\n * The return promise will reject if the browser doesn't support\n * FCM, if permission is denied for notifications or it's not\n * possible to generate a token.\n * @export\n * @return {Promise<string> | Promise<null>} Returns a promise the\n * resolves to an FCM token or null if permission isn't granted.\n */\n getToken() {\n // Check that the required API's are available\n if (!this.isSupported_()) {\n return Promise.reject(\n this.errorFactory_.create(Errors.codes.UNSUPPORTED_BROWSER)\n );\n }\n\n return this.manifestCheck_().then(() => {\n return super.getToken();\n });\n }\n\n /**\n * The method checks that a manifest is defined and has the correct GCM\n * sender ID.\n * @private\n * @return {Promise} Returns a promise that resolves if the manifest matches\n * our required sender ID\n */\n manifestCheck_() {\n if (this.manifestCheckPromise_) {\n return this.manifestCheckPromise_;\n }\n\n const manifestTag = <HTMLAnchorElement>document.querySelector(\n 'link[rel=\"manifest\"]'\n );\n if (!manifestTag) {\n this.manifestCheckPromise_ = Promise.resolve();\n } else {\n this.manifestCheckPromise_ = fetch(manifestTag.href)\n .then(response => {\n return response.json();\n })\n .catch(() => {\n // If the download or parsing fails allow check.\n // We only want to error if we KNOW that the gcm_sender_id is incorrect.\n })\n .then(manifestContent => {\n if (!manifestContent) {\n return;\n }\n\n if (!manifestContent['gcm_sender_id']) {\n return;\n }\n\n if (manifestContent['gcm_sender_id'] !== '103953800507') {\n throw this.errorFactory_.create(\n Errors.codes.INCORRECT_GCM_SENDER_ID\n );\n }\n });\n }\n\n return this.manifestCheckPromise_;\n }\n\n /**\n * Request permission if it is not currently granted\n * @export\n * @returns {Promise} Resolves if the permission was granted, otherwise\n * rejects\n */\n async requestPermission() {\n if ((Notification as any).permission === NOTIFICATION_PERMISSION.granted) {\n return;\n }\n\n return new Promise((resolve, reject) => {\n const managePermissionResult = result => {\n if (result === NOTIFICATION_PERMISSION.granted) {\n return resolve();\n } else if (result === NOTIFICATION_PERMISSION.denied) {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_BLOCKED)\n );\n } else {\n return reject(\n this.errorFactory_.create(Errors.codes.PERMISSION_DEFAULT)\n );\n }\n };\n\n // The Notification.requestPermission API was changed to\n // return a promise so now have to handle both in case\n // browsers stop support callbacks for promised version\n const permissionPromise = Notification.requestPermission(\n managePermissionResult\n );\n if (permissionPromise) {\n // Prefer the promise version as it's the future API.\n permissionPromise.then(managePermissionResult);\n }\n });\n }\n\n /**\n * This method allows a developer to override the default service worker and\n * instead use a custom service worker.\n * @export\n * @param {!ServiceWorkerRegistration} registration The service worker\n * registration that should be used to receive the push messages.\n */\n useServiceWorker(registration) {\n if (!(registration instanceof ServiceWorkerRegistration)) {\n throw this.errorFactory_.create(Errors.codes.SW_REGISTRATION_EXPECTED);\n }\n\n if (typeof this.registrationToUse_ !== 'undefined') {\n throw this.errorFactory_.create(Errors.codes.USE_SW_BEFORE_GET_TOKEN);\n }\n\n this.registrationToUse_ = registration;\n }\n\n /**\n * This method allows a developer to override the default vapid key\n * and instead use a custom VAPID public key.\n * @export\n * @param {!string} publicKey A URL safe base64 encoded string.\n */\n usePublicVapidKey(publicKey) {\n if (typeof publicKey !== 'string') {\n throw this.errorFactory_.create(Errors.codes.INVALID_PUBLIC_VAPID_KEY);\n }\n\n if (typeof this.publicVapidKeyToUse_ !== 'undefined') {\n throw this.errorFactory_.create(\n Errors.codes.USE_PUBLIC_KEY_BEFORE_GET_TOKEN\n );\n }\n\n const parsedKey = base64ToArrayBuffer(publicKey);\n\n if (parsedKey.length !== 65) {\n throw this.errorFactory_.create(\n Errors.codes.PUBLIC_KEY_DECRYPTION_FAILED\n );\n }\n\n this.publicVapidKeyToUse_ = parsedKey;\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function(*)} nextOrObserver An observer object\n * or a function triggered on message.\n * @param {function(!Error)=} optError Optional A function triggered on\n * message error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onMessage(nextOrObserver, optError?, optCompleted?) {\n return this.onMessage_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * @export\n * @param {!firebase.Observer|function()} nextOrObserver An observer object\n * or a function triggered on token refresh.\n * @param {function(!Error)=} optError Optional A function\n * triggered on token refresh error.\n * @param {function()=} optCompleted Optional function triggered when the\n * observer is removed.\n * @return {!function()} The unsubscribe function for the observer.\n */\n onTokenRefresh(nextOrObserver, optError, optCompleted) {\n return this.onTokenRefresh_(nextOrObserver, optError, optCompleted);\n }\n\n /**\n * Given a registration, wait for the service worker it relates to\n * become activer\n * @private\n * @param {ServiceWorkerRegistration} registration Registration to wait\n * for service worker to become active\n * @return {Promise<!ServiceWorkerRegistration>} Wait for service worker\n * registration to become active\n */\n waitForRegistrationToActivate_(registration) {\n const serviceWorker =\n registration.installing || registration.waiting || registration.active;\n\n return new Promise<ServiceWorkerRegistration>((resolve, reject) => {\n if (!serviceWorker) {\n // This is a rare scenario but has occured in firefox\n reject(this.errorFactory_.create(Errors.codes.NO_SW_IN_REG));\n return;\n }\n // Because the Promise function is called on next tick there is a\n // small chance that the worker became active or redundant already.\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n return;\n }\n\n if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n return;\n }\n\n let stateChangeListener = () => {\n if (serviceWorker.state === 'activated') {\n resolve(registration);\n } else if (serviceWorker.state === 'redundant') {\n reject(this.errorFactory_.create(Errors.codes.SW_REG_REDUNDANT));\n } else {\n // Return early and wait to next state change\n return;\n }\n serviceWorker.removeEventListener('statechange', stateChangeListener);\n };\n serviceWorker.addEventListener('statechange', stateChangeListener);\n });\n }\n\n /**\n * This will regiater the default service worker and return the registration\n * @private\n * @return {Promise<!ServiceWorkerRegistration>} The service worker\n * registration to be used for the push service.\n */\n getSWRegistration_() {\n if (this.registrationToUse_) {\n return this.waitForRegistrationToActivate_(this.registrationToUse_);\n }\n\n // Make the registration null so we know useServiceWorker will not\n // use a new service worker as registrationToUse_ is no longer undefined\n this.registrationToUse_ = null;\n\n return navigator.serviceWorker\n .register(DefaultSW.path, {\n scope: DefaultSW.scope\n })\n .catch(err => {\n throw this.errorFactory_.create(\n Errors.codes.FAILED_DEFAULT_REGISTRATION,\n {\n browserErrorMessage: err.message\n }\n );\n })\n .then(registration => {\n return this.waitForRegistrationToActivate_(registration).then(() => {\n this.registrationToUse_ = registration;\n\n // We update after activation due to an issue with Firefox v49 where\n // a race condition occassionally causes the service work to not\n // install\n registration.update();\n\n return registration;\n });\n });\n }\n\n /**\n * This will return the default VAPID key or the uint8array version of the public VAPID key\n * provided by the developer.\n * @private\n */\n getPublicVapidKey_(): Promise<Uint8Array> {\n if (this.publicVapidKeyToUse_) {\n return Promise.resolve(this.publicVapidKeyToUse_);\n }\n\n return Promise.resolve(FCMDetails.DEFAULT_PUBLIC_VAPID_KEY);\n }\n\n /**\n * This method will set up a message listener to handle\n * events from the service worker that should trigger\n * events in the page.\n *\n * @private\n */\n setupSWMessageListener_() {\n if (!('serviceWorker' in navigator)) {\n return;\n }\n\n navigator.serviceWorker.addEventListener(\n 'message',\n event => {\n if (!event.data || !event.data[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n // Not a message from FCM\n return;\n }\n\n const workerPageMessage = event.data;\n switch (workerPageMessage[WorkerPageMessage.PARAMS.TYPE_OF_MSG]) {\n case WorkerPageMessage.TYPES_OF_MSG.PUSH_MSG_RECEIVED:\n case WorkerPageMessage.TYPES_OF_MSG.NOTIFICATION_CLICKED:\n const pushMessage =\n workerPageMessage[WorkerPageMessage.PARAMS.DATA];\n if (this.messageObserver_) {\n this.messageObserver_.next(pushMessage);\n }\n break;\n default:\n // Noop.\n break;\n }\n },\n false\n );\n }\n\n /**\n * Checks to see if the required API's are valid or not.\n * @private\n * @return {boolean} Returns true if the desired APIs are available.\n */\n isSupported_() {\n return (\n 'serviceWorker' in navigator &&\n 'PushManager' in window &&\n 'Notification' in window &&\n 'fetch' in window &&\n ServiceWorkerRegistration.prototype.hasOwnProperty('showNotification') &&\n PushSubscription.prototype.hasOwnProperty('getKey')\n );\n }\n}\n"]} |
+4
-4
| { | ||
| "name": "@firebase/messaging", | ||
| "version": "0.2.2-canary.9d00c6f", | ||
| "version": "0.2.2-canary.ab0faeb", | ||
| "description": "", | ||
@@ -16,7 +16,7 @@ "author": "Firebase <firebase-support@google.com> (https://firebase.google.com/)", | ||
| "peerDependencies": { | ||
| "@firebase/app": "0.1.10-canary.9d00c6f" | ||
| "@firebase/app": "0.1.10-canary.ab0faeb" | ||
| }, | ||
| "dependencies": { | ||
| "@firebase/messaging-types": "0.1.2-canary.9d00c6f", | ||
| "@firebase/util": "0.1.10-canary.9d00c6f", | ||
| "@firebase/messaging-types": "0.1.2-canary.ab0faeb", | ||
| "@firebase/util": "0.1.10-canary.ab0faeb", | ||
| "tslib": "^1.9.0" | ||
@@ -23,0 +23,0 @@ }, |
New alerts
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Fixed alerts
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Worsened metrics
- Total package byte prevSize
479234
-0.44%- Lines of code
5372
-0.48%Dependency changes
+ Added
@firebase/app@0.1.10-canary.ab0faeb(transitive)+ Added
@firebase/app-types@0.1.2-canary.ab0faeb(transitive)+ Added
@firebase/messaging-types@0.1.2-canary.ab0faeb(transitive)+ Added
@firebase/util@0.1.10-canary.ab0faeb(transitive)- Removed
@firebase/app@0.1.10-canary.9d00c6f(transitive)- Removed
@firebase/app-types@0.1.2-canary.9d00c6f(transitive)- Removed
@firebase/messaging-types@0.1.2-canary.9d00c6f(transitive)- Removed
@firebase/util@0.1.10-canary.9d00c6f(transitive)