starred/CoreStore
1
0
Fork 0
mirror of https://github.com/JohnEstropia/CoreStore.git synced 2026-03-25 02:41:24 +01:00
Code Issues 95 Packages Projects Releases 10 Wiki Activity

pass transaction to ImportableObject methods

Browse Source
This commit is contained in:
John Estropia
2015-08-21 18:19:21 +09:00
parent 2bcf8008c5
commit 1121d44d7b
1 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
CoreStore/Importing Data/BaseDataTransaction+Importing.swift
View File

@@ -31,16 +31,16 @@ public protocol ImportableObject: class {
typealias ImportSource typealias ImportSource
static func shouldImportFromSource(source: ImportSource) -> Bool static func shouldImportFromSource(source: ImportSource, inTransaction transaction: BaseDataTransaction) -> Bool
func didInsertFromImportSource(source: ImportSource) throws func didInsertFromImportSource(source: ImportSource, inTransaction transaction: BaseDataTransaction) throws
func updateFromImportSource(source: ImportSource) throws func updateFromImportSource(source: ImportSource, inTransaction transaction: BaseDataTransaction) throws
} }
public extension ImportableObject { public extension ImportableObject {
static func shouldImportFromSource(source: ImportSource) -> Bool { static func shouldImportFromSource(source: ImportSource, inTransaction transaction: BaseDataTransaction) -> Bool {
return true return true
} }
@@ -55,7 +55,7 @@ public protocol ImportableUniqueObject: ImportableObject {
var uniqueIDValue: UniqueIDType { get set } var uniqueIDValue: UniqueIDType { get set }
static func uniqueIDFromImportSource(source: ImportSource) throws -> UniqueIDType static func uniqueIDFromImportSource(source: ImportSource, inTransaction transaction: BaseDataTransaction) throws -> UniqueIDType
} }
@@ -72,13 +72,13 @@ public extension BaseDataTransaction {
return try autoreleasepool { return try autoreleasepool {
if !T.shouldImportFromSource(source) { if !T.shouldImportFromSource(source, inTransaction: self) {
return nil return nil
} }
let object = self.create(into) let object = self.create(into)
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
return object return object
} }
} }
@@ -99,7 +99,7 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
let object = self.create(into) let object = self.create(into)
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
} }
} }
} }
@@ -123,7 +123,7 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
let object = self.create(into) let object = self.create(into)
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
objects.append(object) objects.append(object)
} }
@@ -143,24 +143,24 @@ public extension BaseDataTransaction {
return try autoreleasepool { return try autoreleasepool {
if !T.shouldImportFromSource(source) { if !T.shouldImportFromSource(source, inTransaction: self) {
return nil return nil
} }
let uniqueIDKeyPath = T.uniqueIDKeyPath let uniqueIDKeyPath = T.uniqueIDKeyPath
let uniqueIDValue = try T.uniqueIDFromImportSource(source) let uniqueIDValue = try T.uniqueIDFromImportSource(source, inTransaction: self)
if let object = self.fetchOne(From(T), Where(uniqueIDKeyPath, isEqualTo: uniqueIDValue)) { if let object = self.fetchOne(From(T), Where(uniqueIDKeyPath, isEqualTo: uniqueIDValue)) {
try object.updateFromImportSource(source) try object.updateFromImportSource(source, inTransaction: self)
return object return object
} }
else { else {
let object = self.create(into) let object = self.create(into)
object.uniqueIDValue = uniqueIDValue object.uniqueIDValue = uniqueIDValue
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
return object return object
} }
} }
@@ -183,12 +183,12 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
if !T.shouldImportFromSource(source) { if !T.shouldImportFromSource(source, inTransaction: self) {
return return
} }
let uniqueIDValue = try T.uniqueIDFromImportSource(source) let uniqueIDValue = try T.uniqueIDFromImportSource(source, inTransaction: self)
mapping[uniqueIDValue] = source mapping[uniqueIDValue] = source
} }
} }
@@ -206,7 +206,7 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
let uniqueIDValue = object.uniqueIDValue let uniqueIDValue = object.uniqueIDValue
try object.updateFromImportSource(mapping.removeValueForKey(uniqueIDValue)!) try object.updateFromImportSource(mapping.removeValueForKey(uniqueIDValue)!, inTransaction: self)
} }
} }
@@ -216,7 +216,7 @@ public extension BaseDataTransaction {
let object = self.create(into) let object = self.create(into)
object.uniqueIDValue = uniqueIDValue object.uniqueIDValue = uniqueIDValue
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
} }
} }
} }
@@ -241,12 +241,12 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
if !T.shouldImportFromSource(source) { if !T.shouldImportFromSource(source, inTransaction: self) {
return return
} }
let uniqueIDValue = try T.uniqueIDFromImportSource(source) let uniqueIDValue = try T.uniqueIDFromImportSource(source, inTransaction: self)
mapping[uniqueIDValue] = source mapping[uniqueIDValue] = source
sortedIDs.append(uniqueIDValue) sortedIDs.append(uniqueIDValue)
} }
@@ -266,7 +266,7 @@ public extension BaseDataTransaction {
try autoreleasepool { try autoreleasepool {
let uniqueIDValue = object.uniqueIDValue let uniqueIDValue = object.uniqueIDValue
try object.updateFromImportSource(mapping.removeValueForKey(uniqueIDValue)!) try object.updateFromImportSource(mapping.removeValueForKey(uniqueIDValue)!, inTransaction: self)
objects[uniqueIDValue] = object objects[uniqueIDValue] = object
} }
} }
@@ -277,7 +277,7 @@ public extension BaseDataTransaction {
let object = self.create(into) let object = self.create(into)
object.uniqueIDValue = uniqueIDValue object.uniqueIDValue = uniqueIDValue
try object.didInsertFromImportSource(source) try object.didInsertFromImportSource(source, inTransaction: self)
objects[uniqueIDValue] = object objects[uniqueIDValue] = object
} }