@preconcurrency import Dispatch
@preconcurrency import Foundation
import SourceKittenFramework

private let outputQueue: DispatchQueue = {
    let queue = DispatchQueue(
        label: "io.realm.swiftlint.outputQueue",
        qos: .userInteractive,
        target: .global(qos: .userInteractive)
    )

    defer {
        setupAtExitHandler()
    }

    return queue
}()

private func setupAtExitHandler() {
    atexit {
        // Ensure all queued output is written before exiting.
        outputQueue.sync(flags: .barrier) {
            // Just wait.
        }
    }
}

/**
 A thread-safe version of Swift's standard `print()`.

 - parameter object: Object to print.
 */
public func queuedPrint<T: Sendable>(_ object: T) {
    outputQueue.async {
        print(object)
    }
}

/**
 A thread-safe, newline-terminated version of `fputs(..., stderr)`.

 - parameter string: String to print.
 */
public func queuedPrintError(_ string: String) {
    outputQueue.async {
        fflush(stdout)
        fputs(string + "\n", stderr)
    }
}

/**
 A thread-safe, newline-terminated version of `fatalError(...)` that doesn't leak
 the source path from the compiled binary.
 */
public func queuedFatalError(_ string: String, file: StaticString = #file, line: UInt = #line) -> Never {
    outputQueue.sync {
        fflush(stdout)
        let file = "\(file)".bridge().lastPathComponent
        fputs("\(string): file \(file), line \(line)\n", stderr)
    }

    abort()
}