1
1
2
2
import { firebaseConfig } from "./src/environments/firebase.config" ;
3
3
import { initializeApp , auth , database } from 'firebase' ;
4
+ var Queue = require ( 'firebase-queue' ) ;
4
5
5
6
6
7
console . log ( 'Running batch server ...' ) ;
7
8
8
9
initializeApp ( firebaseConfig ) ;
9
10
10
-
11
11
auth ( )
12
12
. signInWithEmailAndPassword ( 'admin@angular-university.io' , 'test123' )
13
13
. then ( runConsumer )
@@ -18,40 +18,54 @@ function onError(err) {
18
18
process . exit ( ) ;
19
19
}
20
20
21
+
21
22
function runConsumer ( ) {
23
+
22
24
console . log ( "Running consumer ..." ) ;
23
25
24
- var Queue = require ( 'firebase-queue' ) ;
25
- var queueRef = database ( ) . ref ( 'queue' ) ;
26
+ const lessonsRef = database ( ) . ref ( "lessons" ) ;
27
+ const lessonsPerCourseRef = database ( ) . ref ( "lessonsPerCourse" ) ;
26
28
27
- var lessonsRef = database ( ) . ref ( "lessons" ) ;
28
- var lessonsPerCourseRef = database ( ) . ref ( "lessonsPerCourse" ) ;
29
+ const queueRef = database ( ) . ref ( 'queue' ) ;
29
30
30
31
31
- var queue = new Queue ( queueRef , function ( data , progress , resolve , reject ) {
32
+ const queue = new Queue ( queueRef , function ( data , progress , resolve , reject ) {
32
33
33
34
console . log ( 'received delete request ...' , data ) ;
34
35
35
36
const deleteLessonPromise = lessonsRef . child ( data . lessonId ) . remove ( ) ;
36
37
37
- const deleteLessonPerCourseRef =
38
+ const deleteLessonPerCoursePromise =
38
39
lessonsPerCourseRef . child ( `${ data . courseId } /${ data . lessonId } ` ) . remove ( ) ;
39
40
40
- Promise . all ( [ deleteLessonPromise , deleteLessonPerCourseRef ] )
41
+ Promise . all ( [ deleteLessonPromise , deleteLessonPerCoursePromise ] )
41
42
. then (
42
- function ( ) {
43
+ ( ) => {
43
44
console . log ( "lesson deleted" ) ;
44
45
resolve ( ) ;
45
46
}
46
- ) . catch ( function ( ) {
47
+ )
48
+ . catch ( ( ) => {
47
49
console . log ( "lesson deletion in error" ) ;
48
50
reject ( ) ;
49
51
} ) ;
50
52
53
+
51
54
} ) ;
52
55
56
+
53
57
}
54
58
55
59
56
60
57
61
62
+
63
+
64
+
65
+
66
+
67
+
68
+
69
+
70
+
71
+
0 commit comments