const request = require('request-promise-native');

const appliancesStorageFacade = [];

const yaasData = {
    client: {
        clientID: 'ecxEHXeKZJdo4xhVvEvZPX9uyccRMqCl',
        clientSecret: 'rIITEf40Hh8lIbXK'
    },
    scopes: ['hybris.document_manage', 'hybris.document_view', 'thack.infinitecart_manage']
};

const yaasConfig = {
    url: 'https://api.us.yaas.io/hybris/document/v1',
    tenant: 'inficart',
    client: 'inficart.appliancedoc',
    type: 'savedAppliances'
};

const yaasConfigBuilderModule = {
    url: 'https://api.us.yaas.io/hybris/document/v1',
    tenant: 'inficart',
    client: 'inficart.appliancedoc',
    type: 'builderModule'
};

appliancesStorageFacade.getToken = async (yaasData) => {
    const { client, tenant, scopes } = yaasData;

    let requestedScopes = [];

    if (tenant) {
        requestedScopes.push(`hybris.tenant=${tenant}`);
    }

    if (scopes) {
        requestedScopes = requestedScopes.concat(scopes);
    }
    const requestOptions = {
        auth: {
            username: client.clientID,
            password: client.clientSecret
        },
        form: {
            grant_type: 'client_credentials',
            scope: requestedScopes.join(' ')
        }
    };

    const url = 'https://api.us.yaas.io/hybris/oauth2/v1/token';

    try {
        const token = await request.post(url, requestOptions);
        return JSON.parse(token);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }
};

appliancesStorageFacade.getCartID = async (deviceID, token) => {
    const tokenAuthorization = `${token.token_type} ${token.access_token}`;
    const options = {
        uri: `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/${deviceID}`,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };

    try {
        const appliances = await request.get(options);
        return appliances.cartID;
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }
};

appliancesStorageFacade.registerDevice = async (JSONInfo, cartID) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.status, message: err.message };
    }

    const tokenAuthorization = `${token.token_type} ${token.access_token}`;

    JSONInfo.cartID = cartID;

    const options = {
        body: JSONInfo,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };
    const uri = `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/`;

    try {
        const res = await request.post(uri, options);
        return { status: '201', message: 'Device registered successfully' };
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }
};


appliancesStorageFacade.unregisterDevice = async (deviceID) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }

    const tokenAuthorization = `${token.token_type} ${token.access_token}`;

    const options = {
        uri: `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/${deviceID}`,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };

    try {
        const appliances = await request.delete(options);
        return { status: '204', message: 'The request succeeded' };
    }
    catch (err) {
        if (err.error.status === '400') {
            err.error.message = 'Parameter is not valid: Parameter is empty or has special characters.';
        }
        if (err.error.status === '404') {
            err.error.message = 'The request is about to delete a non-existing resource/object.';
        }
        throw { status: err.error.status, message: err.error.message };
    }
};

appliancesStorageFacade.getDevices = async (applianceOwner) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }

    const tokenAuthorization = `${token.token_type} ${token.access_token}`;

    const options = {
        uri: `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/?fetchAll=true&q=applianceOwner:"${applianceOwner}"`,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };

    try {
        const appliances = await request.get(options);
        if (appliances.length === 0) {
            throw { error: { status: '404', message: 'Not Found. The server did not find anything matching the Request-URI.' } };
        }
        return { status: '200', message: appliances };
    }
    catch (err) {
        if (err.error.status === '304') {
            err.error.message = 'Entity has not been modified and the version cached by the client may be used';
        }
        if (err.error.status === '404') {
            err.error.message = 'Not Found. The server did not find anything matching the Request-URI.';
        }
        throw { status: err.error.status, message: err.error.message };
    }
};

appliancesStorageFacade.getDevice = async (deviceID) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }


    const tokenAuthorization = `${token.token_type} ${token.access_token}`;

    const options = {
        uri: `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/${deviceID}`,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };


    try {
        const appliances = await request.get(options);
        return { status: 200, device: appliances };
    }
    catch (err) {
        if (err.error.status === '304') {
            err.error.message = 'Entity has not been modified and the version cached by the client may be used';
        }
        if (err.error.status === '404') {
            err.error.message = 'Not Found. The server did not find anything matching the Request-URI.';
        }
        throw { status: err.error.status, message: err.error.message };

    }
};

