|
|
@ -1,10 +1,10 @@
|
|
|
|
#import "OWSSyncOpenGroupsMessage.h"
|
|
|
|
#import "LKSyncOpenGroupsMessage.h"
|
|
|
|
#import "OWSPrimaryStorage.h"
|
|
|
|
#import "OWSPrimaryStorage.h"
|
|
|
|
#import <SignalServiceKit/SignalServiceKit-Swift.h>
|
|
|
|
#import <SignalServiceKit/SignalServiceKit-Swift.h>
|
|
|
|
|
|
|
|
|
|
|
|
NS_ASSUME_NONNULL_BEGIN
|
|
|
|
NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
|
|
|
|
|
|
|
@implementation OWSSyncOpenGroupsMessage
|
|
|
|
@implementation LKSyncOpenGroupsMessage
|
|
|
|
|
|
|
|
|
|
|
|
- (instancetype)init
|
|
|
|
- (instancetype)init
|
|
|
|
{
|
|
|
|
{
|
|
|
@ -19,26 +19,24 @@ NS_ASSUME_NONNULL_BEGIN
|
|
|
|
- (nullable SSKProtoSyncMessageBuilder *)syncMessageBuilder
|
|
|
|
- (nullable SSKProtoSyncMessageBuilder *)syncMessageBuilder
|
|
|
|
{
|
|
|
|
{
|
|
|
|
NSError *error;
|
|
|
|
NSError *error;
|
|
|
|
NSMutableArray<SSKProtoSyncMessageOpenGroups *> *sessionOpenGroups = @[].mutableCopy;
|
|
|
|
NSMutableArray<SSKProtoSyncMessageOpenGroups *> *openGroups = @[].mutableCopy;
|
|
|
|
__block NSDictionary<NSString *, LKPublicChat *> *publicChats;
|
|
|
|
__block NSDictionary<NSString *, LKPublicChat *> *publicChats;
|
|
|
|
[OWSPrimaryStorage.sharedManager.dbReadConnection readWithBlock:^(YapDatabaseReadTransaction *transaction) {
|
|
|
|
[OWSPrimaryStorage.sharedManager.dbReadConnection readWithBlock:^(YapDatabaseReadTransaction *transaction) {
|
|
|
|
publicChats = [LKDatabaseUtilities getAllPublicChats:transaction];
|
|
|
|
publicChats = [LKDatabaseUtilities getAllPublicChats:transaction];
|
|
|
|
}];
|
|
|
|
}];
|
|
|
|
for (LKPublicChat *openGroup in publicChats.allValues) {
|
|
|
|
for (LKPublicChat *openGroup in publicChats.allValues) {
|
|
|
|
SSKProtoSyncMessageOpenGroupsBuilder *openGroupBuilder = [SSKProtoSyncMessageOpenGroups builder];
|
|
|
|
SSKProtoSyncMessageOpenGroupsBuilder *openGroupMessageBuilder = [SSKProtoSyncMessageOpenGroups builder];
|
|
|
|
[openGroupBuilder setUrl:openGroup.server];
|
|
|
|
[openGroupMessageBuilder setUrl:openGroup.server];
|
|
|
|
[openGroupBuilder setChannel:openGroup.channel];
|
|
|
|
[openGroupMessageBuilder setChannel:openGroup.channel];
|
|
|
|
SSKProtoSyncMessageOpenGroups *_Nullable openGroupProto = [openGroupBuilder buildAndReturnError:&error];
|
|
|
|
SSKProtoSyncMessageOpenGroups *_Nullable openGroupMessageProto = [openGroupMessageBuilder buildAndReturnError:&error];
|
|
|
|
if (error || !openGroupProto) {
|
|
|
|
if (error || !openGroupMessageProto) {
|
|
|
|
OWSFailDebug(@"could not build protobuf: %@", error);
|
|
|
|
OWSFailDebug(@"Couldn't build protobuf due to error: %@", error);
|
|
|
|
return nil;
|
|
|
|
return nil;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
[sessionOpenGroups addObject:openGroupProto];
|
|
|
|
[openGroups addObject:openGroupMessageProto];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
SSKProtoSyncMessageBuilder *syncMessageBuilder = [SSKProtoSyncMessage builder];
|
|
|
|
SSKProtoSyncMessageBuilder *syncMessageBuilder = [SSKProtoSyncMessage builder];
|
|
|
|
[syncMessageBuilder setOpenGroups:sessionOpenGroups];
|
|
|
|
[syncMessageBuilder setOpenGroups:openGroups];
|
|
|
|
|
|
|
|
|
|
|
|
return syncMessageBuilder;
|
|
|
|
return syncMessageBuilder;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|