Drop Node 6 / Replace grpc w/ @grpc/grpc-js

Author: schmidt-sebastian

package.json

@@ -5,12 +5,16 @@
   "private": true,
   "author": "Firebase <[email protected]> (https://firebase.google.com/)",
   "license": "Apache-2.0",
+  "engines": {
+    "node": "^8.13.0 || >=10.10.0"
+  },
   "homepage": "https://github.com/firebase/firebase-js-sdk",
   "keywords": [
     "authentication",
     "database",
     "Firebase",
     "firebase",
+    "firestore",
     "functions",
     "realtime",
     "storage",
@@ -55,7 +59,7 @@
     "@types/chai-as-promised": "7.1.2",
     "@types/long": "4.0.1",
     "@types/mocha": "7.0.2",
-    "@types/node": "8.10.59",
+    "@types/node": "13.11.0",
     "@types/sinon": "7.5.2",
     "@types/sinon-chai": "3.2.3",
     "@typescript-eslint/eslint-plugin": "2.24.0",

packages/firebase/package.json

@@ -5,11 +5,15 @@
   "author": "Firebase <[email protected]> (https://firebase.google.com/)",
   "license": "Apache-2.0",
   "homepage": "https://firebase.google.com/",
+  "engines": {
+    "node": "^8.13.0 || >=10.10.0"
+  },
   "keywords": [
     "authentication",
     "database",
     "Firebase",
     "firebase",
+    "firestore",
     "realtime",
     "storage",
     "performance",

packages/firestore/package.json

@@ -1,6 +1,9 @@
 {
   "name": "@firebase/firestore",
   "version": "1.13.0",
+  "engines": {
+    "node": "^8.13.0 || >=10.10.0"
+  },
   "description": "The Cloud Firestore component of the Firebase JS SDK.",
   "author": "Firebase <[email protected]> (https://firebase.google.com/)",
   "scripts": {
@@ -41,8 +44,8 @@
     "@firebase/logger": "0.2.0",
     "@firebase/util": "0.2.43",
     "@firebase/webchannel-wrapper": "0.2.38",
+    "@grpc/grpc-js": "0.7.5",
     "@grpc/proto-loader": "^0.5.0",
-    "grpc": "1.24.2",
     "tslib": "1.11.1"
   },
   "peerDependencies": {

packages/firestore/src/local/local_serializer.ts

@@ -170,7 +170,7 @@ export class LocalSerializer {
       mutations
     );
   }
-  
+
   /** Decodes a DbTarget into TargetData */
   fromDbTarget(dbTarget: DbTarget): TargetData {
     const version = this.fromDbTimestamp(dbTarget.readTime);

packages/firestore/src/platform_node/grpc_connection.ts

@@ -15,13 +15,18 @@
  * limitations under the License.
  */
 
-import * as grpc from 'grpc';
+import {
+  Metadata,
+  GrpcObject,
+  credentials as GrpcCredentials,
+  ServiceError
+} from '@grpc/grpc-js';
 
 import firebase from '@firebase/app';
 const SDK_VERSION = firebase.SDK_VERSION;
 
 // eslint-disable-next-line @typescript-eslint/no-require-imports
-const grpcVersion = require('grpc/package.json').version;
+const grpcVersion = require('@grpc/grpc-js/package.json').version;
 
 import { Token } from '../api/credentials';
 import { DatabaseInfo } from '../core/database_info';
@@ -44,13 +49,13 @@ const X_GOOG_API_CLIENT_VALUE = `gl-node/${process.versions.node} fire/${SDK_VER
 function createMetadata(
   databaseInfo: DatabaseInfo,
   token: Token | null
-): grpc.Metadata {
+): Metadata {
   assert(
     token === null || token.type === 'OAuth',
     'If provided, token must be OAuth'
   );
 
-  const metadata = new grpc.Metadata();
+  const metadata = new Metadata();
   if (token) {
     for (const header in token.authHeaders) {
       if (token.authHeaders.hasOwnProperty(header)) {
@@ -84,7 +89,7 @@ export class GrpcConnection implements Connection {
   // We cache stubs for the most-recently-used token.
   private cachedStub: GeneratedGrpcStub | null = null;
 
-  constructor(protos: grpc.GrpcObject, private databaseInfo: DatabaseInfo) {
+  constructor(protos: GrpcObject, private databaseInfo: DatabaseInfo) {
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
     this.firestore = (protos as any)['google']['firestore']['v1'];
   }
@@ -93,8 +98,8 @@ export class GrpcConnection implements Connection {
     if (!this.cachedStub) {
       logDebug(LOG_TAG, 'Creating Firestore stub.');
       const credentials = this.databaseInfo.ssl
-        ? grpc.credentials.createSsl()
-        : grpc.credentials.createInsecure();
+        ? GrpcCredentials.createSsl()
+        : GrpcCredentials.createInsecure();
       this.cachedStub = new this.firestore.Firestore(
         this.databaseInfo.host,
         credentials
@@ -116,7 +121,7 @@ export class GrpcConnection implements Connection {
       return stub[rpcName](
         request,
         metadata,
-        (grpcError?: grpc.ServiceError, value?: Resp) => {
+        (grpcError?: ServiceError, value?: Resp) => {
           if (grpcError) {
             logDebug(LOG_TAG, `RPC '${rpcName}' failed with error:`, grpcError);
             callback(
@@ -162,7 +167,7 @@ export class GrpcConnection implements Connection {
       logDebug(LOG_TAG, `RPC '${rpcName}' completed.`);
       responseDeferred.resolve(results);
     });
-    stream.on('error', (grpcError: grpc.ServiceError) => {
+    stream.on('error', (grpcError: ServiceError) => {
       logDebug(LOG_TAG, `RPC '${rpcName}' failed with error:`, grpcError);
       const code = mapCodeFromRpcCode(grpcError.code);
       responseDeferred.reject(new FirestoreError(code, grpcError.message));
@@ -224,7 +229,7 @@ export class GrpcConnection implements Connection {
       close();
     });
 
-    grpcStream.on('error', (grpcError: grpc.ServiceError) => {
+    grpcStream.on('error', (grpcError: ServiceError) => {
       logDebug(
         LOG_TAG,
         'GRPC stream error. Code:',

packages/firestore/src/platform_node/load_protos.ts

@@ -16,7 +16,7 @@
  */
 
 import { loadSync } from '@grpc/proto-loader';
-import { loadPackageDefinition, GrpcObject } from 'grpc';
+import { loadPackageDefinition, GrpcObject } from '@grpc/grpc-js';
 import { join, resolve, isAbsolute } from 'path';
 // only used in tests
 // eslint-disable-next-line import/no-extraneous-dependencies

packages/firestore/src/util/async_queue.ts

@@ -168,6 +168,7 @@ class DelayedOperation<T extends unknown> implements CancelablePromise<T> {
   readonly [Symbol.toStringTag]: 'Promise';
   then = this.deferred.promise.then.bind(this.deferred.promise);
   catch = this.deferred.promise.catch.bind(this.deferred.promise);
+  finally = this.deferred.promise.finally.bind(this.deferred.promise);
 
   private handleDelayElapsed(): void {
     this.asyncQueue.enqueueAndForget(() => {

packages/testing/package.json

@@ -4,6 +4,9 @@
   "description": "",
   "author": "Firebase <[email protected]> (https://firebase.google.com/)",
   "main": "dist/index.cjs.js",
+  "engines": {
+    "node": "^8.13.0 || >=10.10.0"
+  },
   "files": [
     "dist"
   ],
@@ -16,11 +19,10 @@
   },
   "license": "Apache-2.0",
   "dependencies": {
-    "firebase": "7.13.1",
     "@firebase/logger": "0.2.0",
     "@firebase/util": "0.2.43",
     "@types/request": "2.48.4",
-    "grpc": "1.24.2",
+    "firebase": "7.13.1",
     "request": "2.88.2"
   },
   "devDependencies": {

packages/testing/src/api/index.ts

@@ -21,7 +21,7 @@ import { FirebaseAuthInternal } from '@firebase/auth-interop-types';
 import * as request from 'request';
 import { base64 } from '@firebase/util';
 import { setLogLevel, LogLevel } from '@firebase/logger';
-import * as grpc from 'grpc';
+import * as grpc from '@grpc/grpc-js';
 import * as protoLoader from '@grpc/proto-loader';
 import { resolve } from 'path';
 import { Component, ComponentType } from '@firebase/component';