Refactor server data fetching to batch query all servers in a single API call
This commit is contained in:
@@ -57,38 +57,58 @@ export function ServerProvider({ children }: { children: ReactNode }) {
|
|||||||
const [lastUpdated, setLastUpdated] = useState(Date.now())
|
const [lastUpdated, setLastUpdated] = useState(Date.now())
|
||||||
|
|
||||||
const fetchServerData = async () => {
|
const fetchServerData = async () => {
|
||||||
const serverPromises = serverList.map(async (server) => {
|
try {
|
||||||
try {
|
// Batch query all servers in a single API call
|
||||||
const response = await fetch('/api/server/statistics/a2s-query', {
|
const response = await fetch('/api/server/statistics/a2s-query', {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: { 'Content-Type': 'application/json' },
|
headers: { 'Content-Type': 'application/json' },
|
||||||
body: JSON.stringify({
|
body: JSON.stringify({
|
||||||
|
servers: serverList.map(server => ({
|
||||||
serverIP: server.ip,
|
serverIP: server.ip,
|
||||||
serverPort: server.port,
|
serverPort: server.port,
|
||||||
timeout: 3000
|
timeout: 3000
|
||||||
})
|
}))
|
||||||
})
|
})
|
||||||
|
})
|
||||||
|
|
||||||
if (!response.ok) {
|
if (!response.ok) {
|
||||||
throw new Error(`HTTP ${response.status}`)
|
throw new Error(`HTTP ${response.status}`)
|
||||||
}
|
|
||||||
|
|
||||||
const a2sData: A2SResponse = await response.json()
|
|
||||||
return { ...server, a2sData, status: 'online' as const }
|
|
||||||
} catch (error) {
|
|
||||||
console.error(`Failed to fetch data for ${server.name}:`, error)
|
|
||||||
return {
|
|
||||||
...server,
|
|
||||||
status: 'offline' as const,
|
|
||||||
error: error instanceof Error ? error.message : 'Unknown error'
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
})
|
|
||||||
|
|
||||||
const results = await Promise.all(serverPromises)
|
const data = await response.json()
|
||||||
setServers(results)
|
const results: ServerData[] = serverList.map((server, index) => {
|
||||||
setLoading(false)
|
const a2sData = data.results?.[index]
|
||||||
setLastUpdated(Date.now())
|
|
||||||
|
if (a2sData) {
|
||||||
|
return {
|
||||||
|
...server,
|
||||||
|
a2sData,
|
||||||
|
status: 'online' as const
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
return {
|
||||||
|
...server,
|
||||||
|
status: 'offline' as const,
|
||||||
|
error: 'No response from server'
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
setServers(results)
|
||||||
|
setLoading(false)
|
||||||
|
setLastUpdated(Date.now())
|
||||||
|
} catch (error) {
|
||||||
|
console.error('Failed to fetch server data:', error)
|
||||||
|
// Set all servers to offline on error
|
||||||
|
const offlineServers: ServerData[] = serverList.map(server => ({
|
||||||
|
...server,
|
||||||
|
status: 'offline' as const,
|
||||||
|
error: error instanceof Error ? error.message : 'Unknown error'
|
||||||
|
}))
|
||||||
|
setServers(offlineServers)
|
||||||
|
setLoading(false)
|
||||||
|
setLastUpdated(Date.now())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Initial fetch and polling every 2 seconds
|
// Initial fetch and polling every 2 seconds
|
||||||
|
|||||||
Reference in New Issue
Block a user