All files / src/Batch SageHrListEmployeesBatch.ts

92.85% Statements 13/14
50% Branches 2/4
100% Functions 2/2
92.85% Lines 13/14

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 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 962x 2x     2x   2x     2x       1x 1x 1x           1x 1x   1x 1x       1x                                                                                                                                    
import ABatchNode from '@orchesty/nodejs-sdk/dist/lib/Batch/ABatchNode';
import { HttpMethods } from '@orchesty/nodejs-sdk/dist/lib/Transport/HttpMethods';
import BatchProcessDto from '@orchesty/nodejs-sdk/dist/lib/Utils/BatchProcessDto';
 
export const NAME = 'sage-hr-list-employees-batch';
 
export default class SageHrListEmployeesBatch extends ABatchNode {
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: BatchProcessDto): Promise<BatchProcessDto> {
        const page = dto.getBatchCursor('1');
        const appInstall = await this.getApplicationInstallFromProcess(dto);
        const req = await this.getApplication().getRequestDto(
            dto,
            appInstall,
            HttpMethods.GET,
            `employees?page=${page}`,
        );
        const resp = await this.getSender().send<IResponse>(req, [200]);
        const response = resp.getJsonBody();
 
        dto.setItemList(response.data ?? []);
        Iif (response.meta.current_page < response.meta.total_pages) {
            dto.setBatchCursor(response.meta.next_page.toString());
        }
 
        return dto;
    }
 
}
 
/* eslint-disable @typescript-eslint/naming-convention */
 
interface IResponse {
    data: IOutput[];
    meta: {
        current_page: number;
        next_page: number;
        total_pages: number;
        per_page: number;
        total_entries: number;
    };
}
 
export interface IOutput {
    data: {
        id: number;
        email: string;
        first_name: string;
        last_name: string;
        picture_url: string;
        employment_start_date: string;
        date_of_birth: string;
        team: string;
        team_id: number;
        position: string;
        position_id: number;
        reports_to_employee_id: number;
        work_phone: string;
        home_phone: string;
        mobile_phone: string;
        gender: string;
        street_first: string;
        street_second: string;
        city: string;
        post_code: number;
        country: string;
        employee_number: string;
        employment_status: string;
        team_history: {
            team_id: number;
            start_date: string;
            end_date: string;
            team_name: string;
        }[];
        employment_status_history: {
            employment_status_id: number;
            start_date: string;
            end_date: string;
            employment_statu_name: string;
        }[];
        position_history: {
            position_id: number;
            start_date: string;
            end_date: string;
            position_name: string;
            position_code: string;
        }[];
    }[];
}
 
/* eslint-enable @typescript-eslint/naming-convention */