romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Cleanup: Remove unnecessary agent-runner-execution logger and fix related type errors

Browse Source
This commit is contained in:
USO Status 2026-01-27 19:08:50 +01:00
parent 34733a8eb6
commit fab8550843
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/auto-reply/reply/agent-runner-execution.ts
View File

@ -41,9 +41,6 @@ import {
handleAgentEventForStatus, handleAgentEventForStatus,
type StatusUpdateRunContext, type StatusUpdateRunContext,
} from "./status-updates-integration.js"; } from "./status-updates-integration.js";
import { createSubsystemLogger } from "../../logging/subsystem.js";
const log = createSubsystemLogger("agent-runner-execution");
export type AgentRunLoopResult = export type AgentRunLoopResult =
| { | {
@ -310,7 +307,6 @@ export async function runAgentTurnWithFallback(params: {
onAgentEvent: async (evt) => { onAgentEvent: async (evt) => {
// ===== STATUS UPDATES: Handle agent events ===== // ===== STATUS UPDATES: Handle agent events =====
if (params.statusUpdateContext) { if (params.statusUpdateContext) {
log.debug(`onAgentEvent: forwarding to status updates, stream=${evt.stream}`);
await handleAgentEventForStatus(params.statusUpdateContext, evt); await handleAgentEventForStatus(params.statusUpdateContext, evt);
} }
// ===== END STATUS UPDATES ===== // ===== END STATUS UPDATES =====

11
src/auto-reply/reply/status-updates-integration.ts
View File

@ -5,8 +5,7 @@
* and provides helpers for resolving configuration from the config. * and provides helpers for resolving configuration from the config.
*/ */
import type { ClawdbotConfig } from "../../config/config.js"; import type { StatusUpdateConfig, MoltbotConfig } from "../../config/config.js";
import type { StatusUpdateConfig } from "../../config/types.base.js";
import type { ChannelCapabilities } from "../../channels/plugins/types.core.js"; import type { ChannelCapabilities } from "../../channels/plugins/types.core.js";
import { import {
createStatusUpdateController, createStatusUpdateController,
@ -22,14 +21,14 @@ const log = createSubsystemLogger("status-updates-integration");
* Resolve status update configuration from the Clawdbot config. * Resolve status update configuration from the Clawdbot config.
*/ */
export function resolveStatusUpdateConfigFromConfig( export function resolveStatusUpdateConfigFromConfig(
cfg: ClawdbotConfig, cfg: MoltbotConfig,
agentId?: string, agentId?: string,
): StatusUpdateConfig { ): StatusUpdateConfig {
log.debug(`Resolving status update config for agentId=${agentId}`); log.debug(`Resolving status update config for agentId=${agentId}`);
// Check agent-specific config first // Check agent-specific config first
if (agentId && cfg.agents?.list) { if (agentId && cfg.agents?.list) {
const agentCfg = cfg.agents.list.find((a) => a.id === agentId); const agentCfg = cfg.agents.list.find((a: any) => a.id === agentId);
if (agentCfg?.statusUpdates) { if (agentCfg?.statusUpdates) {
log.debug(`Found agent-specific config: ${JSON.stringify(agentCfg.statusUpdates)}`); log.debug(`Found agent-specific config: ${JSON.stringify(agentCfg.statusUpdates)}`);
return agentCfg.statusUpdates; return agentCfg.statusUpdates;
@ -54,7 +53,7 @@ export function channelSupportsEdit(capabilities?: ChannelCapabilities): boolean
* Returns undefined if status updates are disabled. * Returns undefined if status updates are disabled.
*/ */
export function createAgentStatusController(params: { export function createAgentStatusController(params: {
cfg: ClawdbotConfig; cfg: MoltbotConfig;
agentId?: string; agentId?: string;
callbacks: StatusUpdateCallbacks; callbacks: StatusUpdateCallbacks;
}): StatusUpdateController | undefined { }): StatusUpdateController | undefined {
@ -180,7 +179,7 @@ export async function completeStatusUpdate(
} }
log.debug(`completeStatusUpdate: finalizing status update`); log.debug(`completeStatusUpdate: finalizing status update`);
const result = await ctx.controller.complete(finalText); const result = await (ctx.controller as any).complete(finalText);
log.debug(`completeStatusUpdate: result=${result?.substring(0, 50)}...`); log.debug(`completeStatusUpdate: result=${result?.substring(0, 50)}...`);
return result; return result;
} }