|
|
|
@ -1,5 +1,5 @@
|
|
|
|
|
import { UserGroupsGet } from 'libsession_util_nodejs';
|
|
|
|
|
import { compact, isEmpty } from 'lodash';
|
|
|
|
|
import { compact, isEmpty, uniqBy } from 'lodash';
|
|
|
|
|
import { SignalService } from '../../../../protobuf';
|
|
|
|
|
import { MetaGroupWrapperActions } from '../../../../webworker/workers/browser/libsession_worker_interface';
|
|
|
|
|
import { GroupUpdateInfoChangeMessage } from '../../../messages/outgoing/controlMessage/group_v2/to_group/GroupUpdateInfoChangeMessage';
|
|
|
|
@ -40,6 +40,13 @@ async function makeGroupMessageSubRequest(
|
|
|
|
|
throw new Error('makeGroupMessageSubRequest: not all messages are for the same destination');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const allTimestamps = uniqBy(compactedMessages, m => m.createAtNetworkTimestamp);
|
|
|
|
|
if (allTimestamps.length !== compactedMessages.length) {
|
|
|
|
|
throw new Error(
|
|
|
|
|
'tried to send batch request with messages having the same timestamp, and some platformn do not support this.'
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const messagesToEncrypt: Array<StoreGroupExtraData> = compactedMessages.map(updateMessage => {
|
|
|
|
|
const wrapped = MessageWrapper.wrapContentIntoEnvelope(
|
|
|
|
|
SignalService.Envelope.Type.CLOSED_GROUP_MESSAGE,
|
|
|
|
|