task-assigned.ts•5.25 kB
import {
TriggerStrategy,
createTrigger,
} from '@activepieces/pieces-framework';
import { common, OnfleetWebhookTriggers } from '../common';
import { onfleetAuth } from '../..';
import { WebhookHandshakeStrategy } from '@activepieces/shared';
export const taskAssigned = createTrigger({
auth: onfleetAuth,
name: 'task_assigned',
displayName: 'Task Assigned',
description: 'Triggers when a task is assigned',
type: TriggerStrategy.WEBHOOK,
props: {},
//Create the webhook and save the webhook ID in store for disable behavior
async onEnable(context) {
const webhookId = await common.subscribeWebhook(
context.auth,
context.webhookUrl,
OnfleetWebhookTriggers.TASK_ASSIGNED
);
await context.store?.put('_task_assigned_trigger', {
webhookId: webhookId,
});
},
//Delete the webhook
async onDisable(context) {
const response: any = await context.store?.get('_task_assigned_trigger');
if (response !== null && response !== undefined) {
await common.unsubscribeWebhook(context.auth, response.webhookId);
}
},
//Return task
async run(context) {
return [context.payload.body];
},
handshakeConfiguration: {
strategy: WebhookHandshakeStrategy.QUERY_PRESENT,
paramName: 'check',
},
async onHandshake(context) {
return {
status: 200,
body: context.payload.queryParams['check'],
};
},
sampleData: {
actionContext: {
id: 'vjw*RDMKDljKVDve1Vtcplgu',
type: 'ADMIN',
},
adminId: 'vjw*RDMKDljKVDve1Vtcplgu',
data: {
task: {
appearance: {
triangleColor: null,
},
completeAfter: 1612987200000,
completeBefore: 1613008800000,
completionDetails: {
actions: [],
events: [],
failureNotes: '',
failureReason: 'NONE',
firstLocation: [],
lastLocation: [],
time: null,
unavailableAttachments: [],
},
container: {
type: 'WORKER',
worker: 'COwfwH~Zogm1LXIZYbPlLAyw',
},
creator: 'vjw*RDMKDljKVDve1Vtcplgu',
delayTime: null,
dependencies: [],
destination: {
address: {
apartment: '',
city: 'Anaheim',
country: 'United States',
name: 'Honda Center',
number: '2695',
postalCode: '92806',
state: 'California',
street: 'East Katella Avenue',
},
id: 'I5rMyWx4YHDcMGIwfD3TL8nf',
location: [-117.8764687, 33.8078476],
metadata: [],
notes: 'This is a destination note',
timeCreated: 1613002583000,
timeLastModified: 1613002583913,
},
estimatedArrivalTime: null,
estimatedCompletionTime: null,
executor: 'nYrkNP6jZMSKgBwG9qG7ci3J',
feedback: [],
id: 'txiK2xHBIaUwAKB~BJrjscKu',
identity: {
checksum: null,
failedScanCount: 0,
},
merchant: 'nYrkNP6jZMSKgBwG9qG7ci3J',
metadata: [],
notes: 'This is a Task note',
organization: 'nYrkNP6jZMSKgBwG9qG7ci3J',
overrides: {},
pickupTask: false,
quantity: 1,
recipients: [
{
id: 'A~pBTrc5~dTMBBImswg7U4YT',
metadata: [],
name: 'Test User One',
notes: 'This is a recipient note',
organization: 'nYrkNP6jZMSKgBwG9qG7ci3J',
phone: '+17145554231',
skipSMSNotifications: false,
timeCreated: 1613002583000,
timeLastModified: 1613002583931,
},
],
serviceTime: 3,
shortId: 'fab829cf',
state: 1,
timeCreated: 1613002583000,
timeLastModified: 1613004164514,
trackingURL: 'https://onf.lt/fab829cf81',
trackingViewed: false,
worker: 'COwfwH~Zogm1LXIZYbPlLAyw',
},
worker: {
accountStatus: 'ACCEPTED',
activeTask: null,
capacity: 3,
delayTime: null,
displayName: '',
hasRecentlyUsedSpoofedLocations: false,
id: 'COwfwH~Zogm1LXIZYbPlLAyw',
imageUrl: null,
location: [-117.8901118, 33.893365],
metadata: [],
name: 'Shured Shuanger',
onDuty: true,
organization: 'nYrkNP6jZMSKgBwG9qG7ci3J',
phone: '+17145555678',
tasks: ['txiK2xHBIaUwAKB~BJrjscKu'],
teams: ['K3FXFtJj2FtaO2~H60evRrDc'],
timeCreated: 1585254830000,
timeLastModified: 1613004164511,
timeLastSeen: 1613004141332,
timezone: 'America/Los_Angeles',
userData: {
appVersion: '2.1.11.1',
batteryLevel: 0.64,
deviceDescription: 'Google Pixel 2 (Android 11)',
platform: 'ANDROID',
},
vehicle: {
color: '',
description: '',
id: 'Dib0eZfs*uJhJmWHKL~tExub',
licensePlate: '',
timeLastModified: 1612226873144,
type: 'CAR',
},
},
},
taskId: 'txiK2xHBIaUwAKB~BJrjscKu',
time: 1613004164575,
triggerId: 9,
triggerName: 'taskAssigned',
workerId: 'COwfwH~Zogm1LXIZYbPlLAyw',
},
});