Function useBatchLatencyTest

packages/ui/composables/useBatchLatencyTest.ts:42–387

()

}

export function useBatchLatencyTest() {
  const configStore = useConfigStore()
  const proxiesStore = useProxiesStore()
  const nodeRecommendationStore = useNodeRecommendationStore()
  const { t } = useI18n()

  const isRunning = ref(false)
  const progress = ref({ completed: 0, total: 0, current: '' })
  const abortController = ref<AbortController | null>(null)

  // Test a single proxy node
  const testSingleNode = async (
    proxyName: string,
    url: string,
    timeout: number,
    signal?: AbortSignal,
  ): Promise<{ proxyName: string; delay: number }> => {
    try {
      const request = useRequest()
      const result = await request
        .get(`proxies/${encodeURIComponent(proxyName)}/delay`, {
          searchParams: { url, timeout },
          signal,
          // Client timeout must exceed the backend per-node budget + network
          // overhead, else ky aborts a slow-but-valid probe before the kernel
          // answers and the node always reads as failed (#2041).
          timeout: Math.max(20_000, timeout + 10_000),
        })
        .json<{ delay: number }>()
      return { proxyName, delay: result.delay }
    } catch {
      return { proxyName, delay: 0 } // 0 indicates failure
    }
  }

  // Test a proxy group (uses backend batch API)
  const testProxyGroup = async (
    groupName: string,
    url: string,
    timeout: number,
  ): Promise<Record<string, number>> => {
    try {
      const request = useRequest()
      const result = await request
        .get(`group/${encodeURIComponent(groupName)}/delay`, {
          searchParams: { url, timeout },
          // The backend timeout is per-node; the group test fans out to every
          // member, so the overall round trip easily exceeds ky's 5s default.
          // Scale the client timeout generously, floored at 30s, plus 10s of
          // headroom.
          timeout: Math.max(30_000, timeout * 2 + 10_000),
        })
        .json<Record<string, number>>()
      return result
    } catch {
      return {}
    }
  }