MirrorHub/mautrix-whatsapp
0
0
Fork 1
mirror of https://github.com/tulir/mautrix-whatsapp synced 2024-06-18 10:58:20 +02:00
Code Issues Projects Releases Wiki Activity

Count messages that failed to save

Browse source
This commit is contained in:
Tulir Asokan 2024-03-12 20:58:16 +02:00
parent 46420c1319
commit fee357b652
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
historysync.go
View file

@ -526,6 +526,7 @@ func (user *User) storeHistorySync(evt *waProto.HistorySync) {
Msg("Storing history sync") Msg("Storing history sync")
successfullySavedTotal := 0 successfullySavedTotal := 0
failedToSaveTotal := 0
totalMessageCount := 0 totalMessageCount := 0
for _, conv := range evt.GetConversations() { for _, conv := range evt.GetConversations() {
jid, err := types.ParseJID(conv.GetId()) jid, err := types.ParseJID(conv.GetId())
@ -578,6 +579,7 @@ func (user *User) storeHistorySync(evt *waProto.HistorySync) {
var minTimeIndex, maxTimeIndex int var minTimeIndex, maxTimeIndex int
successfullySaved := 0 successfullySaved := 0
failedToSave := 0
unsupportedTypes := 0 unsupportedTypes := 0
for i, rawMsg := range conv.GetMessages() { for i, rawMsg := range conv.GetMessages() {
// Don't store messages that will just be skipped. // Don't store messages that will just be skipped.
@ -614,6 +616,7 @@ func (user *User) storeHistorySync(evt *waProto.HistorySync) {
Str("msg_id", msgEvt.Info.ID). Str("msg_id", msgEvt.Info.ID).
Time("msg_time", msgEvt.Info.Timestamp). Time("msg_time", msgEvt.Info.Timestamp).
Msg("Failed to save historical message") Msg("Failed to save historical message")
failedToSave++
continue continue
} }
err = message.Insert(ctx) err = message.Insert(ctx)
@ -623,12 +626,16 @@ func (user *User) storeHistorySync(evt *waProto.HistorySync) {
Str("msg_id", msgEvt.Info.ID). Str("msg_id", msgEvt.Info.ID).
Time("msg_time", msgEvt.Info.Timestamp). Time("msg_time", msgEvt.Info.Timestamp).
Msg("Failed to save historical message") Msg("Failed to save historical message")
} failedToSave++
} else {
successfullySaved++ successfullySaved++
} }
}
successfullySavedTotal += successfullySaved successfullySavedTotal += successfullySaved
failedToSaveTotal += failedToSave
log.Debug(). log.Debug().
Int("saved_count", successfullySaved). Int("saved_count", successfullySaved).
Int("failed_count", failedToSave).
Int("unsupported_msg_type_count", unsupportedTypes). Int("unsupported_msg_type_count", unsupportedTypes).
Time("lowest_time", minTime). Time("lowest_time", minTime).
Int("lowest_time_index", minTimeIndex). Int("lowest_time_index", minTimeIndex).
@ -646,6 +653,7 @@ func (user *User) storeHistorySync(evt *waProto.HistorySync) {
} }
log.Info(). log.Info().
Int("total_saved_count", successfullySavedTotal). Int("total_saved_count", successfullySavedTotal).
Int("total_failed_count", failedToSaveTotal).
Int("total_message_count", totalMessageCount). Int("total_message_count", totalMessageCount).
Msg("Finished storing history sync") Msg("Finished storing history sync")