Showing 35 of 60 total issues
Method repository.FetchOne
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchOne(code string, params *meta.RequestParams) (*model.Order, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
query := r.buildQueryPipeline(bson.M{"unique_id": code}, params)
Method repository.Fetch
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) Fetch(codes []string, params *meta.RequestParams) ([]*model.SneakerProduct, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
filter := bson.M{"uniqueid": bson.M{"$in": codes}}
Method Handler.UploadImages
has 5 return statements (exceeds 4 allowed). Open
Open
func (h *Handler) UploadImages(ctx context.Context, input *proto.UploadImageRequest) (*proto.ProductResponse, error) {
productID := input.ProductID; if len(input.ProductID) == 0 {
return nil, status.Error(codes.InvalidArgument, business.ErrProductNotFound.Error())
}
Method repository.FetchQuery
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchQuery(query meta.RequestQuery, params *meta.RequestParams) ([]*model.SneakerReference, error) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
sneakerReferences := make([]*model.SneakerReference, 0)
where, err := query.ToSql(); if err != nil {
Method AuthClientInterceptor.requestAccessToken
has 5 return statements (exceeds 4 allowed). Open
Open
func (i *AuthClientInterceptor) requestAccessToken(ctx context.Context) (*meta.AuthToken, error) {
if i.accessToken != nil {
if !i.accessToken.Expires.IsZero() && i.accessToken.Expires.Nanosecond() <= time.Now().Nanosecond() {
newToken, err := i.authClient.Refresh(ctx, proto.AuthToken{}.FromNative(i.accessToken)); if err == nil {
i.accessToken = newToken.ToNative()
Method repository.FetchQuery
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchQuery(query meta.RequestQuery, params *meta.RequestParams) ([]*model.SneakerProduct, error) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
sneakerProducts := make([]*model.SneakerProduct, 0)
where, err := query.ToSql(); if err != nil {
Method repository.Fetch
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) Fetch(codes []string, params *meta.RequestParams) ([]*model.Rating, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
query := r.buildQueryPipeline(bson.M{"entity_id": bson.M{"$in": codes}}, params)
Method repository.FetchAll
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchAll(params *meta.RequestParams) ([]*model.User, error) {
keys := r.client.Keys("user*").Val()
if len(keys) == 0 {
return nil, errors.Wrap(business.ErrUserNotFound, "repository.User.FetchAll")
}
Method TokenManager.Verify
has 5 return statements (exceeds 4 allowed). Open
Open
func (m *TokenManager) Verify(accessToken string) (*meta.AuthClaims, error) {
token, err := jwt.ParseWithClaims(
accessToken,
&meta.AuthClaims{},
func(token *jwt.Token) (interface{}, error) {
Method Broker.Consume
has 5 return statements (exceeds 4 allowed). Open
Open
func (b *Broker) Consume(
queueName,
routingKey string,
handler func(d amqp.Delivery) bool,
concurrency int) error {
Method repository.FetchQuery
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchQuery(query meta.RequestQuery, params *meta.RequestParams) ([]*model.Order, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
filter, err := query.ToBson(); if err != nil {
Method repository.FetchOne
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchOne(code string, params *meta.RequestParams) (*model.SneakerReference, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
query := r.buildQueryPipeline(bson.M{"uniqueid": code}, params)
Method repository.Fetch
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) Fetch(codes []string, params *meta.RequestParams) ([]*model.SneakerReference, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
query := r.buildQueryPipeline(bson.M{"uniqueid": bson.M{"$in": codes}}, params)
Method repository.FetchOne
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchOne(code string, params *meta.RequestParams) (*model.Rating, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
query := r.buildQueryPipeline(bson.M{"entity_id": code}, params)
Method repository.FetchQuery
has 5 return statements (exceeds 4 allowed). Open
Open
func (r *repository) FetchQuery(query meta.RequestQuery, params *meta.RequestParams) ([]*model.Rating, error) {
ctx, cancel := context.WithTimeout(context.Background(), r.timeout)
defer cancel()
filter, err := query.ToBson(); if err != nil {