All files / src/Connector QuickBooksFindCustomerConnector.ts

91.66% Statements 11/12
66.66% Branches 4/6
100% Functions 2/2
91.66% Lines 11/12

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 96 97 98 99 100 101 102 103 104 105 106 1078x 8x   8x   8x   8x     8x       1x 1x                   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 { StatusCodes } from 'http-status-codes';
 
export const NAME = 'quick-books-find-customer-connector';
 
export default class QuickBooksFindCustomerConnector extends AConnector {
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: ProcessDto<IInput>): Promise<ProcessDto<IOutput>> {
        const { contactName } = dto.getJsonData();
        const resp = await this.getSender().send<IResponse>(
            await this.getApplication().getRequestDto(
                dto,
                await this.getApplicationInstallFromProcess(dto),
                HttpMethods.GET,
                encodeURI(`/query?query=select * from Customer where DisplayName = '${contactName}'`),
            ),
            [200, 404],
        );
 
        const data = resp.getJsonBody();
        Iif (resp.getResponseCode() === StatusCodes.NOT_FOUND || data.QueryResponse.Customer === undefined) {
            return dto.setNewJsonData<IOutput>({ customer: null });
        }
        return dto.setNewJsonData<IOutput>({ customer: data.QueryResponse.Customer.shift() ?? null });
    }
 
}
 
/* eslint-disable @typescript-eslint/naming-convention */
export interface IResponse {
    QueryResponse: {
        Customer: ICustomer[];
        startPosition: number;
        maxResults: number;
    };
    time: string;
}
 
export interface ICustomer {
    domain: string;
    FamilyName: string;
    DisplayName: string;
    DefaultTaxCodeRef: {
        value: string;
    };
    PrimaryEmailAddr: {
        Address: string;
    };
    PreferredDeliveryMethod: string;
    GivenName: string;
    FullyQualifiedName: string;
    BillWithParent: boolean;
    Job: boolean;
    BalanceWithJobs: number;
    PrimaryPhone: {
        FreeFormNumber: string;
    };
    Active: boolean;
    MetaData: {
        CreateTime: string;
        LastUpdatedTime: string;
    };
    BillAddr: {
        City: string;
        Line1: string;
        PostalCode: string;
        Lat: string;
        Long: string;
        CountrySubDivisionCode: string;
        Id: string;
    };
    MiddleName: string;
    Notes: string;
    Taxable: boolean;
    Balance: number;
    SyncToken: string;
    CompanyName: string;
    ShipAddr: {
        City: string;
        Line1: string;
        PostalCode: string;
        Lat: string;
        Long: string;
        CountrySubDivisionCode: string;
        Id: string;
    };
    PrintOnCheckName: string;
    sparse: boolean;
    Id: string;
}
 
/* eslint-enable @typescript-eslint/naming-convention */
 
export interface IInput {
    contactName: string;
}
 
export interface IOutput {
    customer: ICustomer | null;
}