All files / src/Connector QuickBooksUploadAttachmentConnector.ts

100% Statements 19/19
100% Branches 0/0
100% Functions 2/2
100% Lines 19/19

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 1028x         8x 8x   8x   8x   8x     8x     8x       1x 1x               1x   1x 1x   1x               1x 1x 1x   1x   1x                                                                                                      
import AConnector from '@orchesty/nodejs-sdk/dist/lib/Connector/AConnector';
import {
    IResultRanges,
    StatusRange,
} from '@orchesty/nodejs-sdk/dist/lib/Transport/Curl/ResultCodeRange';
import { HttpMethods } from '@orchesty/nodejs-sdk/dist/lib/Transport/HttpMethods';
import { CommonHeaders } from '@orchesty/nodejs-sdk/dist/lib/Utils/Headers';
import ProcessDto from '@orchesty/nodejs-sdk/dist/lib/Utils/ProcessDto';
import FormData from 'form-data';
 
export const NAME = 'quick-books-upload-attachment-connector';
 
export default class QuickBooksUploadAttachmentConnector<I extends IInput = IInput,
    O extends IOutput = IOutput> extends AConnector {
 
    protected codeRange?: IResultRanges | StatusRange = { success: 200 };
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: ProcessDto<I>): Promise<ProcessDto<O>> {
        const { FileName, file, ...data } = dto.getJsonData();
        const metadata = {
            /* eslint-disable @typescript-eslint/naming-convention */
            AttachableRef: data.AttachableRef,
            FileName,
            ContentType: data.ContentType,
            /* eslint-enable @typescript-eslint/naming-convention */
        };
 
        const form = new FormData();
 
        form.append('file_metadata_01', JSON.stringify(metadata), { contentType: 'application/json' });
        form.append('file_content_01', Buffer.from(file, 'base64'), FileName);
 
        const request = await this.getApplication().getRequestDto(
            dto,
            await this.getApplicationInstallFromProcess(dto),
            HttpMethods.POST,
            '/upload',
            form,
        );
 
        const headers = request.getHeaders();
        delete headers?.[CommonHeaders.CONTENT_TYPE];
        request.setHeaders(headers);
 
        const response = await this.getSender().send<O>(request, this.codeRange);
 
        return dto.setNewJsonData(response.getJsonBody());
    }
 
}
 
export type IOutput = IResponse;
 
/* eslint-disable @typescript-eslint/naming-convention */
export interface IInput {
    AttachableRef: {
        EntityRef: {
            type: string;
            value: string;
        };
    }[];
    FileName: string;
    file: string;
    ContentType?: string;
}
 
export interface IResponse {
    AttachableResponse: {
        Attachable: {
            SyncToken: string;
            domain: string;
            FileAccessUri: string;
            ThumbnailFileAccessUri: string;
            AttachableRef: {
                IncludeOnSend: boolean;
                EntityRef: {
                    type: string;
                    value: string;
                };
            }[];
            TempDownloadUri: string;
            MetaData: {
                CreateTime: string;
                LastUpdatedTime: string;
            };
            sparse: boolean;
            ContentType: string;
            FileName: string;
            Id: string;
            Size: number;
        };
    }[];
    time?: string;
 
}
 
/* eslint-enable @typescript-eslint/naming-convention */