All files / src/Connector ZohoAddRecordsConnector.ts

94.11% Statements 16/17
50% Branches 1/2
100% Functions 2/2
94.11% Lines 16/17

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 762x 2x   2x   2x   2x     2x       2x 2x 2x 2x 2x   2x             2x   1x   1x       1x                                                                                
import AConnector from '@orchesty/nodejs-sdk/dist/lib/Connector/AConnector';
import { HttpMethods } from '@orchesty/nodejs-sdk/dist/lib/Transport/HttpMethods';
import ProcessDto from '@orchesty/nodejs-sdk/dist/lib/Utils/ProcessDto';
import { ACCOUNT_OWNER_NAME, APP_LINK_NAME, CREATOR_FORM, FORM_LINK_NAME } from '../ZohoApplication';
 
export const NAME = 'zoho-add-records-connector';
 
export default class ZohoAddRecordsConnector extends AConnector {
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: ProcessDto<IInput>): Promise<ProcessDto<IOutput>> {
        const appInstall = await this.getApplicationInstallFromProcess(dto);
        const accountOwnerName = appInstall.getSettings()[CREATOR_FORM][ACCOUNT_OWNER_NAME];
        const appLink = appInstall.getSettings()[CREATOR_FORM][APP_LINK_NAME];
        const formLink = appInstall.getSettings()[CREATOR_FORM][FORM_LINK_NAME];
        const url = `/${accountOwnerName}/${appLink}/form/${formLink}`;
 
        const req = await this.getApplication().getRequestDto(
            dto,
            appInstall,
            HttpMethods.POST,
            url,
            { data: dto.getJsonData() },
        );
        const resp = await this.getSender().send<IResponse>(req, [200]);
 
        const records = resp.getJsonBody();
 
        Iif (records.code !== 3000) {
            throw new Error(records.message);
        }
 
        return dto.setNewJsonData(records.data);
    }
 
}
 
/* eslint-disable @typescript-eslint/naming-convention */
 
export interface IInput {
    data: [
        {
            Email: string;
            Phone_Number: string;
        },
    ];
    result: {
        fields: string[];
        message: boolean;
        tasks: boolean;
    };
}
 
export interface IOutput {
    Email: string;
    Phone_Number: string;
    ID: string;
}
 
export interface IResponse {
    code: number;
    data: IOutput;
    message: string;
    tasks: {
        openurl: {
            type: string;
            url: string;
        };
    };
}
 
/* eslint-enable @typescript-eslint/naming-convention */