// This file was autogenerated by some hot garbage in the `uniffi` crate. // Trust me, you don't want to mess with it! import Foundation // Depending on the consumer's build setup, the low-level FFI code // might be in a separate module, or it might be compiled inline into // this module. This is a bit of light hackery to work with both. #if canImport(pubkymobileFFI) import pubkymobileFFI #endif fileprivate extension RustBuffer { // Allocate a new buffer, copying the contents of a `UInt8` array. init(bytes: [UInt8]) { let rbuf = bytes.withUnsafeBufferPointer { ptr in RustBuffer.from(ptr) } self.init(capacity: rbuf.capacity, len: rbuf.len, data: rbuf.data) } static func from(_ ptr: UnsafeBufferPointer) -> RustBuffer { try! rustCall { ffi_pubkymobile_rustbuffer_from_bytes(ForeignBytes(bufferPointer: ptr), $0) } } // Frees the buffer in place. // The buffer must not be used after this is called. func deallocate() { try! rustCall { ffi_pubkymobile_rustbuffer_free(self, $0) } } } fileprivate extension ForeignBytes { init(bufferPointer: UnsafeBufferPointer) { self.init(len: Int32(bufferPointer.count), data: bufferPointer.baseAddress) } } // For every type used in the interface, we provide helper methods for conveniently // lifting and lowering that type from C-compatible data, and for reading and writing // values of that type in a buffer. // Helper classes/extensions that don't change. // Someday, this will be in a library of its own. fileprivate extension Data { init(rustBuffer: RustBuffer) { // TODO: This copies the buffer. Can we read directly from a // Rust buffer? self.init(bytes: rustBuffer.data!, count: Int(rustBuffer.len)) } } // Define reader functionality. Normally this would be defined in a class or // struct, but we use standalone functions instead in order to make external // types work. // // With external types, one swift source file needs to be able to call the read // method on another source file's FfiConverter, but then what visibility // should Reader have? // - If Reader is fileprivate, then this means the read() must also // be fileprivate, which doesn't work with external types. // - If Reader is internal/public, we'll get compile errors since both source // files will try define the same type. // // Instead, the read() method and these helper functions input a tuple of data fileprivate func createReader(data: Data) -> (data: Data, offset: Data.Index) { (data: data, offset: 0) } // Reads an integer at the current offset, in big-endian order, and advances // the offset on success. Throws if reading the integer would move the // offset past the end of the buffer. fileprivate func readInt(_ reader: inout (data: Data, offset: Data.Index)) throws -> T { let range = reader.offset...size guard reader.data.count >= range.upperBound else { throw UniffiInternalError.bufferOverflow } if T.self == UInt8.self { let value = reader.data[reader.offset] reader.offset += 1 return value as! T } var value: T = 0 let _ = withUnsafeMutableBytes(of: &value, { reader.data.copyBytes(to: $0, from: range)}) reader.offset = range.upperBound return value.bigEndian } // Reads an arbitrary number of bytes, to be used to read // raw bytes, this is useful when lifting strings fileprivate func readBytes(_ reader: inout (data: Data, offset: Data.Index), count: Int) throws -> Array { let range = reader.offset..<(reader.offset+count) guard reader.data.count >= range.upperBound else { throw UniffiInternalError.bufferOverflow } var value = [UInt8](repeating: 0, count: count) value.withUnsafeMutableBufferPointer({ buffer in reader.data.copyBytes(to: buffer, from: range) }) reader.offset = range.upperBound return value } // Reads a float at the current offset. fileprivate func readFloat(_ reader: inout (data: Data, offset: Data.Index)) throws -> Float { return Float(bitPattern: try readInt(&reader)) } // Reads a float at the current offset. fileprivate func readDouble(_ reader: inout (data: Data, offset: Data.Index)) throws -> Double { return Double(bitPattern: try readInt(&reader)) } // Indicates if the offset has reached the end of the buffer. fileprivate func hasRemaining(_ reader: (data: Data, offset: Data.Index)) -> Bool { return reader.offset < reader.data.count } // Define writer functionality. Normally this would be defined in a class or // struct, but we use standalone functions instead in order to make external // types work. See the above discussion on Readers for details. fileprivate func createWriter() -> [UInt8] { return [] } fileprivate func writeBytes(_ writer: inout [UInt8], _ byteArr: S) where S: Sequence, S.Element == UInt8 { writer.append(contentsOf: byteArr) } // Writes an integer in big-endian order. // // Warning: make sure what you are trying to write // is in the correct type! fileprivate func writeInt(_ writer: inout [UInt8], _ value: T) { var value = value.bigEndian withUnsafeBytes(of: &value) { writer.append(contentsOf: $0) } } fileprivate func writeFloat(_ writer: inout [UInt8], _ value: Float) { writeInt(&writer, value.bitPattern) } fileprivate func writeDouble(_ writer: inout [UInt8], _ value: Double) { writeInt(&writer, value.bitPattern) } // Protocol for types that transfer other types across the FFI. This is // analogous go the Rust trait of the same name. fileprivate protocol FfiConverter { associatedtype FfiType associatedtype SwiftType static func lift(_ value: FfiType) throws -> SwiftType static func lower(_ value: SwiftType) -> FfiType static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> SwiftType static func write(_ value: SwiftType, into buf: inout [UInt8]) } // Types conforming to `Primitive` pass themselves directly over the FFI. fileprivate protocol FfiConverterPrimitive: FfiConverter where FfiType == SwiftType { } extension FfiConverterPrimitive { public static func lift(_ value: FfiType) throws -> SwiftType { return value } public static func lower(_ value: SwiftType) -> FfiType { return value } } // Types conforming to `FfiConverterRustBuffer` lift and lower into a `RustBuffer`. // Used for complex types where it's hard to write a custom lift/lower. fileprivate protocol FfiConverterRustBuffer: FfiConverter where FfiType == RustBuffer {} extension FfiConverterRustBuffer { public static func lift(_ buf: RustBuffer) throws -> SwiftType { var reader = createReader(data: Data(rustBuffer: buf)) let value = try read(from: &reader) if hasRemaining(reader) { throw UniffiInternalError.incompleteData } buf.deallocate() return value } public static func lower(_ value: SwiftType) -> RustBuffer { var writer = createWriter() write(value, into: &writer) return RustBuffer(bytes: writer) } } // An error type for FFI errors. These errors occur at the UniFFI level, not // the library level. fileprivate enum UniffiInternalError: LocalizedError { case bufferOverflow case incompleteData case unexpectedOptionalTag case unexpectedEnumCase case unexpectedNullPointer case unexpectedRustCallStatusCode case unexpectedRustCallError case unexpectedStaleHandle case rustPanic(_ message: String) public var errorDescription: String? { switch self { case .bufferOverflow: return "Reading the requested value would read past the end of the buffer" case .incompleteData: return "The buffer still has data after lifting its containing value" case .unexpectedOptionalTag: return "Unexpected optional tag; should be 0 or 1" case .unexpectedEnumCase: return "Raw enum value doesn't match any cases" case .unexpectedNullPointer: return "Raw pointer value was null" case .unexpectedRustCallStatusCode: return "Unexpected RustCallStatus code" case .unexpectedRustCallError: return "CALL_ERROR but no errorClass specified" case .unexpectedStaleHandle: return "The object in the handle map has been dropped already" case let .rustPanic(message): return message } } } fileprivate let CALL_SUCCESS: Int8 = 0 fileprivate let CALL_ERROR: Int8 = 1 fileprivate let CALL_PANIC: Int8 = 2 fileprivate let CALL_CANCELLED: Int8 = 3 fileprivate extension RustCallStatus { init() { self.init( code: CALL_SUCCESS, errorBuf: RustBuffer.init( capacity: 0, len: 0, data: nil ) ) } } private func rustCall(_ callback: (UnsafeMutablePointer) -> T) throws -> T { try makeRustCall(callback, errorHandler: nil) } private func rustCallWithError( _ errorHandler: @escaping (RustBuffer) throws -> Error, _ callback: (UnsafeMutablePointer) -> T) throws -> T { try makeRustCall(callback, errorHandler: errorHandler) } private func makeRustCall( _ callback: (UnsafeMutablePointer) -> T, errorHandler: ((RustBuffer) throws -> Error)? ) throws -> T { uniffiEnsureInitialized() var callStatus = RustCallStatus.init() let returnedVal = callback(&callStatus) try uniffiCheckCallStatus(callStatus: callStatus, errorHandler: errorHandler) return returnedVal } private func uniffiCheckCallStatus( callStatus: RustCallStatus, errorHandler: ((RustBuffer) throws -> Error)? ) throws { switch callStatus.code { case CALL_SUCCESS: return case CALL_ERROR: if let errorHandler = errorHandler { throw try errorHandler(callStatus.errorBuf) } else { callStatus.errorBuf.deallocate() throw UniffiInternalError.unexpectedRustCallError } case CALL_PANIC: // When the rust code sees a panic, it tries to construct a RustBuffer // with the message. But if that code panics, then it just sends back // an empty buffer. if callStatus.errorBuf.len > 0 { throw UniffiInternalError.rustPanic(try FfiConverterString.lift(callStatus.errorBuf)) } else { callStatus.errorBuf.deallocate() throw UniffiInternalError.rustPanic("Rust panic") } case CALL_CANCELLED: throw CancellationError() default: throw UniffiInternalError.unexpectedRustCallStatusCode } } // Public interface members begin here. fileprivate struct FfiConverterString: FfiConverter { typealias SwiftType = String typealias FfiType = RustBuffer public static func lift(_ value: RustBuffer) throws -> String { defer { value.deallocate() } if value.data == nil { return String() } let bytes = UnsafeBufferPointer(start: value.data!, count: Int(value.len)) return String(bytes: bytes, encoding: String.Encoding.utf8)! } public static func lower(_ value: String) -> RustBuffer { return value.utf8CString.withUnsafeBufferPointer { ptr in // The swift string gives us int8_t, we want uint8_t. ptr.withMemoryRebound(to: UInt8.self) { ptr in // The swift string gives us a trailing null byte, we don't want it. let buf = UnsafeBufferPointer(rebasing: ptr.prefix(upTo: ptr.count - 1)) return RustBuffer.from(buf) } } } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> String { let len: Int32 = try readInt(&buf) return String(bytes: try readBytes(&buf, count: Int(len)), encoding: String.Encoding.utf8)! } public static func write(_ value: String, into buf: inout [UInt8]) { let len = Int32(value.utf8.count) writeInt(&buf, len) writeBytes(&buf, value.utf8) } } fileprivate struct FfiConverterSequenceString: FfiConverterRustBuffer { typealias SwiftType = [String] public static func write(_ value: [String], into buf: inout [UInt8]) { let len = Int32(value.count) writeInt(&buf, len) for item in value { FfiConverterString.write(item, into: &buf) } } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> [String] { let len: Int32 = try readInt(&buf) var seq = [String]() seq.reserveCapacity(Int(len)) for _ in 0 ..< len { seq.append(try FfiConverterString.read(from: &buf)) } return seq } } private let UNIFFI_RUST_FUTURE_POLL_READY: Int8 = 0 private let UNIFFI_RUST_FUTURE_POLL_MAYBE_READY: Int8 = 1 fileprivate func uniffiRustCallAsync( rustFutureFunc: () -> UnsafeMutableRawPointer, pollFunc: (UnsafeMutableRawPointer, UnsafeMutableRawPointer) -> (), completeFunc: (UnsafeMutableRawPointer, UnsafeMutablePointer) -> F, freeFunc: (UnsafeMutableRawPointer) -> (), liftFunc: (F) throws -> T, errorHandler: ((RustBuffer) throws -> Error)? ) async throws -> T { // Make sure to call uniffiEnsureInitialized() since future creation doesn't have a // RustCallStatus param, so doesn't use makeRustCall() uniffiEnsureInitialized() let rustFuture = rustFutureFunc() defer { freeFunc(rustFuture) } var pollResult: Int8; repeat { pollResult = await withUnsafeContinuation { pollFunc(rustFuture, ContinuationHolder($0).toOpaque()) } } while pollResult != UNIFFI_RUST_FUTURE_POLL_READY return try liftFunc(makeRustCall( { completeFunc(rustFuture, $0) }, errorHandler: errorHandler )) } // Callback handlers for an async calls. These are invoked by Rust when the future is ready. They // lift the return value or error and resume the suspended function. fileprivate func uniffiFutureContinuationCallback(ptr: UnsafeMutableRawPointer, pollResult: Int8) { ContinuationHolder.fromOpaque(ptr).resume(pollResult) } // Wraps UnsafeContinuation in a class so that we can use reference counting when passing it across // the FFI fileprivate class ContinuationHolder { let continuation: UnsafeContinuation init(_ continuation: UnsafeContinuation) { self.continuation = continuation } func resume(_ pollResult: Int8) { self.continuation.resume(returning: pollResult) } func toOpaque() -> UnsafeMutableRawPointer { return Unmanaged.passRetained(self).toOpaque() } static func fromOpaque(_ ptr: UnsafeRawPointer) -> ContinuationHolder { return Unmanaged.fromOpaque(ptr).takeRetainedValue() } } fileprivate func uniffiInitContinuationCallback() { ffi_pubkymobile_rust_future_continuation_callback_set(uniffiFutureContinuationCallback) } public func auth(url: String, secretKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_auth( FfiConverterString.lower(url), FfiConverterString.lower(secretKey),$0) } ) } public func generateSecretKey() -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_generate_secret_key($0) } ) } public func get(url: String) async -> [String] { return try! await uniffiRustCallAsync( rustFutureFunc: { uniffi_pubkymobile_fn_func_get( FfiConverterString.lower(url) ) }, pollFunc: ffi_pubkymobile_rust_future_poll_rust_buffer, completeFunc: ffi_pubkymobile_rust_future_complete_rust_buffer, freeFunc: ffi_pubkymobile_rust_future_free_rust_buffer, liftFunc: FfiConverterSequenceString.lift, errorHandler: nil ) } public func getPublicKeyFromSecretKey(secretKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_get_public_key_from_secret_key( FfiConverterString.lower(secretKey),$0) } ) } public func list(url: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_list( FfiConverterString.lower(url),$0) } ) } public func parseAuthUrl(url: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_parse_auth_url( FfiConverterString.lower(url),$0) } ) } public func publish(recordName: String, recordContent: String, secretKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_publish( FfiConverterString.lower(recordName), FfiConverterString.lower(recordContent), FfiConverterString.lower(secretKey),$0) } ) } public func publishHttps(recordName: String, target: String, secretKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_publish_https( FfiConverterString.lower(recordName), FfiConverterString.lower(target), FfiConverterString.lower(secretKey),$0) } ) } public func put(url: String, content: String) async -> [String] { return try! await uniffiRustCallAsync( rustFutureFunc: { uniffi_pubkymobile_fn_func_put( FfiConverterString.lower(url), FfiConverterString.lower(content) ) }, pollFunc: ffi_pubkymobile_rust_future_poll_rust_buffer, completeFunc: ffi_pubkymobile_rust_future_complete_rust_buffer, freeFunc: ffi_pubkymobile_rust_future_free_rust_buffer, liftFunc: FfiConverterSequenceString.lift, errorHandler: nil ) } public func resolve(publicKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_resolve( FfiConverterString.lower(publicKey),$0) } ) } public func resolveHttps(publicKey: String) -> [String] { return try! FfiConverterSequenceString.lift( try! rustCall() { uniffi_pubkymobile_fn_func_resolve_https( FfiConverterString.lower(publicKey),$0) } ) } public func signIn(secretKey: String) async -> [String] { return try! await uniffiRustCallAsync( rustFutureFunc: { uniffi_pubkymobile_fn_func_sign_in( FfiConverterString.lower(secretKey) ) }, pollFunc: ffi_pubkymobile_rust_future_poll_rust_buffer, completeFunc: ffi_pubkymobile_rust_future_complete_rust_buffer, freeFunc: ffi_pubkymobile_rust_future_free_rust_buffer, liftFunc: FfiConverterSequenceString.lift, errorHandler: nil ) } public func signOut(secretKey: String) async -> [String] { return try! await uniffiRustCallAsync( rustFutureFunc: { uniffi_pubkymobile_fn_func_sign_out( FfiConverterString.lower(secretKey) ) }, pollFunc: ffi_pubkymobile_rust_future_poll_rust_buffer, completeFunc: ffi_pubkymobile_rust_future_complete_rust_buffer, freeFunc: ffi_pubkymobile_rust_future_free_rust_buffer, liftFunc: FfiConverterSequenceString.lift, errorHandler: nil ) } public func signUp(secretKey: String, homeserver: String) async -> [String] { return try! await uniffiRustCallAsync( rustFutureFunc: { uniffi_pubkymobile_fn_func_sign_up( FfiConverterString.lower(secretKey), FfiConverterString.lower(homeserver) ) }, pollFunc: ffi_pubkymobile_rust_future_poll_rust_buffer, completeFunc: ffi_pubkymobile_rust_future_complete_rust_buffer, freeFunc: ffi_pubkymobile_rust_future_free_rust_buffer, liftFunc: FfiConverterSequenceString.lift, errorHandler: nil ) } private enum InitializationResult { case ok case contractVersionMismatch case apiChecksumMismatch } // Use a global variables to perform the versioning checks. Swift ensures that // the code inside is only computed once. private var initializationResult: InitializationResult { // Get the bindings contract version from our ComponentInterface let bindings_contract_version = 24 // Get the scaffolding contract version by calling the into the dylib let scaffolding_contract_version = ffi_pubkymobile_uniffi_contract_version() if bindings_contract_version != scaffolding_contract_version { return InitializationResult.contractVersionMismatch } if (uniffi_pubkymobile_checksum_func_auth() != 61378) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_generate_secret_key() != 63116) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_get() != 5395) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_get_public_key_from_secret_key() != 23603) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_list() != 8522) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_parse_auth_url() != 29088) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_publish() != 20156) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_publish_https() != 14705) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_put() != 47594) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_resolve() != 18303) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_resolve_https() != 34593) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_sign_in() != 53969) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_sign_out() != 32961) { return InitializationResult.apiChecksumMismatch } if (uniffi_pubkymobile_checksum_func_sign_up() != 28083) { return InitializationResult.apiChecksumMismatch } uniffiInitContinuationCallback() return InitializationResult.ok } private func uniffiEnsureInitialized() { switch initializationResult { case .ok: break case .contractVersionMismatch: fatalError("UniFFI contract version mismatch: try cleaning and rebuilding your project") case .apiChecksumMismatch: fatalError("UniFFI API checksum mismatch: try cleaning and rebuilding your project") } }