Build an App with Firebase

Author: angular-academy-devs

01-getting-started-with-angular2/final-project/src/server/batch-server.js

@@ -8,7 +8,9 @@ var firebaseConfig = {
 };
 
 
-console.log('Initializing FIREStack server ...');
+
+
+console.log('Initializing Firebase batch server ...');
 
 
 var firebase = require('firebase');
@@ -17,34 +19,49 @@ var app = firebase.initializeApp(firebaseConfig);
 var root = app.database();
 
 
-var Queue = require('firebase-queue');
-var queueRef = root.ref('queue');
 
-var lessonsRef = root.ref("lessons");
-var lessonsPerCourseRef = root.ref("lessonsPerCourse");
 
+app.auth().signInWithEmailAndPassword('ca2c-batch@mailinator.com', 'test123')
+ .then(runConsumer)
+ .catch(onError);
+
+
+function onError(err) {
+ console.error("Could not login", error);
+ process.exist();
+}
 
 
-var queue = new Queue(queueRef, function(data, progress, resolve, reject) {
+function runConsumer() {
 
- console.log('received delete request ...',data);
+ var Queue = require('firebase-queue');
+ var queueRef = root.ref('queue');
 
- const deleteLessonPromise = lessonsRef.child(data.lessonId).remove();
+ var lessonsRef = root.ref("lessons");
+ var lessonsPerCourseRef = root.ref("lessonsPerCourse");
 
- const deleteLessonPerCourseRef = lessonsPerCourseRef.child(data.courseId + '/' + data.lessonId).remove();
 
+ var queue = new Queue(queueRef, function(data, progress, resolve, reject) {
 
- Promise.all([deleteLessonPromise, deleteLessonPerCourseRef])
- .then(
- function() {
- console.log("lesson deleted");
- resolve();
- }
- ).catch(function() {
- console.log("lesson deletion in error");
+ console.log('received delete request ...',data);
+
+ const deleteLessonPromise = lessonsRef.child(data.lessonId).remove();
+
+ const deleteLessonPerCourseRef = lessonsPerCourseRef.child(data.courseId + '/' + data.lessonId).remove();
+
+ Promise.all([deleteLessonPromise, deleteLessonPerCourseRef])
+ .then(
+ function() {
+ console.log("lesson deleted");
+ resolve();
+ }
+ ).catch(function() {
+ console.log("lesson deletion in error");
  reject();
+ });
+
  });
 
 
+}
 
-});