fix: send group update promote message and display them
Audric Ackermann
7 months ago
parent
6c945a173d
commit
f4d0e369c9
@ -0,0 +1,155 @@
|
||||
import { Uint8ArrayLen64, WithGroupPubkey } from 'libsession_util_nodejs';
|
||||
import { getSodiumRenderer } from '../../../crypto';
|
||||
import { DisappearingMessages } from '../../../disappearing_messages';
|
||||
|
||||
import { GroupUpdateMemberChangeMessage } from '../../outgoing/controlMessage/group_v2/to_group/GroupUpdateMemberChangeMessage';
|
||||
import { ConversationModel } from '../../../../models/conversation';
|
||||
import {
|
||||
WithAddWithHistoryMembers,
|
||||
WithAddWithoutHistoryMembers,
|
||||
WithFromMemberLeftMessage,
|
||||
WithPromotedMembers,
|
||||
WithRemoveMembers,
|
||||
} from '../../../types/with';
|
||||
|
||||
/**
|
||||
* Return the control messages to be pushed to the group's swarm.
|
||||
* Those are not going to change the state, they are just here as a "notification".
|
||||
* i.e. "Alice was removed from the group"
|
||||
*/
|
||||
async function getRemovedControlMessage({
|
||||
convo,
|
||||
groupPk,
|
||||
removed,
|
||||
adminSecretKey,
|
||||
createAtNetworkTimestamp,
|
||||
fromMemberLeftMessage,
|
||||
dbMsgIdentifier,
|
||||
}: WithFromMemberLeftMessage &
|
||||
WithRemoveMembers &
|
||||
WithGroupPubkey & {
|
||||
convo: ConversationModel;
|
||||
adminSecretKey: Uint8ArrayLen64;
|
||||
createAtNetworkTimestamp: number;
|
||||
dbMsgIdentifier: string;
|
||||
}) {
|
||||
const sodium = await getSodiumRenderer();
|
||||
|
||||
if (fromMemberLeftMessage || !removed.length) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return new GroupUpdateMemberChangeMessage({
|
||||
identifier: dbMsgIdentifier,
|
||||
removed,
|
||||
groupPk,
|
||||
typeOfChange: 'removed',
|
||||
createAtNetworkTimestamp,
|
||||
secretKey: adminSecretKey,
|
||||
sodium,
|
||||
...DisappearingMessages.getExpireDetailsForOutgoingMessage(convo, createAtNetworkTimestamp),
|
||||
});
|
||||
}
|
||||
|
||||
async function getWithoutHistoryControlMessage({
|
||||
convo,
|
||||
withoutHistory,
|
||||
groupPk,
|
||||
adminSecretKey,
|
||||
createAtNetworkTimestamp,
|
||||
dbMsgIdentifier,
|
||||
}: WithAddWithoutHistoryMembers &
|
||||
WithGroupPubkey & {
|
||||
dbMsgIdentifier: string;
|
||||
convo: ConversationModel;
|
||||
adminSecretKey: Uint8ArrayLen64;
|
||||
createAtNetworkTimestamp: number;
|
||||
}) {
|
||||
const sodium = await getSodiumRenderer();
|
||||
|
||||
if (!withoutHistory.length) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return new GroupUpdateMemberChangeMessage({
|
||||
identifier: dbMsgIdentifier,
|
||||
added: withoutHistory,
|
||||
groupPk,
|
||||
typeOfChange: 'added',
|
||||
createAtNetworkTimestamp,
|
||||
secretKey: adminSecretKey,
|
||||
sodium,
|
||||
...DisappearingMessages.getExpireDetailsForOutgoingMessage(convo, createAtNetworkTimestamp),
|
||||
});
|
||||
}
|
||||
|
||||
async function getWithHistoryControlMessage({
|
||||
convo,
|
||||
withHistory,
|
||||
groupPk,
|
||||
adminSecretKey,
|
||||
createAtNetworkTimestamp,
|
||||
dbMsgIdentifier,
|
||||
}: WithAddWithHistoryMembers &
|
||||
WithGroupPubkey & {
|
||||
dbMsgIdentifier: string;
|
||||
convo: ConversationModel;
|
||||
adminSecretKey: Uint8ArrayLen64;
|
||||
createAtNetworkTimestamp: number;
|
||||
}) {
|
||||
const sodium = await getSodiumRenderer();
|
||||
|
||||
if (!withHistory.length) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return new GroupUpdateMemberChangeMessage({
|
||||
identifier: dbMsgIdentifier,
|
||||
added: withHistory,
|
||||
groupPk,
|
||||
typeOfChange: 'addedWithHistory',
|
||||
createAtNetworkTimestamp,
|
||||
secretKey: adminSecretKey,
|
||||
sodium,
|
||||
...DisappearingMessages.getExpireDetailsForOutgoingMessage(convo, createAtNetworkTimestamp),
|
||||
});
|
||||
}
|
||||
|
||||
async function getPromotedControlMessage({
|
||||
convo,
|
||||
promoted,
|
||||
groupPk,
|
||||
adminSecretKey,
|
||||
createAtNetworkTimestamp,
|
||||
dbMsgIdentifier,
|
||||
}: WithPromotedMembers &
|
||||
WithGroupPubkey & {
|
||||
dbMsgIdentifier: string;
|
||||
convo: ConversationModel;
|
||||
adminSecretKey: Uint8ArrayLen64;
|
||||
createAtNetworkTimestamp: number;
|
||||
}) {
|
||||
const sodium = await getSodiumRenderer();
|
||||
|
||||
if (!promoted.length) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return new GroupUpdateMemberChangeMessage({
|
||||
identifier: dbMsgIdentifier,
|
||||
promoted,
|
||||
groupPk,
|
||||
typeOfChange: 'promoted',
|
||||
createAtNetworkTimestamp,
|
||||
secretKey: adminSecretKey,
|
||||
sodium,
|
||||
...DisappearingMessages.getExpireDetailsForOutgoingMessage(convo, createAtNetworkTimestamp),
|
||||
});
|
||||
}
|
||||
|
||||
export const GroupUpdateMessageFactory = {
|
||||
getRemovedControlMessage,
|
||||
getWithoutHistoryControlMessage,
|
||||
getWithHistoryControlMessage,
|
||||
getPromotedControlMessage,
|
||||
};
|
||||
@ -1 +1,13 @@
|
||||
import { PubkeyType } from 'libsession_util_nodejs';
|
||||
|
||||
export type WithMessageHash = { messageHash: string };
|
||||
export type WithTimestamp = { timestamp: number };
|
||||
export type WithSignature = { signature: string };
|
||||
export type WithSecretKey = { secretKey: Uint8Array };
|
||||
|
||||
export type WithFromMemberLeftMessage = { fromMemberLeftMessage: boolean }; // there are some changes we want to skip when doing changes triggered from a memberLeft message.
|
||||
|
||||
export type WithAddWithoutHistoryMembers = { withoutHistory: Array<PubkeyType> };
|
||||
export type WithAddWithHistoryMembers = { withHistory: Array<PubkeyType> };
|
||||
export type WithRemoveMembers = { removed: Array<PubkeyType> };
|
||||
export type WithPromotedMembers = { promoted: Array<PubkeyType> };
|
||||
|
||||
Loading…
Reference in New Issue