-
Notifications
You must be signed in to change notification settings - Fork 731
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1f4048b
commit e7daf86
Showing
14 changed files
with
714 additions
and
77 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,106 @@ | ||
| import Foundation | ||
|
|
||
| public protocol CacheKeyResolver { | ||
| func cacheKey(for: [String: Any]) -> CacheKey? | ||
| } | ||
|
|
||
| public class CacheTransaction { | ||
| let objectFactory: SchemaTypeFactory.Type | ||
| let keyResolver: CacheKeyResolver | ||
| private(set) var errors: [CacheError] = [] | ||
| private var fetchedObjects: [CacheKey: Object] = [:] | ||
|
|
||
| init( | ||
| objectFactory: SchemaTypeFactory.Type, | ||
| keyResolver: CacheKeyResolver | ||
| ) { | ||
| self.objectFactory = objectFactory | ||
| self.keyResolver = keyResolver | ||
| } | ||
|
|
||
| func object(withKey key: CacheKey) -> Object? { | ||
| fetchedObjects[key] // TODO: if not fetched yet, fetch from store | ||
| } | ||
|
|
||
| func object(withData data: [String: Any]) -> Object { | ||
| let cacheKey = keyResolver.cacheKey(for: data) | ||
|
|
||
| if let cacheKey = cacheKey, let object = fetchedObjects[cacheKey] { | ||
| return object | ||
| // TODO: should merge data objects if needed? | ||
| } | ||
|
|
||
| guard let typename = data["__typename"] as? String, | ||
| let type = objectFactory.objectType(forTypename: typename) else { | ||
| fatalError() | ||
| } | ||
|
|
||
| let object = type.init(transaction: self, data: data) | ||
| if let cacheKey = cacheKey { | ||
| fetchedObjects[cacheKey] = object | ||
| } | ||
|
|
||
| return object | ||
| } | ||
|
|
||
| func log(_ error: CacheError) { | ||
| errors.append(error) | ||
| } | ||
|
|
||
| func log(_ error: Error) { | ||
| // TODO | ||
| } | ||
|
|
||
| // func interface<T: Interface>(withData data: [String: Any]) -> T { | ||
| // return T.init(object: object(withData: data)) | ||
| // } | ||
| } | ||
|
|
||
| struct CacheError: Error, Equatable { | ||
| enum Reason: Error { | ||
| case unrecognizedCacheData(_ data: Any, forType: Any.Type) | ||
| case invalidObjectType(_ type: Object.Type, forExpectedType: Cacheable.Type) | ||
| case invalidValue(_ value: Cacheable?, forCovariantFieldOfType: ObjectType.Type) | ||
| case objectNotFound(forCacheKey: CacheKey) | ||
| } | ||
|
|
||
| enum `Type` { | ||
| case read, write | ||
| } | ||
|
|
||
| let reason: Reason | ||
| let type: Type | ||
| let field: String | ||
| let object: ObjectType? | ||
|
|
||
| var message: String { | ||
| switch self.reason { | ||
| case let .unrecognizedCacheData(data, forType: type): | ||
| return "Cache data '\(data)' was unrecognized for conversion to type '\(type)'." | ||
|
|
||
| case let .invalidObjectType(type, forExpectedType: expectedType): | ||
| switch expectedType { | ||
| case is Interface.Type: | ||
| return "Object of type '\(type)' does not implement interface '\(expectedType)'." | ||
| case is AnyUnion.Type: | ||
| return "Object of type '\(type)' is not a valid type for union '\(expectedType)'." | ||
| default: | ||
| return "Object of type '\(type)' is not a valid type for '\(expectedType)'." | ||
| } | ||
|
|
||
| case let .invalidValue(value, forCovariantFieldOfType: fieldType): | ||
| return """ | ||
| Value '\(value ?? "nil")' is not a valid value for covariant field '\(field)'. | ||
| Object of type '\(Swift.type(of: object))' expects value of type '\(fieldType)'. | ||
| """ | ||
|
|
||
| case let .objectNotFound(forCacheKey: key): | ||
| return "Object with cache key \(key.key) was not found in the cache." | ||
|
|
||
| } | ||
| } | ||
|
|
||
| static func ==(lhs: CacheError, rhs: CacheError) -> Bool { | ||
| lhs.message == rhs.message | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| /// A type that can be the value of a `@CacheField` property. In other words, a `Cacheable` type | ||
| /// can be the value of a field on an `Object` or `Interface` | ||
| /// | ||
| /// # Conforming Types: | ||
| /// - `Object` | ||
| /// - `Interface` | ||
| /// - `ScalarType` (`String`, `Int`, `Bool`, `Float`) | ||
| /// - `CustomScalarType` | ||
| /// - `GraphQLEnum` (via `CustomScalarType`) | ||
| public protocol Cacheable { | ||
| static func value(with cacheData: Any, in transaction: CacheTransaction) throws -> Self | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| public protocol SchemaTypeFactory { | ||
| static func objectType(forTypename __typename: String) -> Object.Type? | ||
| } |
Oops, something went wrong.