chore: make FirestoreException factory methods public to allow construction for testing (#477)

BenWhitehead · web-flow · commit 23d54156239e · 2021-01-15T13:30:47.000-05:00
* Expose each factory method at @BetaApi level ensuring no guarantee about api surface * Expose getStatus() at @BetaApi up from package private @internalapi
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkCommitBatch.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkCommitBatch.java
@@ -117,7 +117,7 @@ public List<BatchWriteResult> apply(BatchWriteResponse batchWriteResponse) {
               if (code == Status.OK) {
                 updateTime = Timestamp.fromProto(writeResult.getUpdateTime());
               } else {
-                exception = FirestoreException.serverRejected(code, status.getMessage());
+                exception = FirestoreException.forServerRejection(code, status.getMessage());
               }
               result.add(new BatchWriteResult(updateTime, exception));
             }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkWriterOptions.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/BulkWriterOptions.java
@@ -130,24 +130,24 @@ BulkWriterOptions build() {
       Double maxRate = options.getMaxOpsPerSecond();
 
       if (initialRate != null && initialRate < 1) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             "Value for argument 'initialOpsPerSecond' must be greater than 1, but was: "
                 + initialRate.intValue());
       }
 
       if (maxRate != null && maxRate < 1) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             "Value for argument 'maxOpsPerSecond' must be greater than 1, but was: "
                 + maxRate.intValue());
       }
 
       if (maxRate != null && initialRate != null && initialRate > maxRate) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             "'maxOpsPerSecond' cannot be less than 'initialOpsPerSecond'.");
       }
 
       if (!options.getThrottlingEnabled() && (maxRate != null || initialRate != null)) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             "Cannot set 'initialOpsPerSecond' or 'maxOpsPerSecond' when 'throttlingEnabled' is set to false.");
       }
       return options;
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/CollectionGroup.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/CollectionGroup.java
@@ -82,7 +82,7 @@ public void getPartitions(
                     request.build(), rpcContext.getClient().partitionQueryPagedCallable()));
       } catch (ApiException exception) {
         span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));
-        throw FirestoreException.apiException(exception);
+        throw FirestoreException.forApiException(exception);
       } finally {
         span.end(TraceUtil.END_SPAN_OPTIONS);
       }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/CollectionReference.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/CollectionReference.java
@@ -149,7 +149,7 @@ public Iterable<DocumentReference> listDocuments() {
       response = ApiExceptions.callAndTranslateApiException(future);
     } catch (ApiException exception) {
       span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));
-      throw FirestoreException.apiException(exception);
+      throw FirestoreException.forApiException(exception);
     } finally {
       span.end(TraceUtil.END_SPAN_OPTIONS);
     }
@@ -217,7 +217,8 @@ public DocumentReference apply(WriteResult writeResult) {
   public ApiFuture<DocumentReference> add(Object pojo) {
     Object converted = CustomClassMapper.convertToPlainJavaTypes(pojo);
     if (!(converted instanceof Map)) {
-      throw FirestoreException.invalidState("Can't set a document's data to an array or primitive");
+      throw FirestoreException.forInvalidArgument(
+          "Can't set a document's data to an array or primitive");
     }
     return add((Map<String, Object>) converted);
   }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/DocumentReference.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/DocumentReference.java
@@ -393,7 +393,7 @@ public Iterable<CollectionReference> listCollections() {
                   request.build(), rpcContext.getClient().listCollectionIdsPagedCallable()));
     } catch (ApiException exception) {
       span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));
-      throw FirestoreException.apiException(exception);
+      throw FirestoreException.forApiException(exception);
     } finally {
       span.end(TraceUtil.END_SPAN_OPTIONS);
     }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/DocumentTransform.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/DocumentTransform.java
