|
|
|
@ -25,23 +25,21 @@ extension Config { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
class UserManager { |
|
|
|
private class EnjinUserManager { |
|
|
|
static let shared = UserManager() |
|
|
|
static let shared = EnjinUserManager() |
|
|
|
|
|
|
|
|
|
|
|
private init() { |
|
|
|
private init() { |
|
|
|
} |
|
|
|
} |
|
|
|
private var config = Config() |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private var config = Config() |
|
|
|
private let graphqlClient: ApolloClient = { |
|
|
|
private let graphqlClient: ApolloClient = { |
|
|
|
let client = URLSessionClient() |
|
|
|
let provider = InterceptorProviderForAuthorization(client: EnjinProvider.client, store: EnjinProvider.store) |
|
|
|
let cache = InMemoryNormalizedCache() |
|
|
|
|
|
|
|
let store = ApolloStore(cache: cache) |
|
|
|
|
|
|
|
let provider = InterceptorProviderForAuthorization(client: client, store: store) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let transport = RequestChainNetworkTransport(interceptorProvider: provider, endpointURL: Constants.enjinApiUrl) |
|
|
|
let transport = RequestChainNetworkTransport(interceptorProvider: provider, endpointURL: Constants.enjinApiUrl) |
|
|
|
return ApolloClient(networkTransport: transport, store: store) |
|
|
|
|
|
|
|
|
|
|
|
return ApolloClient(networkTransport: transport, store: EnjinProvider.store) |
|
|
|
}() |
|
|
|
}() |
|
|
|
|
|
|
|
|
|
|
|
enum UserManagerError: Error { |
|
|
|
enum EnjinUserManagerError: Error { |
|
|
|
case fetchAccessTokenFailure |
|
|
|
case fetchAccessTokenFailure |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -59,7 +57,7 @@ class UserManager { |
|
|
|
if let accessToken = oauth.accessTokens?.compactMap({ $0 }).first { |
|
|
|
if let accessToken = oauth.accessTokens?.compactMap({ $0 }).first { |
|
|
|
return accessToken |
|
|
|
return accessToken |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
throw UserManagerError.fetchAccessTokenFailure |
|
|
|
throw EnjinUserManagerError.fetchAccessTokenFailure |
|
|
|
} |
|
|
|
} |
|
|
|
}.get { accessToken in |
|
|
|
}.get { accessToken in |
|
|
|
self.config.accessToken = accessToken |
|
|
|
self.config.accessToken = accessToken |
|
|
|
@ -165,7 +163,7 @@ struct FallbackJSONResponseParsingInterceptor: ApolloInterceptor { |
|
|
|
private func parseResult<Data>(from response: GraphQLResponse<Data>, cachePolicy: CachePolicy) throws -> GraphQLResult<Data> { |
|
|
|
private func parseResult<Data>(from response: GraphQLResponse<Data>, cachePolicy: CachePolicy) throws -> GraphQLResult<Data> { |
|
|
|
switch cachePolicy { |
|
|
|
switch cachePolicy { |
|
|
|
case .fetchIgnoringCacheCompletely: |
|
|
|
case .fetchIgnoringCacheCompletely: |
|
|
|
// There is no cache, so we don't need to get any info on dependencies. Use fast parsing. |
|
|
|
// There is no cache, so we don't need to get any info on dependencies. Use fast parsing. |
|
|
|
return try response.parseResultFast() |
|
|
|
return try response.parseResultFast() |
|
|
|
default: |
|
|
|
default: |
|
|
|
let (parsedResult, _) = try response.parseResult(cacheKeyForObject: self.cacheKeyForObject) |
|
|
|
let (parsedResult, _) = try response.parseResult(cacheKeyForObject: self.cacheKeyForObject) |
|
|
|
@ -175,7 +173,7 @@ struct FallbackJSONResponseParsingInterceptor: ApolloInterceptor { |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
class UserManagementInterceptor: ApolloInterceptor { |
|
|
|
class EnjinUserManagementInterceptor: ApolloInterceptor { |
|
|
|
|
|
|
|
|
|
|
|
enum UserError: Error { |
|
|
|
enum UserError: Error { |
|
|
|
case noUserLoggedIn |
|
|
|
case noUserLoggedIn |
|
|
|
@ -193,7 +191,7 @@ class UserManagementInterceptor: ApolloInterceptor { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
let performAuthorizeEnjinUser: () -> Void = { |
|
|
|
let performAuthorizeEnjinUser: () -> Void = { |
|
|
|
let promise = UserManager.shared.enjinAuthorize() |
|
|
|
let promise = EnjinUserManager.shared.enjinAuthorize() |
|
|
|
promise.done { accessToken in |
|
|
|
promise.done { accessToken in |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
}.catch { error in |
|
|
|
}.catch { error in |
|
|
|
@ -211,9 +209,9 @@ class UserManagementInterceptor: ApolloInterceptor { |
|
|
|
if let accessToken = promise.value { |
|
|
|
if let accessToken = promise.value { |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
} else if promise.isPending { |
|
|
|
} else if promise.isPending { |
|
|
|
//NOTE: wait until access token resolved |
|
|
|
//NOTE: wait until access token resolved |
|
|
|
let block: () -> Void = { |
|
|
|
let block: () -> Void = { |
|
|
|
guard let accessToken = UserManager.shared.accessToken else { return } |
|
|
|
guard let accessToken = EnjinUserManager.shared.accessToken else { return } |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
addTokenAndProceed(accessToken, to: request, chain: chain, response: response, completion: completion) |
|
|
|
} |
|
|
|
} |
|
|
|
Self.pending.append(block) |
|
|
|
Self.pending.append(block) |
|
|
|
@ -245,7 +243,7 @@ class UserManagementInterceptor: ApolloInterceptor { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
guard let token = UserManager.shared.accessToken else { |
|
|
|
guard let token = EnjinUserManager.shared.accessToken else { |
|
|
|
authorizeEnjinUser() |
|
|
|
authorizeEnjinUser() |
|
|
|
return |
|
|
|
return |
|
|
|
} |
|
|
|
} |
Krypto Pank
3 years ago