HyperNet/Messaging
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

✨ New what's new

Browse Source
This commit is contained in:
LittleSheep 2025-02-22 23:58:46 +08:00
parent bf973b3b71
commit 47cced4e75
1 changed files with 21 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
pkg/internal/http/api/whats_new_api.go
View File

@ -16,33 +16,28 @@ func getWhatsNew(c *fiber.Ctx) error {
} }
user := c.Locals("user").(authm.Account) user := c.Locals("user").(authm.Account)
pivot := c.QueryInt("pivot", 0)
if pivot < 0 {
return fiber.NewError(fiber.StatusBadRequest, "pivot must be greater than zero")
}
take := c.QueryInt("take", 10)
if take > 100 {
take = 100
}
tx := database.C
var lookupRange []uint var lookupRange []uint
var lookupPivots []int
var ignoreRange []uint var ignoreRange []uint
var channelMembers []models.ChannelMember var channelMembers []models.ChannelMember
if err := database.C.Where("account_id = ?", user.ID).Select("id", "channel_id").Find(&channelMembers).Error; err != nil { if err := database.C.Where("account_id = ?", user.ID).
Select("id", "channel_id", "reading_anchor").
Find(&channelMembers).Error; err != nil {
return fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("unable to get channel identity of you: %v", err)) return fiber.NewError(fiber.StatusInternalServerError, fmt.Sprintf("unable to get channel identity of you: %v", err))
} else { } else {
for _, member := range channelMembers { for _, member := range channelMembers {
if member.ReadingAnchor == nil {
continue
}
lookupRange = append(lookupRange, member.ChannelID) lookupRange = append(lookupRange, member.ChannelID)
lookupPivots = append(lookupPivots, *member.ReadingAnchor)
ignoreRange = append(ignoreRange, member.ID) ignoreRange = append(ignoreRange, member.ID)
} }
} }
tx := database.C
tx = tx.Where("channel_id IN ?", lookupRange) tx = tx.Where("channel_id IN ?", lookupRange)
tx = tx.Where("sender_id NOT IN ?", ignoreRange) tx = tx.Where("sender_id NOT IN ?", ignoreRange)
tx = tx.Where("id > ?", pivot)
countTx := tx countTx := tx
var count int64 var count int64
@ -50,20 +45,18 @@ func getWhatsNew(c *fiber.Ctx) error {
return fiber.NewError(fiber.StatusInternalServerError, err.Error()) return fiber.NewError(fiber.StatusInternalServerError, err.Error())
} }
var items []models.Event var result []struct {
if err := tx. ChannelID uint `json:"channel_id"`
Limit(take). UnreadMessageCount int `json:"count"`
Order("created_at DESC"). }
Preload("Sender"). if err := database.C.Table("channel_members cm").
Preload("Channel"). Select("cm.channel_id, COUNT(m.id) AS unread_message_count").
Preload("Channel.Realm"). Joins("JOIN messages m ON m.channel_id = cm.channel_id").
Find(&items).Error; err != nil { Where("m.id > cm.reading_anchor AND cm.account_id = ?", 1).
return fiber.NewError(fiber.StatusBadRequest, err.Error()) Group("cm.channel_id").
Scan(&result).Error; err != nil {
return fiber.NewError(fiber.StatusInternalServerError, err.Error())
} }
return c.JSON(fiber.Map{ return c.JSON(result)
"count": count,
"data": items,
})
} }