@@ -75,7 +75,7 @@ private static SortedMap<FieldPath, FieldTransform> extractFromMap(
             transforms.put(path, fieldValue.toProto(path));
           }
         } else {
-          throw FirestoreException.invalidState(
+          throw FirestoreException.forInvalidArgument(
               fieldValue.getMethodName() + " is not supported inside of an array.");
         }
       } else if (value instanceof Map) {
@@ -94,7 +94,7 @@ private static void validateArray(List<Object> values, FieldPath path) {
       Object value = values.get(i);
       path = path.append(FieldPath.of(Integer.toString(i)));
       if (value instanceof FieldValue) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             ((FieldValue) value).getMethodName() + " is not supported inside of an array.");
       } else if (value instanceof Map) {
         extractFromMap((Map<String, Object>) value, path, false);
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreException.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreException.java
@@ -16,7 +16,7 @@
 
 package com.google.cloud.firestore;
 
-import com.google.api.core.InternalApi;
+import com.google.api.core.BetaApi;
 import com.google.api.gax.rpc.ApiException;
 import com.google.cloud.grpc.BaseGrpcServiceException;
 import io.grpc.Status;
@@ -55,7 +55,8 @@ private FirestoreException(IOException exception, boolean retryable) {
    *
    * @return The FirestoreException
    */
-  static FirestoreException invalidState(String message, Object... params) {
+  @BetaApi
+  public static FirestoreException forInvalidArgument(String message, Object... params) {
     return new FirestoreException(String.format(message, params), Status.INVALID_ARGUMENT);
   }
 
@@ -65,8 +66,10 @@ static FirestoreException invalidState(String message, Object... params) {
    *
    * @return The FirestoreException
    */
-  static FirestoreException serverRejected(Status status, String message, Object... params) {
-    return serverRejected(status, null, message, params);
+  @BetaApi
+  public static FirestoreException forServerRejection(
+      Status status, String message, Object... params) {
+    return forServerRejection(status, null, message, params);
   }
 
   /**
@@ -75,7 +78,8 @@ static FirestoreException serverRejected(Status status, String message, Object..
    *
    * @return The FirestoreException
    */
-  static FirestoreException serverRejected(
+  @BetaApi
+  public static FirestoreException forServerRejection(
       Status status, @Nullable Throwable cause, String message, Object... params) {
     return new FirestoreException(String.format(message, params), status, cause);
   }
@@ -85,7 +89,8 @@ static FirestoreException serverRejected(
    *
    * @return The FirestoreException
    */
-  static FirestoreException networkException(IOException exception, boolean retryable) {
+  @BetaApi
+  public static FirestoreException forIOException(IOException exception, boolean retryable) {
     return new FirestoreException(exception, retryable);
   }
 
@@ -94,7 +99,8 @@ static FirestoreException networkException(IOException exception, boolean retrya
    *
    * @return The FirestoreException
    */
-  static FirestoreException apiException(ApiException exception) {
+  @BetaApi
+  public static FirestoreException forApiException(ApiException exception) {
     return new FirestoreException(exception.getMessage(), exception);
   }
 
@@ -103,13 +109,14 @@ static FirestoreException apiException(ApiException exception) {
    *
    * @return The FirestoreException
    */
-  static FirestoreException apiException(ApiException exception, String message) {
+  @BetaApi
+  public static FirestoreException forApiException(ApiException exception, String message) {
     return new FirestoreException(message, exception);
   }
 
-  @InternalApi
+  @BetaApi
   @Nullable
-  Status getStatus() {
+  public Status getStatus() {
     return status;
   }
 }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreOptions.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreOptions.java
@@ -88,7 +88,7 @@ public FirestoreRpc create(@Nonnull FirestoreOptions options) {
       try {
         return new GrpcFirestoreRpc(options);
       } catch (IOException e) {
-        throw FirestoreException.networkException(e, false);
+        throw FirestoreException.forIOException(e, false);
       }
     }
   }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Query.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Query.java
@@ -406,7 +406,7 @@ private Cursor createCursor(List<FieldOrder> order, Object[] fieldValues, boolea
       Value encodedValue = encodeValue(fieldReference, sanitizedValue);
 
       if (encodedValue == null) {
-        throw FirestoreException.invalidState(
+        throw FirestoreException.forInvalidArgument(
             "Cannot use FieldValue.delete() or FieldValue.serverTimestamp() in a query boundary");
       }
       result.addValues(encodedValue);
@@ -1434,7 +1434,7 @@ private Value encodeValue(FieldPath fieldPath, Object value) {
     Value encodedValue =
         UserDataConverter.encodeValue(fieldPath, sanitizedObject, UserDataConverter.ARGUMENT);
     if (encodedValue == null) {
-      throw FirestoreException.invalidState(
+      throw FirestoreException.forInvalidArgument(
           "Cannot use Firestore sentinels in FieldFilter or cursors");
     }
     return encodedValue;
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/TransactionRunner.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/TransactionRunner.java
@@ -236,14 +236,14 @@ public ApiFuture<T> apply(Throwable throwable) {
         } else {
           span.setStatus(TOO_MANY_RETRIES_STATUS);
           final FirestoreException firestoreException =
-              FirestoreException.apiException(
+              FirestoreException.forApiException(
                   apiException, "Transaction was cancelled because of too many retries.");
           return rollbackAndReject(firestoreException);
         }
       } else {
         span.setStatus(TraceUtil.statusFromApiException(apiException));
         final FirestoreException firestoreException =
-            FirestoreException.apiException(
+            FirestoreException.forApiException(
                 apiException, "Transaction failed with non-retryable error");
         return rollbackAndReject(firestoreException);
       }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UpdateBuilder.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UpdateBuilder.java
@@ -172,7 +172,8 @@ private void verifyNotCommitted() {
   public T create(@Nonnull DocumentReference documentReference, @Nonnull Object pojo) {
     Object data = CustomClassMapper.convertToPlainJavaTypes(pojo);
     if (!(data instanceof Map)) {
-      throw FirestoreException.invalidState("Can't set a document's data to an array or primitive");
+      throw FirestoreException.forInvalidArgument(
+          "Can't set a document's data to an array or primitive");
     }
     return performCreate(documentReference, (Map<String, Object>) data);
   }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UserDataConverter.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UserDataConverter.java
@@ -181,7 +181,8 @@ static Value encodeValue(
       }
     }
 
-    throw FirestoreException.invalidState("Cannot convert %s to Firestore Value", sanitizedObject);
+    throw FirestoreException.forInvalidArgument(
+        "Cannot convert %s to Firestore Value", sanitizedObject);
   }
 
   static Object decodeValue(FirestoreRpcContext<?> rpcContext, Value v) {
@@ -222,7 +223,8 @@ static Object decodeValue(FirestoreRpcContext<?> rpcContext, Value v) {
         }
         return outputMap;
       default:
-        throw FirestoreException.invalidState(String.format("Unknown Value Type: %s", typeCase));
+        throw FirestoreException.forInvalidArgument(
+            String.format("Unknown Value Type: %s", typeCase));
     }
   }
 }
diff --git a/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Watch.java b/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Watch.java
@@ -184,7 +184,7 @@ public synchronized void onNext(ListenResponse listenResponse) {
             break;
           case ADD:
             if (WATCH_TARGET_ID != change.getTargetIds(0)) {
-              closeStream(FirestoreException.invalidState("Target ID must be 0x01"));
+              closeStream(FirestoreException.forInvalidArgument("Target ID must be 0x01"));
             }
             break;
           case REMOVE:
@@ -193,7 +193,7 @@ public synchronized void onNext(ListenResponse listenResponse) {
                     ? Status.fromCodeValue(change.getCause().getCode())
                     : Status.CANCELLED;
             closeStream(
-                FirestoreException.serverRejected(
+                FirestoreException.forServerRejection(
                     status, "Backend ended Listen stream: " + change.getCause().getMessage()));
             break;
           case CURRENT:
@@ -204,7 +204,7 @@ public synchronized void onNext(ListenResponse listenResponse) {
             break;
           default:
             closeStream(
-                FirestoreException.invalidState(
+                FirestoreException.forInvalidArgument(
                     "Encountered invalid target change type: " + change.getTargetChangeType()));
         }
 
@@ -247,7 +247,8 @@ && affectsTarget(change.getTargetIdsList(), WATCH_TARGET_ID)) {
         }
         break;
       default:
-        closeStream(FirestoreException.invalidState("Encountered invalid listen response type"));
+        closeStream(
+            FirestoreException.forInvalidArgument("Encountered invalid listen response type"));
         break;
     }
   }
@@ -340,7 +341,7 @@ public void run() {
                   null,
                   throwable instanceof FirestoreException
                       ? (FirestoreException) throwable
-                      : FirestoreException.apiException(
+                      : FirestoreException.forApiException(
                           new ApiException(
                               throwable,
                               GrpcStatusCode.of(getStatus(throwable).getCode()),
diff --git a/google-cloud-firestore/src/test/java/com/google/cloud/firestore/BulkWriterTest.java b/google-cloud-firestore/src/test/java/com/google/cloud/firestore/BulkWriterTest.java
@@ -997,7 +997,7 @@ public void closeSucceedsEvenIfBulkCommitFails() throws Exception {
   public void individualWritesErrorIfBulkCommitFails() throws Exception {
     doReturn(
             ApiFutures.immediateFailedFuture(
-                FirestoreException.serverRejected(
+                FirestoreException.forServerRejection(
                     Status.DEADLINE_EXCEEDED, "Mock batchWrite failed in test")))
         .when(firestoreMock)
         .sendRequest(
@@ -1049,7 +1049,7 @@ public void individualWritesErrorIfBulkCommitFailsWithNonFirestoreException() th
   @Test
   public void retriesWritesWhenBatchWriteFailsWithRetryableError() throws Exception {
     FirestoreException retryableError =
-        FirestoreException.serverRejected(
+        FirestoreException.forServerRejection(
             Status.fromCode(Status.Code.ABORTED), "Mock batchWrite failed in test");
 
     ApiFuture<Void> errorFuture = ApiFutures.immediateFailedFuture(retryableError);
@@ -1077,7 +1077,7 @@ public void failsWritesAfterAllRetryAttemptsFail() throws Exception {
               public ApiFuture<Object> answer(InvocationOnMock mock) {
                 retryAttempts[0]++;
                 return ApiFutures.immediateFailedFuture(
-                    FirestoreException.serverRejected(
+                    FirestoreException.forServerRejection(
                         Status.fromCode(Status.Code.ABORTED), "Mock batchWrite failed in test"));
               }
             })
diff --git a/google-cloud-firestore/src/test/java/com/google/cloud/firestore/QueryTest.java b/google-cloud-firestore/src/test/java/com/google/cloud/firestore/QueryTest.java
@@ -938,7 +938,7 @@ public RunQueryResponse answer(InvocationOnMock invocation) throws Throwable {
                 if (returnError[0]) {
                   returnError[0] = false;
                   return queryResponse(
-                          FirestoreException.serverRejected(
+                          FirestoreException.forServerRejection(
                               Status.DEADLINE_EXCEEDED, "Simulated test failure"),
                           DOCUMENT_NAME + "1",
                           DOCUMENT_NAME + "2")
@@ -998,7 +998,7 @@ public void onCompleted() {
   public void doesNotRetryAfterNonRetryableError() throws Exception {
     doAnswer(
             queryResponse(
-                FirestoreException.serverRejected(
+                FirestoreException.forServerRejection(
                     Status.PERMISSION_DENIED, "Simulated test failure"),
                 DOCUMENT_NAME + "1",
                 DOCUMENT_NAME + "2"))

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ public List<BatchWriteResult> apply(BatchWriteResponse batchWriteResponse) {`
`117`	`117`	`if (code == Status.OK) {`
`118`	`118`	`updateTime = Timestamp.fromProto(writeResult.getUpdateTime());`
`119`	`119`	`} else {`
`120`		`- exception = FirestoreException.serverRejected(code, status.getMessage());`
	`120`	`+ exception = FirestoreException.forServerRejection(code, status.getMessage());`
`121`	`121`	`}`
`122`	`122`	`result.add(new BatchWriteResult(updateTime, exception));`
`123`	`123`	`}`
Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ public void getPartitions(`
`82`	`82`	`request.build(), rpcContext.getClient().partitionQueryPagedCallable()));`
`83`	`83`	`} catch (ApiException exception) {`
`84`	`84`	`span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));`
`85`		`- throw FirestoreException.apiException(exception);`
	`85`	`+ throw FirestoreException.forApiException(exception);`
`86`	`86`	`} finally {`
`87`	`87`	`span.end(TraceUtil.END_SPAN_OPTIONS);`
`88`	`88`	`}`
Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,7 @@ public Iterable<DocumentReference> listDocuments() {`
`149`	`149`	`response = ApiExceptions.callAndTranslateApiException(future);`
`150`	`150`	`} catch (ApiException exception) {`
`151`	`151`	`span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));`
`152`		`- throw FirestoreException.apiException(exception);`
	`152`	`+ throw FirestoreException.forApiException(exception);`
`153`	`153`	`} finally {`
`154`	`154`	`span.end(TraceUtil.END_SPAN_OPTIONS);`
`155`	`155`	`}`
`@@ -217,7 +217,8 @@ public DocumentReference apply(WriteResult writeResult) {`
`217`	`217`	`public ApiFuture<DocumentReference> add(Object pojo) {`
`218`	`218`	`Object converted = CustomClassMapper.convertToPlainJavaTypes(pojo);`
`219`	`219`	`if (!(converted instanceof Map)) {`
`220`		`- throw FirestoreException.invalidState("Can't set a document's data to an array or primitive");`
	`220`	`+ throw FirestoreException.forInvalidArgument(`
	`221`	`+ "Can't set a document's data to an array or primitive");`
`221`	`222`	`}`
`222`	`223`	`return add((Map<String, Object>) converted);`
`223`	`224`	`}`
Original file line number	Diff line number	Diff line change
`@@ -393,7 +393,7 @@ public Iterable<CollectionReference> listCollections() {`
`393`	`393`	`request.build(), rpcContext.getClient().listCollectionIdsPagedCallable()));`
`394`	`394`	`} catch (ApiException exception) {`
`395`	`395`	`span.setStatus(Status.UNKNOWN.withDescription(exception.getMessage()));`
`396`		`- throw FirestoreException.apiException(exception);`
	`396`	`+ throw FirestoreException.forApiException(exception);`
`397`	`397`	`} finally {`
`398`	`398`	`span.end(TraceUtil.END_SPAN_OPTIONS);`
`399`	`399`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@`
`16`	`16`
`17`	`17`	`package com.google.cloud.firestore;`
`18`	`18`
`19`		`-import com.google.api.core.InternalApi;`
	`19`	`+import com.google.api.core.BetaApi;`
`20`	`20`	`import com.google.api.gax.rpc.ApiException;`
`21`	`21`	`import com.google.cloud.grpc.BaseGrpcServiceException;`
`22`	`22`	`import io.grpc.Status;`
`@@ -55,7 +55,8 @@ private FirestoreException(IOException exception, boolean retryable) {`
`55`	`55`	`*`
`56`	`56`	`* @return The FirestoreException`
`57`	`57`	`*/`
`58`		`- static FirestoreException invalidState(String message, Object... params) {`
	`58`	`+ @BetaApi`
	`59`	`+ public static FirestoreException forInvalidArgument(String message, Object... params) {`
`59`	`60`	`return new FirestoreException(String.format(message, params), Status.INVALID_ARGUMENT);`
`60`	`61`	`}`
`61`	`62`
`@@ -65,8 +66,10 @@ static FirestoreException invalidState(String message, Object... params) {`
`65`	`66`	`*`
`66`	`67`	`* @return The FirestoreException`
`67`	`68`	`*/`
`68`		`- static FirestoreException serverRejected(Status status, String message, Object... params) {`
`69`		`- return serverRejected(status, null, message, params);`
	`69`	`+ @BetaApi`
	`70`	`+ public static FirestoreException forServerRejection(`
	`71`	`+ Status status, String message, Object... params) {`
	`72`	`+ return forServerRejection(status, null, message, params);`
`70`	`73`	`}`
`71`	`74`
`72`	`75`	`/**`
`@@ -75,7 +78,8 @@ static FirestoreException serverRejected(Status status, String message, Object..`
`75`	`78`	`*`
`76`	`79`	`* @return The FirestoreException`
`77`	`80`	`*/`
`78`		`- static FirestoreException serverRejected(`
	`81`	`+ @BetaApi`
	`82`	`+ public static FirestoreException forServerRejection(`
`79`	`83`	`Status status, @Nullable Throwable cause, String message, Object... params) {`
`80`	`84`	`return new FirestoreException(String.format(message, params), status, cause);`
`81`	`85`	`}`
`@@ -85,7 +89,8 @@ static FirestoreException serverRejected(`
`85`	`89`	`*`
`86`	`90`	`* @return The FirestoreException`
`87`	`91`	`*/`
`88`		`- static FirestoreException networkException(IOException exception, boolean retryable) {`
	`92`	`+ @BetaApi`
	`93`	`+ public static FirestoreException forIOException(IOException exception, boolean retryable) {`
`89`	`94`	`return new FirestoreException(exception, retryable);`
`90`	`95`	`}`
`91`	`96`
`@@ -94,7 +99,8 @@ static FirestoreException networkException(IOException exception, boolean retrya`
`94`	`99`	`*`
`95`	`100`	`* @return The FirestoreException`
`96`	`101`	`*/`
`97`		`- static FirestoreException apiException(ApiException exception) {`
	`102`	`+ @BetaApi`
	`103`	`+ public static FirestoreException forApiException(ApiException exception) {`
`98`	`104`	`return new FirestoreException(exception.getMessage(), exception);`
`99`	`105`	`}`
`100`	`106`
`@@ -103,13 +109,14 @@ static FirestoreException apiException(ApiException exception) {`
`103`	`109`	`*`
`104`	`110`	`* @return The FirestoreException`
`105`	`111`	`*/`
`106`		`- static FirestoreException apiException(ApiException exception, String message) {`
	`112`	`+ @BetaApi`
	`113`	`+ public static FirestoreException forApiException(ApiException exception, String message) {`
`107`	`114`	`return new FirestoreException(message, exception);`
`108`	`115`	`}`
`109`	`116`
`110`		`- @InternalApi`
	`117`	`+ @BetaApi`
`111`	`118`	`@Nullable`
`112`		`- Status getStatus() {`
	`119`	`+ public Status getStatus() {`
`113`	`120`	`return status;`
`114`	`121`	`}`
`115`	`122`	`}`
Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ public FirestoreRpc create(@Nonnull FirestoreOptions options) {`
`88`	`88`	`try {`
`89`	`89`	`return new GrpcFirestoreRpc(options);`
`90`	`90`	`} catch (IOException e) {`
`91`		`- throw FirestoreException.networkException(e, false);`
	`91`	`+ throw FirestoreException.forIOException(e, false);`
`92`	`92`	`}`
`93`	`93`	`}`
`94`	`94`	`}`