All files / src/Connector MondayCreateBoardConnector.ts

95.23% Statements 20/21
50% Branches 3/6
100% Functions 2/2
95.23% Lines 20/21

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 107 108 109 110 1113x 3x 3x     3x   3x     3x       1x 1x   1x 2x 1x   1x     1x 1x   1x 1x             1x 1x   1x     1x                                                                                                                                          
import AConnector from '@orchesty/nodejs-sdk/dist/lib/Connector/AConnector';
import OnRepeatException from '@orchesty/nodejs-sdk/dist/lib/Exception/OnRepeatException';
import { HttpMethods } from '@orchesty/nodejs-sdk/dist/lib/Transport/HttpMethods';
import ProcessDto from '@orchesty/nodejs-sdk/dist/lib/Utils/ProcessDto';
 
export const NAME = 'monday-create-board';
 
export default class MondayCreateBoardConnector extends AConnector {
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: ProcessDto<IInput>): Promise<ProcessDto> {
        const body = dto.getJsonData();
        let graphQl = 'mutation { create_board (';
 
        for (const [key, value] of Object.entries(body)) {
            if (key === 'board_kind') {
                graphQl += `${key}:${value},`;
            } else {
                graphQl += `${key}:"${value}",`;
            }
        }
        graphQl = graphQl.slice(0, -1);
        graphQl += ') {board_kind description groups{id} id owner{id} owners{id}'
        + ' permissions state subscribers{id} top_group{id}}}';
        const appInstall = await this.getApplicationInstallFromProcess(dto);
        const req = await this.getApplication().getRequestDto(
            dto,
            appInstall,
            HttpMethods.POST,
            undefined,
            { query: graphQl },
        );
        const resp = await this.getSender().send<IOutput>(req, [200]);
        const output = resp.getJsonBody();
 
        Iif (output.error_code) {
            throw new OnRepeatException(60, 10, output.error_code ?? 'Unknown error.');
        }
        return dto.setNewJsonData(output);
    }
 
}
 
/* eslint-disable @typescript-eslint/naming-convention */
 
export interface IInput {
    board_name: string;
    board_kind: 'board_kind' | 'public' | 'share';
    folder_id?: number;
    workspace_id?: number;
    template_id?: number;
    board_owner_ids?: number[];
    board_subscriber_ids?: number[];
}
 
export interface IOutput {
    id: string;
    groups: {
        ids: string[];
    }[];
    board_kind: 'board_kind' | 'public' | 'share';
    owner: string;
    owners: string[];
    permissions: 'assignee' | 'collaborators' | 'everyone' | 'owners';
    state: 'active' | 'all' | 'archived' | 'deleted';
    subscribers: string[];
    top_group: string[];
    activity_logs?: {
        limit?: number;
        page?: number;
        user_ids?: number[];
        column_ids?: string;
        group_ids?: string;
        item_ids?: number;
        from?: Date;
        to?: Date;
    }[];
    board_folder_id?: number;
    columns?: {
        ids?: string[];
    }[];
    name?: string;
    description?: string;
    items?: {
        ids?: number[];
        limit?: number;
        page?: number;
        newest_first?: boolean;
    };
    pos?: string;
    tags?: string[];
    type?: string;
    updated_at?: Date;
    updates?: {
        limit?: number;
        page?: number;
    }[];
    views?: {
        ids?: number[];
        type?: string;
    }[];
    workspace?: string;
    workspace_id?: number;
    error_code?: string;
    status_code?: number;
    error_message?: string;
}