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

refactor: share task flow create params

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-19 05:16:38 +01:00
parent d385b96451
commit 2f84c47b8b
1 changed files with 12 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/tasks/task-flow-registry.ts
View File

@@ -58,12 +58,9 @@ type FlowRecordPatch = Omit<
endedAt?: number | null;
};
export type CreateFlowRecordParams = {
syncMode?: TaskFlowSyncMode;
type FlowRecordCreateFields = {
ownerKey: string;
requesterOrigin?: TaskFlowRecord["requesterOrigin"];
controllerId?: string | null;
revision?: number;
status?: TaskFlowStatus;
notifyPolicy?: TaskNotifyPolicy;
goal: string;
@@ -78,6 +75,12 @@ export type CreateFlowRecordParams = {
endedAt?: number | null;
};
export type CreateFlowRecordParams = FlowRecordCreateFields & {
syncMode?: TaskFlowSyncMode;
controllerId?: string | null;
revision?: number;
};
export type TaskFlowUpdateResult =
| {
applied: true;
@@ -349,23 +352,11 @@ export function createFlowRecord(params: CreateFlowRecordParams): TaskFlowRecord
return writeFlowRecord(record);
}
export function createManagedTaskFlow(params: {
ownerKey: string;
controllerId: string;
requesterOrigin?: TaskFlowRecord["requesterOrigin"];
status?: TaskFlowStatus;
notifyPolicy?: TaskNotifyPolicy;
goal: string;
currentStep?: string | null;
blockedTaskId?: string | null;
blockedSummary?: string | null;
stateJson?: JsonValue | null;
waitJson?: JsonValue | null;
cancelRequestedAt?: number | null;
createdAt?: number;
updatedAt?: number;
endedAt?: number | null;
}): TaskFlowRecord {
export function createManagedTaskFlow(
params: FlowRecordCreateFields & {
controllerId: string;
},
): TaskFlowRecord {
return createFlowRecord({
...params,
syncMode: "managed",