chore: final crud and bucket

Author: DominicGBauer

Sources/PowerSyncSwift/Bucket/OpType.swift

@@ -0,0 +1,14 @@
+import Foundation
+
+enum OpType: Int, Codable {
+    case clear = 1
+    case move = 2
+    case put = 3
+    case remove = 4
+}
+
+extension OpType: CustomStringConvertible {
+    var description: String {
+        return "\(self.rawValue)"
+    }
+}

Sources/PowerSyncSwift/Bucket/OplogEntry.swift

@@ -0,0 +1,39 @@
+import Foundation
+
+struct OplogEntry: Codable, Equatable {
+    let checksum: Int64
+    let opId: String
+    let rowId: String?
+    let rowType: String?
+    let op: OpType.RawValue?
+    let subkey: String?
+    let data: String?
+
+    enum CodingKeys: String, CodingKey {
+        case checksum
+        case opId = "op_id"
+        case rowId = "object_id"
+        case rowType = "object_type"
+        case op
+        case subkey
+        case data
+    }
+
+    init(
+        checksum: Int64,
+        opId: String,
+        rowId: String? = nil,
+        rowType: String? = nil,
+        op: OpType.RawValue? = nil,
+        subkey: String? = nil,
+        data: String? = nil
+    ) {
+        self.checksum = checksum
+        self.opId = opId
+        self.rowId = rowId
+        self.rowType = rowType
+        self.op = op
+        self.subkey = subkey
+        self.data = data
+    }
+}

Sources/PowerSyncSwift/Bucket/SharedPendingDeletesActor.swift

@@ -0,0 +1,17 @@
+import Foundation
+
+actor SharedPendingDeletesActor {
+    private(set) var pendingBucketDeletes: Bool
+    
+    init(initialValue: Bool = false) {
+        self.pendingBucketDeletes = initialValue
+    }
+    
+    func setPendingBucketDeletes(_ value: Bool) {
+        pendingBucketDeletes = value
+    }
+    
+    func getPendingBucketDeletes() -> Bool {
+        return pendingBucketDeletes
+    }
+}

Sources/PowerSyncSwift/Bucket/WriteCheckpointResult.swift

@@ -0,0 +1,13 @@
+import Foundation
+
+struct WriteCheckpointResponse: Codable {
+    let data: WriteCheckpointData
+}
+
+struct WriteCheckpointData: Codable {
+    let writeCheckpoint: String
+
+    enum CodingKeys: String, CodingKey {
+        case writeCheckpoint = "write_checkpoint"
+    }
+}

Sources/PowerSyncSwift/Crud/UpdateType.swift

@@ -0,0 +1,37 @@
+import Foundation
+
+/// Type of local change.
+public enum UpdateType {
+    /// Insert or replace a row. All non-null columns are included in the data.
+    case put
+    
+    /// Update a row if it exists. All updated columns are included in the data.
+    case patch
+    
+    /// Delete a row if it exists.
+    case delete
+    
+    /// The JSON string representation of the update type
+    private var json: String {
+        switch self {
+        case .put: return "PUT"
+        case .patch: return "PATCH"
+        case .delete: return "DELETE"
+        }
+    }
+    
+    /// Convert the update type to its JSON string representation
+    public func toJSON() -> String {
+        return json
+    }
+    
+    /// Create an UpdateType from a JSON string, returning nil if the string doesn't match any known type
+    public static func fromJSON(_ json: String) -> UpdateType? {
+        switch json {
+        case "PUT": return .put
+        case "PATCH": return .patch
+        case "DELETE": return .delete
+        default: return nil
+        }
+    }
+}