接上一篇文章的.filterSuccess(disposeBag: disposeBag, target: target)的作用
直接上代碼
import RxSwift
import Moya
import ObjectMapper
import SwiftyJSON
import Alamofire
//擴(kuò)展Moya
extension ObservableType where E == Response {
func filterSuccess(disposeBag:DisposeBag,target:MultiTarget) -> Observable<E> {
return flatMap { (response) -> Observable<E> in
guard 200 ... 299 ~= response.statusCode else{
return Observable.just(response)
}
let json = JSON(data: response.data).dictionaryValue
guard let code = json["code"]?.intValue else{
return Observable.just(response)
}
//處理過期(過期的code是后臺(tái)定好的)
guard code == ErrorCode.sys_tokenExpired.rawValue else{
return Observable.just(response)
}
//緩存過期是請(qǐng)求的target
UserManager.shared.needResendTarget = target
guard let target = UserManager.shared.needResendTarget else{
fatalError("沒有target")
}
//更新token
let updateToken = MineServices().updateToken()
//替換本地的token
updateToken.drive(onNext: { (json) in
let token = json.dictionaryValue["data"]?.dictionaryValue["token"]?.stringValue
UserManager.shared.loginInfo.token = token
UserManager.shared.updateLocalToken(json.dictionaryValue["data"]?.dictionaryValue["token"]?.stringValue ?? "")
}).disposed(by: disposeBag)
let updateTokenSuccess = updateToken.map{$0.dictionaryValue["code"]?.intValue == 0}
//利用flatMapLatest把上一次緩存的target發(fā)送出去
let responses = updateTokenSuccess.asObservable().flatMapLatest({ _ -> Observable<Response> in
return MyProvider.rx.request(target).asObservable()
})
return responses
}
}
}
大公告成吹榴,主要思路就是發(fā)現(xiàn)token過期后去更新token然后再去請(qǐng)求上一次的請(qǐng)求然后返回respone后面就可以繼續(xù)對(duì)response進(jìn)行處理
喜歡就給點(diǎn)個(gè)贊吧糯景!