appliancesStorageFacade.updateDevice = async (deviceID, newCartID) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }

    const tokenAuthorization = `${token.token_type} ${token.access_token}`;
    const options = {
        uri: `${yaasConfig.url}/${yaasConfig.tenant}/${yaasConfig.client}/data/${yaasConfig.type}/${deviceID}/?&path=true&partial=true`,
        body: {
            cartID: newCartID
        },
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };

    let cartID = '';
    try {
        cartID = await appliancesStorageFacade.getCartID(deviceID, token);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }


    try {
        const appliances = await request.put(options);

        if (appliances.status === '201') {
            return { status: appliances.status, message: 'The request has been fulfilled and a new resource has been created. Returned if upsert==true and the resource did not exist.' };
        }
        return { status: '200', cartID: cartID };
    }
    catch (err) {
        if (err.error.status === '404') {
            err.error.message = 'The request is about to change a non-existing resource/object';
        }
        if (err.error.status === '409') {
            err.error.message = 'Data modification failed because of a version conflict';
        }
        throw { status: err.error.status, message: err.error.message };
    }
};

appliancesStorageFacade.checkTenant = async (JSONInfo) => {
    const tenantInfo = await appliancesStorageFacade.getTenantInfo(JSONInfo.tenant);

    if(tenantInfo.tenant.length === 0) return false;

    if (tenantInfo.tenant[0].tenant === JSONInfo.tenant) {
        let token = '';
        try {
            token = await appliancesStorageFacade.getToken(yaasData);
        }
        catch (err) {
            throw { status: err.error.status, message: err.error.message };
        }
        const tokenAuthorization = `${token.token_type} ${token.access_token}`;
        const options = {
            uri: `${yaasConfigBuilderModule.url}/${yaasConfigBuilderModule.tenant}/${yaasConfigBuilderModule.client}/data/${yaasConfigBuilderModule.type}/${tenantInfo.tenant[0].id}`,
            body: JSONInfo,
            headers: {
                Authorization: tokenAuthorization
            },
            json: true
        };
        try {
            const response = await request.put(options);
            if (response.status === '201') {
                return { status: response.status, message: 'The request has been fulfilled and a new resource has been created. Returned if upsert==true and the resource did not exist.' };
            }
            return { status: '200', message: 'Tenant has been updated properly' };
        }
        catch (err) {
            if (err.error.status === '404') {
                err.error.message = 'The request is about to change a non-existing resource/object';
            }
            if (err.error.status === '409') {
                err.error.message = 'Data modification failed because of a version conflict';
            }
            throw { status: err.error.status, message: err.error.message };
        }
    }
    else {
        return false;
    }


};


appliancesStorageFacade.saveTenantInfo = async (JSONInfo) => {

    let check = '';
    try {
        check = await appliancesStorageFacade.checkTenant(JSONInfo);
    }
    catch (error) {
        throw error;
    }
    if (check !== false) {
        return check;
    }

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.status, message: err.message };
    }

    const tokenAuthorization = `${token.token_type} ${token.access_token}`;


    const options = {
        body: JSONInfo,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };
    const uri = `${yaasConfigBuilderModule.url}/${yaasConfigBuilderModule.tenant}/${yaasConfigBuilderModule.client}/data/${yaasConfigBuilderModule.type}/`;


    try {
        const res = await request.post(uri, options);
        return { status: '201', message: 'Tenant info saved properly' };
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }
};


appliancesStorageFacade.getTenantInfo = async (tenant) => {

    let token = '';
    try {
        token = await appliancesStorageFacade.getToken(yaasData);
    }
    catch (err) {
        throw { status: err.error.status, message: err.error.message };
    }


    const tokenAuthorization = `${token.token_type} ${token.access_token}`;

    const options = {
        uri: `${yaasConfigBuilderModule.url}/${yaasConfigBuilderModule.tenant}/${yaasConfigBuilderModule.client}/data/${yaasConfigBuilderModule.type}/?fetchAll=true&q=tenant:"${tenant}"`,

        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };


    try {
        const tenantInfo = await request.get(options);
        return { status: 200, tenant: tenantInfo };
    }
    catch (err) {
        if (err.error.status === '304') {
            err.error.message = 'Entity has not been modified and the version cached by the client may be used';
        }
        if (err.error.status === '404') {
            err.error.message = 'Not Found. The server did not find anything matching the Request-URI.';
        }
        throw { status: err.error.status, message: err.error.message };

    }
};



appliancesStorageFacade.yaasData = yaasData;
appliancesStorageFacade.yaasConfig = yaasConfig;
module.exports = appliancesStorageFacade;