handlers scheduleCalculations.handler.ts

0% Statements 0/40

0% Branches 0/1

0% Functions 0/1

0% Lines 0/40

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  import { Injectable } from '@nestjs/common';

import { CalculationTrigger, CalculationType, type ScheduleCalculationEvent } from '@amalia/core/types';
import { MessageTasks, MessageType, QueueService, type TaskHandler } from '@amalia/kernel/queue/core';
import { CompaniesService } from '@amalia/tenants/companies/core';

@Injectable()
export class ScheduleCalculationsHandler implements TaskHandler<number> {
  public constructor(
    private readonly companiesService: CompaniesService,
    private readonly queueService: QueueService,
  ) {}

  public async handle(batchNumber: number) {
    const activeCompaniesForThisBatch = await this.companiesService.getActiveCompaniesByBatchNumber(batchNumber);

    await Promise.all(
      activeCompaniesForThisBatch.map((company) =>
        this.queueService.sendToQueue(
          {
            type: MessageType.TASK,
            taskIdentifier: MessageTasks.SCHEDULE_CALCULATION,
          },
          {
            calculationEvent: {
              companyId: company.id,
              query: {
                trigger: CalculationTrigger.NIGHTLY_CALCULATION,
                type: CalculationType.STATEMENT,
              },
              options: {
                withRollingPeriods: true,
              },
            } as ScheduleCalculationEvent,
          },
        ),
      ),
    );
  }
}