Skip to content

Commit

Permalink
fix: fix response time for consul
Browse files Browse the repository at this point in the history
  • Loading branch information
gulivero1773 committed Apr 20, 2024
1 parent 969d28f commit d222e12
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -113,8 +113,8 @@ public struct ConsulHealthChecks: ConsulHealthChecksProtocol {
return HealthCheckItem(
componentId: app.consulConfig?.id,
componentType: .component,
observedValue: response.status == .ok ? Date().timeIntervalSince1970 - start : 0,
observedUnit: "s",
observedValue: response.status == .ok ? (Date().timeIntervalSince1970 - start) * 1000 : 0,
observedUnit: "ms",
status: response.status == .ok ? .pass : .fail,
time: response.status == .ok ? app.dateTimeISOFormat.string(from: Date()) : nil,
output: response.status != .ok ? "Error response from consul, with http status - \(response.status)" : nil,
Expand Down
4 changes: 1 addition & 3 deletions Tests/HealthChecksTests/MongoHealthChecksTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,6 @@ final class MongoHealthChecksTests: XCTestCase {
let result = await app.mongoHealthChecks?.connection()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -61,7 +60,7 @@ final class MongoHealthChecksTests: XCTestCase {
let result = await app.mongoHealthChecks?.responseTime()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.observedUnit, "ms")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -86,7 +85,6 @@ final class MongoHealthChecksTests: XCTestCase {
let mongoConnections = result?["\(ComponentName.mongo):\(MeasurementType.connections)"]
XCTAssertEqual(mongoConnections?.componentType, .datastore)
XCTAssertNotEqual(mongoConnections?.observedValue, 1.0)
XCTAssertEqual(mongoConnections?.observedUnit, "s")
XCTAssertEqual(mongoConnections?.status, .pass)
XCTAssertNil(mongoConnections?.affectedEndpoints)
XCTAssertNil(mongoConnections?.output)
Expand Down
4 changes: 1 addition & 3 deletions Tests/HealthChecksTests/PostgresHealthChecksTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@ final class PostgresHealthChecksTests: XCTestCase {
let result = await app.psqlHealthChecks?.connection()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -59,7 +58,7 @@ final class PostgresHealthChecksTests: XCTestCase {
let result = await app.psqlHealthChecks?.responseTime()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.observedUnit, "ms")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -84,7 +83,6 @@ final class PostgresHealthChecksTests: XCTestCase {
let psqlConnections = result?["\(ComponentName.postgresql):\(MeasurementType.connections)"]
XCTAssertEqual(psqlConnections?.componentType, .datastore)
XCTAssertNotEqual(psqlConnections?.observedValue, 1.0)
XCTAssertEqual(psqlConnections?.observedUnit, "s")
XCTAssertEqual(psqlConnections?.status, .pass)
XCTAssertNil(psqlConnections?.affectedEndpoints)
XCTAssertNil(psqlConnections?.output)
Expand Down
6 changes: 2 additions & 4 deletions Tests/HealthChecksTests/RedisHealthChecksTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@ final class RedisHealthChecksTests: XCTestCase {
let result = await app.redisHealthChecks?.connection()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -59,10 +58,10 @@ final class RedisHealthChecksTests: XCTestCase {

app.redisRequest = RedisRequestMock()
app.redisHealthChecks = RedisHealthChecks(app: app)
let result = await app.redisHealthChecks?.connection()
let result = await app.redisHealthChecks?.responseTime()
XCTAssertEqual(result?.componentType, .datastore)
XCTAssertNotEqual(result?.observedValue, 1.0)
XCTAssertEqual(result?.observedUnit, "s")
XCTAssertEqual(result?.observedUnit, "ms")
XCTAssertEqual(result?.status, .pass)
XCTAssertNil(result?.affectedEndpoints)
XCTAssertNil(result?.output)
Expand All @@ -86,7 +85,6 @@ final class RedisHealthChecksTests: XCTestCase {
let redisConnections = result?["\(ComponentName.redis):\(MeasurementType.connections)"]
XCTAssertEqual(redisConnections?.componentType, .datastore)
XCTAssertNotEqual(redisConnections?.observedValue, 1.0)
XCTAssertEqual(redisConnections?.observedUnit, "s")
XCTAssertEqual(redisConnections?.status, .pass)
XCTAssertNil(redisConnections?.affectedEndpoints)
XCTAssertNil(redisConnections?.output)
Expand Down

0 comments on commit d222e12

Please sign in to comment.