()
| 161 | } |
| 162 | |
| 163 | private async getPausedAgentUrls(): Promise<Set<string>> { |
| 164 | try { |
| 165 | const result = await query( |
| 166 | `SELECT agent_url FROM agent_registry_metadata WHERE monitoring_paused = TRUE`, |
| 167 | ); |
| 168 | return new Set(result.rows.map((r: { agent_url: string }) => r.agent_url)); |
| 169 | } catch (err) { |
| 170 | log.warn({ err }, 'Failed to fetch paused agents, treating all as active'); |
| 171 | return new Set(); |
| 172 | } |
| 173 | } |
| 174 | |
| 175 | private extractDomain(url: string): string { |
| 176 | try { |
no test coverage detected