// This file was autogenerated by some hot garbage in the `uniffi` crate. // Trust me, you don't want to mess with it! // swiftlint:disable all 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(FluxaRustCoreFFI) import FluxaRustCoreFFI #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 empty() -> RustBuffer { RustBuffer(capacity: 0, len:0, data: nil) } static func from(_ ptr: UnsafeBufferPointer) -> RustBuffer { try! rustCall { ffi_fluxa_core_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_fluxa_core_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) { self.init( bytesNoCopy: rustBuffer.data!, count: Int(rustBuffer.len), deallocator: .none ) } } // 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 to 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 { #if swift(>=5.8) @_documentation(visibility: private) #endif public static func lift(_ value: FfiType) throws -> SwiftType { return value } #if swift(>=5.8) @_documentation(visibility: private) #endif 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 { #if swift(>=5.8) @_documentation(visibility: private) #endif 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 } #if swift(>=5.8) @_documentation(visibility: private) #endif 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 extension NSLock { func withLock(f: () throws -> T) rethrows -> T { self.lock() defer { self.unlock() } return try f() } } fileprivate let CALL_SUCCESS: Int8 = 0 fileprivate let CALL_ERROR: Int8 = 1 fileprivate let CALL_UNEXPECTED_ERROR: 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 { let neverThrow: ((RustBuffer) throws -> Never)? = nil return try makeRustCall(callback, errorHandler: neverThrow) } private func rustCallWithError( _ errorHandler: @escaping (RustBuffer) throws -> E, _ callback: (UnsafeMutablePointer) -> T) throws -> T { try makeRustCall(callback, errorHandler: errorHandler) } private func makeRustCall( _ callback: (UnsafeMutablePointer) -> T, errorHandler: ((RustBuffer) throws -> E)? ) throws -> T { uniffiEnsureFluxaCoreInitialized() var callStatus = RustCallStatus.init() let returnedVal = callback(&callStatus) try uniffiCheckCallStatus(callStatus: callStatus, errorHandler: errorHandler) return returnedVal } private func uniffiCheckCallStatus( callStatus: RustCallStatus, errorHandler: ((RustBuffer) throws -> E)? ) 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_UNEXPECTED_ERROR: // 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: fatalError("Cancellation not supported yet") default: throw UniffiInternalError.unexpectedRustCallStatusCode } } private func uniffiTraitInterfaceCall( callStatus: UnsafeMutablePointer, makeCall: () throws -> T, writeReturn: (T) -> () ) { do { try writeReturn(makeCall()) } catch let error { callStatus.pointee.code = CALL_UNEXPECTED_ERROR callStatus.pointee.errorBuf = FfiConverterString.lower(String(describing: error)) } } private func uniffiTraitInterfaceCallWithError( callStatus: UnsafeMutablePointer, makeCall: () throws -> T, writeReturn: (T) -> (), lowerError: (E) -> RustBuffer ) { do { try writeReturn(makeCall()) } catch let error as E { callStatus.pointee.code = CALL_ERROR callStatus.pointee.errorBuf = lowerError(error) } catch { callStatus.pointee.code = CALL_UNEXPECTED_ERROR callStatus.pointee.errorBuf = FfiConverterString.lower(String(describing: error)) } } // Initial value and increment amount for handles. // These ensure that SWIFT handles always have the lowest bit set fileprivate let UNIFFI_HANDLEMAP_INITIAL: UInt64 = 1 fileprivate let UNIFFI_HANDLEMAP_DELTA: UInt64 = 2 fileprivate final class UniffiHandleMap: @unchecked Sendable { // All mutation happens with this lock held, which is why we implement @unchecked Sendable. private let lock = NSLock() private var map: [UInt64: T] = [:] private var currentHandle: UInt64 = UNIFFI_HANDLEMAP_INITIAL func insert(obj: T) -> UInt64 { lock.withLock { return doInsert(obj) } } // Low-level insert function, this assumes `lock` is held. private func doInsert(_ obj: T) -> UInt64 { let handle = currentHandle currentHandle += UNIFFI_HANDLEMAP_DELTA map[handle] = obj return handle } func get(handle: UInt64) throws -> T { try lock.withLock { guard let obj = map[handle] else { throw UniffiInternalError.unexpectedStaleHandle } return obj } } func clone(handle: UInt64) throws -> UInt64 { try lock.withLock { guard let obj = map[handle] else { throw UniffiInternalError.unexpectedStaleHandle } return doInsert(obj) } } @discardableResult func remove(handle: UInt64) throws -> T { try lock.withLock { guard let obj = map.removeValue(forKey: handle) else { throw UniffiInternalError.unexpectedStaleHandle } return obj } } var count: Int { get { map.count } } } // Public interface members begin here. // Magic number for the Rust proxy to call using the same mechanism as every other method, // to free the callback once it's dropped by Rust. private let IDX_CALLBACK_FREE: Int32 = 0 // Callback return codes private let UNIFFI_CALLBACK_SUCCESS: Int32 = 0 private let UNIFFI_CALLBACK_ERROR: Int32 = 1 private let UNIFFI_CALLBACK_UNEXPECTED_ERROR: Int32 = 2 #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterUInt16: FfiConverterPrimitive { typealias FfiType = UInt16 typealias SwiftType = UInt16 public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> UInt16 { return try lift(readInt(&buf)) } public static func write(_ value: SwiftType, into buf: inout [UInt8]) { writeInt(&buf, lower(value)) } } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterInt32: FfiConverterPrimitive { typealias FfiType = Int32 typealias SwiftType = Int32 public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> Int32 { return try lift(readInt(&buf)) } public static func write(_ value: Int32, into buf: inout [UInt8]) { writeInt(&buf, lower(value)) } } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterInt64: FfiConverterPrimitive { typealias FfiType = Int64 typealias SwiftType = Int64 public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> Int64 { return try lift(readInt(&buf)) } public static func write(_ value: Int64, into buf: inout [UInt8]) { writeInt(&buf, lower(value)) } } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterBool : FfiConverter { typealias FfiType = Int8 typealias SwiftType = Bool public static func lift(_ value: Int8) throws -> Bool { return value != 0 } public static func lower(_ value: Bool) -> Int8 { return value ? 1 : 0 } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> Bool { return try lift(readInt(&buf)) } public static func write(_ value: Bool, into buf: inout [UInt8]) { writeInt(&buf, lower(value)) } } #if swift(>=5.8) @_documentation(visibility: private) #endif 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) } } public struct PluginHttpRequest: Equatable, Hashable { public var method: String public var url: String public var headers: [String: String] public var body: String? public var followRedirects: Bool // Default memberwise initializers are never public by default, so we // declare one manually. public init(method: String, url: String, headers: [String: String], body: String?, followRedirects: Bool) { self.method = method self.url = url self.headers = headers self.body = body self.followRedirects = followRedirects } } #if compiler(>=6) extension PluginHttpRequest: Sendable {} #endif #if swift(>=5.8) @_documentation(visibility: private) #endif public struct FfiConverterTypePluginHttpRequest: FfiConverterRustBuffer { public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> PluginHttpRequest { return try PluginHttpRequest( method: FfiConverterString.read(from: &buf), url: FfiConverterString.read(from: &buf), headers: FfiConverterDictionaryStringString.read(from: &buf), body: FfiConverterOptionString.read(from: &buf), followRedirects: FfiConverterBool.read(from: &buf) ) } public static func write(_ value: PluginHttpRequest, into buf: inout [UInt8]) { FfiConverterString.write(value.method, into: &buf) FfiConverterString.write(value.url, into: &buf) FfiConverterDictionaryStringString.write(value.headers, into: &buf) FfiConverterOptionString.write(value.body, into: &buf) FfiConverterBool.write(value.followRedirects, into: &buf) } } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterTypePluginHttpRequest_lift(_ buf: RustBuffer) throws -> PluginHttpRequest { return try FfiConverterTypePluginHttpRequest.lift(buf) } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterTypePluginHttpRequest_lower(_ value: PluginHttpRequest) -> RustBuffer { return FfiConverterTypePluginHttpRequest.lower(value) } public struct PluginHttpResponse: Equatable, Hashable { public var status: UInt16 public var headers: [String: String] public var body: String public var ok: Bool public var error: String? // Default memberwise initializers are never public by default, so we // declare one manually. public init(status: UInt16, headers: [String: String], body: String, ok: Bool, error: String?) { self.status = status self.headers = headers self.body = body self.ok = ok self.error = error } } #if compiler(>=6) extension PluginHttpResponse: Sendable {} #endif #if swift(>=5.8) @_documentation(visibility: private) #endif public struct FfiConverterTypePluginHttpResponse: FfiConverterRustBuffer { public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> PluginHttpResponse { return try PluginHttpResponse( status: FfiConverterUInt16.read(from: &buf), headers: FfiConverterDictionaryStringString.read(from: &buf), body: FfiConverterString.read(from: &buf), ok: FfiConverterBool.read(from: &buf), error: FfiConverterOptionString.read(from: &buf) ) } public static func write(_ value: PluginHttpResponse, into buf: inout [UInt8]) { FfiConverterUInt16.write(value.status, into: &buf) FfiConverterDictionaryStringString.write(value.headers, into: &buf) FfiConverterString.write(value.body, into: &buf) FfiConverterBool.write(value.ok, into: &buf) FfiConverterOptionString.write(value.error, into: &buf) } } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterTypePluginHttpResponse_lift(_ buf: RustBuffer) throws -> PluginHttpResponse { return try FfiConverterTypePluginHttpResponse.lift(buf) } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterTypePluginHttpResponse_lower(_ value: PluginHttpResponse) -> RustBuffer { return FfiConverterTypePluginHttpResponse.lower(value) } public protocol PluginHttpClient: AnyObject, Sendable { func fetch(request: PluginHttpRequest) -> PluginHttpResponse } // Put the implementation in a struct so we don't pollute the top-level namespace fileprivate struct UniffiCallbackInterfacePluginHttpClient { // Create the VTable using a series of closures. // Swift automatically converts these into C callback functions. // // Store the vtable directly. static let vtable: UniffiVTableCallbackInterfacePluginHttpClient = UniffiVTableCallbackInterfacePluginHttpClient( uniffiFree: { (uniffiHandle: UInt64) -> () in do { try FfiConverterCallbackInterfacePluginHttpClient.handleMap.remove(handle: uniffiHandle) } catch { print("Uniffi callback interface PluginHttpClient: handle missing in uniffiFree") } }, uniffiClone: { (uniffiHandle: UInt64) -> UInt64 in do { return try FfiConverterCallbackInterfacePluginHttpClient.handleMap.clone(handle: uniffiHandle) } catch { fatalError("Uniffi callback interface PluginHttpClient: handle missing in uniffiClone") } }, fetch: { ( uniffiHandle: UInt64, request: RustBuffer, uniffiOutReturn: UnsafeMutablePointer, uniffiCallStatus: UnsafeMutablePointer ) in let makeCall = { () throws -> PluginHttpResponse in guard let uniffiObj = try? FfiConverterCallbackInterfacePluginHttpClient.handleMap.get(handle: uniffiHandle) else { throw UniffiInternalError.unexpectedStaleHandle } return uniffiObj.fetch( request: try FfiConverterTypePluginHttpRequest_lift(request) ) } let writeReturn = { uniffiOutReturn.pointee = FfiConverterTypePluginHttpResponse_lower($0) } uniffiTraitInterfaceCall( callStatus: uniffiCallStatus, makeCall: makeCall, writeReturn: writeReturn ) } ) // Rust stores this pointer for future callback invocations, so it must live // for the process lifetime (not just for the init function call). static let vtablePtr: UnsafePointer = { let ptr = UnsafeMutablePointer.allocate(capacity: 1) ptr.initialize(to: vtable) return UnsafePointer(ptr) }() } private func uniffiCallbackInitPluginHttpClient() { uniffi_fluxa_core_fn_init_callback_vtable_pluginhttpclient(UniffiCallbackInterfacePluginHttpClient.vtablePtr) } // FfiConverter protocol for callback interfaces #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterCallbackInterfacePluginHttpClient { fileprivate static let handleMap = UniffiHandleMap() } #if swift(>=5.8) @_documentation(visibility: private) #endif extension FfiConverterCallbackInterfacePluginHttpClient : FfiConverter { typealias SwiftType = PluginHttpClient typealias FfiType = UInt64 #if swift(>=5.8) @_documentation(visibility: private) #endif public static func lift(_ handle: UInt64) throws -> SwiftType { try handleMap.get(handle: handle) } #if swift(>=5.8) @_documentation(visibility: private) #endif public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> SwiftType { let handle: UInt64 = try readInt(&buf) return try lift(handle) } #if swift(>=5.8) @_documentation(visibility: private) #endif public static func lower(_ v: SwiftType) -> UInt64 { return handleMap.insert(obj: v) } #if swift(>=5.8) @_documentation(visibility: private) #endif public static func write(_ v: SwiftType, into buf: inout [UInt8]) { writeInt(&buf, lower(v)) } } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterCallbackInterfacePluginHttpClient_lift(_ handle: UInt64) throws -> PluginHttpClient { return try FfiConverterCallbackInterfacePluginHttpClient.lift(handle) } #if swift(>=5.8) @_documentation(visibility: private) #endif public func FfiConverterCallbackInterfacePluginHttpClient_lower(_ v: PluginHttpClient) -> UInt64 { return FfiConverterCallbackInterfacePluginHttpClient.lower(v) } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterOptionInt32: FfiConverterRustBuffer { typealias SwiftType = Int32? public static func write(_ value: SwiftType, into buf: inout [UInt8]) { guard let value = value else { writeInt(&buf, Int8(0)) return } writeInt(&buf, Int8(1)) FfiConverterInt32.write(value, into: &buf) } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> SwiftType { switch try readInt(&buf) as Int8 { case 0: return nil case 1: return try FfiConverterInt32.read(from: &buf) default: throw UniffiInternalError.unexpectedOptionalTag } } } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterOptionString: FfiConverterRustBuffer { typealias SwiftType = String? public static func write(_ value: SwiftType, into buf: inout [UInt8]) { guard let value = value else { writeInt(&buf, Int8(0)) return } writeInt(&buf, Int8(1)) FfiConverterString.write(value, into: &buf) } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> SwiftType { switch try readInt(&buf) as Int8 { case 0: return nil case 1: return try FfiConverterString.read(from: &buf) default: throw UniffiInternalError.unexpectedOptionalTag } } } #if swift(>=5.8) @_documentation(visibility: private) #endif fileprivate struct FfiConverterDictionaryStringString: FfiConverterRustBuffer { public static func write(_ value: [String: String], into buf: inout [UInt8]) { let len = Int32(value.count) writeInt(&buf, len) for (key, value) in value { FfiConverterString.write(key, into: &buf) FfiConverterString.write(value, into: &buf) } } public static func read(from buf: inout (data: Data, offset: Data.Index)) throws -> [String: String] { let len: Int32 = try readInt(&buf) var dict = [String: String]() dict.reserveCapacity(Int(len)) for _ in 0.. String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_app_core_dispatch_json( FfiConverterInt64.lower(handle), FfiConverterString.lower(actionJson),$0 ) }) } public func appCoreStateJson(handle: Int64) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_app_core_state_json( FfiConverterInt64.lower(handle),$0 ) }) } public func coreCapabilitiesJson(portable: Bool) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_core_capabilities_json( FfiConverterBool.lower(portable),$0 ) }) } /** * Funnel entry point — Swift calls this instead of binding each helper. */ public func coreInvoke(method: String, argsJson: String) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_core_invoke( FfiConverterString.lower(method), FfiConverterString.lower(argsJson),$0 ) }) } public func createAppCoreStateJson(initialJson: String) -> Int64 { return try! FfiConverterInt64.lift(try! rustCall() { uniffi_fluxa_core_fn_func_create_app_core_state_json( FfiConverterString.lower(initialJson),$0 ) }) } public func createHeadlessEngineJson(initialJson: String) -> Int64 { return try! FfiConverterInt64.lift(try! rustCall() { uniffi_fluxa_core_fn_func_create_headless_engine_json( FfiConverterString.lower(initialJson),$0 ) }) } public func destroyAppCoreStateJson(handle: Int64) -> Bool { return try! FfiConverterBool.lift(try! rustCall() { uniffi_fluxa_core_fn_func_destroy_app_core_state_json( FfiConverterInt64.lower(handle),$0 ) }) } public func destroyHeadlessEngineJson(handle: Int64) -> Bool { return try! FfiConverterBool.lift(try! rustCall() { uniffi_fluxa_core_fn_func_destroy_headless_engine_json( FfiConverterInt64.lower(handle),$0 ) }) } public func drainCoreErrorLogJson() -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_drain_core_error_log_json($0 ) }) } public func executePluginScraper(client: PluginHttpClient, code: String, scraperId: String, scraperSettingsJson: String, tmdbId: String, mediaType: String, season: Int32?, episode: Int32?) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_execute_plugin_scraper( FfiConverterCallbackInterfacePluginHttpClient_lower(client), FfiConverterString.lower(code), FfiConverterString.lower(scraperId), FfiConverterString.lower(scraperSettingsJson), FfiConverterString.lower(tmdbId), FfiConverterString.lower(mediaType), FfiConverterOptionInt32.lower(season), FfiConverterOptionInt32.lower(episode),$0 ) }) } public func fluxaCoreVersion() -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_fluxa_core_version($0 ) }) } public func getPluginScraperSettingsLayout(code: String, scraperId: String) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_get_plugin_scraper_settings_layout( FfiConverterString.lower(code), FfiConverterString.lower(scraperId),$0 ) }) } public func headlessEngineCompleteEffectJson(handle: Int64, resultJson: String) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_headless_engine_complete_effect_json( FfiConverterInt64.lower(handle), FfiConverterString.lower(resultJson),$0 ) }) } public func headlessEngineDispatchJson(handle: Int64, actionJson: String) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_headless_engine_dispatch_json( FfiConverterInt64.lower(handle), FfiConverterString.lower(actionJson),$0 ) }) } public func headlessEngineSnapshotJson(handle: Int64) -> String { return try! FfiConverterString.lift(try! rustCall() { uniffi_fluxa_core_fn_func_headless_engine_snapshot_json( FfiConverterInt64.lower(handle),$0 ) }) } private enum InitializationResult { case ok case contractVersionMismatch case apiChecksumMismatch } // Use a global variable to perform the versioning checks. Swift ensures that // the code inside is only computed once. private let initializationResult: InitializationResult = { // Get the bindings contract version from our ComponentInterface let bindings_contract_version = 30 // Get the scaffolding contract version by calling the into the dylib let scaffolding_contract_version = ffi_fluxa_core_uniffi_contract_version() if bindings_contract_version != scaffolding_contract_version { return InitializationResult.contractVersionMismatch } if (uniffi_fluxa_core_checksum_func_app_core_dispatch_json() != 29233) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_app_core_state_json() != 13708) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_core_capabilities_json() != 55183) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_core_invoke() != 1384) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_create_app_core_state_json() != 6511) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_create_headless_engine_json() != 61916) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_destroy_app_core_state_json() != 42634) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_destroy_headless_engine_json() != 52168) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_drain_core_error_log_json() != 16662) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_execute_plugin_scraper() != 40233) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_fluxa_core_version() != 38862) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_get_plugin_scraper_settings_layout() != 56596) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_headless_engine_complete_effect_json() != 61331) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_headless_engine_dispatch_json() != 33612) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_func_headless_engine_snapshot_json() != 60797) { return InitializationResult.apiChecksumMismatch } if (uniffi_fluxa_core_checksum_method_pluginhttpclient_fetch() != 61885) { return InitializationResult.apiChecksumMismatch } uniffiCallbackInitPluginHttpClient() return InitializationResult.ok }() // Make the ensure init function public so that other modules which have external type references to // our types can call it. public func uniffiEnsureFluxaCoreInitialized() { 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") } } // swiftlint:enable all