import common from "../common/common.mjs";
const { asana } = common.props;
export default {
...common,
key: "asana-task-updated-in-project",
type: "source",
name: "New Task Updated In Project (Instant)",
description: "Emit new event for each update to a task.",
version: "1.1.6",
dedupe: "unique",
props: {
...common.props,
project: {
label: "Project",
description: "Gid of a project.",
type: "string",
propDefinition: [
asana,
"projects",
(c) => ({
workspace: c.workspace,
}),
],
},
tasks: {
optional: true,
propDefinition: [
asana,
"tasks",
(c) => ({
project: c.project,
}),
],
},
user: {
label: "Assignee",
type: "string",
description: "Only emit events for tasks assigned to this user GID",
optional: true,
propDefinition: [
asana,
"users",
({ workspace }) => ({
workspace,
}),
],
},
delay: {
type: "integer",
label: "Delay In Seconds",
description: "How long to wait before emitting events.",
default: 15,
optional: true,
},
},
methods: {
...common.methods,
getLastEventDate() {
return this.db.get("lastEventDate");
},
setLastEventDate(value) {
this.db.set("lastEventDate", value);
},
debounce(fn, delay = 15000) {
const lastEventDate = this.getLastEventDate();
if (lastEventDate) {
const diff = Date.now() - new Date(lastEventDate).getTime();
if (diff < delay) {
return;
}
}
fn();
this.setLastEventDate(new Date());
},
getWebhookFilter() {
return {
filters: [
{
action: "changed",
resource_type: "task",
},
],
resource: this.project,
};
},
async emitEvent(event) {
const {
tasks, user, delay,
} = this;
const { events = [] } = event.body || {};
const promises = events
.filter(({ resource }) => {
return tasks?.length
? tasks.includes(String(resource.gid))
: true;
})
.map(async (event) => ({
event,
task: (await this.asana.getTask({
taskId: event.resource.gid,
})).data,
}));
const responses = await Promise.all(promises);
responses
.filter(({ task }) => !user || task.assignee && task.assignee.gid === user)
.forEach(({
event, task,
}) => {
const ts = Date.parse(event.created_at);
this.debounce(() => this.$emit(task, {
id: `${task.gid}-${ts}`,
summary: task.name,
ts,
}), delay * 1000);
});
},
},
};