hubspot engagements api

engag

const axiosDefault = require("axios");

const CSVtoJSON = (strData, strDelimiter) => {
  strDelimiter = strDelimiter || ",";
  if (strData.substr(-1) !== "\n") strData += "\n";

  let objPattern = new RegExp(
    "(\\" + strDelimiter + "|\\r?\\n|\\r|^)" + '(?:"([^"]*(?:""[^"]*)*)"|' + '([^"\\' + strDelimiter + "\\r\\n]*))",
    "gi"
  );

  const jsonData = [];
  let arrMatches = null;
  let keys = [];
  let row = [];

  while ((arrMatches = objPattern.exec(strData))) {
    const strMatchedDelimiter = arrMatches[1];

    const newRow = strMatchedDelimiter.length && strMatchedDelimiter !== strDelimiter;

    if (newRow) {
      if (!keys.length) {
        keys = row;
      } else {
        let data = {};
        for (let i in row) {
          data[keys[i]] = row[i];
        }
        jsonData.push(data);
      }
      row = [];
    }

    let strMatchedValue;
    if (arrMatches[2]) {
      strMatchedValue = arrMatches[2].replace(new RegExp('""', "g"), '"');
    } else {
      strMatchedValue = arrMatches[3];
    }
    row.push(strMatchedValue);
  }
  return jsonData;
};


function csvJSON(csv){
  var lines = csv.split("\n");

  var result = [];
  var headers=lines[0].split(",");

  for(var i=1;i<lines.length;i++){

    var obj = {};
    var currentline=lines[i].split(",");

    for(var j=0;j<headers.length;j++){
      obj[headers[j]] = currentline[j];
    }

    result.push(obj);

  }
  return result; //JSON
}


exports.main = async (event, callback) => {
  // const fileToLoad = "https://gist.githubusercontent.com/NickDeckerDevs/259033e173bedfb5f6e3f133ad313c19/raw/28ec9b94dddbf446ff6b3799224378ee3910e8e3/test-import-engagements.csv"
  const fileToLoad = "https://gist.githubusercontent.com/NickDeckerDevs/7c1aad2f8504e05ea62a18998e0abc45/raw/afd4c5be3dcf2c42bf512fc4af7bf2046e43fb89/one.csv"
  
  
  try {
    const axios = axiosDefault.create({
      baseURL: "https://api.hubapi.com",
      params: {
        hapikey: process.env.hsapikey,
      },
      headers: {
        accept: "application/json",
        "content-type": "application/json",
      },
    });

    const { data: file } = await axiosDefault.get(fileToLoad, { responseType: "blob" });
    const engagements = fileToLoad.indexOf('.csv') > -1 ? CSVtoJSON(file) : file
	// console.log(engagements)

    let interation = 0;
    for (const engagement of engagements) {
      try {
        interation++;
        if (interation % 20 === 0) {
          // Every 20 interation for 10 seconds
          await new Promise((resolve) => setTimeout(resolve, 10000));
        }
        const testing = true
        
        const timestamp = Date.parse(engagement['Date'])
        const owner = testing ? 151 : engagement["Owner ID"]
        
        

        
        const properties = {
          hs_timestamp: timestamp,
          hubspot_owner_id: owner
        };
		
        let endpoint = false
        const fromObjectType = engagement['Activity Type']
        switch(fromObjectType) {
          case 'Phone Call':
            endpoint = 'calls'
            properties['hs_call_body'] = engagement['Details']
            properties['hs_call_direction'] = 'OUTBOUND'
            properties['hs_call_title'] = engagement['Details']
            break
          case 'Note':
            endpoint = 'notes'
            properties['hs_note_body'] = engagement['Details']
            break  
          case 'Meeting':
            endpoint = 'meetings'
            properties['hs_meeting_title'] = engagement['Details']
            properties['hs_meeting_body'] = engagement['Details']
            break
          case 'To Do':
            endpoint = 'tasks'
            // possible ternary below
            properties['hs_task_subject'] = engagement['Details']
			properties['hs_task_status'] = "WAITING"
			properties['hs_task_priority'] = "NONE"
            break
          default:
            endpoint = false

        }
		const postUrl = `/crm/v3/objects/${endpoint}`
        const createEngagement = await axios.post(postUrl, { properties });

        
        

		const engagementId = createEngagement.data.id;
        
		const toObjectId = testing ? 124875674 : engagement["HubSpot ID"];
		const toObjectType = engagement['Association']
        
        let associationObject = false

        switch(toObjectType) {
          case 'Contact':
            associationObject = 'contact'
            break
          case 'Deal':
            associationObject = 'deal'
            break
          case 'Company':
            associationObject = 'company'
            break
          default: 
            associationObject = false
            
        }
        
        const getAssociationId = await axios.get(`/crm/v3/associations/${fromObjectType}/${toObjectType}/types`)

        const associationTypeId = getAssociationId.data.results[0].id

        const assocationUrl = `/crm/v3/objects/${endpoint}/${engagementId}/associations/${associationObject}/${toObjectId}/${associationTypeId}`
        console.log(getAssociationId.data.results[0].id, assocationUrl)
        const connectObjects = await axios.put(assocationUrl);
        
      } catch (err) {
        console.log(err.data);
      }
    }
//        engagements,
    callback({
      outputFields: {
        error: false,
      },
    });
  } catch (err) {
    console.log(err.data);
    callback({
      outputFields: {
        error: true,
      },
    });
  }
};