backend for xcvr appview
add logging to oauth db
+6
-6
+6
-6
server/internal/db/oauth.go
+6
-6
server/internal/db/oauth.go
···
53
53
session.AccessToken,
54
54
session.RefreshToken,
55
55
session.Expiration)
56
-
return err
56
+
return errors.New("error storing oauth session" + err.Error())
57
57
}
58
58
59
59
func (s *Store) GetOauthRequest(state string, ctx context.Context) (*oauth.OAuthRequest, error) {
···
70
70
LIMIT 1
71
71
`, state)
72
72
if err != nil {
73
-
return nil, err
73
+
return nil, errors.New("error querying for oauth request:" + err.Error())
74
74
}
75
75
defer rows.Close()
76
76
var req oauth.OAuthRequest
···
80
80
}
81
81
err = rows.Scan(&req.AuthserverIss, &req.Did, &req.PdsUrl, &req.PkceVerifier, &req.DpopAuthServerNonce, &req.DpopPrivKey)
82
82
if err != nil {
83
-
return nil, err
83
+
return nil, errors.New("error scanning rows while getting oauth request:" + err.Error())
84
84
}
85
85
return &req, nil
86
86
}
···
103
103
LIMIT 1
104
104
`, did)
105
105
if err != nil {
106
-
return nil, err
106
+
return nil, errors.New("error querying oauthsessions:" + err.Error())
107
107
}
108
108
defer rows.Close()
109
109
var session oauth.Session
···
123
123
&session.RefreshToken,
124
124
&session.Expiration)
125
125
if err != nil {
126
-
return nil, err
126
+
return nil, errors.New("error scanning oauthsession row: " + err.Error())
127
127
}
128
128
return &session, nil
129
129
}
···
132
132
_, err := s.pool.Exec(ctx, `
133
133
DELETE FROM oauthrequests r WHERE r.state = $1
134
134
`, state)
135
-
return err
135
+
return errors.New("error deleting oauth request:" + err.Error())
136
136
}