File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -205,7 +205,7 @@ export default class GrouperWorker extends Worker {
205205 groupHash : uniqueEventHash ,
206206 delta : JSON . stringify ( delta ) ,
207207 timestamp : task . event . timestamp ,
208- // payload: task.event,
208+ payload : task . event ,
209209 } as RepetitionDBScheme ;
210210
211211 repetitionId = await this . saveRepetition ( task . projectId , newRepetition ) ;
@@ -270,7 +270,7 @@ export default class GrouperWorker extends Worker {
270270 * @param projectId - where to find
271271 * @param count - how many events to return
272272 */
273- private findLastEvents ( projectId : string , count ) : Promise < GroupedEventDBScheme [ ] > {
273+ private findLastEvents ( projectId : string , count : number ) : Promise < GroupedEventDBScheme [ ] > {
274274 return this . cache . get ( `last:${ count } :eventsOf:${ projectId } ` , async ( ) => {
275275 return this . db . getConnection ( )
276276 . collection ( `events:${ projectId } ` )
You can’t perform that action at this time.
0 commit comments