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.error.status, message: err.error.message };
    }

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

    JSONInfo.cartID = cartID;

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

    try {
        const res = await request.post(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.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.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.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.saveTenantInfo = async (JSONInfo) => {

    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 = {
        body: JSONInfo,
        uri: `${yaasConfigBuilderModule.url}/${yaasConfigBuilderModule.tenant}/${yaasConfigBuilderModule.client}/data/${yaasConfigBuilderModule.type}/`,
        headers: {
            Authorization: tokenAuthorization
        },
        json: true
    };

    try {
        const res = await request.post(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;