commit
24a4c73351
3 changed files with 9 additions and 2 deletions
|
@ -52,7 +52,7 @@ func (c *Controller) PaymentUpgradeOrDowngradeCron() {
|
|||
return
|
||||
}
|
||||
if len(bonusPenaltyCandidates) > 0 {
|
||||
logger.WithField("count", len(bonusPenaltyCandidates)).Error("candidates found for downgrade penalty")
|
||||
// todo: implement downgrade penalty
|
||||
logger.WithField("count", len(bonusPenaltyCandidates)).Warn("candidates found for downgrade penalty")
|
||||
}
|
||||
}
|
||||
|
|
|
@ -2,6 +2,8 @@ package user
|
|||
|
||||
import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"errors"
|
||||
"github.com/ente-io/museum/ente"
|
||||
"github.com/ente-io/museum/pkg/utils/auth"
|
||||
"github.com/ente-io/stacktrace"
|
||||
|
@ -88,7 +90,11 @@ func (c *UserController) UpdateSrpAndKeyAttributes(context *gin.Context,
|
|||
func (c *UserController) GetSRPAttributes(context *gin.Context, email string) (*ente.GetSRPAttributesResponse, error) {
|
||||
userID, err := c.UserRepo.GetUserIDWithEmail(email)
|
||||
if err != nil {
|
||||
return nil, stacktrace.Propagate(err, "user does not exist")
|
||||
if errors.Is(err, sql.ErrNoRows) {
|
||||
return nil, stacktrace.Propagate(ente.ErrNotFound, "user does not exist")
|
||||
} else {
|
||||
return nil, stacktrace.Propagate(err, "failed to get user")
|
||||
}
|
||||
}
|
||||
srpAttributes, err := c.UserAuthRepo.GetSRPAttributes(userID)
|
||||
if err != nil {
|
||||
|
|
|
@ -30,6 +30,7 @@ func Error(c *gin.Context, err error) {
|
|||
// echo "GET /ping HTTP/1.0\r\nContent-Length: 300\r\n\r\n" | nc localhost 8080
|
||||
if errors.Is(err, ente.ErrStorageLimitExceeded) ||
|
||||
errors.Is(err, ente.ErrNoActiveSubscription) ||
|
||||
errors.Is(err, ente.ErrInvalidPassword) ||
|
||||
errors.Is(err, io.ErrUnexpectedEOF) ||
|
||||
errors.Is(err, syscall.EPIPE) ||
|
||||
errors.Is(err, syscall.ECONNRESET) {
|
||||
|
|
Loading…
Add table
Reference in a new issue