Skip to content

Commit

Permalink
debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
bryce-b committed Jun 4, 2024
1 parent f4185a8 commit 5c2f814
Show file tree
Hide file tree
Showing 3 changed files with 62 additions and 62 deletions.
120 changes: 60 additions & 60 deletions Tests/ExportersTests/DatadogExporter/DatadogExporterTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -98,64 +98,64 @@ class DatadogExporterTests: XCTestCase {
span.end()
}

func testWhenExportMetricIsCalled_thenMetricsAreUploaded() throws {
#if os(watchOS)
throw XCTSkip("Test is flaky on watchOS")
#endif

var metricsSent = false
let expecMetrics = expectation(description: "metrics received")
expecMetrics.assertForOverFulfill = false

let server = HttpTestServer(url: URL(string: "http://localhost:33333"),
config: HttpTestServerConfig(metricsReceivedCallback: {
metricsSent = true
expecMetrics.fulfill()
}))

let sem = DispatchSemaphore(value: 0)
DispatchQueue.global(qos: .default).async {
do {
try server.start(semaphore: sem)
} catch {
XCTFail()
return
}
}
sem.wait()

let exporterConfiguration = ExporterConfiguration(serviceName: "serviceName",
resource: "resource",
applicationName: "applicationName",
applicationVersion: "applicationVersion",
environment: "environment",
apiKey: "apikey",
endpoint: Endpoint.custom(
tracesURL: URL(string: "http://localhost:33333/traces")!,
logsURL: URL(string: "http://localhost:33333/logs")!,
metricsURL: URL(string: "http://localhost:33333/metrics")!),
uploadCondition: { true })

let datadogExporter = try! DatadogExporter(config: exporterConfiguration)

let provider = MeterProviderSdk(metricProcessor: MetricProcessorSdk(),
metricExporter: datadogExporter,
metricPushInterval: 0.1)

let meter = provider.get(instrumentationName: "MyMeter")

let testCounter = meter.createIntCounter(name: "MyCounter")

testCounter.add(value: 100, labelset: LabelSet.empty)

let result = XCTWaiter().wait(for: [expecMetrics], timeout: 20)

if result == .completed {
XCTAssertTrue(metricsSent)
} else {
XCTFail()
}

server.stop()
}
// func testWhenExportMetricIsCalled_thenMetricsAreUploaded() throws {
//#if os(watchOS)
// throw XCTSkip("Test is flaky on watchOS")
//#endif
//
// var metricsSent = false
// let expecMetrics = expectation(description: "metrics received")
// expecMetrics.assertForOverFulfill = false
//
// let server = HttpTestServer(url: URL(string: "http://localhost:33333"),
// config: HttpTestServerConfig(metricsReceivedCallback: {
// metricsSent = true
// expecMetrics.fulfill()
// }))
//
// let sem = DispatchSemaphore(value: 0)
// DispatchQueue.global(qos: .default).async {
// do {
// try server.start(semaphore: sem)
// } catch {
// XCTFail()
// return
// }
// }
// sem.wait()
//
// let exporterConfiguration = ExporterConfiguration(serviceName: "serviceName",
// resource: "resource",
// applicationName: "applicationName",
// applicationVersion: "applicationVersion",
// environment: "environment",
// apiKey: "apikey",
// endpoint: Endpoint.custom(
// tracesURL: URL(string: "http://localhost:33333/traces")!,
// logsURL: URL(string: "http://localhost:33333/logs")!,
// metricsURL: URL(string: "http://localhost:33333/metrics")!),
// uploadCondition: { true })
//
// let datadogExporter = try! DatadogExporter(config: exporterConfiguration)
//
// let provider = MeterProviderSdk(metricProcessor: MetricProcessorSdk(),
// metricExporter: datadogExporter,
// metricPushInterval: 0.1)
//
// let meter = provider.get(instrumentationName: "MyMeter")
//
// let testCounter = meter.createIntCounter(name: "MyCounter")
//
// testCounter.add(value: 100, labelset: LabelSet.empty)
//
// let result = XCTWaiter().wait(for: [expecMetrics], timeout: 20)
//
// if result == .completed {
// XCTAssertTrue(metricsSent)
// } else {
// XCTFail()
// }
//
// server.stop()
// }
}
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ class DataUploadWorkerTests: XCTestCase {
XCTAssertEqual(try temporaryDirectory.files().count, 1, "When upload finishes with `needsRetry: true`, data should be preserved")
}

// MARK: - Upload Interval Changes
// MARK: - Upload Interval Changes

func testWhenThereIsNoBatch_thenIntervalIncreases() {
let delayChangeExpectation = expectation(description: "Upload delay is increased")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ class DataExportWorkerTests: XCTestCase {
// When
let fileReader = FileReaderMock()
let mockDataExporter = DataExporterMock(exportStatus: .mockWith(needsRetry: false))

let worker = DataExportWorker(
fileReader: fileReader,
dataExporter: mockDataExporter,
Expand Down

0 comments on commit 5c2f814

Please sign in to comment.