vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-22 14:41:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: dedupe lobster managed flow formatting

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-06 20:31:39 +01:00
parent 7d54f2a3c2
commit 95df6d9332
1 changed files with 21 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
extensions/lobster/src/lobster-tool.ts
View File

@@ -42,6 +42,13 @@ type ManagedFlowResumeParams = {
waitingStep?: string;
};
type ManagedFlowSuccessResult = {
ok: true;
envelope: unknown;
flow: unknown;
mutation: unknown;
};
function readOptionalTrimmedString(value: unknown, fieldName: string): string | undefined {
if (value === undefined) {
return undefined;
@@ -167,6 +174,18 @@ function parseResumeFlowParams(params: Record<string, unknown>): ManagedFlowResu
};
}
function formatManagedFlowResult(result: ManagedFlowSuccessResult) {
const details = {
...result.envelope,
flow: result.flow,
mutation: result.mutation,
};
return {
content: [{ type: "text", text: JSON.stringify(details, null, 2) }],
details,
};
}
export function createLobsterTool(api: OpenClawPluginApi, options?: LobsterToolOptions) {
const runner = options?.runner ?? createEmbeddedLobsterRunner();
return {
@@ -246,15 +265,7 @@ export function createLobsterTool(api: OpenClawPluginApi, options?: LobsterToolO
if (!result.ok) {
throw result.error;
}
const details = {
...result.envelope,
flow: result.flow,
mutation: result.mutation,
};
return {
content: [{ type: "text", text: JSON.stringify(details, null, 2) }],
details,
};
return formatManagedFlowResult(result);
}
} else {
const flowParams = parseResumeFlowParams(params);
@@ -278,15 +289,7 @@ export function createLobsterTool(api: OpenClawPluginApi, options?: LobsterToolO
if (!result.ok) {
throw result.error;
}
const details = {
...result.envelope,
flow: result.flow,
mutation: result.mutation,
};
return {
content: [{ type: "text", text: JSON.stringify(details, null, 2) }],
details,
};
return formatManagedFlowResult(result);
}
}