watsonb8/groupme
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Parellel goroutine

Browse Source
This commit is contained in:
Karmanyaah Malhotra 2021-03-02 19:56:02 -05:00
parent 27bbc12d77
commit a571f12af1
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
user.go
View File

@ -593,11 +593,13 @@ func (user *User) syncPortals(chatMap map[string]groupme.Group, createAll bool)
} }
create := (chat.LastMessageTime >= user.LastConnection && user.LastConnection > 0) || i < limit create := (chat.LastMessageTime >= user.LastConnection && user.LastConnection > 0) || i < limit
if len(chat.Portal.MXID) > 0 || create || createAll { if len(chat.Portal.MXID) > 0 || create || createAll {
chat.Portal.Sync(user, chat.Group) go func() {
err := chat.Portal.BackfillHistory(user, chat.LastMessageTime) chat.Portal.Sync(user, chat.Group)
if err != nil { err := chat.Portal.BackfillHistory(user, chat.LastMessageTime)
chat.Portal.log.Errorln("Error backfilling history:", err) if err != nil {
} chat.Portal.log.Errorln("Error backfilling history:", err)
}
}()
} }
} }
//TODO: handle leave from groupme side //TODO: handle leave from groupme side