@@ -43,22 +43,21 @@ FCM.prototype.send = function(data, devices) {
43
43
44
44
// We can only have 500 recepients per send, so we need to slice devices to
45
45
// chunk if necessary
46
- let slices = sliceDevices ( devices , FCM . FCMRegistrationTokensMax ) ;
46
+ const slices = sliceDevices ( devices , FCM . FCMRegistrationTokensMax ) ;
47
47
48
48
const sendToDeviceSlice = ( deviceSlice ) => {
49
- let pushId = randomString ( 10 ) ;
50
- let timestamp = Date . now ( ) ;
49
+ const pushId = randomString ( 10 ) ;
50
+ const timestamp = Date . now ( ) ;
51
51
52
52
// Build a device map
53
- let devicesMap = deviceSlice . reduce ( ( memo , device ) => {
53
+ const devicesMap = deviceSlice . reduce ( ( memo , device ) => {
54
54
memo [ device . deviceToken ] = device ;
55
55
return memo ;
56
56
} , { } ) ;
57
57
58
- let deviceTokens = Object . keys ( devicesMap ) ;
59
- let fcmPayload = generateFCMPayload ( data , pushId , timestamp , deviceTokens ) ;
60
- let registrationTokens = deviceTokens ;
61
- let length = registrationTokens . length ;
58
+ const deviceTokens = Object . keys ( devicesMap ) ;
59
+ const fcmPayload = generateFCMPayload ( data , pushId , timestamp , deviceTokens ) ;
60
+ const length = deviceTokens . length ;
62
61
log . info ( LOG_PREFIX , `sending push to ${ length } devices` ) ;
63
62
64
63
return this . sender . sendEachForMulticast ( fcmPayload . payload . data )
@@ -69,12 +68,12 @@ FCM.prototype.send = function(data, devices) {
69
68
70
69
response . responses . forEach ( ( resp , idx ) => {
71
70
if ( resp . success ) {
72
- successfulTokens . push ( registrationTokens [ idx ] ) ;
73
- promises . push ( createSuccesfullPromise ( registrationTokens [ idx ] , devicesMap [ registrationTokens [ idx ] ] . deviceType ) ) ;
71
+ successfulTokens . push ( deviceTokens [ idx ] ) ;
72
+ promises . push ( createSuccesfullPromise ( deviceTokens [ idx ] , devicesMap [ deviceTokens [ idx ] ] . deviceType ) ) ;
74
73
} else {
75
- failedTokens . push ( registrationTokens [ idx ] ) ;
76
- promises . push ( createErrorPromise ( registrationTokens [ idx ] , devicesMap [ registrationTokens [ idx ] ] . deviceType , resp . error ) ) ;
77
- log . error ( LOG_PREFIX , `failed to send to ${ registrationTokens [ idx ] } with error: ${ JSON . stringify ( resp . error ) } ` ) ;
74
+ failedTokens . push ( deviceTokens [ idx ] ) ;
75
+ promises . push ( createErrorPromise ( deviceTokens [ idx ] , devicesMap [ deviceTokens [ idx ] ] . deviceType , resp . error ) ) ;
76
+ log . error ( LOG_PREFIX , `failed to send to ${ deviceTokens [ idx ] } with error: ${ JSON . stringify ( resp . error ) } ` ) ;
78
77
}
79
78
} ) ;
80
79
@@ -108,7 +107,7 @@ FCM.prototype.send = function(data, devices) {
108
107
function generateFCMPayload ( requestData , pushId , timeStamp , deviceTokens ) {
109
108
delete requestData [ 'where' ] ;
110
109
requestData . tokens = deviceTokens ;
111
- let payload = { }
110
+ const payload = { }
112
111
113
112
payload . payload = {
114
113
data : requestData ,
@@ -126,7 +125,7 @@ function generateFCMPayload(requestData, pushId, timeStamp, deviceTokens) {
126
125
* @returns {Array } An array which contains several arrays of devices with fixed chunk size
127
126
*/
128
127
function sliceDevices ( devices , chunkSize ) {
129
- let chunkDevices = [ ] ;
128
+ const chunkDevices = [ ] ;
130
129
while ( devices . length > 0 ) {
131
130
chunkDevices . push ( devices . splice ( 0 , chunkSize ) ) ;
132
131
}
0 commit comments