update-ticket.ts•3.81 kB
import { createAction, Property } from '@activepieces/pieces-framework';
import { Client } from '@hubspot/api-client';
import { MarkdownVariant } from '@activepieces/shared';
import { hubspotAuth } from '../../';
import { getDefaultPropertiesForObject, pipelineDropdown, pipelineStageDropdown, standardObjectDynamicProperties, standardObjectPropertiesDropdown } from '../common/props';
import { OBJECT_TYPE } from '../common/constants';
export const updateTicketAction = createAction({
auth: hubspotAuth,
name: 'update-ticket',
displayName: 'Update Ticket',
description: 'Updates a ticket in HubSpot.',
props: {
ticketId: Property.ShortText({
displayName: 'Ticket ID',
description: 'The ID of the ticket to update.',
required: true,
}),
ticketName: Property.ShortText({
displayName: 'Ticket Name',
required: false,
}),
pipelineId: pipelineDropdown({
objectType: OBJECT_TYPE.TICKET,
displayName: 'Ticket Pipeline',
required: false,
}),
pipelineStageId: pipelineStageDropdown({
objectType: OBJECT_TYPE.TICKET,
displayName: 'Ticket Pipeline Stage',
required: false,
}),
objectProperties: standardObjectDynamicProperties(OBJECT_TYPE.TICKET, [
'subject',
'hs_pipeline',
'hs_pipeline_stage',
]),
markdown: Property.MarkDown({
variant: MarkdownVariant.INFO,
value: `### Properties to retrieve:
subject, content, source_type, createdate, hs_pipeline, hs_pipeline_stage, hs_resolution, hs_ticket_category, hs_ticket_id, hs_ticket_priority, hs_lastmodifieddate, hubspot_owner_id, hubspot_team_id
**Specify here a list of additional properties to retrieve**`,
}),
additionalPropertiesToRetrieve: standardObjectPropertiesDropdown({
objectType: OBJECT_TYPE.TICKET,
displayName: 'Additional properties to retrieve',
required: false,
}),
},
async run(context) {
const {
ticketId,
ticketName,
pipelineId,
pipelineStageId,
} = context.propsValue;
const objectProperties = context.propsValue.objectProperties??{};
const additionalPropertiesToRetrieve = context.propsValue.additionalPropertiesToRetrieve??[];
const ticketProperties: Record<string, string> = {
};
if(ticketName)
{
ticketProperties['subject'] = ticketName;
}
if(pipelineId)
{
ticketProperties['hs_pipeline'] = pipelineId;
}
if(pipelineStageId)
{
ticketProperties['hs_pipeline_stage'] = pipelineStageId;
}
// Add additional properties to the ticketProperties object
Object.entries(objectProperties).forEach(([key, value]) => {
// Format values if they are arrays
ticketProperties[key] = Array.isArray(value) ? value.join(';') : value;
});
const client = new Client({ accessToken: context.auth.access_token });
const updatedTicket = await client.crm.tickets.basicApi.update(ticketId,{
properties: ticketProperties,
});
// Retrieve default properties for the ticket and merge with additional properties to retrieve
const defaultTicketProperties = getDefaultPropertiesForObject(OBJECT_TYPE.TICKET);
const ticketDetails = await client.crm.tickets.basicApi.getById(updatedTicket.id, [
...defaultTicketProperties,
...additionalPropertiesToRetrieve,
]);
return ticketDetails;
},
});