All files / src/Connector XeroUploadFile.ts

100% Statements 22/22
75% Branches 6/8
100% Functions 2/2
100% Lines 22/22

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 8710x   10x 10x 10x 10x 10x 10x   10x   10x         10x   10x     10x       10x 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 { validate } from '@orchesty/nodejs-sdk/dist/lib/Utils/Validations';
import FormData from 'form-data';
import Joi from 'joi';
 
export const NAME = 'xero-upload-file';
 
const inputSchema = Joi.object({
    file: Joi.string().required(),
    fileName: Joi.string().required(),
});
 
export default class XeroUploadFile<I extends IInput = IInput, O extends IOutput = IOutput> extends AConnector {
 
    protected codeRange?: IResultRanges | StatusRange = { success: 200 };
 
    public getName(): string {
        return NAME;
    }
 
    @validate(inputSchema)
    public async processAction(dto: ProcessDto<I>): Promise<ProcessDto<IErrorResponse | O>> {
        const { file, fileName } = dto.getJsonData();
 
        const form = new FormData();
        form.append(fileName, Buffer.from(file, 'base64'), fileName);
 
        const request = await this.getApplication().getRequestDto(
            dto,
            await this.getApplicationInstallFromProcess(dto),
            HttpMethods.POST,
            'https://api.xero.com/files.xro/1.0/Files',
            form,
        );
 
        const headers = request.getHeaders();
        delete headers?.[CommonHeaders.CONTENT_TYPE];
        request.setHeaders(headers);
 
        const response = await this.getSender().send<IErrorResponse | O>(request, this.codeRange);
 
        return dto.setNewJsonData(response.getJsonBody());
    }
 
}
 
export type IOutput = IResponse;
 
export interface IInput {
    file: string;
    fileName: string;
}
 
/* eslint-disable @typescript-eslint/naming-convention */
export interface IResponse {
    Name: string;
    MimeType: string;
    Size: number;
    CreatedDateUtc: string;
    UpdatedDateUtc: string;
    User: {
        Name: string;
        FirstName: string;
        LastName: string;
        FullName: string;
        Id: string;
    };
    FolderId: string;
    Id: string;
}
/* eslint-enable @typescript-eslint/naming-convention */
 
export interface IErrorResponse {
    /* eslint-disable @typescript-eslint/naming-convention */
    ErrorNumber: number;
    Type: string;
    Message: string;
    Elements: {
        ValidationErrors: { Message: string }[];
    }[];
    /* eslint-enable @typescript-eslint/naming-convention */
}