Module where the record is located.
Id of the record to get.
async
(params, auths) => {
}
//See Zoho CRM API docs at: https://www.zoho.com/crm/developer/docs/api/v2/get-records.html
if (!params.module || !params.record_id) {
throw new Error("Must provide module, and record_id parameters.");
}
return await require("@pipedreamhq/platform").axios(this, {
url: `https://www.zohoapis.com/crm/v2/${params.module}/${params.record_id}`,
headers: {
"Authorization": `Zoho-oauthtoken ${auths.zoho_crm.oauth_access_token}`,
},
})
async
(params, auths) => {
}
const fs = require('fs')
const file = await require("@pipedreamhq/platform").axios(this, {
url: `${auths.zoho_crm.api_domain}/crm/v2/${params.module}/${params.record_id}/Attachments/${params.attachment_id}`,
headers: {
"Authorization": `Zoho-oauthtoken ${auths.zoho_crm.oauth_access_token}`,
},
responseType: 'arraybuffer'
})
const file_path = '/tmp/' + params.attachment_id
fs.writeFileSync(file_path, file)
this.file_path = file_path
async
(params, auths) => {
}
const fs = require('fs')
const {axios} = require('@pipedreamhq/platform')
const file_name = params.file_name
const file_path = params.file_path
try{
const account_info = await axios(this, {
method: 'GET',
url: 'http://mail.zoho.com/api/accounts',
headers: {
Authorization: `Zoho-oauthtoken ${auths.zoho_mail.oauth_access_token}`
}
})
const account_id = account_info.data[0].accountId
const file = await fs.createReadStream(file_path)
const response = await axios(this, {
method: 'POST',
url: `https://mail.zoho.com/api/accounts/${account_id}/messages/attachments`,
headers: {
"Authorization": `Zoho-oauthtoken ${auths.zoho_mail.oauth_access_token}`,
'Content-Type': 'application/octet-stream'
},
params: {
fileName: file_name
},
data: file
})
this.attachment = response.data
} catch (err){
console.log(err.message)
console.log(err.response)
}