@@ -743,11 +789,65 @@ function formatBytes(bytes: number): string {
return `${(bytes / 1024).toFixed(0)} KB`
}
+// --- Tor Services ---
+interface TorServiceInfo {
+ name: string
+ local_port: number
+ onion_address: string | null
+ enabled: boolean
+}
+
+const torServices = ref([])
+const torServicesLoading = ref(false)
+
+async function loadTorServices() {
+ torServicesLoading.value = true
+ try {
+ const res = await rpcClient.call<{ services: TorServiceInfo[] }>({ method: 'tor.list-services' })
+ torServices.value = res.services || []
+ } catch {
+ torServices.value = []
+ } finally {
+ torServicesLoading.value = false
+ }
+}
+
+const torRotating = ref(false)
+
+function copyTorAddress(address: string) {
+ navigator.clipboard.writeText(address)
+ logsToast.value = 'Onion address copied to clipboard'
+ setTimeout(() => { logsToast.value = '' }, 3000)
+}
+
+async function toggleTorApp(appId: string, enabled: boolean) {
+ try {
+ await rpcClient.call({ method: 'tor.toggle-service', params: { name: appId, enabled } })
+ await loadTorServices()
+ } catch (e) {
+ if (import.meta.env.DEV) console.warn('Failed to toggle Tor app:', e)
+ }
+}
+
+async function rotateNodeAddress() {
+ torRotating.value = true
+ try {
+ await rpcClient.call({ method: 'tor.rotate-address', params: { name: 'archipelago' } })
+ await loadTorServices()
+ } catch (e) {
+ if (import.meta.env.DEV) console.warn('Failed to rotate Tor address:', e)
+ } finally {
+ torRotating.value = false
+ }
+}
+
onMounted(() => {
+ checkConnectivity()
loadNetworkData()
loadPeerCount()
loadInterfaces()
loadDiskStatus()
+ loadTorServices()
})
watch(showWifiModal, (open) => {
@@ -774,10 +874,24 @@ async function restartServices() {
setTimeout(() => { logsToast.value = '' }, 6000)
if (import.meta.env.DEV) console.warn('Restart RPC failed', e)
}
- setTimeout(() => {
+ // Poll health to confirm recovery instead of assuming success
+ const pollHealth = async (retries: number) => {
+ for (let i = 0; i < retries; i++) {
+ await new Promise(r => setTimeout(r, 2000))
+ try {
+ await rpcClient.call({ method: 'server.health', params: {} })
+ servicesRunning.value = true
+ restarting.value = false
+ return
+ } catch {
+ // Still restarting
+ }
+ }
restarting.value = false
- servicesRunning.value = true
- }, 2000)
+ servicesRunning.value = false
+ connectivityStatus.value = 'disconnected'
+ }
+ pollHealth(15)
}
async function checkConnectivity() {