renamed folder; added crud methods for single object;

Author: Roman Kyrylenko

DBClient.podspec

@@ -1,6 +1,6 @@
 Pod::Spec.new do |s|
   s.name             = "DBClient"
-  s.version          = "0.1"
+  s.version          = "0.1.1"
   s.requires_arc = true
   s.summary          = "CoreData & Realm wrapper written on Swift"
   s.homepage         = ""
@@ -11,19 +11,19 @@ Pod::Spec.new do |s|
   s.homepage = 'https://yalantis.com/'
 
   s.ios.deployment_target = "10.0"
-  s.source_files = ['DBClient/Core/**/*.{swift}']
+  s.source_files = ['Source/Core/*']
   s.dependency "Bolts-Swift", "~> 1.3.0"
   s.frameworks = ['Foundation']
 
   s.default_subspec = "CoreData"
 
   s.subspec "CoreData" do  |spec|
-    spec.source_files = ['DBClient/CoreData/*']
+    spec.source_files = ['CoreData/*']
     spec.frameworks = ['CoreData']
   end
 
   s.subspec "Realm" do  |spec|
-    spec.source_files = ['DBClient/Realm/*']
+    spec.source_files = ['Realm/*']
     spec.dependency "RealmSwift", "~> 2.1.1"
   end
 

DBClient/Core/DBClient.swift renamed to Source/Core/DBClient.swift

@@ -104,4 +104,47 @@ public extension DBClient {
     return Task(nil)
   }
 
+  /**
+   Deletes object from database.
+
+   - Parameter object: object to be deleted
+
+   - Returns: `Task` with deleted object or appropriate error in case of failure.
+   */
+  func delete<T: Stored>(_ object: T) -> Task<T> {
+    return convertArrayTaskToSingleObject(delete([object]))
+  }
+
+  /**
+   Updates changed performed with object to database.
+
+   - Parameter object: object to be updated
+
+   - Returns: `Task` with updated object or appropriate error in case of failure.
+   */
+  func update<T: Stored>(_ object: T) -> Task<T> {
+    return convertArrayTaskToSingleObject(update([object]))
+  }
+
+  /**
+   Saves object to database.
+
+   - Parameter object: object to be saved
+
+   - Returns: `Task` with saved object or appropriate error in case of failure.
+   */
+  func save<T: Stored>(_ object: T) -> Task<T> {
+    return convertArrayTaskToSingleObject(save([object]))
+  }
+
+  private func convertArrayTaskToSingleObject<T>(_ task: Task<[T]>) -> Task<T> {
+    if let objects = task.result, let object = objects.first {
+      return Task<T>(object)
+    } else if let error = task.error {
+      return Task<T>(error: error)
+    } else { // no objects returned
+      return Task<T>.cancelledTask()
+    }
+  }
+
 }

DBClient/Core/DatabaseError.swift renamed to Source/Core/DatabaseError.swift

@@ -120,5 +120,5 @@ extension RealmDBClient: DBClient {
 //    return RealmObservable(request: request, realm: realm)
     return RequestObservable(request: request)
   }
-  
+
 }

DBClient/Core/FetchRequest.swift renamed to Source/Core/FetchRequest.swift

@@ -37,7 +37,7 @@ public class RealmObservable<T: Object>: RequestObservable<T> {
     }
   }
 
-  public override func stopObserving() {
+  public func stopObserving() {
     notificationToken = nil
   }