arch/soju
1
0
Fork 0
Code Issues Pull requests 1 Actions Packages Projects Releases Wiki Activity

Add context to network.storeClientDeliveryReceipts

Browse source
This commit is contained in:
Simon Ser 2021-12-02 23:32:12 +01:00
parent 04b0c2fd6b
commit f75ee272a4
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
user.go
View file

@ -372,7 +372,7 @@ func (net *network) updateCasemapping(newCasemap casemapping) {
}) })
} }
func (net *network) storeClientDeliveryReceipts(clientName string) { func (net *network) storeClientDeliveryReceipts(ctx context.Context, clientName string) {
if !net.user.hasPersistentMsgStore() { if !net.user.hasPersistentMsgStore() {
return return
} }
@ -389,7 +389,7 @@ func (net *network) storeClientDeliveryReceipts(clientName string) {
}) })
}) })
if err := net.user.srv.db.StoreClientDeliveryReceipts(context.TODO(), net.ID, clientName, receipts); err != nil { if err := net.user.srv.db.StoreClientDeliveryReceipts(ctx, net.ID, clientName, receipts); err != nil {
net.logger.Printf("failed to store delivery receipts for client %q: %v", clientName, err) net.logger.Printf("failed to store delivery receipts for client %q: %v", clientName, err)
} }
} }
@ -658,7 +658,7 @@ func (u *user) run() {
} }
dc.forEachNetwork(func(net *network) { dc.forEachNetwork(func(net *network) {
net.storeClientDeliveryReceipts(dc.clientName) net.storeClientDeliveryReceipts(context.TODO(), dc.clientName)
}) })
u.forEachUpstream(func(uc *upstreamConn) { u.forEachUpstream(func(uc *upstreamConn) {
@ -713,7 +713,7 @@ func (u *user) run() {
n.stop() n.stop()
n.delivered.ForEachClient(func(clientName string) { n.delivered.ForEachClient(func(clientName string) {
n.storeClientDeliveryReceipts(clientName) n.storeClientDeliveryReceipts(context.TODO(), clientName)
}) })
} }
return return