Files
openclaw/apps/ios/Sources/Design/AgentProTab+Skills.swift
Vyctor H. Brzezowski f61ec66249 Preserve ClawHub external source identity and expose only supported actions (#124250)
* fix(skills): keep ClawHub search results on the source the operator picked

ClawHub search returns each result's origin under `install.reference`, but the
response model expected a flat `installRef`. That field is never present, so
every row fell through to a synthesized `@owner/slug` reference. External
skills.sh results were rewritten onto a ClawHub-native identity, dropping both
the commit-pinned source and the "not scanned by ClawHub" trust record.

Map the search wire shape explicitly and make the search contract
action-specific: `installRef` always names the result's own source, `detailRef`
appears only while ClawHub can serve a detail card for that identity, and
`trustState` travels with unscanned sources. Clients render install directly
when detail is absent instead of offering a review the Gateway must refuse.

Covers the Control UI, macOS, iOS Settings, iOS AgentPro, and Android, which
previously routed every row through review and could not install an external
skill at all.

* fix(skills): make install-only sources explicit and keep legacy review intact

Address review findings on the search identity contract:

- Replace the detail-reference capability with an explicit `installOnly` flag.
  A Gateway released before this field omits it, and reading omission as
  install-only made ordinary registry results skip the reviewed-version flow on
  every client. Absence now means the existing review-then-install path.
- Parse closed source variants in the producer. A row whose source is unknown,
  whose external reference is missing, or whose registry publisher is absent is
  dropped instead of falling through to `@owner/slug`, which was the original
  source swap in a different disguise.
- Carry the exact install reference alongside the canonical slug. The Gateway
  already records `requestedReference`; the clients dropped it and matched
  installs by slug, so a completed external install read back as unknown.
- Gate the direct-install action on admin rights. The row previously stayed
  enabled for read-only operators and reached a guard that silently returned.
- Route the unscanned-source warning through the native and Control UI string
  catalogs instead of a hardcoded literal.

* chore(i18n): leave generated native locale artifacts to the refresh workflow

Preflight isolates generated locale output from source changes: only the native
sources and apps/.i18n/native-source.json belong in a feature commit.

* fix(skills): satisfy Android ktlint wrapping and Swift test link construction

Extract the ClawHub result action guard into a named value so the multiline
condition follows ktlint wrapping, and pass the new requestedReference field in
the OpenClawKit installed-link fixtures.

* fix(skills): preserve external install identity across clients

* test(skills): add exact refs to recommendation fixtures

---------

Co-authored-by: Patrick Erichsen <patrick.a.erichsen@gmail.com>
2026-08-15 21:38:46 -07:00

899 lines
35 KiB
Swift

import OpenClawKit
import OpenClawProtocol
import SwiftUI
extension AgentProTab {
var skillsPolicyControls: some View {
ProCard(radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 12) {
HStack(alignment: .firstTextBaseline) {
VStack(alignment: .leading, spacing: 3) {
Text(self.activeAgentName)
.font(OpenClawType.headline)
Text(self.skillPolicySummary)
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
}
Spacer(minLength: 8)
ProValuePill(
value: self.agentSkillFilter == nil ? "all" : "\(self.agentSkillFilter?.count ?? 0)",
color: OpenClawBrand.accent)
}
HStack(spacing: 8) {
Button {
Task { await self.enableAllSkills() }
} label: {
Text("Enable All")
.font(OpenClawType.captionSemiBold)
}
.disabled(self.skillMutationBusy)
Button(role: .destructive) {
Task { await self.disableAllSkills() }
} label: {
Text("Disable All")
.font(OpenClawType.captionSemiBold)
}
.disabled(self.skillMutationBusy)
Button {
Task { await self.resetSkillPolicy() }
} label: {
Text("Reset")
.font(OpenClawType.captionSemiBold)
}
.disabled(self.skillMutationBusy || self.agentSkillFilter == nil)
}
.buttonStyle(.bordered)
.controlSize(.small)
if let skillMutationStatusText {
Text(skillMutationStatusText)
.font(OpenClawType.caption2)
.foregroundStyle(OpenClawBrand.accent)
}
if let skillMutationErrorText {
Text(skillMutationErrorText)
.font(OpenClawType.caption2)
.foregroundStyle(OpenClawBrand.warn)
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
var skillsFilterField: some View {
ProCard(padding: 10, radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 10) {
HStack(spacing: 10) {
Image(systemName: "magnifyingglass")
.font(OpenClawType.captionSemiBold)
.foregroundStyle(.secondary)
TextField("Search skills", text: self.$skillFilter)
.textInputAutocapitalization(.never)
.autocorrectionDisabled()
.font(OpenClawType.subhead)
if !self.skillFilter.isEmpty {
Button {
self.skillFilter = ""
} label: {
Image(systemName: "xmark.circle.fill")
.foregroundStyle(.secondary)
}
.buttonStyle(.plain)
}
}
Picker(selection: self.$skillStatusFilter) {
ForEach(SkillStatusFilter.allCases) { filter in
Text(filter.title)
.font(OpenClawType.captionSemiBold)
.tag(filter)
}
} label: {
Text("Status")
.font(OpenClawType.captionSemiBold)
}
.pickerStyle(.segmented)
.controlSize(.small)
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
var clawHubSearchCard: some View {
ProCard(radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 12) {
HStack(spacing: 10) {
ProIconBadge(systemName: "square.and.arrow.down", color: OpenClawBrand.accent)
VStack(alignment: .leading, spacing: 2) {
Text("Install Skills")
.font(OpenClawType.headline)
Text("Search ClawHub and install into this workspace.")
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
}
Spacer(minLength: 8)
Button {
Task { await self.searchClawHubSkills() }
} label: {
Image(systemName: "magnifyingglass")
}
.buttonStyle(.bordered)
.controlSize(.small)
.disabled(self.clawHubLoading || !self.liveGatewayConnected)
.accessibilityLabel("Search ClawHub")
}
TextField("Search ClawHub", text: self.$clawHubQuery)
.textInputAutocapitalization(.never)
.autocorrectionDisabled()
.font(OpenClawType.subhead)
.submitLabel(.search)
.onSubmit {
Task { await self.searchClawHubSkills() }
}
if self.clawHubLoading {
ProgressView()
.controlSize(.small)
}
if let clawHubErrorText {
Text(clawHubErrorText)
.font(OpenClawType.caption2)
.foregroundStyle(OpenClawBrand.warn)
}
if !self.clawHubResults.isEmpty {
VStack(spacing: 0) {
let results = Array(self.clawHubResults.prefix(8))
ForEach(Array(results.enumerated()), id: \.element.reference) { index, result in
self.clawHubResultRow(result)
if index < results.count - 1 {
Divider().padding(.leading, 42)
}
}
}
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
func clawHubResultRow(_ result: ClawHubSearchResultLite) -> some View {
let installing = clawHubInstallSlug == result.reference
return HStack(alignment: .top, spacing: 10) {
ProIconBadge(systemName: "sparkles", color: OpenClawBrand.accent)
VStack(alignment: .leading, spacing: 3) {
Text(result.displayName)
.font(OpenClawType.subheadSemiBold)
.lineLimit(1)
// This surface installs directly, so the publisher reference always shows:
// same-slug rows are otherwise identical and the button would look ambiguous.
Text(result.summary.map { "\($0) · \(result.reference)" } ?? result.reference)
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
.lineLimit(2)
if result.isUnscannedSource {
// No review card on this surface, so the trust warning has to live in the row.
Text("Not scanned by ClawHub")
.font(OpenClawType.caption)
.foregroundStyle(OpenClawBrand.warn)
}
}
Spacer(minLength: 8)
Button {
Task { await self.installClawHubSkill(result) }
} label: {
Image(systemName: installing ? "hourglass" : "square.and.arrow.down")
}
.buttonStyle(.bordered)
.controlSize(.small)
.disabled(installing || !self.skillConfigBusyKeys.isEmpty)
.accessibilityLabel(
String(
format: String(localized: "Install %@"),
result.displayName))
}
.padding(.vertical, 10)
}
var skillsList: some View {
VStack(alignment: .leading, spacing: 8) {
ProSectionHeader(title: "Installed Skills")
ProCard(padding: 0, radius: AgentLayout.cardRadius) {
let skills = self.filteredSkills
if skills.isEmpty {
self.emptyDetailRow(
icon: "sparkles",
title: self.gatewayConnected ? "No skills found" : "Skills unavailable",
detail: self.gatewayConnected
? "Try a different search or refresh from the gateway."
: "Connect a gateway to load workspace skills.")
.padding(14)
} else {
VStack(spacing: 0) {
ForEach(Array(skills.enumerated()), id: \.element.name) { index, skill in
self.skillRow(skill)
if index < skills.count - 1 {
Divider().padding(.leading, 60)
}
}
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
}
var activeAgentName: String {
if let agent = appModel.gatewayAgents.first(where: { $0.id == self.activeAgentID }) {
return agentName(for: agent)
}
return activeAgentID
}
var agentSkillFilter: Set<String>? {
overview?.agentSkillFilter.map { Set($0) }
}
var skillPolicySummary: String {
if appModel.isAppleReviewDemoModeEnabled { return "Demo mode keeps live skill changes disabled." }
guard gatewayConnected else { return "Connect a gateway to edit skills." }
guard let filter = agentSkillFilter else {
return "All available skills are allowed for this agent."
}
if filter.isEmpty {
return "No skills are allowed for this agent."
}
return "\(filter.count) skills are allowed for this agent."
}
var skillMutationBusy: Bool {
!skillMutationBusyKeys.isEmpty
}
var filteredSkills: [SkillStatusEntryLite] {
let skills = overview?.skills?.skills ?? []
let filter = skillFilter.trimmingCharacters(in: .whitespacesAndNewlines).lowercased()
return skills
.filter { skill in
self.matchesSkillStatusFilter(skill)
}
.filter { skill in
guard !filter.isEmpty else { return true }
return [
skill.name,
skill.description,
skill.source,
].compactMap(\.self)
.joined(separator: " ")
.lowercased()
.contains(filter)
}
.sorted(by: self.sortSkills)
}
func matchesSkillStatusFilter(_ skill: SkillStatusEntryLite) -> Bool {
switch skillStatusFilter {
case .all:
true
case .enabled:
self.skillStatus(skill).text == "enabled"
case .off:
!self.isSkillAllowed(skill) || skill.blockedByAgentFilter == true
case .setup:
skill.hasMissingRequirements
case .blocked:
skill.blockedByAllowlist == true
}
}
func sortSkills(_ lhs: SkillStatusEntryLite, _ rhs: SkillStatusEntryLite) -> Bool {
let lhsEnabled = self.isSkillAllowed(lhs)
let rhsEnabled = self.isSkillAllowed(rhs)
if lhsEnabled != rhsEnabled { return lhsEnabled && !rhsEnabled }
return lhs.name.localizedCaseInsensitiveCompare(rhs.name) == .orderedAscending
}
func skillRow(_ skill: SkillStatusEntryLite) -> some View {
let status = self.skillStatus(skill)
let busy = skillMutationBusyKeys.contains(skill.name)
return HStack(alignment: .top, spacing: 12) {
ProIconBadge(systemName: self.isSkillAllowed(skill) ? "checkmark.circle" : "nosign", color: status.color)
VStack(alignment: .leading, spacing: 4) {
Text(skill.displayName)
.font(OpenClawType.subheadSemiBold)
.lineLimit(1)
Text(verbatim: self.normalized(skill.description)
?? self.normalized(skill.source)
?? String(localized: "Workspace skill"))
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
.lineLimit(2)
if let missing = skill.missingSummary {
Text(verbatim: String(
format: String(localized: "Missing: %@"),
missing))
.font(OpenClawType.caption2)
.foregroundStyle(OpenClawBrand.warn)
.lineLimit(1)
}
if let install = skill.installSummary {
Text(verbatim: String(
format: String(localized: "Setup: %@"),
install))
.font(OpenClawType.caption2)
.foregroundStyle(.secondary)
.lineLimit(1)
}
}
Spacer(minLength: 8)
VStack(alignment: .trailing, spacing: 6) {
self.skillToggle(skill, title: self.localizedSkillStatus(status.text))
HStack(spacing: 6) {
if self.canInstallSkillRequirements(skill) {
Button {
Task { await self.installSkillRequirements(skill) }
} label: {
Image(systemName: "wrench.and.screwdriver")
}
.buttonStyle(.bordered)
.controlSize(.mini)
.disabled(self.isSkillConfigBusy(skill))
.accessibilityLabel(
String(
format: String(localized: "Set up %@"),
skill.displayName))
}
Button {
self.openSkillEditor(skill)
} label: {
Image(systemName: "slider.horizontal.3")
}
.buttonStyle(.bordered)
.controlSize(.mini)
.accessibilityLabel(
String(
format: String(localized: "Edit %@"),
skill.displayName))
}
Text(verbatim: busy
? String(localized: "saving")
: self.localizedSkillStatus(status.text))
.font(OpenClawType.caption2SemiBold)
.foregroundStyle(status.color)
.lineLimit(1)
}
}
.padding(.vertical, 10)
.padding(.horizontal, 14)
}
func skillToggle(_ skill: SkillStatusEntryLite, title: String) -> some View {
Toggle(isOn: Binding(
get: { self.isSkillAllowed(skill) },
set: { enabled in
Task { await self.setSkillAllowed(skill, enabled: enabled) }
})) {
Text(title)
.font(OpenClawType.body)
}
.labelsHidden()
.disabled(self.skillMutationBusy)
.toggleStyle(.switch)
.controlSize(.mini)
}
func isSkillAllowed(_ skill: SkillStatusEntryLite) -> Bool {
guard let filter = agentSkillFilter else { return true }
return filter.contains(skill.name)
}
func isSkillConfigBusy(_ skill: SkillStatusEntryLite) -> Bool {
skillConfigBusyKeys.contains(skill.effectiveSkillKey)
|| clawHubInstallSlug != nil
}
func canInstallSkillRequirements(_ skill: SkillStatusEntryLite) -> Bool {
skill.install?.first?.id?.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty == false
&& !skill.missingBins.isEmpty
}
func skillByKey(_ key: String) -> SkillStatusEntryLite? {
(overview?.skills?.skills ?? []).first { skill in
skill.effectiveSkillKey == key || skill.name == key
}
}
func openSkillEditor(_ skill: SkillStatusEntryLite) {
skillEditorSelection = SkillEditorSelection(id: skill.effectiveSkillKey)
}
func skillAPIKeyBinding(for skill: SkillStatusEntryLite) -> Binding<String> {
Binding(
get: { self.skillAPIKeyDrafts[skill.effectiveSkillKey] ?? "" },
set: { self.skillAPIKeyDrafts[skill.effectiveSkillKey] = $0 })
}
var missingSkillEditorSheet: some View {
NavigationStack {
ZStack {
OpenClawProBackground()
VStack(spacing: 12) {
ProIconBadge(systemName: "sparkles", color: .secondary)
Text("Skill unavailable")
.font(OpenClawType.headline)
Text("Return to the skills list and choose another skill.")
.font(OpenClawType.subhead)
.foregroundStyle(.secondary)
.multilineTextAlignment(.center)
}
.padding(OpenClawSpacing.space6)
}
.navigationTitle("Skill")
.toolbar {
ToolbarItem(placement: .cancellationAction) {
Button {
self.skillEditorSelection = nil
} label: {
Text("Close")
.font(OpenClawType.subheadSemiBold)
}
}
}
}
}
func skillEditorSheet(_ skill: SkillStatusEntryLite) -> some View {
NavigationStack {
ZStack {
OpenClawProBackground()
ScrollView {
VStack(alignment: .leading, spacing: 16) {
self.skillEditorHeader(skill)
self.skillEditorControls(skill)
self.skillEditorSetup(skill)
self.skillEditorMetadata(skill)
}
.padding(.vertical, 18)
}
}
.navigationTitle(skill.displayName)
.navigationBarTitleDisplayMode(.inline)
.toolbar {
ToolbarItem(placement: .cancellationAction) {
Button {
self.skillEditorSelection = nil
} label: {
Text("Close")
.font(OpenClawType.subheadSemiBold)
}
}
}
}
}
func skillEditorHeader(_ skill: SkillStatusEntryLite) -> some View {
let status = self.skillStatus(skill)
return ProCard(radius: AgentLayout.cardRadius) {
HStack(spacing: 12) {
ProIconBadge(
systemName: skill.isGloballyEnabled ? "checkmark.circle" : "pause.circle",
color: status.color)
VStack(alignment: .leading, spacing: 3) {
Text(skill.displayName)
.font(OpenClawType.headline)
Text(verbatim: self.normalized(skill.description)
?? self.normalized(skill.source)
?? String(localized: "Workspace skill"))
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
.lineLimit(3)
}
Spacer(minLength: 8)
ProValuePill(value: self.localizedSkillStatus(status.text), color: status.color)
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
func skillEditorControls(_ skill: SkillStatusEntryLite) -> some View {
ProCard(radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 12) {
self.skillEditorToggleRow(
"Enabled globally",
isOn: skill.isGloballyEnabled,
disabled: self.isSkillConfigBusy(skill))
{ enabled in
Task { await self.updateSkillGlobalEnabled(skill, enabled: enabled) }
}
if let primaryEnv = skill.primaryEnv, !primaryEnv.isEmpty {
VStack(alignment: .leading, spacing: 8) {
Text("API key")
.font(OpenClawType.subheadSemiBold)
self.skillSecureField(primaryEnv, text: self.skillAPIKeyBinding(for: skill))
.textInputAutocapitalization(.never)
.autocorrectionDisabled()
Button {
Task { await self.saveSkillAPIKey(skill) }
} label: {
Label("Save key", systemImage: "key")
.font(OpenClawType.captionSemiBold)
}
.buttonStyle(.borderedProminent)
.controlSize(.small)
.disabled(self.isSkillConfigBusy(skill))
if let homepage = skill.homepageURL {
Link("Get key", destination: homepage)
.font(OpenClawType.caption)
}
}
}
if let message = self.skillConfigMessages[skill.effectiveSkillKey] {
Text(message.text)
.font(OpenClawType.caption2)
.foregroundStyle(message.kind == .success ? OpenClawBrand.accent : OpenClawBrand.warn)
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
private func skillSecureField(_ placeholder: String, text: Binding<String>) -> some View {
ZStack(alignment: .leading) {
SecureField("", text: text)
.font(OpenClawType.subhead)
.accessibilityLabel(placeholder)
if text.wrappedValue.isEmpty {
Text(placeholder)
.font(OpenClawType.subheadSemiBold)
.foregroundStyle(.tertiary)
.allowsHitTesting(false)
.accessibilityHidden(true)
}
}
.font(OpenClawType.subhead)
}
func skillEditorToggleRow(
_ title: String,
isOn: Bool,
disabled: Bool,
onToggle: @escaping (Bool) -> Void) -> some View
{
// Native Toggle rows in this sheet can ignore visible-row taps on iOS 26.
// Keep the switch semantics explicit so the control always dispatches the mutation.
Button {
onToggle(!isOn)
} label: {
HStack {
Text(title)
.font(OpenClawType.subhead)
Spacer(minLength: 8)
OpenClawToggleIndicator(isOn: isOn)
}
.contentShape(Rectangle())
}
.buttonStyle(.plain)
.disabled(disabled)
.accessibilityLabel(title)
.accessibilityValue(isOn ? "On" : "Off")
}
func skillEditorSetup(_ skill: SkillStatusEntryLite) -> some View {
ProCard(radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 10) {
Text("Setup")
.font(OpenClawType.headline)
if let missing = skill.missingSummary {
Text(verbatim: String(
format: String(localized: "Missing: %@"),
missing))
.font(OpenClawType.caption)
.foregroundStyle(OpenClawBrand.warn)
} else {
Text("No missing requirements reported.")
.font(OpenClawType.caption)
.foregroundStyle(.secondary)
}
if let install = skill.install?.first {
Button {
Task { await self.installSkillRequirements(skill) }
} label: {
Label(install.label, systemImage: "wrench.and.screwdriver")
.font(OpenClawType.captionSemiBold)
}
.buttonStyle(.bordered)
.controlSize(.small)
.disabled(self.isSkillConfigBusy(skill) || install.id == nil)
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
func skillEditorMetadata(_ skill: SkillStatusEntryLite) -> some View {
ProCard(radius: AgentLayout.cardRadius) {
VStack(alignment: .leading, spacing: 8) {
self.detailMetric(label: "Key", value: skill.effectiveSkillKey)
self.detailMetric(label: "Source", value: self.normalized(skill.source) ?? "unknown")
if let filePath = self.normalized(skill.filePath) {
Text(filePath)
.font(OpenClawType.monoCaption2)
.foregroundStyle(.secondary)
.textSelection(.enabled)
}
}
}
.padding(.horizontal, OpenClawProMetric.pagePadding)
}
@MainActor
func setSkillAllowed(_ skill: SkillStatusEntryLite, enabled: Bool) async {
let allNames = self.allSkillNames
guard !allNames.isEmpty else { return }
let base = self.agentSkillFilter ?? Set(allNames)
var next = base
if enabled {
next.insert(skill.name)
} else {
next.remove(skill.name)
}
await self.patchAgentSkills(Array(next).sorted(), busyKey: skill.name)
}
@MainActor
func enableAllSkills() async {
let allNames = self.allSkillNames
guard !allNames.isEmpty else { return }
await self.patchAgentSkills(allNames, busyKey: "__all__")
}
@MainActor
func disableAllSkills() async {
await self.patchAgentSkills([], busyKey: "__all__")
}
@MainActor
func resetSkillPolicy() async {
await self.patchAgentSkills(nil, busyKey: "__all__")
}
var allSkillNames: [String] {
(overview?.skills?.skills ?? [])
.map(\.name)
.filter { !$0.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty }
.sorted()
}
@MainActor
func patchAgentSkills(_ skills: [String]?, busyKey: String) async {
guard liveGatewayConnected else { return }
skillMutationBusyKeys.insert(busyKey)
skillMutationErrorText = nil
skillMutationStatusText = nil
defer { self.skillMutationBusyKeys.remove(busyKey) }
do {
let config = try await requestConfigSnapshot()
guard let baseHash = normalized(config.hash) else {
throw SkillMutationError.missingConfigHash
}
if skills == nil,
config.agentConfig(id: activeAgentID) == nil
{
skillMutationStatusText = "This agent already inherits the default skill policy."
return
}
let raw = try Self.agentSkillsPatchRaw(agentId: activeAgentID, skills: skills)
let params = ConfigPatchParams(
raw: raw,
baseHash: baseHash,
replacePaths: ["agents.list[].skills"])
let data = try JSONEncoder().encode(params)
guard let json = String(data: data, encoding: .utf8) else {
throw SkillMutationError.invalidPatchPayload
}
_ = try await appModel.operatorSession.request(
method: "config.patch",
paramsJSON: json,
timeoutSeconds: 20)
skillMutationStatusText = skills == nil ? "Skill policy reset." : "Skill policy saved."
await appModel.refreshGatewayOverviewIfConnected()
await refreshOverview(force: true)
} catch {
skillMutationErrorText = Self.skillMutationMessage(error)
}
}
@MainActor
func updateSkillGlobalEnabled(_ skill: SkillStatusEntryLite, enabled: Bool) async {
await self.runSkillConfigMutation(skill) {
let params = SkillUpdateParams(skillKey: skill.effectiveSkillKey, enabled: enabled)
_ = try await self.requestGateway(method: "skills.update", params: params, timeoutSeconds: 20)
return enabled ? "Skill enabled." : "Skill disabled."
}
}
@MainActor
func saveSkillAPIKey(_ skill: SkillStatusEntryLite) async {
await self.runSkillConfigMutation(skill) {
let apiKey = self.skillAPIKeyDrafts[skill.effectiveSkillKey] ?? ""
let params = SkillUpdateParams(skillKey: skill.effectiveSkillKey, apiKey: apiKey)
_ = try await self.requestGateway(method: "skills.update", params: params, timeoutSeconds: 20)
self.skillAPIKeyDrafts[skill.effectiveSkillKey] = ""
return apiKey.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty
? "API key cleared."
: "API key saved."
}
}
@MainActor
func installSkillRequirements(_ skill: SkillStatusEntryLite) async {
guard let installId = skill.install?.first?.id?.trimmingCharacters(in: .whitespacesAndNewlines),
!installId.isEmpty
else { return }
await self.runSkillConfigMutation(skill) {
let params = SkillInstallParams(name: skill.name, installId: installId, timeoutMs: 120_000)
let data = try await self.requestGateway(
method: "skills.install",
params: params,
timeoutSeconds: 125)
return (try? JSONDecoder().decode(SkillInstallResultLite.self, from: data).message) ?? "Installed."
}
}
@MainActor
func installClawHubSkill(_ result: ClawHubSearchResultLite) async {
guard liveGatewayConnected else { return }
clawHubInstallSlug = result.reference
clawHubErrorText = nil
defer { self.clawHubInstallSlug = nil }
do {
let params = ClawHubInstallParams(slug: result.reference)
_ = try await self.requestGateway(method: "skills.install", params: params, timeoutSeconds: 125)
await appModel.refreshGatewayOverviewIfConnected()
await refreshOverview(force: true)
} catch {
clawHubErrorText = Self.skillMutationMessage(error)
}
}
@MainActor
func searchClawHubSkills() async {
guard liveGatewayConnected else { return }
clawHubLoading = true
clawHubErrorText = nil
defer { self.clawHubLoading = false }
do {
let query = clawHubQuery.trimmingCharacters(in: .whitespacesAndNewlines)
let params = ClawHubSearchParams(query: query.isEmpty ? nil : query, limit: 20)
let data = try await requestGateway(method: "skills.search", params: params, timeoutSeconds: 20)
clawHubResults = try JSONDecoder().decode(ClawHubSearchResponseLite.self, from: data).results
} catch {
clawHubErrorText = Self.skillMutationMessage(error)
}
}
@MainActor
func runSkillConfigMutation(
_ skill: SkillStatusEntryLite,
action: () async throws -> String) async
{
guard liveGatewayConnected else { return }
let key = skill.effectiveSkillKey
skillConfigBusyKeys.insert(key)
skillConfigMessages[key] = nil
defer { self.skillConfigBusyKeys.remove(key) }
do {
let message = try await action()
skillConfigMessages[key] = SkillEditorMessage(kind: .success, text: message)
await appModel.refreshGatewayOverviewIfConnected()
await refreshOverview(force: true)
} catch {
skillConfigMessages[key] = SkillEditorMessage(
kind: .error,
text: Self.skillMutationMessage(error))
}
}
func requestGateway(
method: String,
params: some Encodable,
timeoutSeconds: Int) async throws -> Data
{
guard liveGatewayConnected else {
throw SkillMutationError.liveGatewayUnavailable
}
let data = try JSONEncoder().encode(params)
guard let json = String(data: data, encoding: .utf8) else {
throw SkillMutationError.invalidPatchPayload
}
return try await appModel.operatorSession.request(
method: method,
paramsJSON: json,
timeoutSeconds: timeoutSeconds)
}
func requestConfigSnapshot() async throws -> ConfigSnapshotLite {
guard liveGatewayConnected else {
throw SkillMutationError.liveGatewayUnavailable
}
let data = try await appModel.operatorSession.request(
method: "config.get",
paramsJSON: "{}",
timeoutSeconds: 12)
return try JSONDecoder().decode(ConfigSnapshotLite.self, from: data)
}
static func agentSkillsPatchRaw(agentId: String, skills: [String]?) throws -> String {
let skillValue: Any = skills ?? NSNull()
let patch: [String: Any] = [
"agents": [
"list": [
[
"id": agentId,
"skills": skillValue,
],
],
],
]
let data = try JSONSerialization.data(withJSONObject: patch, options: [.sortedKeys])
guard let raw = String(data: data, encoding: .utf8) else {
throw SkillMutationError.invalidPatchPayload
}
return raw
}
static func skillMutationMessage(_ error: Error) -> String {
if let gatewayError = error as? GatewayResponseError {
let lower = gatewayError.message.lowercased()
if lower.contains("operator.admin") || lower.contains("unauthorized") {
return "This gateway connection cannot edit config yet. Reconnect with admin scope."
}
return gatewayError.message
}
return error.localizedDescription
}
func skillStatus(_ skill: SkillStatusEntryLite) -> (text: String, color: Color) {
if !self.isSkillAllowed(skill) {
return ("off", .secondary)
}
if skill.blockedByAllowlist == true {
return ("blocked", .secondary)
}
if skill.blockedByAgentFilter == true {
return ("off", .secondary)
}
if skill.disabled == true {
return ("disabled", .secondary)
}
if skill.hasMissingRequirements {
return ("setup", OpenClawBrand.warn)
}
return ("enabled", OpenClawBrand.accent)
}
func localizedSkillStatus(_ status: String) -> String {
switch status {
case "off":
String(localized: "off")
case "blocked":
String(localized: "blocked")
case "disabled":
String(localized: "disabled")
case "setup":
String(localized: "setup")
case "enabled":
String(localized: "enabled")
default:
status
}
}
}