diff --git a/LeStorage/ApiCallCollection.swift b/LeStorage/ApiCallCollection.swift index afe796e..3ded39e 100644 --- a/LeStorage/ApiCallCollection.swift +++ b/LeStorage/ApiCallCollection.swift @@ -188,7 +188,6 @@ actor ApiCallCollection: SomeCallCollection { /// Reschedule the execution of API calls fileprivate func _waitAndExecuteApiCalls() async { -// Logger.log("\(T.resourceName()) > RESCHED") guard !self._isExecutingCalls, self.storeCenter.forceNoSynchronization == false else { return } guard self.items.isNotEmpty else { return } @@ -419,6 +418,9 @@ actor ApiCallCollection: SomeCallCollection { /// Executes an API call /// For POST requests, potentially copies additional data coming from the server during the insert fileprivate func _executeApiCalls(_ apiCalls: [ApiCall]) async throws -> [OperationResult] { + +// Logger.log("/// \(T.resourceName()) > Start \(apiCalls.count) calls execution...") + let results = try await self.storeCenter.execute(apiCalls: apiCalls) for result in results { switch result.status { diff --git a/LeStorage/Services.swift b/LeStorage/Services.swift index 107d520..62a8234 100644 --- a/LeStorage/Services.swift +++ b/LeStorage/Services.swift @@ -91,11 +91,11 @@ public class Services { if let response = task.1 as? HTTPURLResponse { let statusCode = response.statusCode - print("\(debugURL) ended, status code = \(statusCode)") switch statusCode { case 200..<300: // success try await self.storeCenter.deleteApiCallById(type: T.self, id: apiCall.id) default: // error + print("\(debugURL) ended, status code = \(statusCode)") Logger.log( "Failed Run \(request.httpMethod ?? "") \(request.url?.absoluteString ?? "")") let errorString: String = String(data: task.0, encoding: .utf8) ?? "" @@ -142,11 +142,11 @@ public class Services { if let response = task.1 as? HTTPURLResponse { let statusCode = response.statusCode - print("\(debugURL) ended, status code = \(statusCode)") switch statusCode { case 200..<300: // success break default: // error + print("\(debugURL) ended, status code = \(statusCode)") Logger.log( "Failed Run \(request.httpMethod ?? "") \(request.url?.absoluteString ?? "")") let errorString: String = String(data: task.0, encoding: .utf8) ?? "" @@ -280,7 +280,6 @@ public class Services { if let response = task.1 as? HTTPURLResponse { let statusCode = response.statusCode - print("\(String(describing: T.self))> \(debugURL) ended, status code = \(statusCode)") switch statusCode { case 200..<300: // success @@ -295,7 +294,7 @@ public class Services { default: if let message = result.message { let type = String(describing: T.self) - print("\(type) - \(result.apiCallId): \(result.status) > \(message)") + print("*** \(type) - \(result.data?.stringId ?? ""): \(result.status) > \(message)") } rescheduleApiCalls = true break @@ -303,6 +302,7 @@ public class Services { } default: // error + print("\(String(describing: T.self))> \(debugURL) ended, status code = \(statusCode)") Logger.log( "Failed Run \(request.httpMethod ?? "") \(request.url?.absoluteString ?? "")") let errorString: String = String(data: task.0, encoding: .utf8) ?? "" @@ -408,6 +408,11 @@ public class Services { storeId: apiCall.data?.getStoreId()) } +// let posts = apiCalls.filter({ $0.method == .post }) +// for post in posts { +// print("POST \(T.resourceName()): id = \(post.dataId ?? "")") +// } + let payload = SyncPayload(operations: operations, deviceId: self.storeCenter.deviceId()) request.httpBody = try JSON.encoder.encode(payload) @@ -463,12 +468,12 @@ public class Services { if let response = task.1 as? HTTPURLResponse { let statusCode = response.statusCode - print("\(debugURL) ended, status code = \(statusCode)") switch statusCode { case 200..<300: // success return task.0 // success(task.0) default: // error + print("\(debugURL) ended, status code = \(statusCode)") Logger.log( "Failed Run \(request.httpMethod ?? "") \(request.url?.absoluteString ?? "")") let errorString: String = String(data: task.0, encoding: .utf8) ?? ""