mirror of
https://github.com/openclaw/openclaw.git
synced 2026-08-26 04:15:48 -06:00
Peter Steinberger
3e0c980aaf
* fix(models): honor per-agent model metadata Resolve per-agent aliases, bare providers, fallbacks, and catalog tags consistently across runtime, CLI, Gateway, sessions, and the Control UI. * fix(models): preserve projection ownership * fix(models): carry agent scope through fallbacks * test(models): complete compaction fallback mock * test(models): complete startup fallback mock * test(agents): isolate recovery id expectations * refactor(protocol): split public schema barrel * test(cron): await child readiness events * fix(models): scope native catalogs to session agent * perf(ui): tighten agent model option projection * perf(ui): reduce agent model projection overhead
150 lines
4.7 KiB
Swift
150 lines
4.7 KiB
Swift
#if DEBUG
|
|
import Foundation
|
|
import OpenClawChatUI
|
|
import OpenClawProtocol
|
|
|
|
struct MacSwarmFixtureChatTransport: OpenClawChatTransport {
|
|
let sessionKey = "agent:main:swarm-fixture"
|
|
|
|
func requestHistory(sessionKey: String) async throws -> OpenClawChatHistoryPayload {
|
|
OpenClawChatHistoryPayload(
|
|
sessionKey: sessionKey,
|
|
sessionId: "mac-swarm-fixture",
|
|
messages: [
|
|
AnyCodable([
|
|
"role": "assistant",
|
|
"content": [["type": "text", "text": "Coordinating five independent research threads."]],
|
|
"timestamp": 1,
|
|
]),
|
|
],
|
|
thinkingLevel: "medium")
|
|
}
|
|
|
|
func listModels(agentID _: String?) async throws -> [OpenClawChatModelChoice] {
|
|
[OpenClawChatModelChoice(
|
|
modelID: "gpt-5.6-sol",
|
|
name: "GPT-5.6 Sol",
|
|
provider: "openai",
|
|
contextWindow: 400_000)]
|
|
}
|
|
|
|
func isSwarmEnabled(sessionKey _: String) async throws -> Bool {
|
|
true
|
|
}
|
|
|
|
func sendMessage(
|
|
sessionKey _: String,
|
|
message _: String,
|
|
thinking _: String,
|
|
idempotencyKey: String,
|
|
attachments _: [OpenClawChatAttachmentPayload]) async throws -> OpenClawChatSendResponse
|
|
{
|
|
try JSONDecoder().decode(
|
|
OpenClawChatSendResponse.self,
|
|
from: Data("{\"runId\":\"\(idempotencyKey)\",\"status\":\"ok\"}".utf8))
|
|
}
|
|
|
|
func listSessions(
|
|
limit _: Int?,
|
|
search _: String?,
|
|
archived _: Bool) async throws -> OpenClawChatSessionsListResponse
|
|
{
|
|
OpenClawChatSessionsListResponse(
|
|
ts: 1,
|
|
path: nil,
|
|
count: 1,
|
|
defaults: OpenClawChatSessionsDefaults(
|
|
modelProvider: "openai",
|
|
model: "gpt-5.6-sol",
|
|
contextTokens: 400_000,
|
|
mainSessionKey: self.sessionKey),
|
|
sessions: [self.session(
|
|
key: self.sessionKey,
|
|
label: "Swarm research",
|
|
status: "running",
|
|
groupID: nil)])
|
|
}
|
|
|
|
func listChildSessions(parentKey: String) async throws -> [OpenClawChatSessionEntry] {
|
|
let groupID = "swarm:\(parentKey):research"
|
|
return [
|
|
self.session(
|
|
key: "polling",
|
|
label: "National polling",
|
|
status: "done",
|
|
groupID: groupID,
|
|
parentKey: parentKey),
|
|
self.session(
|
|
key: "work",
|
|
label: "Work and labor",
|
|
status: "running",
|
|
groupID: groupID,
|
|
parentKey: parentKey),
|
|
self.session(key: "health", label: "Health", status: "running", groupID: groupID, parentKey: parentKey),
|
|
self.session(
|
|
key: "trust",
|
|
label: "Governance and trust",
|
|
status: nil,
|
|
groupID: groupID,
|
|
parentKey: parentKey,
|
|
queued: true),
|
|
self.session(
|
|
key: "media",
|
|
label: "Media signals",
|
|
status: "failed",
|
|
groupID: groupID,
|
|
parentKey: parentKey),
|
|
]
|
|
}
|
|
|
|
func requestHealth(timeoutMs _: Int) async throws -> Bool {
|
|
true
|
|
}
|
|
|
|
func events() -> AsyncStream<OpenClawChatTransportEvent> {
|
|
AsyncStream { continuation in continuation.finish() }
|
|
}
|
|
|
|
func setActiveSessionKey(_: String) async throws {}
|
|
|
|
private func session(
|
|
key: String,
|
|
label: String,
|
|
status: String?,
|
|
groupID: String?,
|
|
parentKey: String? = nil,
|
|
queued: Bool = false) -> OpenClawChatSessionEntry
|
|
{
|
|
OpenClawChatSessionEntry(
|
|
key: key,
|
|
kind: "direct",
|
|
displayName: label,
|
|
surface: nil,
|
|
subject: nil,
|
|
room: nil,
|
|
space: nil,
|
|
updatedAt: 1,
|
|
sessionId: nil,
|
|
systemSent: nil,
|
|
abortedLastRun: nil,
|
|
thinkingLevel: nil,
|
|
verboseLevel: nil,
|
|
inputTokens: nil,
|
|
outputTokens: nil,
|
|
totalTokens: nil,
|
|
modelProvider: "openai",
|
|
model: "gpt-5.6-sol",
|
|
contextTokens: 400_000,
|
|
parentSessionKey: parentKey,
|
|
spawnedBy: parentKey,
|
|
status: status,
|
|
hasActiveRun: status == "running",
|
|
subagentRunState: queued ? "active" : nil,
|
|
swarmGroupId: groupID,
|
|
swarmPhase: groupID == nil ? nil : "Research",
|
|
swarmPhaseRank: groupID == nil ? nil : 0,
|
|
swarmLog: groupID == nil ? nil : "Comparing labor, education, health, trust, and media signals.")
|
|
}
|
|
}
|
|
#endif
|