vbatts/ntfy
1
0
Fork 0
Code Pull requests Activity

Merge branch 'main' into user-account

Browse source
This commit is contained in:
binwiederhier 2022-12-12 11:12:05 -05:00
commit cf68414c40
6 changed files with 64 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

11
server/message_cache.go
View file

@ -258,12 +258,20 @@ func (c *messageCache) addMessages(ms []*message) error {
if c.nop {
return nil
}
if len(ms) == 0 {
return nil
}
start := time.Now()
tx, err := c.db.Begin()
if err != nil {
return err
}
defer tx.Rollback()
stmt, err := tx.Prepare(insertMessageQuery)
if err != nil {
return err
}
defer stmt.Close()
for _, m := range ms {
if m.Event != messageEvent {
return errUnexpectedMessageType
@ -291,8 +299,7 @@ func (c *messageCache) addMessages(ms []*message) error {
if m.Sender.IsValid() {
sender = m.Sender.String()
}
_, err := tx.Exec(
insertMessageQuery,
_, err := stmt.Exec(
m.ID,
m.Time,
m.Topic,