aboutsummaryrefslogtreecommitdiffhomepage
path: root/Firestore/Source/Remote/FSTDatastore.mm
diff options
context:
space:
mode:
authorGravatar rsgowman <rgowman@google.com>2018-03-21 11:04:40 -0400
committerGravatar GitHub <noreply@github.com>2018-03-21 11:04:40 -0400
commit308acc09bfaf6dabf4b6d5f5e39f33854df8ce34 (patch)
tree3706bbbe40d08569795634fd2f30a07fd348b399 /Firestore/Source/Remote/FSTDatastore.mm
parentd924771453d000e708bd5d239da3bae4feb489ac (diff)
Change CredentialsProvider::TokenListener to use StatusOr<Token> (#945)
* Change CredentialsProvider::TokenListener to use StatusOr Rather than a token plus error code/msg. * Eliminate the concept of an invalid Token Instead, we'll just use StatusOr<Token>. Note that unauthenticated tokens are handled as a special case; they're created via: Token::Unauthenticated() and are otherwise "valid", though attempting to retrieve the raw token on one of these tokens will cause an assertion failure.
Diffstat (limited to 'Firestore/Source/Remote/FSTDatastore.mm')
-rw-r--r--Firestore/Source/Remote/FSTDatastore.mm14
1 files changed, 6 insertions, 8 deletions
diff --git a/Firestore/Source/Remote/FSTDatastore.mm b/Firestore/Source/Remote/FSTDatastore.mm
index e63017a..63499df 100644
--- a/Firestore/Source/Remote/FSTDatastore.mm
+++ b/Firestore/Source/Remote/FSTDatastore.mm
@@ -305,20 +305,18 @@ typedef GRPCProtoCall * (^RPCFactory)(void);
// TODO(mikelehen): We should force a refresh if the previous RPC failed due to an expired token,
// but I'm not sure how to detect that right now. http://b/32762461
_credentials->GetToken(
- /*force_refresh=*/false,
- [self, rpcFactory, errorHandler](Token result, const int64_t error_code,
- const absl::string_view error_msg) {
- NSError *error = util::WrapNSError(error_code, error_msg);
+ /*force_refresh=*/false, [self, rpcFactory, errorHandler](util::StatusOr<Token> result) {
[self.workerDispatchQueue dispatchAsyncAllowingSameQueue:^{
- if (error) {
- errorHandler(error);
+ if (!result.ok()) {
+ errorHandler(util::MakeNSError(result.status()));
} else {
GRPCProtoCall *rpc = rpcFactory();
+ const Token &token = result.ValueOrDie();
[FSTDatastore
prepareHeadersForRPC:rpc
databaseID:&self.databaseInfo->database_id()
- token:(result.user().is_authenticated() ? result.token()
- : absl::string_view())];
+ token:(token.user().is_authenticated() ? token.token()
+ : absl::string_view())];
[rpc start];
}
}];