You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
constfetch=require("node-fetch");// code to create caseasyncfunctioncreateCase(subject,at,priority){constsobj='Case';// TODO: change the url as requiredconsturl=`https://mohansun-fsc-21.my.salesforce.com/services/data/v46.0/sobjects/${sobj}`;// TODO: design the fields needed for the case creation and get it a part of the message dataconstpostbody={"Subject": `${subject}`,"Priority": `${priority}`};constparams={method: "POST",mode: "cors",headers: {"Content-Type":"application/json","Authorization": `Bearer ${at}`},body: JSON.stringify(postbody)};try{awaitfetch(url,params)}catch(err){console.log('Fetch ERROR!'+err);}}constsubscriptionName='CV19_CASE';consttimeout=60;// Imports the Google Cloud client libraryconst{PubSub}=require('@google-cloud/pubsub');// Creates a client; cache this for further useconstpubSubClient=newPubSub();functionlistenForMessages(){// References an existing subscriptionconstsubscription=pubSubClient.subscription(subscriptionName);// Create an event handler to handle messagesletmessageCount=0;constmessageHandler=message=>{console.log(`Received message ${message.id}:`);console.log(`\tData: ${message.data}`);console.log(`\tAttributes: ${message.attributes}`);messageCount+=1;// CREATE Case hereconstcst=awaitcreateCase(message.data.subject,message.data.at,message.data.priority);// "Ack" (acknowledge receipt of) the messagemessage.ack(message.data.);};// Listen for new messages until timeout is hitsubscription.on('message',messageHandler);setTimeout(()=>{subscription.removeListener('message',messageHandler);console.log(`${messageCount} message(s) received.`);},timeout*1000);}listenForMessages()
// filename:index.js// test file for sfbulk2js // author: mohan chinnappan (mar-18-2020) constsfb2=require('sfbulk2js');// the npm package we just installedconstfs=require('fs');constprocess=require('process');// read access-token from the envconstAT=process.env.AT;constcji={instanceUrl: 'https://mohansun-fsc-21.my.salesforce.com',apiVersion: 'v46.0',accessToken: `${AT}`,contentType: 'CSV',lineEnding: 'LF'};constwaitTimeMs=5000;functionsleep(ms){console.log('WAITING');returnnewPromise(resolve=>setTimeout(resolve,ms));}asyncfunctiondataload(datafile){try{console.log(`=== CREATE JOB === `);constjob=awaitsfb2.createJob(cji.instanceUrl,cji.apiVersion,cji.accessToken,'insert','Case',cji.contentType,cji.lineEnding);console.log(job);console.log(`jobId: ${job.id}`);console.log(`=== JOB STATUS === `);letjobStatus=awaitsfb2.getJobStatus(cji.instanceUrl,cji.apiVersion,cji.accessToken,'ingest',job.id);console.log(`=== JOB STATUS for job: ${job.id} ===`);console.log(jobStatus);console.log(`=== PUT DATA === `);constfdata=fs.readFileSync(datafile,'utf8');constputDataStatus=awaitsfb2.putData(cji.instanceUrl,cji.accessToken,job.contentUrl,fdata);console.log(`=== JOB STATUS === `);jobStatus=awaitsfb2.getJobStatus(cji.instanceUrl,cji.apiVersion,cji.accessToken,'ingest',job.id);console.log(`=== JOB STATUS for job: ${job.id} ===`);console.log(jobStatus);console.log(`=== PATCH STATAE === `);constpatchDataStatus=awaitsfb2.patchState(cji.instanceUrl,cji.apiVersion,cji.accessToken,job.id,'UploadComplete');console.log(patchDataStatus);console.log(`=== JOB STATUS === `);jobStatus=awaitsfb2.getJobStatus(cji.instanceUrl,cji.apiVersion,cji.accessToken,'ingest',job.id);console.log(`=== JOB STATUS for job: ${job.id} ===`);console.log(jobStatus);while(jobStatus.state==='InProgress'){// wait for it awaitsleep(waitTimeMs);jobStatus=awaitsfb2.getJobStatus(cji.instanceUrl,cji.apiVersion,cji.accessToken,'ingest',job.id);console.log(jobStatus);}console.log(`=== JOB Failure STATUS === `);jobStatus=awaitsfb2.getJobFailureStatus(cji.instanceUrl,cji.apiVersion,cji.accessToken,job.id);console.log(`=== JOB Failure STATUS for job: ${job.id} ===`);console.log(jobStatus);console.log(`=== JOB getUnprocessedRecords STATUS === `);jobStatus=awaitsfb2.getUnprocessedRecords(cji.instanceUrl,cji.apiVersion,cji.accessToken,job.id);console.log(`=== JOB getUnprocessedRecords STATUS for job: ${job.id} ===`);console.log(jobStatus);}catch(err){console.log(`ERROR in dataload : ${err}`);}}// here we run itdataload('input.csv');