Releases/v0.3.1 (#28)

## Fixes

* fix: Manually-paused uploads don't resume again (#27)



Co-authored-by: Emily Dixon <edixon@mux.com>
Co-authored-by: GitHub <noreply@github.com>

Author: daytime-em

Mux-Upload-SDK.podspec

@@ -1,7 +1,7 @@
 Pod::Spec.new do |s|
   s.name             = 'Mux-Upload-SDK'
   s.module_name      = 'MuxUploadSDK'
-  s.version          = '0.3.0'
+  s.version          = '0.3.1'
   s.summary          = 'Upload video to Mux.'
   s.description      = 'A library for uploading video to Mux. Similar to UpChunk, but for iOS.'
 

Sources/MuxUploadSDK/PublicAPI/MuxUpload.swift

@@ -173,7 +173,7 @@ public final class MuxUpload : Hashable, Equatable {
             MuxUploadSDK.logger?.warning("start() called but upload is already in progress")
             fileWorker?.addDelegate(
                 withToken: id,
-                InternalUploaderDelegate { [weak self] state in self?.handleStateUpdate(state) }
+                InternalUploaderDelegate { [self] state in handleStateUpdate(state) }
             )
             fileWorker?.start()
             return

Sources/MuxUploadSDK/PublicAPI/Version.swift

@@ -13,7 +13,7 @@ public struct Version {
   /// Minor version.
   public static let minor = 3
   /// Revision number.
-  public static let revision = 0
+  public static let revision = 1
 
   /// String form of the version number.
   public static let versionString = "\(major).\(minor).\(revision)"

Sources/MuxUploadSDK/Upload/ChunkedFileUploader.swift

@@ -22,7 +22,6 @@ class ChunkedFileUploader {
     private var currentWorkTask: Task<(), Never>? = nil
     private var _currentState: InternalUploadState = .ready
     private var overallProgress: Progress = Progress()
-    private var lastSeenUpdate: InternalUploadState? = nil
     private var lastReadCount: UInt64 = 0
     private let reporter = Reporter()
 
@@ -121,20 +120,17 @@ class ChunkedFileUploader {
                 notifyStateFromWorker(.success(success))
             } catch {
                 file.close()
-                if let lastUpdate = lastSeenUpdate {
-                    switch lastUpdate {
-                    case .uploading(let update): do {
-                        if lastReadCount > 0 {
-                            lastReadCount = UInt64(update.progress.completedUnitCount)
-                        }
-                    }
-                    default: break
+                if error is CancellationError {
+                    MuxUploadSDK.logger?.debug("Task finished due to cancellation in state \(String(describing: self.currentState))")
+                    if case let .uploading(update) = self.currentState {
+                        self._currentState = .paused(update)
                     }
+                } else {
+                    MuxUploadSDK.logger?.debug("Task finished due to error in state \(String(describing: self.currentState))")
+                    let uploadError = InternalUploaderError(reason: error, lastByte: lastReadCount)
+                    notifyStateFromWorker(.failure(uploadError))
                 }
-                let uploadError = InternalUploaderError(reason: error, lastByte: lastReadCount)
-                notifyStateFromWorker(.failure(uploadError))
             }
-            
         }
         currentWorkTask = task
     }

Sources/MuxUploadSDK/Upload/UploadPersistence.swift

@@ -27,7 +27,8 @@ class UploadPersistence {
                 try remove(entryAtAbsUrl: upload.uploadURL)
             }
         } catch {
-            MuxUploadSDK.logger?.critical("Swallowed error writing to UploadPersistence! Error below:\n\(error.localizedDescription)")
+            // This makes a lot of noise on the emulator, but might be worth logging if you're having issues around here
+            //MuxUploadSDK.logger?.critical("Swallowed error writing to UploadPersistence! Error below:\n\(error.localizedDescription)")
         }
     }
 
@@ -81,8 +82,6 @@ class UploadPersistence {
 
     func maybeOpenCache() throws {
         if cache == nil {
-            MuxUploadSDK.logger?.info("Had to populate write-through cache")
-            
             try self.uploadsFile.maybeOpenCache()
             self.cache = try uploadsFile.readContents().asDictionary()
             try cleanUpOldEntries() // Obligatory
@@ -207,7 +206,6 @@ fileprivate struct UploadsFileImpl : UploadsFile {
     func maybeOpenCache() throws {
         let dir = fileURL.deletingLastPathComponent()
         if !FileManager.default.fileExists(atPath: dir.path) {
-            MuxUploadSDK.logger?.info("Had to create temp dir")
             try FileManager.default.createDirectory(atPath: dir.path, withIntermediateDirectories: true)
         }