refactor(db): Begin database refactor

Author: davideast

.DS_Store

@@ -9,3 +9,4 @@ npm-debug.log
 angularfire2-*.tgz
 *.ngfactory.ts
 *.ngsummary.json
+*.bak

.gitignore

@@ -0,0 +1,25 @@
+import { NgModule } from '@angular/core';
+import * as firebase from 'firebase/app';
+import 'firebase/database';
+import { AngularFireModule, FirebaseApp } from 'angularfire2';
+import { AngularFireDatabase } from './database';
+
+export function _getAngularFireDatabase(app: FirebaseApp) {
+  return new AngularFireDatabase(app);
+}
+
+export const AngularFireDatabaseProvider = {
+  provide: AngularFireDatabase,
+  useFactory: _getAngularFireDatabase,
+  deps: [ FirebaseApp ]
+};
+
+export const DATABASE_PROVIDERS = [
+  AngularFireDatabaseProvider,
+];
+
+@NgModule({
+  imports: [ AngularFireModule ],
+  providers: [ DATABASE_PROVIDERS ]
+})
+export class AngularFireDatabaseModule { }

src/.DS_Store

@@ -0,0 +1,34 @@
+import { Injectable } from '@angular/core';
+import * as firebase from 'firebase/app';
+import 'firebase/database';
+import { FirebaseApp } from 'angularfire2';
+import { PathReference, DatabaseQuery, DatabaseReference, DatabaseSnapshot, ChildEvent, ListenEvent, SnapshotChange, QueryFn, AngularFireList } from './interfaces';
+import * as utils from './utils';
+import { Observable } from 'rxjs/Observable';
+import { fromRef } from './observable/fromRef';
+import { createValueChanges } from './observable/value-changes';
+import { createList } from './list/create.list';
+
+@Injectable()
+export class AngularFireDatabase {
+  database: firebase.database.Database;
+
+  constructor(public app: FirebaseApp) {
+    this.database = app.database();
+  }
+
+  list<T>(pathOrRef: PathReference, queryFn?: QueryFn): AngularFireList<T> {
+    const ref = utils.getRef(this.app, pathOrRef);
+    let query: DatabaseQuery = ref;
+    if(queryFn) {
+      query = queryFn(ref);
+    }
+    return createList<T>(query);
+  }
+
+  object<T>(pathOrRef: PathReference) {
+
+  }
+
+}
+

src/database-new/database.module.ts

@@ -0,0 +1,5 @@
+// import './firebase_list_factory.spec';
+// import './firebase_object_factory.spec';
+// import './firebase_list_observable.spec';
+// import './firebase_object_observable.spec';
+// import './query_observable.spec';

src/database-new/database.ts

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

src/database-new/index.spec.ts

@@ -0,0 +1,104 @@
+import * as firebase from 'firebase/app';
+import { Observable } from 'rxjs/Observable';
+
+export interface AngularFireList<T> {
+  query: DatabaseQuery;
+  valueChanges<T>(events: ChildEvent[]): Observable<T[]>;
+  //snapshotChanges<T>(): Observable<DatabaseSnapshot>;
+  //childChanges<T>(events: ChildEvent[]): Observable<DatabaseSnapshot>;
+}
+
+export interface FirebaseOperationCases {
+  stringCase: () => firebase.Promise<void>;
+  firebaseCase?: () => firebase.Promise<void>;
+  snapshotCase?: () => firebase.Promise<void>;
+  unwrappedSnapshotCase?: () => firebase.Promise<void>;
+}
+
+export interface AFUnwrappedDataSnapshot {
+  $key: string;
+  $value?: string | number | boolean;
+  $exists: () => boolean;
+}
+
+export interface Query {
+  [key: string]: any;
+  orderByKey?: boolean | Observable<boolean>;
+  orderByPriority?: boolean | Observable<boolean>;
+  orderByChild?: string | Observable<string>;
+  orderByValue?: boolean | Observable<boolean>;
+  equalTo?: any | Observable<any>;
+  startAt?: any | Observable<any>;
+  endAt?: any | Observable<any>;
+  limitToFirst?: number | Observable<number>;
+  limitToLast?: number | Observable<number>;
+}
+
+export interface ScalarQuery {
+  [key: string]: any;
+  orderByKey?: boolean;
+  orderByPriority?: boolean;
+  orderByChild?: string;
+  orderByValue?: boolean;
+  equalTo?: any;
+  startAt?: any;
+  endAt?: any;
+  limitToFirst?: number;
+  limitToLast?: number;
+}
+
+export interface OrderBySelection {
+  key: OrderByOptions;
+  value: boolean | string;
+}
+
+export interface LimitToSelection {
+  key: LimitToOptions;
+  value: number;
+}
+
+export interface FirebaseListFactoryOpts {
+  preserveSnapshot?: boolean;
+  query?: Query;
+}
+
+
+export interface FirebaseObjectFactoryOpts {
+  preserveSnapshot?: boolean;
+}
+
+
+export enum OrderByOptions {
+  Child,
+  Key,
+  Value,
+  Priority
+}
+
+export enum LimitToOptions {
+  First,
+  Last
+}
+
+export enum QueryOptions {
+  EqualTo,
+  StartAt,
+  EndAt
+}
+
+export type QueryFn = (ref: DatabaseReference) => DatabaseQuery;
+export type ChildEvent = 'added' | 'removed' | 'changed' | 'moved';
+export type ListenEvent = 'value' | ChildEvent;
+
+export type SnapshotChange = { 
+  event: string; 
+  snapshot: DatabaseSnapshot | null; 
+}
+
+export type Primitive = number | string | boolean;
+
+export type DatabaseSnapshot = firebase.database.DataSnapshot;
+export type DatabaseReference = firebase.database.Reference;
+export type DatabaseQuery = firebase.database.Query;
+export type QueryReference = DatabaseReference | DatabaseQuery;
+export type PathReference = QueryReference | string;

src/database-new/index.ts

@@ -0,0 +1,9 @@
+import { DatabaseQuery, AngularFireList } from '../interfaces';
+import { createValueChanges } from '../observable/value-changes';
+
+export function createList<T>(query: DatabaseQuery): AngularFireList<T> {
+  return {
+    query,
+    valueChanges: createValueChanges(query)
+  }
+}