slicetools.Batch (#35)

* slicetools/Batch

* lint

Author: mmetc

.github/workflows/tests.yml

@@ -34,6 +34,6 @@ jobs:
     - name: golangci-lint
       uses: golangci/golangci-lint-action@4afd733a84b1f43292c63897423277bb7f4313a9 # v8.0.0
       with:
-        version: v2.1
+        version: v2.4
         args: --issues-exit-code=1 --timeout 10m
         only-new-issues: false

.golangci.yml

@@ -11,7 +11,7 @@ linters:
     - inamedparam           # reports interfaces with unnamed method parameters
     - wrapcheck             # Checks that errors returned from external packages are wrapped
     - err113                # Go linter to check the errors handling expressions
-    #- noinlineerr
+    - noinlineerr
     - paralleltest          # Detects missing usage of t.Parallel() method in your Go test
     - testpackage           # linter that makes you use a separate _test package
     - exhaustruct           # Checks if all structure fields are initialized
@@ -104,15 +104,15 @@ linters:
             - 43
         - name: defer
           disabled: true
-        #- name: enforce-switch-style
-        #  disabled: true
+        - name: enforce-switch-style
+          disabled: true
         - name: flag-parameter
           disabled: true
         - name: function-length
           arguments:
             # lower this after refactoring
             - 104
-            - 196
+            - 198
         - name: line-length-limit
           arguments:
             # lower this after refactoring

cstest/aws.go

@@ -5,6 +5,7 @@ import (
 	"os"
 	"strings"
 	"testing"
+	"time"
 )
 
 // SetAWSTestEnv sets the environment variables required to run tests against LocalStack,
@@ -30,7 +31,9 @@ func SetAWSTestEnv(t *testing.T) string {
 	t.Setenv("AWS_ACCESS_KEY_ID", "test")
 	t.Setenv("AWS_SECRET_ACCESS_KEY", "test")
 
-	_, err := net.Dial("tcp", strings.TrimPrefix(endpoint, "http://"))
+	dialer := &net.Dialer{Timeout: 2 * time.Second}
+
+	_, err := dialer.DialContext(t.Context(), "tcp", strings.TrimPrefix(endpoint, "http://"))
 	if err != nil {
 		t.Fatalf("%s: make sure localstack is running and retry", err)
 	}

cstime/cstime.go

@@ -8,7 +8,7 @@ import (
 	"time"
 )
 
-// ParseDuration parses a string representing a duration, and supports
+// ParseDurationWithDays parses a string representing a duration, and supports
 // days as a unit (e.g., "2d", "2d3h", "24h", "2h45m").
 func ParseDurationWithDays(input string) (time.Duration, error) {
 	var total time.Duration
@@ -55,6 +55,7 @@ func ParseDurationWithDays(input string) (time.Duration, error) {
 		if err != nil {
 			return 0, err
 		}
+
 		total += dur
 	}
 

cstime/duration.go

@@ -20,11 +20,14 @@ type DurationWithDays time.Duration
 // UnmarshalText implements encoding.TextUnmarshaler (used by YAML/JSON libs).
 func (d *DurationWithDays) UnmarshalText(text []byte) error {
 	s := string(text)
+
 	dur, err := ParseDurationWithDays(s)
 	if err != nil {
 		return err
 	}
+
 	*d = DurationWithDays(dur)
+
 	return nil
 }
 
@@ -39,6 +42,7 @@ func (d *DurationWithDays) UnmarshalJSON(b []byte) error {
 	if err := json.Unmarshal(b, &s); err != nil {
 		return err
 	}
+
 	return d.UnmarshalText([]byte(s))
 }
 
@@ -48,6 +52,7 @@ func (d DurationWithDays) MarshalJSON() ([]byte, error) {
 	if err != nil {
 		return nil, err
 	}
+
 	return json.Marshal(string(s))
 }
 

cstime/duration_test.go

@@ -59,11 +59,14 @@ func TestUnmarshalText(t *testing.T) {
 	for _, tc := range tests {
 		t.Run(tc.name, func(t *testing.T) {
 			var d DurationWithDays
+
 			err := d.UnmarshalText([]byte(tc.input))
 			cstest.RequireErrorContains(t, err, tc.wantErr)
+
 			if tc.wantErr != "" {
 				return
 			}
+
 			assert.Equal(t, tc.want, time.Duration(d))
 		})
 	}
@@ -115,6 +118,7 @@ func TestDuration_UnmarshalJSON(t *testing.T) {
 	jsonInput := `{"timeout": "2d3h45m"}`
 
 	var cfg Config
+
 	err := json.Unmarshal([]byte(jsonInput), &cfg)
 	require.NoError(t, err)
 
@@ -130,6 +134,7 @@ func TestDuration_UnmarshalYAML(t *testing.T) {
 	yamlInput := "timeout: 2d3h45m"
 
 	var cfg Config
+
 	err := yaml.Unmarshal([]byte(yamlInput), &cfg)
 	require.NoError(t, err)
 

csyaml/keys.go

@@ -30,8 +30,10 @@ func GetDocumentKeys(r io.Reader) ([][]string, error) {
 			if errors.Is(err, io.EOF) {
 				break
 			}
+
 			return nil, fmt.Errorf("position %d: %s", idx, yaml.FormatError(err, false, false))
 		}
+
 		keys := []string{}
 
 		// Only mapping nodes become MapSlice with UseOrderedMap()

csyaml/merge.go

@@ -22,7 +22,9 @@ import (
 // Always runs in strict mode: type mismatches or duplicate keys cause an error.
 func Merge(inputs [][]byte) (*bytes.Buffer, error) {
 	var merged any
+
 	hasContent := false
+
 	for idx, data := range inputs {
 		dec := yaml.NewDecoder(bytes.NewReader(data), yaml.UseOrderedMap(), yaml.Strict())
 
@@ -31,8 +33,10 @@ func Merge(inputs [][]byte) (*bytes.Buffer, error) {
 			if errors.Is(err, io.EOF) {
 				continue
 			}
+
 			return nil, fmt.Errorf("decoding document %d: %s", idx, yaml.FormatError(err, false, false))
 		}
+
 		hasContent = true
 
 		mergedValue, err := mergeValue(merged, value)
@@ -91,8 +95,10 @@ func mergeValue(into, from any) (any, error) {
 func mergeMap(into, from yaml.MapSlice) (yaml.MapSlice, error) {
 	out := make(yaml.MapSlice, len(into))
 	copy(out, into)
+
 	for _, item := range from {
 		matched := false
+
 		for i, existing := range out {
 			if !reflect.DeepEqual(existing.Key, item.Key) {
 				continue
@@ -102,13 +108,16 @@ func mergeMap(into, from yaml.MapSlice) (yaml.MapSlice, error) {
 			if err != nil {
 				return nil, err
 			}
+
 			out[i].Value = mergedVal
 			matched = true
 		}
+
 		if !matched {
 			out = append(out, yaml.MapItem{Key: item.Key, Value: item.Value})
 		}
 	}
+
 	return out, nil
 }
 
@@ -126,8 +135,10 @@ func describe(i any) string {
 	if isMapping(i) {
 		return "mapping"
 	}
+
 	if isSequence(i) {
 		return "sequence"
 	}
+
 	return "scalar"
 }

csyaml/merge_test.go

@@ -68,6 +68,7 @@ func TestMergeYAML(t *testing.T) {
 
 			buf, err := csyaml.Merge(bs)
 			cstest.RequireErrorContains(t, err, tc.wantErr)
+
 			if tc.wantErr != "" {
 				require.Nil(t, buf)
 				return

csyaml/splityaml.go

@@ -34,6 +34,7 @@ func SplitDocumentsDecEnc(r io.Reader) ([][]byte, error) {
 
 		enc := yaml.NewEncoder(&buf)
 		enc.SetIndent(2)
+
 		if err := enc.Encode(&node); err != nil {
 			return nil, fmt.Errorf("encode doc %d: %w", idx, err)
 		}