diff --git a/protocol/message_persistence.go b/protocol/message_persistence.go index f482ac64942..4d6fcc00ee8 100644 --- a/protocol/message_persistence.go +++ b/protocol/message_persistence.go @@ -3075,15 +3075,7 @@ func (db sqlitePersistence) findAndUpdateReplies(tx *sql.Tx, bridgeMessageID str } func (db sqlitePersistence) findAndUpdateRepliedTo(tx *sql.Tx, discordParentMessageID string, statusMessageID string) error { - // Finds status messages id which are replies for bridgeMessageID - repliedMessageID, err := db.findStatusMessageIDForBridgeMessageID(tx, discordParentMessageID) - if err != nil { - return err - } - if repliedMessageID == "" { - return nil - } - return db.updateStatusMessagesWithResponse(tx, []string{statusMessageID}, repliedMessageID) + return db.updateStatusMessagesWithResponse(tx, []string{statusMessageID}, discordParentMessageID) } func (db sqlitePersistence) GetCommunityMemberAllMessages(member string, communityID string) ([]*common.Message, error) {