anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

接受好友请求后发的通知的发送者改为接受者发送

Browse Source
This commit is contained in:
heavyrian2012
2025-12-17 09:38:55 +08:00
parent 2f9c4e028c
commit 6c9df5c071
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/imhandler/HandleFriendRequestHandler.java
+4 -4
View File
@@ -45,20 +45,20 @@ public class HandleFriendRequestHandler extends IMHandler<WFCMessage.HandleFrien
contentBuilder.setType(92); contentBuilder.setType(92);
builder = WFCMessage.Message.newBuilder(); builder = WFCMessage.Message.newBuilder();
builder.setFromUser(request.getTargetUid()); builder.setFromUser(fromUser);
builder.setConversation(WFCMessage.Conversation.newBuilder().setTarget(fromUser).setLine(0).setType(ProtoConstants.ConversationType.ConversationType_Private).build()); builder.setConversation(WFCMessage.Conversation.newBuilder().setTarget(request.getTargetUid()).setLine(0).setType(ProtoConstants.ConversationType.ConversationType_Private).build());
builder.setContent(contentBuilder); builder.setContent(contentBuilder);
builder.setServerTimestamp(++timestamp); builder.setServerTimestamp(++timestamp);
messageId = MessageShardingUtil.generateId(); messageId = MessageShardingUtil.generateId();
builder.setMessageId(messageId); builder.setMessageId(messageId);
saveAndPublish(request.getTargetUid(), null, builder.build(), requestSourceType); saveAndPublish(fromUser, null, builder.build(), requestSourceType);
contentBuilder.setType(93); contentBuilder.setType(93);
builder.setContent(contentBuilder); builder.setContent(contentBuilder);
messageId = MessageShardingUtil.generateId(); messageId = MessageShardingUtil.generateId();
builder.setMessageId(messageId); builder.setMessageId(messageId);
builder.setServerTimestamp(++timestamp); builder.setServerTimestamp(++timestamp);
saveAndPublish(request.getTargetUid(), null, builder.build(), requestSourceType); saveAndPublish(fromUser, null, builder.build(), requestSourceType);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }