dependencies: [
    .package(url: "https://github.com/pokryfka/aws-xray-sdk-swift.git", from: "0.1.0")
]

let recorder = XRayRecorder()

let segment = recorder.beginSegment(name: "Segment 1")
usleep(100_000)
segment.end()

recorder.segment(name: "Segment 2") { segment in
    try? segment.subsegment(name: "Subsegment 2.1") { segment in
        _ = segment.subsegment(name: "Subsegment 2.1.1 with Result") { _ -> String in
            usleep(100_000)
            return "Result"
        }
        try segment.subsegment(name: "Subsegment 2.1.1 with Error") { _ in
            usleep(200_000)
            throw ExampleError.test
        }
    }
}

let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
let emmiter = XRayEmmiter(eventLoop: group.next())

try emmiter.send(segments: recorder.removeReady()).wait()

try group.syncShutdownGracefully()

segment.setAnnotation("zip_code", value: 98101)

segment.setMetadata(["debug": ["test": "Metadata string"]])

let s3 = S3(middlewares: [XRayMiddleware(recorder: recorder, name: "S3")],
            httpClientProvider: .createNew)

recorder.segment(name: "List Buckets") {
    s3.listBuckets()
}