Apply go fix modernizers

Author: bobheadxi

cmd/src/code_intel_upload_vendored.go

@@ -176,7 +176,6 @@ func uploadMultipartIndexParts(ctx context.Context, httpClient upload.Client, op
 	}
 
 	for i, reader := range readers {
-		i, reader := i, reader
 
 		pool.Go(func(ctx context.Context) error {
 			// Determine size of this reader. If we're not the last reader in the slice,

cmd/src/snapshot_upload.go

@@ -292,8 +292,6 @@ func uploadFilesToBucket(client *gcsClient, args *uploadArgs, openedFiles []uplo
 	// Upload each file in parallel
 	for fileIndex, openedFile := range openedFiles {
 
-		openedFile := openedFile
-
 		uploadPool.Go(func(ctx context.Context) error {
 			progressFn := func(bytesWritten int64) { progress.SetValue(fileIndex, float64(bytesWritten)) }
 

internal/api/api.go

@@ -12,6 +12,7 @@ import (
 	"net/url"
 	"os"
 	"runtime"
+	"strings"
 
 	ioaux "github.com/jig/teereadcloser"
 	"github.com/kballard/go-shellquote"
@@ -371,18 +372,19 @@ func (r *request) curlCmd() (string, error) {
 		return "", err
 	}
 
-	s := "curl \\\n"
+	var s strings.Builder
+	s.WriteString("curl \\\n")
 	if r.client.opts.AccessToken != "" {
-		s += fmt.Sprintf("   %s \\\n", shellquote.Join("-H", "Authorization: token "+r.client.opts.AccessToken))
+		s.WriteString(fmt.Sprintf("   %s \\\n", shellquote.Join("-H", "Authorization: token "+r.client.opts.AccessToken)))
 	}
 	// Preserve overrides if Content-Type is set
 	if r.client.opts.AdditionalHeaders["Content-Type"] == "" {
 		r.client.opts.AdditionalHeaders["Content-Type"] = "application/json"
 	}
 	for k, v := range r.client.opts.AdditionalHeaders {
-		s += fmt.Sprintf("   %s \\\n", shellquote.Join("-H", k+": "+v))
+		s.WriteString(fmt.Sprintf("   %s \\\n", shellquote.Join("-H", k+": "+v)))
 	}
-	s += fmt.Sprintf("   %s \\\n", shellquote.Join("-d", string(data)))
-	s += fmt.Sprintf("   %s", shellquote.Join(r.client.opts.EndpointURL.JoinPath(".api/graphql").String()))
-	return s, nil
+	s.WriteString(fmt.Sprintf("   %s \\\n", shellquote.Join("-d", string(data))))
+	s.WriteString(fmt.Sprintf("   %s", shellquote.Join(r.client.opts.EndpointURL.JoinPath(".api/graphql").String())))
+	return s.String(), nil
 }

internal/api/test_unix_socket_server.go

@@ -57,9 +57,7 @@ func StartUnixSocketServer(socketPath string) (*Server, error) {
 		StopChan: make(chan struct{}),
 	}
 
-	server.Wg.Add(1)
-	go func() {
-		defer server.Wg.Done()
+	server.Wg.Go(func() {
 		for {
 			conn, err := server.Listener.Accept()
 			if err != nil {
@@ -96,7 +94,7 @@ func StartUnixSocketServer(socketPath string) (*Server, error) {
 				}
 			}(conn)
 		}
-	}()
+	})
 
 	return server, nil
 }

internal/batches/service/service.go

@@ -337,9 +337,7 @@ func (svc *Service) EnsureDockerImages(
 	}
 	var wg sync.WaitGroup
 	for i := 0; i < parallelism; i++ {
-		wg.Add(1)
-		go func() {
-			defer wg.Done()
+		wg.Go(func() {
 			for {
 				select {
 				case <-workerCtx.Done():
@@ -363,7 +361,7 @@ func (svc *Service) EnsureDockerImages(
 					}
 				}
 			}
-		}()
+		})
 	}
 
 	go func() {