feat(functions): Adding AngularFireFunctions with httpCallable

package.json

@@ -42,11 +42,13 @@
     "@firebase/database-types": "^0.1.1",
     "@firebase/firestore": "^0.2.3",
     "@firebase/firestore-types": "^0.1.1",
+    "@firebase/functions": "^0.1.0",
+    "@firebase/functions-types": "^0.1.0",
     "@firebase/messaging-types": "^0.1.1",
     "@firebase/storage": "^0.1.6",
     "@firebase/storage-types": "^0.1.1",
     "bufferutil": "^3.0.3",
-    "firebase": "^4.8.2",
+    "firebase": "^4.11.0",
     "rxjs": "^5.5.4",
     "utf-8-validate": "^4.0.0",
     "ws": "^3.3.2",

src/core/firebase.app.module.ts

@@ -9,6 +9,7 @@ import { FirebaseDatabase } from '@firebase/database-types';
 import { FirebaseMessaging } from '@firebase/messaging-types';
 import { FirebaseStorage } from '@firebase/storage-types';
 import { FirebaseFirestore } from '@firebase/firestore-types';
+import { FirebaseFunctions } from '@firebase/functions-types';
 
 export class FirebaseApp implements _FirebaseApp {
     name: string;
@@ -19,6 +20,7 @@ export class FirebaseApp implements _FirebaseApp {
     storage: (storageBucket?: string) => FirebaseStorage;
     delete: () => Promise<void>;
     firestore: () => FirebaseFirestore;
+    functions: () => FirebaseFunctions;
 }
 
 export function _firebaseAppFactory(config: FirebaseOptions, name?: string): FirebaseApp {

src/functions/functions.module.ts

@@ -0,0 +1,8 @@
+import { NgModule } from '@angular/core';
+import { AngularFireFunctions } from './functions';
+import '@firebase/functions'
+
+@NgModule({
+  providers: [ AngularFireFunctions ]
+})
+export class AngularFireFunctionsModule { }

src/functions/functions.spec.ts

@@ -0,0 +1,79 @@
+import { ReflectiveInjector, Provider } from '@angular/core';
+import { Observable } from 'rxjs/Observable'
+import { Subject } from 'rxjs/Subject'
+import { Observer } from 'rxjs/Observer';
+import { TestBed, inject } from '@angular/core/testing';
+import { _do } from 'rxjs/operator/do';
+import { take } from 'rxjs/operator/take';
+import { skip } from 'rxjs/operator/skip';
+import { FirebaseApp, FirebaseAppConfig, AngularFireModule, FirebaseAppName } from 'angularfire2';
+import { AngularFireFunctions, AngularFireFunctionsModule } from 'angularfire2/functions';
+import { COMMON_CONFIG } from './test-config';
+
+describe('AngularFireFunctions', () => {
+  let app: FirebaseApp;
+  let afFns: AngularFireFunctions;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({
+      imports: [
+        AngularFireModule.initializeApp(COMMON_CONFIG),
+        AngularFireFunctionsModule
+      ]
+    });
+    inject([FirebaseApp, AngularFireFunctions], (app_: FirebaseApp, _fn: AngularFireFunctions) => {
+      app = app_;
+      afFns = _fn;
+    })();
+  });
+
+  afterEach(done => {
+    app.delete().then(done, done.fail);
+  });
+
+  it('should be exist', () => {
+    expect(afFns instanceof AngularFireFunctions).toBe(true);
+  });
+
+  it('should have the Firebase Functions instance', () => {
+    expect(afFns.functions).toBeDefined();
+  });
+
+});
+
+const FIREBASE_APP_NAME_TOO = (Math.random() + 1).toString(36).substring(7);
+
+describe('AngularFireFunctions with different app', () => {
+  let app: FirebaseApp;
+  let afFns: AngularFireFunctions;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({
+      imports: [
+        AngularFireModule.initializeApp(COMMON_CONFIG),
+        AngularFireFunctionsModule
+      ],
+      providers: [
+        { provide: FirebaseAppName, useValue: FIREBASE_APP_NAME_TOO },
+        { provide: FirebaseAppConfig, useValue:  COMMON_CONFIG }
+      ]
+    });
+    inject([FirebaseApp, AngularFireFunctions], (app_: FirebaseApp, _fns: AngularFireFunctions) => {
+      app = app_;
+      afFns = _fns;
+    })();
+  });
+
+  afterEach(done => {
+    app.delete().then(done, done.fail);
+  });
+
+  describe('<constructor>', () => {
+
+    it('should be an AngularFireAuth type', () => {
+      expect(afFns instanceof AngularFireFunctions).toEqual(true);
+    });
+
+  });
+
+});

src/functions/functions.ts

@@ -0,0 +1,45 @@
+import { FirebaseFunctions, HttpsCallableResult } from '@firebase/functions-types';
+import { FirebaseOptions } from '@firebase/app-types';
+import { Injectable, Inject, Optional, NgZone } from '@angular/core';
+import { Observable } from 'rxjs/Observable';
+
+import { FirebaseAppConfig, FirebaseAppName, _firebaseAppFactory, FirebaseZoneScheduler } from 'angularfire2';
+
+import 'rxjs/add/observable/fromPromise';
+import 'rxjs/add/operator/map'
+
+@Injectable()
+export class AngularFireFunctions {
+
+  /**
+   * Firebase Functions instance
+   */
+  public readonly functions: FirebaseFunctions;
+
+  public readonly scheduler: FirebaseZoneScheduler;
+
+  public httpsCallable<T, R>(name: string) {
+    const callable = this.functions.httpsCallable(name);
+    return (data: T) => {
+      return this.scheduler.runOutsideAngular(
+        Observable.fromPromise(callable(data))
+          .map(r => r.data as R)
+      )
+    }
+  }
+
+  constructor(
+    @Inject(FirebaseAppConfig) config:FirebaseOptions,
+    @Optional() @Inject(FirebaseAppName) name:string,
+    private zone: NgZone
+  ) {
+    this.scheduler = new FirebaseZoneScheduler(zone);
+
+    this.functions = zone.runOutsideAngular(() => {
+      const app = _firebaseAppFactory(config, name);
+      return app.functions();
+    });
+
+  }
+
+}

