let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: swiftformat gateway process manager

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-24 00:33:40 +00:00
parent 267cdf20e1
commit 96da2efb13
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
apps/macos/Sources/Clawdis/GatewayProcessManager.swift
View File

@@ -167,7 +167,7 @@ final class GatewayProcessManager {
private func attachExistingGatewayIfAvailable() async -> Bool { private func attachExistingGatewayIfAvailable() async -> Bool {
let port = GatewayEnvironment.gatewayPort() let port = GatewayEnvironment.gatewayPort()
let instance = await PortGuardian.shared.describe(port: port) let instance = await PortGuardian.shared.describe(port: port)
let instanceText = instance.map { describe(instance: $0) } let instanceText = instance.map { self.describe(instance: $0) }
let hasListener = instance != nil let hasListener = instance != nil
let attemptAttach = { let attemptAttach = {
@@ -178,20 +178,20 @@ final class GatewayProcessManager {
do { do {
let data = try await attemptAttach() let data = try await attemptAttach()
let snap = decodeHealthSnapshot(from: data) let snap = decodeHealthSnapshot(from: data)
let details = describe(details: instanceText, port: port, snap: snap) let details = self.describe(details: instanceText, port: port, snap: snap)
self.existingGatewayDetails = details self.existingGatewayDetails = details
self.status = .attachedExisting(details: details) self.status = .attachedExisting(details: details)
self.appendLog("[gateway] using existing instance: \(details)\n") self.appendLog("[gateway] using existing instance: \(details)\n")
self.refreshLog() self.refreshLog()
return true return true
} catch { } catch {
if attempt < 2 && hasListener { if attempt < 2, hasListener {
try? await Task.sleep(nanoseconds: 250_000_000) try? await Task.sleep(nanoseconds: 250_000_000)
continue continue
} }
if hasListener { if hasListener {
let reason = describeAttachFailure(error, port: port, instance: instance) let reason = self.describeAttachFailure(error, port: port, instance: instance)
self.existingGatewayDetails = instanceText self.existingGatewayDetails = instanceText
self.status = .failed(reason) self.status = .failed(reason)
self.lastFailureReason = reason self.lastFailureReason = reason
@@ -228,7 +228,7 @@ final class GatewayProcessManager {
let ns = error as NSError let ns = error as NSError
let message = ns.localizedDescription.isEmpty ? "unknown error" : ns.localizedDescription let message = ns.localizedDescription.isEmpty ? "unknown error" : ns.localizedDescription
let lower = message.lowercased() let lower = message.lowercased()
if isGatewayAuthFailure(error) { if self.isGatewayAuthFailure(error) {
return """ return """
Gateway on port \(port) rejected auth. Set CLAWDIS_GATEWAY_TOKEN in the app \ Gateway on port \(port) rejected auth. Set CLAWDIS_GATEWAY_TOKEN in the app \
to match the running gateway (or clear it on the gateway) and retry. to match the running gateway (or clear it on the gateway) and retry.
@@ -241,7 +241,7 @@ final class GatewayProcessManager {
return "Port \(port) returned non-gateway data; another process is using it." return "Port \(port) returned non-gateway data; another process is using it."
} }
if let instance { if let instance {
let instanceText = describe(instance: instance) let instanceText = self.describe(instance: instance)
return "Gateway listener found on port \(port) (\(instanceText)) but health check failed: \(message)" return "Gateway listener found on port \(port) (\(instanceText)) but health check failed: \(message)"
} }
return "Gateway listener found on port \(port) but health check failed: \(message)" return "Gateway listener found on port \(port) but health check failed: \(message)"