🔄 Sync from monorepo

wearemojo/mojo@9aa23e1

lib/ab/ab_test.go

@@ -44,7 +44,7 @@ var (
 )
 
 func BenchmarkParse(b *testing.B) {
-	for i := 0; i < b.N; i++ {
+	for range b.N {
 		Check(testID, userID, 5000)
 	}
 }

lib/crpc/server_test.go

@@ -1,4 +1,3 @@
-//nolint:bodyclose // incorrect
 package crpc
 
 import (

lib/ksuid/id_test.go

@@ -111,7 +111,7 @@ func TestParse(t *testing.T) {
 }
 
 func BenchmarkParse(b *testing.B) {
-	for i := 0; i < b.N; i++ {
+	for range b.N {
 		_, _ = Parse("user_000000BPG6Lks9tQoAiJYrBRSXPX6")
 	}
 }

lib/ksuid/node_test.go

@@ -6,7 +6,7 @@ import (
 )
 
 func BenchmarkGenerate(b *testing.B) {
-	for i := 0; i < b.N; i++ {
+	for range b.N {
 		Generate(context.Background(), "user")
 	}
 }

lib/middleware/request/logger.go

@@ -97,36 +97,35 @@ func Logger(log *logrus.Entry) func(http.Handler) http.Handler {
 			err := getError(clog.Get(ctx))
 			if err == nil {
 				mlog.Info(ctx, merr.New(ctx, "request_completed", nil))
-			} else {
-				var fn func(context.Context, merr.Merrer)
-				switch clog.DetermineLevel(err, clog.TimeoutsAsErrors(ctx)) {
-				case
-					logrus.PanicLevel,
-					logrus.FatalLevel,
-					logrus.ErrorLevel:
-					fn = mlog.Error
-				case
-					logrus.WarnLevel:
-					fn = mlog.Warn
-				case
-					logrus.InfoLevel,
-					logrus.DebugLevel,
-					logrus.TraceLevel:
-					fn = mlog.Info
-				}
+				return
+			}
+			var fn func(context.Context, merr.Merrer)
+			switch clog.DetermineLevel(err, clog.TimeoutsAsErrors(ctx)) {
+			case
+				logrus.PanicLevel,
+				logrus.FatalLevel,
+				logrus.ErrorLevel:
+				fn = mlog.Error
+			case logrus.WarnLevel:
+				fn = mlog.Warn
+			case
+				logrus.InfoLevel,
+				logrus.DebugLevel,
+				logrus.TraceLevel:
+				fn = mlog.Info
+			}
 
-				if mErr, ok := gerrors.As[merr.E](err); ok {
-					fn(ctx, mErr)
-				} else if cErr, ok := gerrors.As[cher.E](err); ok {
-					reasons := slicefn.Map(cErr.Reasons, func(r cher.E) error { return r })
-					// If the cher error has no reasons, add the cher error itself
-					if len(reasons) == 0 {
-						reasons = append(reasons, cErr)
-					}
-					fn(ctx, merr.New(ctx, merr.Code(cErr.Code), merr.M(cErr.Meta), reasons...))
-				} else {
-					fn(ctx, merr.New(ctx, "unexpected_request_failure", nil, err))
+			if mErr, ok := gerrors.As[merr.E](err); ok {
+				fn(ctx, mErr)
+			} else if cErr, ok := gerrors.As[cher.E](err); ok {
+				reasons := slicefn.Map(cErr.Reasons, func(r cher.E) error { return r })
+				// If the cher error has no reasons, add the cher error itself
+				if len(reasons) == 0 {
+					reasons = append(reasons, cErr)
 				}
+				fn(ctx, merr.New(ctx, merr.Code(cErr.Code), merr.M(cErr.Meta), reasons...))
+			} else {
+				fn(ctx, merr.New(ctx, "unexpected_request_failure", nil, err))
 			}
 		})
 	}

lib/revenuecat/revenuecat.go

@@ -3,14 +3,15 @@ package revenuecat
 import (
 	"context"
 	"fmt"
+	"maps"
 	"net/url"
+	"slices"
 	"time"
 
 	"github.com/samber/lo"
 	"github.com/wearemojo/mojo-public-go/lib/httpclient"
 	"github.com/wearemojo/mojo-public-go/lib/jsonclient"
 	"github.com/wearemojo/mojo-public-go/lib/secret"
-	"golang.org/x/exp/maps"
 )
 
 const baseURL = "https://api.revenuecat.com/v1"
@@ -92,7 +93,7 @@ func (c *Client) GetOrCreateSubscriberInfo(ctx context.Context, appUserID string
 }
 
 func (s *Subscriber) ActiveSubscriptionCount() int {
-	activeNonSubCount := len(lo.Flatten(maps.Values(s.NonSubscriptions))) // always active
+	activeNonSubCount := len(lo.Flatten(slices.Collect(maps.Values(s.NonSubscriptions)))) // always active
 	activeSubCount := 0
 	now := time.Now()