src/functions/index.spec.ts

@@ -0,0 +1 @@
+import './functions.spec';

src/functions/index.ts

@@ -0,0 +1 @@
+export * from './public_api';

src/functions/package.json

@@ -0,0 +1,31 @@
+{
+  "name": "angularfire2/functions",
+  "version": "ANGULARFIRE2_VERSION",
+  "description": "The functions module",
+  "main": "../bundles/functions.umd.js",
+  "module": "index.js",
+  "es2015": "./es2015/index.js",
+  "keywords": [
+    "angular",
+    "firebase",
+    "rxjs"
+  ],
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/angular/angularfire2.git"
+  },
+  "author": "angular,firebase",
+  "license": "MIT",
+  "peerDependencies": {
+    "angularfire2": "ANGULARFIRE2_VERSION",
+    "@angular/common": "ANGULAR_VERSION",
+    "@angular/core": "ANGULAR_VERSION",
+    "@angular/platform-browser": "ANGULAR_VERSION",
+    "@angular/platform-browser-dynamic": "ANGULAR_VERSION",
+    "@firebase/app": "FIREBASE_APP_VERSION",
+    "@firebase/functions": "FIREBASE_FUNCTIONS_VERSION",
+    "rxjs": "RXJS_VERSION",
+    "zone.js": "ZONEJS_VERSION"
+  },
+  "typings": "index.d.ts"
+}

src/functions/public_api.ts

@@ -0,0 +1,2 @@
+export * from './functions';
+export * from './functions.module';

src/functions/test-config.ts

@@ -0,0 +1,7 @@
+
+export const COMMON_CONFIG = {
+  apiKey: "AIzaSyBVSy3YpkVGiKXbbxeK0qBnu3-MNZ9UIjA",
+  authDomain: "angularfire2-test.firebaseapp.com",
+  databaseURL: "https://angularfire2-test.firebaseio.com",
+  storageBucket: "angularfire2-test.appspot.com",
+};

src/functions/tsconfig-build.json

@@ -0,0 +1,33 @@
+{
+  "compilerOptions": {
+    "baseUrl": ".",
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true,
+    "module": "es2015",
+    "target": "es2015",
+    "noImplicitAny": false,
+    "outDir": "../../dist/packages-dist/functions/es2015",
+    "rootDir": ".",
+    "sourceMap": true,
+    "inlineSources": true,
+    "declaration": false,
+    "removeComments": true,
+    "strictNullChecks": true,
+    "lib": ["es2015", "dom", "es2015.promise", "es2015.collection", "es2015.iterable"],
+    "skipLibCheck": true,
+    "moduleResolution": "node",
+    "paths": {
+      "angularfire2": ["../../dist/packages-dist"]
+    }
+  },
+  "files": [
+    "index.ts",
+    "../../node_modules/zone.js/dist/zone.js.d.ts"
+  ],
+  "angularCompilerOptions": {
+    "skipTemplateCodegen": true,
+    "strictMetadataEmit": true,
+    "enableSummariesForJit": false
+  }
+}
+

src/functions/tsconfig-esm.json

@@ -0,0 +1,19 @@
+{
+  "extends": "./tsconfig-build.json",
+  "compilerOptions": {
+    "target": "es5",
+    "outDir": "../../dist/packages-dist/functions",
+    "declaration": true
+  },
+  "files": [
+    "public_api.ts",
+    "../../node_modules/zone.js/dist/zone.js.d.ts"
+  ],  
+  "angularCompilerOptions": {
+    "skipTemplateCodegen": true,
+    "strictMetadataEmit": true,
+    "enableSummariesForJit": false,
+    "flatModuleOutFile": "index.js",
+    "flatModuleId": "angularfire2/functions"
+  }    
+}

src/functions/tsconfig-test.json

@@ -0,0 +1,14 @@
+{
+  "extends": "./tsconfig-esm.json",
+  "compilerOptions": {
+    "baseUrl": ".",
+    "paths": {
+      "angularfire2": ["../../dist/packages-dist"],
+      "angularfire2/functions": ["../../dist/packages-dist/functions"]
+    }
+  },
+  "files": [
+    "index.spec.ts",
+    "../../node_modules/zone.js/dist/zone.js.d.ts"
+  ]
+}

src/root.spec.js

@@ -4,6 +4,7 @@ export * from './packages-dist/auth/auth.spec';
 export * from './packages-dist/firestore/firestore.spec';
 export * from './packages-dist/firestore/document/document.spec';
 export * from './packages-dist/firestore/collection/collection.spec';
+export * from './packages-dist/functions/functions.spec';
 export * from './packages-dist/database/database.spec';
 export * from './packages-dist/database/utils.spec';
 export * from './packages-dist/database/observable/fromRef.spec';

src/tsconfig.json

@@ -14,6 +14,7 @@
       "angularfire2/auth": ["./auth"],
       "angularfire2/database": ["./database"],
       "angularfire2/firestore": ["./firestore"],
+      "angularfire2/functions": ["./functions"],
       "angularfire2/storage": ["./storage"],
       "angularfire2/database-deprecated": ["./database-deprecated"]
     },