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

downstream: break findWebPushSubscription in two functions

Browse source 
We'll use that to count the number of existing subscriptions in
the next commit.
This commit is contained in:
Simon Ser 2022-08-17 17:04:11 +02:00
parent 65f0b2367e
commit cffdbc16b4
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
downstream.go
View file

@ -3327,7 +3327,7 @@ func (dc *downstreamConn) handleMessageRegistered(ctx context.Context, msg *irc.
newSub.Keys.Auth = string(authKey) newSub.Keys.Auth = string(authKey)
newSub.Keys.P256DH = string(p256dhKey) newSub.Keys.P256DH = string(p256dhKey)
oldSub, err := dc.findWebPushSubscription(ctx, endpoint) subs, err := dc.listWebPushSubscriptions(ctx)
if err != nil { if err != nil {
dc.logger.Printf("failed to fetch Web push subscription: %v", err) dc.logger.Printf("failed to fetch Web push subscription: %v", err)
return ircError{&irc.Message{ return ircError{&irc.Message{
@ -3336,6 +3336,7 @@ func (dc *downstreamConn) handleMessageRegistered(ctx context.Context, msg *irc.
}} }}
} }
oldSub := findWebPushSubscription(subs, endpoint)
if oldSub != nil { if oldSub != nil {
// Update the old subscription instead of creating a new one // Update the old subscription instead of creating a new one
newSub.ID = oldSub.ID newSub.ID = oldSub.ID
@ -3381,7 +3382,7 @@ func (dc *downstreamConn) handleMessageRegistered(ctx context.Context, msg *irc.
return err return err
} }
oldSub, err := dc.findWebPushSubscription(ctx, endpoint) subs, err := dc.listWebPushSubscriptions(ctx)
if err != nil { if err != nil {
dc.logger.Printf("failed to fetch Web push subscription: %v", err) dc.logger.Printf("failed to fetch Web push subscription: %v", err)
return ircError{&irc.Message{ return ircError{&irc.Message{
@ -3390,6 +3391,7 @@ func (dc *downstreamConn) handleMessageRegistered(ctx context.Context, msg *irc.
}} }}
} }
oldSub := findWebPushSubscription(subs, endpoint)
if oldSub == nil { if oldSub == nil {
dc.SendMessage(&irc.Message{ dc.SendMessage(&irc.Message{
Prefix: dc.srv.prefix(), Prefix: dc.srv.prefix(),
@ -3446,23 +3448,22 @@ func (dc *downstreamConn) handleNickServPRIVMSG(ctx context.Context, uc *upstrea
} }
} }
func (dc *downstreamConn) findWebPushSubscription(ctx context.Context, endpoint string) (*database.WebPushSubscription, error) { func (dc *downstreamConn) listWebPushSubscriptions(ctx context.Context) ([]database.WebPushSubscription, error) {
var networkID int64 var networkID int64
if dc.network != nil { if dc.network != nil {
networkID = dc.network.ID networkID = dc.network.ID
} }
subs, err := dc.user.srv.db.ListWebPushSubscriptions(ctx, dc.user.ID, networkID) return dc.user.srv.db.ListWebPushSubscriptions(ctx, dc.user.ID, networkID)
if err != nil { }
return nil, err
}
func findWebPushSubscription(subs []database.WebPushSubscription, endpoint string) *database.WebPushSubscription {
for i, sub := range subs { for i, sub := range subs {
if sub.Endpoint == endpoint { if sub.Endpoint == endpoint {
return &subs[i], nil return &subs[i]
} }
} }
return nil, nil return nil
} }
func parseNickServCredentials(text, nick string) (username, password string, ok bool) { func parseNickServCredentials(text, nick string) (username, password string, ok bool) {