All files / src/Connector HeurekaProductFeedConnector.ts

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

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 882x 2x   2x 2x   2x   2x     2x       1x 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 { XMLParser } from 'fast-xml-parser';
import { PRODUCT_FEED_URL, SETTINGS } from '../HeurekaFeedApplication';
 
export const NAME = 'heureka-product-feed-connector';
 
export default class HeurekaProductFeedConnector extends AConnector {
 
    public getName(): string {
        return NAME;
    }
 
    public async processAction(dto: ProcessDto): Promise<ProcessDto<IOutput>> {
        const appInstall = await this.getApplicationInstallFromProcess(dto);
        const req = await this.getApplication()
            .getRequestDto(
                dto,
                appInstall,
                HttpMethods.GET,
                appInstall.getSettings()[SETTINGS][PRODUCT_FEED_URL],
            );
        const resp = await this.getSender()
            .send(req, [200]);
 
        const parser = new XMLParser();
        const shopItems = parser.parse(resp.getBody()) as IOutput;
 
        return dto.setNewJsonData<IOutput>(shopItems);
    }
 
}
 
/* eslint-disable @typescript-eslint/naming-convention */
export interface IOutput {
    SHOPITEM: IShopItem[];
}
 
export interface IShopItem {
    ITEM_ID: string;
    PRODUCTNAME: string;
    PRODUCT: string;
    DESCRIPTION: string;
    URL: string;
    IMGURL: string;
    IMGURL_ALTERNATIVE: string;
    VIDEO_URL: string;
    PRICE_VAT: number;
    HEUREKA_CPC: number;
    MANUFACTURER: string;
    CATEGORYTEXT: string;
    EAN: string;
    PRODUCTNO: string;
    PARAM: IParam[];
    DELIVERY_DATE: number;
    DELIVERY: IDelivery[];
    ITEMGROUP_ID: string;
    ACCESSORY: string;
    GIFT: string;
    EXTENDED_WARRANTY: IExtendedWarranty;
    SPECIAL_SERVICE: string;
    SALES_VOUCHER: ISalesVoucher;
 
}
 
export interface IParam {
    PARAM_NAME: string;
    VAL: string;
}
 
export interface IDelivery {
    DELIVERY_ID: string;
    DELIVERY_PRICE: string;
    DELIVERY_PRICE_COD: string;
}
 
export interface IExtendedWarranty {
    VAL: number;
    DESC: string;
}
 
export interface ISalesVoucher {
    CODE: string;
    DESC: string;
}
/* eslint-enable @typescript-eslint/naming-convention */