anyproto/anytype-heart
1
0
Fork 0
mirror of https://github.com/anyproto/anytype-heart.git synced 2025-06-11 02:13:41 +09:00
Code Activity

GO-3701 After-review changes

Browse source
This commit is contained in:
Anthony Akentiev 2024-07-05 13:49:01 +01:00
parent 685a78c1b6
commit f7629b373e
No known key found for this signature in database
GPG key ID: 017A11DC01A79831
1 changed files with 1 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

11
core/payments/payments.go
View file

@ -2,12 +2,11 @@ package payments
import (
"context"
"errors"
"sync"
"time"
"unicode/utf8"
"github.com/pkg/errors"
"github.com/anyproto/any-sync/app"
"github.com/anyproto/any-sync/app/logger"
"github.com/anyproto/any-sync/util/periodicsync"
@ -274,7 +273,6 @@ func (s *service) GetSubscriptionStatus(ctx context.Context, req *pb.RpcMembersh
err = s.cache.CacheSet(&out, nil)
if err != nil {
log.Warn("can not save subscription status to cache", zap.Error(err))
// skip this error, even if we can not save to cache
// return nil, ErrCacheProblem
}
@ -323,7 +321,6 @@ func (s *service) GetSubscriptionStatus(ctx context.Context, req *pb.RpcMembersh
err = s.cache.CacheDisableForNextMinutes(cacheDisableMinutes)
if err != nil {
log.Warn("can not disable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
}
@ -337,7 +334,6 @@ func (s *service) GetSubscriptionStatus(ctx context.Context, req *pb.RpcMembersh
err = s.cache.CacheEnable()
if err != nil {
log.Warn("can not enable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
}
@ -543,7 +539,6 @@ func (s *service) RegisterPaymentRequest(ctx context.Context, req *pb.RpcMembers
err = s.cache.CacheDisableForNextMinutes(cacheDisableMinutes)
if err != nil {
log.Warn("can not disable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
@ -591,7 +586,6 @@ func (s *service) GetPortalLink(ctx context.Context, req *pb.RpcMembershipGetPor
err = s.cache.CacheDisableForNextMinutes(cacheDisableMinutes)
if err != nil {
log.Warn("can not disable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
@ -676,7 +670,6 @@ func (s *service) VerifyEmailCode(ctx context.Context, req *pb.RpcMembershipVeri
err = s.cache.CacheDisableForNextMinutes(cacheDisableMinutes)
if err != nil {
log.Warn("can not disable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
@ -727,7 +720,6 @@ func (s *service) FinalizeSubscription(ctx context.Context, req *pb.RpcMembershi
err = s.cache.CacheDisableForNextMinutes(cacheDisableMinutes)
if err != nil {
log.Warn("can not disable cache", zap.Error(err))
// skip this error
// return nil, errors.Wrap(ErrCacheProblem, err.Error())
}
@ -861,7 +853,6 @@ func (s *service) getAllTiers(ctx context.Context, req *pb.RpcMembershipGetTiers
err = s.cache.CacheSet(nil, &out)
if err != nil {
log.Warn("can not save tiers to cache", zap.Error(err))
// skip this error, even if we can not save to cache
// return nil, ErrCacheProblem
}