@@ -26,9 +26,9 @@ export default function pushStatusHandler(config) {
26
26
let data = body . data || { } ;
27
27
let payloadString = JSON . stringify ( data ) ;
28
28
let object = {
29
- _id : objectId ,
29
+ objectId,
30
+ createdAt : now ,
30
31
pushTime : now . toISOString ( ) ,
31
- _created_at : now ,
32
32
query : JSON . stringify ( where ) ,
33
33
payload : payloadString ,
34
34
source : options . source ,
@@ -38,8 +38,7 @@ export default function pushStatusHandler(config) {
38
38
numSent : 0 ,
39
39
pushHash : md5Hash ( payloadString ) ,
40
40
// lockdown!
41
- _wperm : [ ] ,
42
- _rperm : [ ]
41
+ ACL : { }
43
42
}
44
43
45
44
return database . create ( PUSH_STATUS_COLLECTION , object ) . then ( ( ) => {
@@ -54,12 +53,13 @@ export default function pushStatusHandler(config) {
54
53
logger . verbose ( 'sending push to %d installations' , installations . length ) ;
55
54
return database . update ( PUSH_STATUS_COLLECTION ,
56
55
{ status :"pending" , objectId : objectId } ,
57
- { status : "running" } ) ;
56
+ { status : "running" , updatedAt : new Date ( ) } ) ;
58
57
}
59
58
60
59
let complete = function ( results ) {
61
60
let update = {
62
61
status : 'succeeded' ,
62
+ updatedAt : new Date ( ) ,
63
63
numSent : 0 ,
64
64
numFailed : 0 ,
65
65
} ;
@@ -87,16 +87,17 @@ export default function pushStatusHandler(config) {
87
87
} , update ) ;
88
88
}
89
89
logger . verbose ( 'sent push! %d success, %d failures' , update . numSent , update . numFailed ) ;
90
- return database . update ( '_PushStatus' , { status :"running" , objectId } , update ) ;
90
+ return database . update ( PUSH_STATUS_COLLECTION , { status :"running" , objectId } , update ) ;
91
91
}
92
92
93
93
let fail = function ( err ) {
94
94
let update = {
95
95
errorMessage : JSON . stringify ( err ) ,
96
- status : 'failed'
96
+ status : 'failed' ,
97
+ updatedAt : new Date ( )
97
98
}
98
99
logger . error ( 'error while sending push' , err ) ;
99
- return database . update ( '_PushStatus' , { objectId } , update ) ;
100
+ return database . update ( PUSH_STATUS_COLLECTION , { objectId } , update ) ;
100
101
}
101
102
102
103
return Object . freeze ( {
0 commit comments