wehub-resource-sync
71 lines
2.5 KiB
Swift
71 lines
2.5 KiB
Swift
import Foundation
|
|
import os
|
|
import Testing
|
|
@testable import CodexBar
|
|
|
|
@MainActor
|
|
struct GoogleWorkspaceStatusNetworkTests {
|
|
@Test
|
|
func `fetchWorkspaceStatus uses shared client`() async throws {
|
|
let transport = ProviderHTTPTransportStub { request in
|
|
let response = try HTTPURLResponse(
|
|
url: #require(request.url),
|
|
statusCode: 200,
|
|
httpVersion: "HTTP/1.1",
|
|
headerFields: ["Content-Type": "application/json"])!
|
|
let body = Data(#"""
|
|
[
|
|
{
|
|
"begin": "2026-05-10T10:00:00+00:00",
|
|
"end": null,
|
|
"affected_products": [
|
|
{"title": "Gemini", "id": "npdyhgECDJ6tB66MxXyo"}
|
|
],
|
|
"most_recent_update": {
|
|
"when": "2026-05-10T10:15:00+00:00",
|
|
"status": "SERVICE_OUTAGE",
|
|
"text": "**Summary**\nGemini API error.\n"
|
|
}
|
|
}
|
|
]
|
|
"""#.utf8)
|
|
return (body, response)
|
|
}
|
|
|
|
let status = try await UsageStore.fetchWorkspaceStatus(
|
|
productID: "npdyhgECDJ6tB66MxXyo",
|
|
transport: transport)
|
|
|
|
#expect(status.indicator == .critical)
|
|
#expect(status.description == "Gemini API error.")
|
|
let requests = await transport.requests()
|
|
#expect(requests.count == 1)
|
|
#expect(requests.first?.url?.host == "www.google.com")
|
|
}
|
|
|
|
@Test
|
|
func `fetchWorkspaceStatus decodes off the main thread when called from the main actor`() async throws {
|
|
// The incidents feed can run to hundreds of kilobytes; decoding it on the main
|
|
// actor stalls the UI for 150-340ms per Google-status provider per refresh (#1399).
|
|
let decodedOffMainThread = OSAllocatedUnfairLock(initialState: false)
|
|
let transport = ProviderHTTPTransportStub { request in
|
|
let response = try HTTPURLResponse(
|
|
url: #require(request.url),
|
|
statusCode: 200,
|
|
httpVersion: "HTTP/1.1",
|
|
headerFields: ["Content-Type": "application/json"])!
|
|
return (Data("[]".utf8), response)
|
|
}
|
|
|
|
let status = try await UsageStore.fetchWorkspaceStatus(
|
|
productID: "npdyhgECDJ6tB66MxXyo",
|
|
transport: transport,
|
|
beforeDecoding: {
|
|
decodedOffMainThread.withLock { $0 = !Thread.isMainThread }
|
|
})
|
|
|
|
#expect(status.indicator == .none)
|
|
#expect(decodedOffMainThread.withLock { $0 })
|
|
}
|
|
}
|