empathicqubit/Signal-Android
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Use readBodyBytes for correct exceptions.

Browse source
This commit is contained in:
Alan Evans 2020-04-07 16:42:02 -03:00 • committed by Greyson Parrelli
parent 8e13403cca
commit e2d3a43593
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
libsignal/service/src/main/java/org/whispersystems/signalservice/internal/push/PushServiceSocket.java
View file

@ -828,7 +828,7 @@ public class PushServiceSocket {
throw new IOException("Missing body!");
}
return StorageManifest.parseFrom(response.bytes());
return StorageManifest.parseFrom(readBodyBytes(response));
}
public StorageManifest getStorageManifestIfDifferentVersion(String authToken, long version) throws IOException {
@ -838,7 +838,7 @@ public class PushServiceSocket {
throw new IOException("Missing body!");
}
return StorageManifest.parseFrom(response.bytes());
return StorageManifest.parseFrom(readBodyBytes(response));
}
public StorageItems readStorageItems(String authToken, ReadOperation operation) throws IOException {
@ -848,7 +848,7 @@ public class PushServiceSocket {
throw new IOException("Missing body!");
}
return StorageItems.parseFrom(response.bytes());
return StorageItems.parseFrom(readBodyBytes(response));
}
public Optional<StorageManifest> writeStorageContacts(String authToken, WriteOperation writeOperation) throws IOException {
@ -1733,7 +1733,7 @@ public class PushServiceSocket {
null);
try {
return Group.parseFrom(response.bytes());
return Group.parseFrom(readBodyBytes(response));
} catch (InvalidProtocolBufferException e) {
throw new IOException("Cannot read protobuf", e);
}
@ -1748,7 +1748,7 @@ public class PushServiceSocket {
null);
try {
return AvatarUploadAttributes.parseFrom(response.bytes());
return AvatarUploadAttributes.parseFrom(readBodyBytes(response));
} catch (InvalidProtocolBufferException e) {
throw new IOException("Cannot read protobuf", e);
}
@ -1763,7 +1763,7 @@ public class PushServiceSocket {
protobufRequestBody(groupChange));
try {
return GroupChange.parseFrom(response.bytes());
return GroupChange.parseFrom(readBodyBytes(response));
} catch (InvalidProtocolBufferException e) {
throw new IOException("Cannot read protobuf", e);
}
@ -1778,7 +1778,7 @@ public class PushServiceSocket {
null);
try {
return GroupChanges.parseFrom(response.bytes());
return GroupChanges.parseFrom(readBodyBytes(response));
} catch (InvalidProtocolBufferException e) {
throw new IOException("Cannot read protobuf", e);
}