twonly/twonly-app
1
0
Fork 0
mirror of https://github.com/twonlyapp/twonly-app.git synced 2026-05-25 03:42:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

check original sender id

Browse source
This commit is contained in:
otsmr 2026-04-22 19:47:43 +02:00
parent be35336a5d
commit 1371cf80cb
2 changed files with 25 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
lib/src/services/api/client2client/additional_data.c2c.dart
View file

@ -14,6 +14,19 @@ Future<void> handleAdditionalDataMessage(
Log.info( Log.info(
'Got a additional data message: ${message.senderMessageId} from $groupId', 'Got a additional data message: ${message.senderMessageId} from $groupId',
); );
// Prevent message overwrite: reject if a message with this ID already
// exists from a different sender.
final existing = await twonlyDB.messagesDao
.getMessageById(message.senderMessageId)
.getSingleOrNull();
if (existing != null && existing.senderId != fromUserId) {
Log.warn(
'$fromUserId tried to overwrite message from ${existing.senderId}. Dropping.',
);
return;
}
final msg = await twonlyDB.messagesDao.insertMessage( final msg = await twonlyDB.messagesDao.insertMessage(
MessagesCompanion( MessagesCompanion(
messageId: Value(message.senderMessageId), messageId: Value(message.senderMessageId),

12
lib/src/services/api/client2client/text_message.c2c.dart
View file

@ -16,6 +16,18 @@ Future<void> handleTextMessage(
'Got a text message: ${textMessage.senderMessageId} from $groupId', 'Got a text message: ${textMessage.senderMessageId} from $groupId',
); );
// Prevent message overwrite: reject if a message with this ID already
// exists from a different sender.
final existing = await twonlyDB.messagesDao
.getMessageById(textMessage.senderMessageId)
.getSingleOrNull();
if (existing != null && existing.senderId != fromUserId) {
Log.warn(
'$fromUserId tried to overwrite message from ${existing.senderId}. Dropping.',
);
return;
}
final message = await twonlyDB.messagesDao.insertMessage( final message = await twonlyDB.messagesDao.insertMessage(
MessagesCompanion( MessagesCompanion(
messageId: Value(textMessage.senderMessageId), messageId: Value(textMessage.senderMessageId),