mirror of
https://github.com/FluxaMedia/fluxa.git
synced 2026-07-28 04:42:09 +00:00
Replaces the checked-in 6-function stub with actual uniffi-bindgen output, exposing PluginHttpClient, PluginHttpRequest/Response, executePluginScraper, getPluginScraperSettingsLayout, and coreInvoke to Swift for the first time.
1074 lines
No EOL
36 KiB
Swift
1074 lines
No EOL
36 KiB
Swift
// 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<UInt8>) -> 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<UInt8>) {
|
|
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<T: FixedWidthInteger>(_ reader: inout (data: Data, offset: Data.Index)) throws -> T {
|
|
let range = reader.offset..<reader.offset + MemoryLayout<T>.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<UInt8> {
|
|
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<S>(_ 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<T: FixedWidthInteger>(_ 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<T>(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<T>(_ callback: (UnsafeMutablePointer<RustCallStatus>) -> T) throws -> T {
|
|
let neverThrow: ((RustBuffer) throws -> Never)? = nil
|
|
return try makeRustCall(callback, errorHandler: neverThrow)
|
|
}
|
|
|
|
private func rustCallWithError<T, E: Swift.Error>(
|
|
_ errorHandler: @escaping (RustBuffer) throws -> E,
|
|
_ callback: (UnsafeMutablePointer<RustCallStatus>) -> T) throws -> T {
|
|
try makeRustCall(callback, errorHandler: errorHandler)
|
|
}
|
|
|
|
private func makeRustCall<T, E: Swift.Error>(
|
|
_ callback: (UnsafeMutablePointer<RustCallStatus>) -> 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<E: Swift.Error>(
|
|
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<T>(
|
|
callStatus: UnsafeMutablePointer<RustCallStatus>,
|
|
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<T, E>(
|
|
callStatus: UnsafeMutablePointer<RustCallStatus>,
|
|
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<T>: @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<UInt8>(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<RustBuffer>,
|
|
uniffiCallStatus: UnsafeMutablePointer<RustCallStatus>
|
|
) 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<UniffiVTableCallbackInterfacePluginHttpClient> = {
|
|
let ptr = UnsafeMutablePointer<UniffiVTableCallbackInterfacePluginHttpClient>.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<PluginHttpClient>()
|
|
}
|
|
|
|
#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..<len {
|
|
let key = try FfiConverterString.read(from: &buf)
|
|
let value = try FfiConverterString.read(from: &buf)
|
|
dict[key] = value
|
|
}
|
|
return dict
|
|
}
|
|
}
|
|
public func appCoreDispatchJson(handle: Int64, actionJson: String) -> 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 |