const request = require('request');
const db = require('../utils/db_config')


const fetchInvestorDetails = ((req, res) => {
    getAllInvstorData();
    res.send("in procress");
})

const getAllInvstorData = async () => {

    var options = {
        method: 'POST',
        url: 'https://supply-integration.liquiloans.com/api/v2/GetAllInvestors',
        headers: {
            'Content-Type': 'application/json',
        },
        body: JSON.stringify({
            mid: "M00201",
            checksum: "e7d0ab9fb1c79796a6ae6fd22600e22129e9fef1bfe9577717f9953d0e9064ff",
            timestamp: "2023-12-11 14:57:38",
            filter_on: "",
            filter_data: []
        })

    };
    request(options, function (error, response) {
        if (error) throw new Error(error);
        getAllInvstorDataStore(response.body);
    });
}


const getAllInvstorDataStore = async (body) => {
    const records = JSON.parse(body)
    let item = records?.data
    let storeData = [];
    if (item.length) {
        for (let i = 0; i < item?.length; i++) {
            let data = {};
                data.investor_id = item[i].investor_id,
                data.name = item[i].name,
                data.entity_type = item[i].entity_type,
                data.pan = item[i].pan,
                data.email = item[i].email,
                data.contact_number = item[i].contact_number,
                data.ifa_id = item[i].ifa_id,
                data.created_at = item[i].created_at,
                data.rm_name = item[i].rm_name,

                storeData.push(data);
        }
        console.log("AAAADDDDDDDDDDD_________", storeData);
          await db.liquiloansInvestors.bulkCreate(storeData);
    }
}



module.exports = {
    fetchInvestorDetails
}