mirror of
https://github.com/AsamK/signal-cli
synced 2025-08-29 10:30:38 +00:00
parent
39c4cf24b8
commit
0001a9b300
1 changed files with 10 additions and 1 deletions
|
@ -2240,7 +2240,16 @@ public class Manager implements Closeable {
|
||||||
try (var attachmentAsStream = retrieveAttachmentAsStream(groupsMessage.asPointer(), tmpFile)) {
|
try (var attachmentAsStream = retrieveAttachmentAsStream(groupsMessage.asPointer(), tmpFile)) {
|
||||||
var s = new DeviceGroupsInputStream(attachmentAsStream);
|
var s = new DeviceGroupsInputStream(attachmentAsStream);
|
||||||
DeviceGroup g;
|
DeviceGroup g;
|
||||||
while ((g = s.read()) != null) {
|
while (true) {
|
||||||
|
try {
|
||||||
|
g = s.read();
|
||||||
|
} catch (IOException e) {
|
||||||
|
logger.warn("Sync groups contained invalid group, ignoring: {}", e.getMessage());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if (g == null) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
var syncGroup = account.getGroupStore().getOrCreateGroupV1(GroupId.v1(g.getId()));
|
var syncGroup = account.getGroupStore().getOrCreateGroupV1(GroupId.v1(g.getId()));
|
||||||
if (syncGroup != null) {
|
if (syncGroup != null) {
|
||||||
if (g.getName().isPresent()) {
|
if (g.getName().isPresent()) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue