firebase queue

batch-server.ts

@@ -0,0 +1,53 @@
+import {firebaseConfig} from "./src/environments/firebase.config";
+import {initializeApp, auth,database} from 'firebase';
+const Queue = require('firebase-queue');
+import Promise from "ts-promise";
+
+
+console.log('Running batch server ...');
+
+initializeApp(firebaseConfig);
+
+auth()
+  .signInWithEmailAndPassword('two@admin.com', 'admin123')
+  .then(runConsumer)
+  .catch(onError);
+
+function onError(err) {
+  console.error("Could not login", err);
+  process.exit();
+}
+
+
+function runConsumer() {
+
+  console.log("Running consumer ...");
+
+  const lessonsRef = database().ref("lessons");
+  const lessonsPerCourseRef = database().ref("lessonsPerCourse");
+
+  const queueRef = database().ref('queue');
+
+
+  const queue = new Queue(queueRef, function(data, progress, resolve, reject) {
+
+    console.log('received delete request ...',data);
+
+    const deleteLessonPromise = lessonsRef.child(data.lessonId).remove();
+
+    const deleteLessonPerCoursePromise =
+      lessonsPerCourseRef.child(`${data.courseId}/${data.lessonId}`).remove();
+
+    Promise.all([deleteLessonPromise, deleteLessonPerCoursePromise])
+      .then(
+        () => {
+          console.log("lesson deleted");
+          resolve();
+        }
+      )
+      .catch(() => {
+        console.log("lesson deletion in error");
+        reject();
+      });
+  });
+}

package.json

@@ -9,6 +9,7 @@
     "test": "ng test",
     "pree2e": "webdriver-manager update",
     "e2e": "protractor",
+    "batch-server": "./node_modules/.bin/ts-node ./batch-server.ts",
     "db": "./node_modules/.bin/ts-node ./popluate-db.ts"
   },
   "private": true,
@@ -32,6 +33,7 @@
     "rxjs": "5.0.0-beta.12",
     "ts-helpers": "^1.1.1",
     "ts-node": "^1.4.3",
+    "ts-promise": "^0.3.4",
     "zone.js": "^0.6.23"
   },
   "devDependencies": {

src/app/courses/course.service.ts

@@ -201,4 +201,11 @@ export class CourseService {
     return subject.asObservable();
   }
 
+  deleteLEssonById(lessonId: string, courseId) {
+    return this.rootDb.child('queue/tasks')
+      .push({
+        lessonId,
+        courseId
+      })
+  }
 }

src/app/courses/lesson-detail/lesson-detail.component.ts

@@ -3,6 +3,7 @@ import {ActivatedRoute} from "@angular/router";
 import {Course} from "../courses";
 import {CourseService} from "../course.service";
 import {Observable} from "rxjs";
+import {Lesson} from "../lessons/lessons";
 
 @Component({
   selector: 'app-lesson-detail',
@@ -16,7 +17,7 @@ export class LessonDetailComponent implements OnInit {
 
   }
 
-  lesson: Observable<any>;
+  lesson: Observable<Lesson>;
   ngOnInit() {
     /*this.route.params
       .map(p => p['id'])
@@ -36,4 +37,13 @@ export class LessonDetailComponent implements OnInit {
       )
   }
 
+  requestLessonDeletion() {
+    this.courseService.deleteLEssonById(
+      this.lesson.$key,
+      this.lesson.courseId
+    )
+      .then(() => alert("lesson delete successfully"))
+      .catch((err) => console.error(err));
+  }
+
 }

src/app/heros/hero/hero.component.ts

@@ -55,8 +55,7 @@ export class HeroComponent implements OnInit, OnDestroy {
         this.editing = false;
         this.heroId = id;
       });
-    this.hero = this.route.data
-      .map((d:any)=> d['hero']);
+    this.hero = <Observable<Hero>>this.route.data.pluck('hero');
 
 
    /* // since herocomponent get init everytime, it would be better to use snapshot for proferemence

src/app/home/home.module.ts

@@ -9,13 +9,11 @@ import {MdToolbarModule} from "@angular2-material/toolbar";
 import {MdInputModule} from "@angular2-material/input";
 import {MdButtonModule} from "@angular2-material/button";
 import homeRoutes from './home.routes';
+import {MaterialModule} from "@angular/material";
 @NgModule({
   imports: [
     CommonModule,
-    MdButtonModule.forRoot(),
-    MdInputModule.forRoot(),
-    MdToolbarModule.forRoot(),
-    MdListModule.forRoot(),
+    MaterialModule,
     homeRoutes
   ],
   declarations: [HomeComponent, SearchBarComponent, ResultListComponent],

src/tsconfig.json

@@ -12,6 +12,10 @@
     "target": "es5",
     "typeRoots": [
       "../node_modules/@types"
+    ],
+    "types": [
+      "node",
+      "firebase"
     ]
   }
 }