vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-04 03:00:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: dedupe webhook task view helpers

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-06 18:38:42 +01:00
parent 90f33ed5da
commit 00e46301a4
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
extensions/webhooks/src/http.ts
View File

@@ -223,6 +223,13 @@ type TaskView = {
terminalOutcome?: string;
};
function optionalField<TKey extends string, TValue>(
key: TKey,
value: TValue | undefined,
): Partial<Record<TKey, TValue>> {
return value !== undefined ? ({ [key]: value } as Record<TKey, TValue>) : {};
}
function toFlowView(flow: {
flowId: string;
syncMode: "task_mirrored" | "managed";
@@ -252,12 +259,12 @@ function toFlowView(flow: {
...(flow.currentStep ? { currentStep: flow.currentStep } : {}),
...(flow.blockedTaskId ? { blockedTaskId: flow.blockedTaskId } : {}),
...(flow.blockedSummary ? { blockedSummary: flow.blockedSummary } : {}),
...(flow.stateJson !== undefined ? { stateJson: flow.stateJson } : {}),
...(flow.waitJson !== undefined ? { waitJson: flow.waitJson } : {}),
...(flow.cancelRequestedAt !== undefined ? { cancelRequestedAt: flow.cancelRequestedAt } : {}),
...optionalField("stateJson", flow.stateJson),
...optionalField("waitJson", flow.waitJson),
...optionalField("cancelRequestedAt", flow.cancelRequestedAt),
createdAt: flow.createdAt,
updatedAt: flow.updatedAt,
...(flow.endedAt !== undefined ? { endedAt: flow.endedAt } : {}),
...optionalField("endedAt", flow.endedAt),
};
}
@@ -302,10 +309,10 @@ function toTaskView(task: {
deliveryStatus: task.deliveryStatus,
notifyPolicy: task.notifyPolicy,
createdAt: task.createdAt,
...(task.startedAt !== undefined ? { startedAt: task.startedAt } : {}),
...(task.endedAt !== undefined ? { endedAt: task.endedAt } : {}),
...(task.lastEventAt !== undefined ? { lastEventAt: task.lastEventAt } : {}),
...(task.cleanupAfter !== undefined ? { cleanupAfter: task.cleanupAfter } : {}),
...optionalField("startedAt", task.startedAt),
...optionalField("endedAt", task.endedAt),
...optionalField("lastEventAt", task.lastEventAt),
...optionalField("cleanupAfter", task.cleanupAfter),
...(task.error ? { error: task.error } : {}),
...(task.progressSummary ? { progressSummary: task.progressSummary } : {}),
...(task.terminalSummary ? { terminalSummary: task.terminalSummary } : {}),