@@ -138,14 +138,19 @@ class TopEventsJob extends job.Job {
138138 * The errors of all functions will be caught here.
139139 */
140140 async getAllApps ( ) {
141+ log . d ( "Fetching all apps" ) ;
141142 try {
142143 const getAllApps = await new Promise ( ( res , rej ) => common . db . collection ( "apps" ) . find ( { } , { _id : 1 , timezone : 1 } ) . toArray ( ( err , apps ) => err ? rej ( err ) : res ( apps ) ) ) ;
143- await Promise . all ( getAllApps . map ( ( app ) => this . getAppEvents ( app ) ) ) ;
144+ for ( var z = 0 ; z < getAllApps . length ; z ++ ) {
145+ //Calculating for each app serially.
146+ await this . getAppEvents ( getAllApps [ z ] ) ;
147+ }
144148 }
145149 catch ( error ) {
146150 log . e ( "TopEvents Job has a error: " , error ) ;
147151 throw error ;
148152 }
153+ log . d ( "Finished processing" ) ;
149154 }
150155
151156 /**
@@ -178,6 +183,7 @@ class TopEventsJob extends job.Job {
178183 * @param {Object } app - saveAppEvents object
179184 */
180185 async getAppEvents ( app ) {
186+ log . d ( app . _id + ": Fetching app events" ) ;
181187 const getEvents = await new Promise ( ( res , rej ) => common . db . collection ( "events" ) . findOne ( { _id : app . _id } , ( errorEvents , result ) => errorEvents ? rej ( errorEvents ) : res ( result ) ) ) ;
182188 if ( getEvents && 'list' in getEvents ) {
183189 const eventMap = this . eventsFilter ( getEvents . list ) ;
@@ -199,6 +205,7 @@ class TopEventsJob extends job.Job {
199205 let totalDuration = 0 ;
200206 let prevTotalDuration = 0 ;
201207 for ( const event of eventMap ) {
208+ log . d ( " getting event data for event: " + event + " (" + period + ")" ) ;
202209 const collectionNameEvents = this . eventsCollentions ( { event, id : app . _id } ) ;
203210 await this . getEventsCount ( { collectionNameEvents, ob, data, event } ) ;
204211 totalCount += data [ event ] . data . count . total ;
@@ -208,11 +215,16 @@ class TopEventsJob extends job.Job {
208215 totalDuration += data [ event ] . data . duration . total ;
209216 prevTotalDuration += data [ event ] . data . duration [ "prev-total" ] ;
210217 }
218+ log . d ( " getting session count (" + period + ")" ) ;
211219 await this . getSessionCount ( { ob, sessionData, usersData, usersCollectionName } ) ;
220+ log . d ( " saving data (" + period + ")" ) ;
212221 await this . saveAppEvents ( { app, data, sessionData, usersData, period, totalCount, prevTotalCount, totalSum, prevTotalSum, totalDuration, prevTotalDuration } ) ;
213222 }
214223 }
215224 }
225+ else {
226+ log . d ( " No events found for app" ) ;
227+ }
216228
217229 }
218230
0 commit comments