API

API.swift

public struct API<T: TargetType> {

    fileprivate var provider: RxMoyaProvider<T> = RxMoyaProvider(plugins: [CachingPlugin()], trackInflights: true)
    
    private func request(_ endpoint: T) -> Observable<Response> {
        return provider.request(endpoint).asObservable()
    }

    public func request<O: JSONDecodable>(_ endpoint: T) -> Observable<O> {
        return provider.request(endpoint).asObservable().mapObject()
    }
    
    public func request<O: JSONDecodable>(_ endpoint: T) -> Observable<[O]> {
        return provider.request(endpoint).asObservable().mapObject()
    }
}

extension API where T: CachableTarget {
    
    public func provide<O: JSONDecodable>(_ endpoint: T) -> Observable<O> {
        let network: Observable<O> = self.request(endpoint)
        
        return self.cache(endpoint)
            .concat(network)
    }
    
    public func provide<O: JSONDecodable>(_ endpoint: T) -> Observable<[O]> {
        let network: Observable<[O]> = self.request(endpoint)
        
        return self.cache(endpoint)
            .concat(network)
    }
    
    public func cache<O: JSONDecodable>(_ endpoint: T) -> Observable<[O]> {
        let cache = CacheStorage(cacheKey: endpoint.cacheKey)
        
        guard let readObject: [O] = cache.read() else {
            return Observable.empty()
        }
        
        return Observable.just(readObject)
    }
    
    public func cache<O: JSONDecodable>(_ endpoint: T) -> Observable<O> {
        let cache = CacheStorage(cacheKey: endpoint.cacheKey)
        
        guard let readObject: O = cache.read() else {
            return Observable.empty()
        }
        
        return Observable.just(readObject)
    }
}