feat(storage): Implement AngularFireStorage

Author: davideast

package.json

@@ -1,6 +1,6 @@
 {
   "name": "angularfire2",
-  "version": "5.0.0-rc.4",
+  "version": "5.0.0-rc.5",
   "description": "The official library of Firebase and Angular.",
   "private": true,
   "scripts": {

src/storage/index.ts

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

src/storage/observable/fromTask.ts

@@ -0,0 +1,10 @@
+import { storage } from 'firebase/app';
+import 'firebase/storage';
+import { Observable } from 'rxjs/Observable';
+
+export function fromTask(task: storage.UploadTask) {
+  return new Observable<storage.UploadTaskSnapshot>(subscriber => {
+    task.on('state_changed', subscriber);
+    return { unsubscribe: task.cancel };
+  });
+}

src/storage/package.json

@@ -0,0 +1,30 @@
+{
+  "name": "angularfire2/storage",
+  "version": "ANGULARFIRE2_VERSION",
+  "description": "The storage module",
+  "main": "../bundles/storage.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": "FIREBASE_VERSION",
+    "rxjs": "RXJS_VERSION",
+    "zone.js": "ZONEJS_VERSION"
+  },
+  "typings": "index.d.ts"
+}

src/storage/public_api.ts

@@ -0,0 +1,5 @@
+export * from './ref';
+export * from './storage';
+export * from './task';
+export * from './observable/fromTask';
+export * from './storage.module';

src/storage/ref.ts

@@ -0,0 +1,11 @@
+import { storage } from 'firebase/app';
+import { AngularFireUploadTask } from './task';
+
+export class AngularFireStorageRef {
+  constructor(public ref: storage.Reference) { }
+  put(data: any, metadata: storage.UploadMetadata | undefined) {
+    const task = this.ref.put(data, metadata);
+    return new AngularFireUploadTask(task);
+  }
+}
+

src/storage/storage.module.ts

@@ -0,0 +1,25 @@
+import { NgModule } from '@angular/core';
+import * as firebase from 'firebase/app';
+import 'firebase/storage';
+import { AngularFireModule, FirebaseApp } from 'angularfire2';
+import { AngularFireStorage } from './storage';
+
+export function _getAngularFireStorage(app: FirebaseApp) {
+  return new AngularFireStorage(app);
+}
+
+export const AngularFireStorageProvider = {
+  provide: AngularFireStorage,
+  useFactory: _getAngularFireStorage,
+  deps: [ FirebaseApp ]
+};
+
+export const STORAGE_PROVIDERS = [
+  AngularFireStorageProvider,
+];
+
+@NgModule({
+  imports: [ AngularFireModule ],
+  providers: [ STORAGE_PROVIDERS ]
+})
+export class AngularFireStorageModule { }

src/storage/storage.ts

@@ -0,0 +1,26 @@
+import { Injectable } from '@angular/core';
+import { storage } from 'firebase/app';
+import 'firebase/storage';
+import { FirebaseApp } from 'angularfire2';
+import { AngularFireStorageRef } from './ref';
+import { AngularFireUploadTask } from './task';
+
+@Injectable()
+export class AngularFireStorage {
+  storage: storage.Storage;
+  
+    constructor(public app: FirebaseApp) {
+      this.storage = app.storage();
+    }
+
+    ref(path: string) {
+      return new AngularFireStorageRef(this.storage.ref(path));
+    }
+
+    upload(pathOrRef: string, data: any, metadata: storage.UploadMetadata | undefined) {
+      const storageRef = this.storage.ref(pathOrRef);
+      const ref = new AngularFireStorageRef(storageRef);
+      return ref.put(data, metadata);
+    }
+
+}

src/storage/task.ts

@@ -0,0 +1,19 @@
+import { storage } from 'firebase/app';
+import { fromTask } from './observable/fromTask';
+import { Observable } from 'rxjs/Observable';
+
+export class AngularFireUploadTask {
+  constructor(public task: storage.UploadTask) {}
+
+  snapshotChanges() { return fromTask(this.task); }
+
+  pause() { return this.task.pause(); }
+
+  cancel() { return this.task.cancel(); }
+
+  resume() { return this.task.resume(); }
+
+  then() { return this.task.then(); }
+
+  catch(onRejected: (a: Error) => any) { return this.task.catch(onRejected); } 
+}

src/storage/tsconfig-build.json

@@ -0,0 +1,33 @@
+{
+  "compilerOptions": {
+    "baseUrl": ".",
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true,
+    "module": "es2015",
+    "target": "es2015",
+    "noImplicitAny": false,
+    "outDir": "../../dist/packages-dist/storage/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
+  }
+}
+