Function clearRuntimeToolProgress

desktop/runtime/thread-publisher.ts:114–139

(
  runtime: PiRuntime,
  options: { toolCallId?: string | undefined; toolName?: string | undefined } = {},
)

}

export function clearRuntimeToolProgress(
  runtime: PiRuntime,
  options: { toolCallId?: string | undefined; toolName?: string | undefined } = {},
) {
  const progress = liveToolProgressByRuntime.get(runtime)
  if (!progress) {
    return
  }

  if (options.toolCallId) {
    progress.delete(options.toolCallId)
  } else if (options.toolName) {
    for (const [toolCallId, entry] of progress) {
      if (entry.toolName === options.toolName) {
        progress.delete(toolCallId)
        break
      }
    }
  } else {
    progress.clear()
  }

  if (progress.size === 0) {
    liveToolProgressByRuntime.delete(runtime)
  }
}

function buildLiveThreadData(runtime: PiRuntime) {
  const sessionPath = runtime.session.sessionFile