initial work

Author: donnywals

Sources/TUSKit/Files.swift

@@ -157,6 +157,37 @@ final class Files {
         }
     }
 
+    @available(iOS 13.4, *)
+    func streamingData(_ dataGenerator: () -> Data?, id: UUID, preferredFileExtension: String? = nil) throws -> URL {
+        try queue.sync {
+            try makeDirectoryIfNeeded()
+            
+            let fileName: String
+            if let fileExtension = preferredFileExtension {
+                fileName = id.uuidString + fileExtension
+            } else {
+                fileName = id.uuidString
+            }
+            
+            let targetLocation = storageDirectory.appendingPathComponent(fileName)
+            if !FileManager.default.fileExists(atPath: targetLocation.path) {
+                FileManager.default.createFile(atPath: targetLocation.path, contents: nil)
+            }
+            
+            let destinationHandle = try FileHandle(forWritingTo: targetLocation)
+            defer {
+                try? destinationHandle.close()
+            }
+            
+            while let data = dataGenerator() {
+                guard !data.isEmpty else { throw FilesError.dataIsEmpty }
+                try destinationHandle.write(contentsOf: data)
+            }
+            
+            return targetLocation
+        }
+    }
+    
     /// Removes metadata and its related file from disk
     /// - Parameter metaData: The metadata description
     /// - Throws: Any error from FileManager when removing a file.

Sources/TUSKit/Tasks/UploadDataTask.swift

@@ -182,9 +182,25 @@ final class UploadDataTask: NSObject, IdentifiableTask {
 
         // Can't use switch with #available :'(
         let data: Data
-        if let range = self.range, #available(iOS 13.0, macOS 10.15, *) { // Has range, for newer versions
-            try fileHandle.seek(toOffset: UInt64(range.startIndex))
-            data = fileHandle.readData(ofLength: range.count)
+        if let range = self.range, #available(iOS 13.4, macOS 10.15, *) { // Has range, for newer versions
+            var offset = range.startIndex
+            
+            return try files.streamingData({
+                autoreleasepool {
+                    do {
+                        let chunkSize = min(1024 * 1024 * 500, range.endIndex - offset)
+                        try fileHandle.seek(toOffset: UInt64(offset))
+                        guard offset < range.endIndex else { return nil }
+                        
+                        let data = fileHandle.readData(ofLength: chunkSize)
+                        print("read data of size \(data.count) at offset \(offset)")
+                        offset += chunkSize
+                        return data
+                    } catch {
+                        return nil
+                    }
+                }
+            }, id: metaData.id, preferredFileExtension: "uploadData")
         } else if let range = self.range { // Has range, for older versions
             fileHandle.seek(toFileOffset: UInt64(range.startIndex))
             data = fileHandle.readData(ofLength: range.count)

TUSKitExample/TUSKitExample/Screens/Upload/RowViews/ProgressRowView.swift

@@ -96,8 +96,8 @@ struct ProgressRowView: View {
             UploadActionImage(icon: .pause)
         }
 
-        DestructiveButton(title: showTitle ? "Remove" : nil) {
-            tusWrapper.clearUpload(id: key)
-        }
+//        DestructiveButton(title: showTitle ? "Remove" : nil) {
+//            tusWrapper.clearUpload(id: key)
+//        }
     }
 }

TUSKitExample/TUSKitExample/Screens/Upload/UploadsListView.swift

@@ -117,8 +117,6 @@ extension UploadsListView {
 
 
     // MARK: - Records List View
-    
-    
     @ViewBuilder
     private func uploadRecordsListView(items: [UUID: UploadStatus]) -> some View {
         ScrollView {
@@ -134,6 +132,7 @@ extension UploadsListView {
                             case .uploaded(let url):
                                 UploadedRowView(key: idx.key, url: url)
                             case .failed(let error):
+                                let _ = print(error)
                                 FailedRowView(key: idx.key, error: error)
                         }
                     }