new-task.ts•3.91 kB
import { createTrigger, TriggerStrategy } from '@activepieces/pieces-framework';
import { fragmentAuth } from '../common/auth';
import { fragmentClient, FragmentTask } from '../common/client';
import { HttpMethod, QueryParams } from '@activepieces/pieces-common';
import { DedupeStrategy, Polling, pollingHelper } from '@activepieces/pieces-common';
import dayjs from 'dayjs';
const polling: Polling<string, Record<string, never>> = {
strategy: DedupeStrategy.TIMEBASED,
items: async ({ auth, lastFetchEpochMS }) => {
const isTest = lastFetchEpochMS > 0;
const qs: QueryParams = {
order_by: 'created_at',
limit: isTest ? '10' : '100',
};
if (!isTest) {
qs['created_at_after'] = dayjs(lastFetchEpochMS).toISOString();
}
const response = await fragmentClient.makeRequest<{ items: FragmentTask[] }>(
HttpMethod.GET,
'/tasks',
auth,
undefined,
qs,
);
const items = response.items.map((task) => ({
epochMilliSeconds: dayjs(task.created_at).valueOf(),
data: task,
}));
return items;
},
};
export const newTaskTrigger = createTrigger({
auth: fragmentAuth,
name: 'new_task',
displayName: 'New Task',
description: 'Triggers when a new task is created.',
props: {},
type: TriggerStrategy.POLLING,
async onEnable(context) {
await pollingHelper.onEnable(polling, {
auth: context.auth,
store: context.store,
propsValue: context.propsValue,
});
},
async onDisable(context) {
await pollingHelper.onDisable(polling, {
auth: context.auth,
store: context.store,
propsValue: context.propsValue,
});
},
async test(context) {
return await pollingHelper.test(polling, context);
},
async run(context) {
return await pollingHelper.poll(polling, context);
},
sampleData: {
uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
archived: true,
status: 'TODO',
legacy_data: {},
skills: ['3c90c3cc-0d44-4b50-8888-8dd25736052a'],
queue_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
assignee_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
participants: {},
case_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
parent_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
due_at: '2023-11-07T05:31:56Z',
snooze_expires_at: '2023-11-07T05:31:56Z',
fields: {},
metadata_form_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
form_data: {},
form_type: '<string>',
assigned_at: '2023-11-07T05:31:56Z',
started_at: '2023-11-07T05:31:56Z',
done_at: '2023-11-07T05:31:56Z',
created_at: '2023-11-07T05:31:56Z',
updated_at: '2023-11-07T05:31:56Z',
assignee_updated_by: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
queue_updated_by: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
is_assigned_player: true,
internal_created_at: '2023-11-07T05:31:56Z',
internal_updated_at: '2023-11-07T05:31:56Z',
external_created_at: '2023-11-07T05:31:56Z',
external_updated_at: '2023-11-07T05:31:56Z',
external_status: 'TODO',
external_status_updated_at: '2023-11-07T05:31:56Z',
external_assignee_uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
queue_time: 123,
queue_time_business: 123,
work_time: 123,
work_time_business: 123,
incremental_work_time: 123,
incremental_work_time_business: 123,
resolution_time: 123,
resolution_time_business: 123,
num_children: 123,
num_children_done: 123,
sla_breach_at: '2023-11-07T05:31:56Z',
sla_breach_business_at: '2023-11-07T05:31:56Z',
wait_time: 123,
wait_time_business: 123,
review_status: '<string>',
task_type: '<string>',
played_at: '2023-11-07T05:31:56Z',
assignee: {
uid: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
archived: true,
role: 'super_admin',
email: 'jsmith@example.com',
first_name: '<string>',
last_name: '<string>',
skills: ['3c90c3cc-0d44-4b50-8888-8dd25736052a'],
legacy_data: {},
created_at: '2023-11-07T05:31:56Z',
updated_at: '2023-11-07T05:31:56Z',
is_registered: true,
},
parent: {},
children: [{}],
},
});