mirror of
https://github.com/openclaw/openclaw.git
synced 2026-08-12 21:53:00 -06:00
refactor(core): drop unused internal helpers
This commit is contained in:
@@ -18,10 +18,6 @@ export class SessionActorQueue {
|
||||
return total;
|
||||
}
|
||||
|
||||
getPendingCountForSession(actorKey: string): number {
|
||||
return this.pendingBySession.get(actorKey) ?? 0;
|
||||
}
|
||||
|
||||
async run<T>(actorKey: string, op: () => Promise<T>): Promise<T> {
|
||||
return this.queue.enqueue(actorKey, op, {
|
||||
onEnqueue: () => {
|
||||
|
||||
@@ -123,7 +123,7 @@ export function createMediaGenerateProviderListActionResult<
|
||||
};
|
||||
}
|
||||
|
||||
/** Creates status and duplicate-guard action helpers for a media generation task type. */
|
||||
/** Creates status action helpers for a media generation task type. */
|
||||
export function createMediaGenerateTaskStatusActions<Task>(params: {
|
||||
inactiveText: string;
|
||||
findActiveTask: (sessionKey?: string) => Task | undefined;
|
||||
@@ -140,15 +140,6 @@ export function createMediaGenerateTaskStatusActions<Task>(params: {
|
||||
buildStatusDetails: params.buildStatusDetails,
|
||||
});
|
||||
},
|
||||
|
||||
createDuplicateGuardResult(sessionKey?: string): MediaGenerateActionResult | undefined {
|
||||
return createMediaGenerateDuplicateGuardResult({
|
||||
sessionKey,
|
||||
findActiveTask: params.findActiveTask,
|
||||
buildStatusText: params.buildStatusText,
|
||||
buildStatusDetails: params.buildStatusDetails,
|
||||
});
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
@@ -177,29 +168,3 @@ function createMediaGenerateStatusActionResult<Task>(params: {
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
function createMediaGenerateDuplicateGuardResult<Task>(params: {
|
||||
sessionKey?: string;
|
||||
findActiveTask: (sessionKey?: string) => Task | undefined;
|
||||
buildStatusText: TaskStatusTextBuilder<Task>;
|
||||
buildStatusDetails: (task: Task) => Record<string, unknown>;
|
||||
}): MediaGenerateActionResult | undefined {
|
||||
const activeTask = params.findActiveTask(params.sessionKey);
|
||||
if (!activeTask) {
|
||||
return undefined;
|
||||
}
|
||||
// Duplicate guard returns the active status payload so callers can show current progress.
|
||||
return {
|
||||
content: [
|
||||
{
|
||||
type: "text",
|
||||
text: params.buildStatusText(activeTask, { duplicateGuard: true }),
|
||||
},
|
||||
],
|
||||
details: {
|
||||
action: "status",
|
||||
duplicateGuard: true,
|
||||
...params.buildStatusDetails(activeTask),
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
@@ -162,14 +162,3 @@ function setPrecomputedSubcommandHelpText(
|
||||
[commandName]: value,
|
||||
};
|
||||
}
|
||||
|
||||
export const testing = {
|
||||
resetPrecomputedRootHelpTextForTests(): void {
|
||||
precomputedRootHelpText = undefined;
|
||||
precomputedBrowserHelpText = undefined;
|
||||
precomputedSecretsHelpText = undefined;
|
||||
precomputedNodesHelpText = undefined;
|
||||
precomputedSubcommandHelpText = undefined;
|
||||
},
|
||||
};
|
||||
export { testing as __testing };
|
||||
|
||||
@@ -150,14 +150,6 @@ export class TranscriptsStore {
|
||||
return session ? { session, sessionDir: dir } : undefined;
|
||||
}
|
||||
|
||||
/** Append an utterance by session id, creating a dated session directory if needed. */
|
||||
async appendUtterance(sessionId: string, utterance: TranscriptUtterance): Promise<void> {
|
||||
const dir =
|
||||
(await this.findSessionDir(sessionId)) ??
|
||||
path.join(this.rootDir, dateSegment(sessionId), safeSegment(sessionId));
|
||||
await this.appendUtteranceToDir(dir, sessionId, utterance);
|
||||
}
|
||||
|
||||
/** Append an utterance for an exact session descriptor. */
|
||||
async appendUtteranceForSession(
|
||||
session: TranscriptSessionDescriptor,
|
||||
@@ -195,18 +187,6 @@ export class TranscriptsStore {
|
||||
return await this.readUtterancesFromDir(sessionDir, options);
|
||||
}
|
||||
|
||||
/** Read utterances by session id or qualified date/id selector. */
|
||||
async readUtterances(
|
||||
sessionId: string,
|
||||
options: { maxUtterances?: number } = {},
|
||||
): Promise<TranscriptUtterance[]> {
|
||||
const dir = await this.findSessionDir(sessionId);
|
||||
if (!dir) {
|
||||
return [];
|
||||
}
|
||||
return await this.readUtterancesFromDir(dir, options);
|
||||
}
|
||||
|
||||
private async readUtterancesFromDir(
|
||||
dir: string,
|
||||
options: { maxUtterances?: number } = {},
|
||||
|
||||
@@ -363,14 +363,6 @@ export class ChatLog extends Container {
|
||||
return component;
|
||||
}
|
||||
|
||||
updateToolArgs(toolCallId: string, args: unknown) {
|
||||
const existing = this.toolById.get(toolCallId);
|
||||
if (!existing) {
|
||||
return;
|
||||
}
|
||||
existing.setArgs(args);
|
||||
}
|
||||
|
||||
updateToolResult(
|
||||
toolCallId: string,
|
||||
result: unknown,
|
||||
|
||||
Reference in New Issue
Block a user