feat(clickup): add new tasks trigger
This commit is contained in:
@@ -1,5 +1,7 @@
|
||||
import listFolders from './list-folders/index.js';
|
||||
import listLists from './list-lists/index.js';
|
||||
import listSpaces from './list-spaces/index.js';
|
||||
import listTasks from './list-tasks/index.js';
|
||||
import listWorkspaces from './list-workspaces/index.js';
|
||||
|
||||
export default [listFolders, listSpaces, listWorkspaces];
|
||||
export default [listFolders, listLists, listSpaces, listTasks, listWorkspaces];
|
||||
|
@@ -0,0 +1,28 @@
|
||||
export default {
|
||||
name: 'List lists',
|
||||
key: 'listLists',
|
||||
|
||||
async run($) {
|
||||
const lists = {
|
||||
data: [],
|
||||
};
|
||||
const folderId = $.step.parameters.folderId;
|
||||
|
||||
if (!folderId) {
|
||||
return lists;
|
||||
}
|
||||
|
||||
const { data } = await $.http.get(`/v2/folder/${folderId}/list`);
|
||||
|
||||
if (data.lists) {
|
||||
for (const list of data.lists) {
|
||||
lists.data.push({
|
||||
value: list.id,
|
||||
name: list.name,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
return lists;
|
||||
},
|
||||
};
|
@@ -0,0 +1,41 @@
|
||||
export default {
|
||||
name: 'List tasks',
|
||||
key: 'listTasks',
|
||||
|
||||
async run($) {
|
||||
const tasks = {
|
||||
data: [],
|
||||
};
|
||||
const listId = $.step.parameters.listId;
|
||||
let next = false;
|
||||
|
||||
if (!listId) {
|
||||
return tasks;
|
||||
}
|
||||
|
||||
const params = {
|
||||
order_by: 'created',
|
||||
reverse: true,
|
||||
};
|
||||
|
||||
do {
|
||||
const { data } = await $.http.get(`/v2/list/${listId}/task`, { params });
|
||||
if (data.last_page) {
|
||||
next = false;
|
||||
} else {
|
||||
next = true;
|
||||
}
|
||||
|
||||
if (data.tasks) {
|
||||
for (const task of data.tasks) {
|
||||
tasks.data.push({
|
||||
value: task.id,
|
||||
name: task.name,
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (next);
|
||||
|
||||
return tasks;
|
||||
},
|
||||
};
|
@@ -1,4 +1,5 @@
|
||||
import newFolders from './new-folders/index.js';
|
||||
import newLists from './new-lists/index.js';
|
||||
import newTasks from './new-tasks/index.js';
|
||||
|
||||
export default [newFolders, newLists];
|
||||
export default [newFolders, newLists, newTasks];
|
||||
|
186
packages/backend/src/apps/clickup/triggers/new-tasks/index.js
Normal file
186
packages/backend/src/apps/clickup/triggers/new-tasks/index.js
Normal file
@@ -0,0 +1,186 @@
|
||||
import Crypto from 'crypto';
|
||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
||||
|
||||
export default defineTrigger({
|
||||
name: 'New tasks',
|
||||
key: 'newTasks',
|
||||
type: 'webhook',
|
||||
description: 'Triggers when a new task is created.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Workspace',
|
||||
key: 'workspaceId',
|
||||
type: 'dropdown',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listWorkspaces',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'Space',
|
||||
key: 'spaceId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
dependsOn: ['parameters.workspaceId'],
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listSpaces',
|
||||
},
|
||||
{
|
||||
name: 'parameters.workspaceId',
|
||||
value: '{parameters.workspaceId}',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'Folder',
|
||||
key: 'folderId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
dependsOn: ['parameters.spaceId'],
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listFolders',
|
||||
},
|
||||
{
|
||||
name: 'parameters.spaceId',
|
||||
value: '{parameters.spaceId}',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'List',
|
||||
key: 'listId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
dependsOn: ['parameters.folderId'],
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listLists',
|
||||
},
|
||||
{
|
||||
name: 'parameters.folderId',
|
||||
value: '{parameters.folderId}',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'Task',
|
||||
key: 'taskId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
dependsOn: ['parameters.listId'],
|
||||
description:
|
||||
'Choose an optional task to determine when this flow should be activated. In this scenario, only subtasks will initiate this flow.',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listTasks',
|
||||
},
|
||||
{
|
||||
name: 'parameters.listId',
|
||||
value: '{parameters.listId}',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const dataItem = {
|
||||
raw: $.request.body,
|
||||
meta: {
|
||||
internalId: Crypto.randomUUID(),
|
||||
},
|
||||
};
|
||||
|
||||
$.pushTriggerItem(dataItem);
|
||||
},
|
||||
|
||||
async testRun($) {
|
||||
const sampleEventData = {
|
||||
event: 'taskCreated',
|
||||
task_id: '86enn7pg7',
|
||||
webhook_id: $.webhookUrl.split('/')[5],
|
||||
history_items: [],
|
||||
};
|
||||
|
||||
const dataItem = {
|
||||
raw: sampleEventData,
|
||||
meta: {
|
||||
internalId: sampleEventData.webhook_id,
|
||||
},
|
||||
};
|
||||
|
||||
$.pushTriggerItem(dataItem);
|
||||
},
|
||||
|
||||
async registerHook($) {
|
||||
const { workspaceId, spaceId, folderId, listId, taskId } =
|
||||
$.step.parameters;
|
||||
|
||||
const payload = {
|
||||
name: $.flow.id,
|
||||
endpoint: $.webhookUrl,
|
||||
events: ['taskCreated'],
|
||||
space_id: spaceId,
|
||||
};
|
||||
|
||||
if (folderId) {
|
||||
payload.folder_id = folderId;
|
||||
}
|
||||
|
||||
if (listId) {
|
||||
payload.list_id = listId;
|
||||
}
|
||||
|
||||
if (taskId) {
|
||||
payload.task_id = taskId;
|
||||
}
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/v2/team/${workspaceId}/webhook`,
|
||||
payload
|
||||
);
|
||||
|
||||
await $.flow.setRemoteWebhookId(data.id);
|
||||
},
|
||||
|
||||
async unregisterHook($) {
|
||||
await $.http.delete(`/v2/webhook/${$.flow.remoteWebhookId}`);
|
||||
},
|
||||
});
|
@@ -5,6 +5,8 @@ items:
|
||||
desc: Triggers when a new folder is created.
|
||||
- name: New lists
|
||||
desc: Triggers when a new list is created.
|
||||
- name: New tasks
|
||||
desc: Triggers when a new task is created.
|
||||
---
|
||||
|
||||
<script setup>
|
||||
|
Reference in New Issue
Block a user