Skip to content

Commit

Permalink
Fix linting issue
Browse files Browse the repository at this point in the history
  • Loading branch information
clarkmalmgren committed Dec 6, 2017
1 parent 62672f0 commit e2a4581
Show file tree
Hide file tree
Showing 2 changed files with 91 additions and 90 deletions.
122 changes: 61 additions & 61 deletions src/app/services/firebase.browser.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,67 @@ import {
FirebaseUtils
} from './firebase.service';

export class FirebaseBrowserStorage implements FirebaseStorage {

constructor(private storage: firebase.storage.Storage) {}

getUrl(path: string): Observable<string> {
if (!path || path.length < 1) {
return Observable.of(undefined);
}

return observe(this.storage.ref(path).getDownloadURL());
}

upload(path: string, file: File): Observable<any> {
if (!path || path.length < 1) {
return Observable.throw(new Error('No uploading to root!'));
}

return observe(this.storage.ref(path).put(file));
}

delete(path: string): Observable<any> {
return observe(this.storage.ref(path).delete());
}
}

export class FirebaseBrowserDatabase implements FirebaseDatabase {

constructor(private database: firebase.database.Database) {}

exists(path: string): Observable<Boolean> {
return observe(this.database.ref(path).once('value'))
.map((snap: firebase.database.DataSnapshot) => snap.exists());
}

getOnce(path: string): Observable<any> {
return observe(this.database.ref(path).once('value'))
.map((snap: firebase.database.DataSnapshot) => snap.val());
}

watch(path: string): Observable<any> {
return Observable
.create((observer: Observer<any>) => {
this.database.ref(path).on('value', (snap) => {
observer.next(snap.val());
});
});
}

put(path: string, value: any): Observable<any> {
return observe(this.database.ref(path).set(value));
}

push(path: string, value: any): Observable<any> {
return observe(this.database.ref(path).push(value));
}

delete(path: string): Observable<any> {
return observe(this.database.ref(path).remove());
}
}

@Injectable()
export class FirebaseBrowserService extends FirebaseService {

Expand Down Expand Up @@ -72,67 +133,6 @@ export class FirebaseBrowserService extends FirebaseService {
}
}

export class FirebaseBrowserStorage implements FirebaseStorage {

constructor(private storage: firebase.storage.Storage) {}

getUrl(path: string): Observable<string> {
if (!path || path.length < 1) {
return Observable.of(undefined);
}

return observe(this.storage.ref(path).getDownloadURL());
}

upload(path: string, file: File): Observable<any> {
if (!path || path.length < 1) {
return Observable.throw(new Error('No uploading to root!'));
}

return observe(this.storage.ref(path).put(file));
}

delete(path: string): Observable<any> {
return observe(this.storage.ref(path).delete());
}
}

export class FirebaseBrowserDatabase implements FirebaseDatabase {

constructor(private database: firebase.database.Database) {}

exists(path: string): Observable<Boolean> {
return observe(this.database.ref(path).once('value'))
.map((snap: firebase.database.DataSnapshot) => snap.exists());
}

getOnce(path: string): Observable<any> {
return observe(this.database.ref(path).once('value'))
.map((snap: firebase.database.DataSnapshot) => snap.val());
}

watch(path: string): Observable<any> {
return Observable
.create((observer: Observer<any>) => {
this.database.ref(path).on('value', (snap) => {
observer.next(snap.val());
});
});
}

put(path: string, value: any): Observable<any> {
return observe(this.database.ref(path).set(value));
}

push(path: string, value: any): Observable<any> {
return observe(this.database.ref(path).push(value));
}

delete(path: string): Observable<any> {
return observe(this.database.ref(path).remove());
}
}

function observe<T>(promise: PromiseLike<any>): Observable<any> {
return Observable.create((observer: Observer<any>) => {
promise
Expand Down
59 changes: 30 additions & 29 deletions src/app/services/firebase.server.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,35 +9,6 @@ import {
FirebaseUtils
} from './firebase.service';

@Injectable()
export class FirebaseServerService extends FirebaseService {

private static initialized: boolean = false;
private _storage: FirebaseServerStorage;
private _database: FirebaseServerDatabase;

constructor(private env: Env, private http: HttpClient) {
super();
this._storage = new FirebaseServerStorage();
this._database = new FirebaseServerDatabase(env, http);
}

public auth(): Observable<any> {
return Observable.throw('No custom authentication allowed on ');
}

authenticated(): Observable<boolean> {
return Observable.of(false);
}

storage(): Observable<FirebaseStorage> {
return Observable.of(this._storage);
}

database(): Observable<FirebaseDatabase> {
return Observable.of(this._database);
}
}

export class FirebaseServerStorage implements FirebaseStorage {

Expand Down Expand Up @@ -91,3 +62,33 @@ export class FirebaseServerDatabase implements FirebaseDatabase {
}
}

@Injectable()
export class FirebaseServerService extends FirebaseService {

private static initialized: boolean = false;
private _storage: FirebaseServerStorage;
private _database: FirebaseServerDatabase;

constructor(private env: Env, private http: HttpClient) {
super();

this._storage = new FirebaseServerStorage();
this._database = new FirebaseServerDatabase(env, http);
}

public auth(): Observable<any> {
return Observable.throw('No custom authentication allowed on ');
}

authenticated(): Observable<boolean> {
return Observable.of(false);
}

storage(): Observable<FirebaseStorage> {
return Observable.of(this._storage);
}

database(): Observable<FirebaseDatabase> {
return Observable.of(this._database);
}
}

0 comments on commit e2a4581

Please sign in to comment.