Add golangci-lint

.github/workflows/golangci-lint.yml

@@ -0,0 +1,40 @@
+name: golangci-lint
+on:
+  push:
+    branches:
+      - dev
+      - main
+  pull_request:
+    branches:
+      - dev
+      - main
+permissions:
+  contents: read
+  # Optional: allow read access to pull request. Use with `only-new-issues` option.
+  # pull-requests: read
+jobs:
+  golangci:
+    strategy:
+      matrix:
+        go: [1.17]
+        os: [ubuntu-latest, windows-latest, macos-latest]
+    name: lint
+    runs-on: ${{ matrix.os }}
+    steps:
+      - uses: actions/setup-go@v3
+        with:
+          go-version: ${{ matrix.go }}
+      - uses: actions/checkout@v2
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v2
+        with:
+          # Required: the version of golangci-lint is required and must be specified without patch version: we always use the latest patch version.
+          version: v1.46
+          # Optional: working directory, useful for monorepos
+          # working-directory: somedir
+
+          # Optional: golangci-lint command line arguments.
+          args: --tests=false --max-issues-per-linter=0 --skip-files=azbfs/zz_generated_* --exclude=S1008 --max-same-issues=0 --timeout 5m0s
+
+          # Optional: show only new issues if it's a pull request. The default value is `false`.
+          # only-new-issues: true

azbfs/zc_credential_anonymous.go

@@ -12,13 +12,16 @@ type Credential interface {
 	credentialMarker()
 }
 
+//nolint:unused
 type credentialFunc pipeline.FactoryFunc
 
+//nolint:unused
 func (f credentialFunc) New(next pipeline.Policy, po *pipeline.PolicyOptions) pipeline.Policy {
 	return f(next, po)
 }
 
 // credentialMarker is a package-internal method that exists just to satisfy the Credential interface.
+//nolint:unused
 func (credentialFunc) credentialMarker() {}
 
 //////////////////////////////
@@ -36,11 +39,15 @@ type anonymousCredentialPolicyFactory struct {
 }
 
 // New creates a credential policy object.
+//
+//nolint:unused
 func (f *anonymousCredentialPolicyFactory) New(next pipeline.Policy, po *pipeline.PolicyOptions) pipeline.Policy {
 	return &anonymousCredentialPolicy{next: next}
 }
 
 // credentialMarker is a package-internal method that exists just to satisfy the Credential interface.
+//
+//nolint:unused
 func (*anonymousCredentialPolicyFactory) credentialMarker() {}
 
 // anonymousCredentialPolicy is the credential's policy object.

azbfs/zc_credential_shared_key.go

@@ -62,25 +62,19 @@ func (f *SharedKeyCredential) New(next pipeline.Policy, po *pipeline.PolicyOptio
 // credentialMarker is a package-internal method that exists just to satisfy the Credential interface.
 func (*SharedKeyCredential) credentialMarker() {}
 
-// Constants ensuring that header names are correctly spelled and consistently cased.
 const (
-	headerAuthorization      = "Authorization"
-	headerCacheControl       = "Cache-Control"
-	headerContentEncoding    = "Content-Encoding"
-	headerContentDisposition = "Content-Disposition"
-	headerContentLanguage    = "Content-Language"
-	headerContentLength      = "Content-Length"
-	headerContentMD5         = "Content-MD5"
-	headerContentType        = "Content-Type"
-	headerDate               = "Date"
-	headerIfMatch            = "If-Match"
-	headerIfModifiedSince    = "If-Modified-Since"
-	headerIfNoneMatch        = "If-None-Match"
-	headerIfUnmodifiedSince  = "If-Unmodified-Since"
-	headerRange              = "Range"
-	headerUserAgent          = "User-Agent"
-	headerXmsDate            = "x-ms-date"
-	headerXmsVersion         = "x-ms-version"
+	headerAuthorization     = "Authorization"
+	headerContentEncoding   = "Content-Encoding"
+	headerContentLanguage   = "Content-Language"
+	headerContentLength     = "Content-Length"
+	headerContentMD5        = "Content-MD5"
+	headerContentType       = "Content-Type"
+	headerIfMatch           = "If-Match"
+	headerIfModifiedSince   = "If-Modified-Since"
+	headerIfNoneMatch       = "If-None-Match"
+	headerIfUnmodifiedSince = "If-Unmodified-Since"
+	headerRange             = "Range"
+	headerXmsDate           = "x-ms-date"
 )
 
 // ComputeHMACSHA256 generates a hash signature for an HTTP request or for a SAS.
@@ -143,7 +137,7 @@ func buildCanonicalizedHeader(headers http.Header) string {
 		ch.WriteRune(':')
 		ch.WriteString(strings.Join(cm[key], ","))
 	}
-	return string(ch.Bytes())
+	return ch.String()
 }
 
 func (f *SharedKeyCredential) buildCanonicalizedResource(u *url.URL) string {
@@ -190,5 +184,5 @@ func (f *SharedKeyCredential) buildCanonicalizedResource(u *url.URL) string {
 			cr.WriteString("\n" + paramName + ":" + strings.Join(paramValues, ","))
 		}
 	}
-	return string(cr.Bytes())
+	return cr.String()
 }

azbfs/zc_mmf_unix.go

@@ -1,3 +1,4 @@
+//go:build linux || darwin
 // +build linux darwin
 
 package azbfs
@@ -7,8 +8,10 @@ import (
 	"syscall"
 )
 
+//nolint:unused
 type mmf []byte
 
+//nolint:unused,deadcode
 func newMMF(file *os.File, writable bool, offset int64, length int) (mmf, error) {
 	prot, flags := syscall.PROT_READ, syscall.MAP_SHARED // Assume read-only
 	if writable {
@@ -18,6 +21,7 @@ func newMMF(file *os.File, writable bool, offset int64, length int) (mmf, error)
 	return mmf(addr), err
 }
 
+//nolint:unused
 func (m *mmf) unmap() {
 	err := syscall.Munmap(*m)
 	*m = nil

azbfs/zc_mmf_windows.go

@@ -7,8 +7,10 @@ import (
 	"unsafe"
 )
 
+//nolint:unused
 type mmf []byte
 
+//nolint:deadcode,unused
 func newMMF(file *os.File, writable bool, offset int64, length int) (mmf, error) {
 	prot, access := uint32(syscall.PAGE_READONLY), uint32(syscall.FILE_MAP_READ) // Assume read-only
 	if writable {
@@ -19,8 +21,8 @@ func newMMF(file *os.File, writable bool, offset int64, length int) (mmf, error)
 	if hMMF == 0 {
 		return nil, os.NewSyscallError("CreateFileMapping", errno)
 	}
-	defer syscall.CloseHandle(hMMF)
-	addr, errno := syscall.MapViewOfFile(hMMF, access, uint32(offset>>32), uint32(offset&0xffffffff), uintptr(length))
+	defer syscall.CloseHandle(hMMF) //nolint:errcheck
+	addr, _ := syscall.MapViewOfFile(hMMF, access, uint32(offset>>32), uint32(offset&0xffffffff), uintptr(length))
 	m := mmf{}
 	h := (*reflect.SliceHeader)(unsafe.Pointer(&m))
 	h.Data = addr
@@ -29,6 +31,7 @@ func newMMF(file *os.File, writable bool, offset int64, length int) (mmf, error)
 	return m, nil
 }
 
+//nolint:unused
 func (m *mmf) unmap() {
 	addr := uintptr(unsafe.Pointer(&(([]byte)(*m)[0])))
 	*m = mmf{}

azbfs/zc_policy_request_log.go

@@ -76,9 +76,9 @@ func NewRequestLogPolicyFactory_Deprecated(o RequestLogOptions) pipeline.Factory
 				sc := response.Response().StatusCode
 				if ((sc >= 400 && sc <= 499) && sc != http.StatusNotFound && sc != http.StatusConflict && sc != http.StatusPreconditionFailed && sc != http.StatusRequestedRangeNotSatisfiable) || (sc >= 500 && sc <= 599) {
 					logLevel, forceLog = pipeline.LogError, !o.SyslogDisabled // Promote to Error any 4xx (except those listed is an error) or any 5xx
-				} else {
-					// For other status codes, we leave the level as is.
 				}
+				// For other status codes, we leave the level as is.
+
 			} else { // This error did not get an HTTP response from the service; upgrade the severity to Error
 				logLevel, forceLog = pipeline.LogError, !o.SyslogDisabled
 			}

azbfs/zc_policy_retry.go

@@ -3,7 +3,6 @@ package azbfs
 import (
 	"context"
 	"io"
-	"io/ioutil"
 	"math/rand"
 	"net"
 	"net/http"
@@ -134,7 +133,7 @@ func (o RetryOptions) calcDelay(try int32) time.Duration { // try is >=1; never
 // Note: forked from the standard package url.go
 // The content is exactly the same but the spaces are encoded as %20 instead of +
 // TODO: remove after the service fix
-// Encode encodes the values into ``URL encoded'' form
+// Encode encodes the values into “URL encoded” form
 // ("bar=baz&foo=quux") sorted by key.
 func alternativeEncode(v url.Values) string {
 	if v == nil {
@@ -217,7 +216,7 @@ func NewRetryPolicyFactory(o RetryOptions) pipeline.Factory {
 				// Set the server-side timeout query parameter "timeout=[seconds]"
 				timeout := int32(o.TryTimeout.Seconds()) // Max seconds per try
 				if deadline, ok := ctx.Deadline(); ok {  // If user's ctx has a deadline, make the timeout the smaller of the two
-					t := int32(deadline.Sub(time.Now()).Seconds()) // Duration from now until user's ctx reaches its deadline
+					t := int32(time.Until(deadline).Seconds()) // Duration from now until user's ctx reaches its deadline
 					logf("MaxTryTimeout=%d secs, TimeTilDeadline=%d sec\n", timeout, t)
 					if t < timeout {
 						timeout = t
@@ -254,7 +253,7 @@ func NewRetryPolicyFactory(o RetryOptions) pipeline.Factory {
 					action = "Retry: Secondary URL returned 404"
 				case err != nil:
 					// NOTE: Protocol Responder returns non-nil if REST API returns invalid status code for the invoked operation
-					if netErr, ok := err.(net.Error); ok && (netErr.Temporary() || netErr.Timeout()) {
+					if netErr, ok := err.(net.Error); ok && (netErr.Temporary() || netErr.Timeout()) { //nolint:staticcheck
 						action = "Retry: net.Error and Temporary() or Timeout()"
 					} else if err == io.ErrUnexpectedEOF {
 						// Some of our methods under the zz_ files do use io.Copy and other related methods that can throw an unexpectedEOF.
@@ -284,7 +283,7 @@ func NewRetryPolicyFactory(o RetryOptions) pipeline.Factory {
 				}
 				if response != nil && response.Response() != nil {
 					// If we're going to retry and we got a previous response, then flush its body to avoid leaking its TCP connection
-					io.Copy(ioutil.Discard, response.Response().Body)
+					_, _ = io.Copy(io.Discard, response.Response().Body)
 					response.Response().Body.Close()
 				}
 				// If retrying, cancel the current per-try timeout context

azbfs/zc_sas_query_params.go

@@ -200,7 +200,7 @@ func newSASQueryParameters(values url.Values, deleteSASParametersFromValues bool
 		case "st":
 			p.startTime, p.stTimeFormat, _ = parseSASTimeString(val)
 		case "se":
-			p.expiryTime, p.stTimeFormat, _ = parseSASTimeString(val)
+			p.expiryTime, p.seTimeFormat, _ = parseSASTimeString(val)
 		case "sip":
 			dashIndex := strings.Index(val, "-")
 			if dashIndex == -1 {
@@ -255,7 +255,7 @@ func (p *SASQueryParameters) addToValues(v url.Values) url.Values {
 		v.Add("st", formatSASTime(&p.startTime, p.stTimeFormat))
 	}
 	if !p.expiryTime.IsZero() {
-		v.Add("se", formatSASTime(&p.expiryTime, p.stTimeFormat))
+		v.Add("se", formatSASTime(&p.expiryTime, p.seTimeFormat))
 	}
 	if len(p.ipRange.Start) > 0 {
 		v.Add("sip", p.ipRange.String())

azbfs/zc_util_validate.go

@@ -58,7 +58,7 @@ func validateSeekableStreamAt0AndGetCount(body io.ReadSeeker) int64 {
 	if err != nil {
 		panic("failed to seek stream")
 	}
-	body.Seek(0, io.SeekStart)
+	_, _ = body.Seek(0, io.SeekStart)
 	return count
 }
 

azbfs/zc_uuid.go

@@ -7,6 +7,7 @@ import (
 )
 
 // The UUID reserved variants.
+//nolint:deadcode,varcheck
 const (
 	reservedNCS       byte = 0x80
 	reservedRFC4122   byte = 0x40
@@ -39,6 +40,7 @@ func (u uuid) String() string {
 
 // ParseUUID parses a string formatted as "003020100-0504-0706-0809-0a0b0c0d0e0f"
 // or "{03020100-0504-0706-0809-0a0b0c0d0e0f}" into a UUID.
+//nolint:unused,deadcode
 func parseUUID(uuidStr string) uuid {
 	char := func(hexString string) byte {
 		i, _ := strconv.ParseUint(hexString, 16, 8)
@@ -75,6 +77,7 @@ func parseUUID(uuidStr string) uuid {
 	return uuidVal
 }
 
+//nolint:unused
 func (u uuid) bytes() []byte {
 	return u[:]
 }

azbfs/zt_url_file_test.go

@@ -16,7 +16,6 @@ import (
 	"net/url"
 	//"strings"
 
-	"io/ioutil"
 	"net/http"
 
 	"github.com/Azure/azure-storage-azcopy/v10/azbfs"
@@ -213,7 +212,7 @@ func (s *FileURLSuite) TestFileGetProperties(c *chk.C) {
 //	c.Assert(resp.ContentType(), chk.Equals, "application/octet-stream")
 //	c.Assert(resp.Status(), chk.Not(chk.Equals), "")
 //
-//	download, err := ioutil.ReadAll(resp.Response().Body)
+//	download, err := io.ReadAll(resp.Response().Body)
 //	c.Assert(err, chk.IsNil)
 //	c.Assert(download, chk.DeepEquals, contentD[:1024])
 //}
@@ -250,14 +249,14 @@ func (s *FileURLSuite) TestUnexpectedEOFRecovery(c *chk.C) {
 	// Verify that we can inject errors first.
 	reader := dResp.Body(azbfs.InjectErrorInRetryReaderOptions(errors.New("unrecoverable error")))
 
-	_, err = ioutil.ReadAll(reader)
+	_, err = io.ReadAll(reader)
 	c.Assert(err, chk.NotNil)
 	c.Assert(err.Error(), chk.Equals, "unrecoverable error")
 
 	// Then inject the retryable error.
 	reader = dResp.Body(azbfs.InjectErrorInRetryReaderOptions(io.ErrUnexpectedEOF))
 
-	buf, err := ioutil.ReadAll(reader)
+	buf, err := io.ReadAll(reader)
 	c.Assert(err, chk.IsNil)
 	c.Assert(buf, chk.DeepEquals, contentD)
 }
@@ -309,7 +308,7 @@ func (s *FileURLSuite) TestUploadDownloadRoundTrip(c *chk.C) {
 	c.Assert(resp.Status(), chk.Not(chk.Equals), "")
 
 	// Verify the partial data
-	download, err := ioutil.ReadAll(resp.Response().Body)
+	download, err := io.ReadAll(resp.Response().Body)
 	c.Assert(err, chk.IsNil)
 	c.Assert(download, chk.DeepEquals, contentD1[:1024])
 
@@ -325,7 +324,7 @@ func (s *FileURLSuite) TestUploadDownloadRoundTrip(c *chk.C) {
 	c.Assert(resp.Version(), chk.Not(chk.Equals), "")
 
 	// Verify the entire content
-	download, err = ioutil.ReadAll(resp.Response().Body)
+	download, err = io.ReadAll(resp.Response().Body)
 	c.Assert(err, chk.IsNil)
 	c.Assert(download[:2048], chk.DeepEquals, contentD1[:])
 	c.Assert(download[2048:], chk.DeepEquals, contentD2[:])

azbfs/zz_response_model.go

@@ -295,9 +295,8 @@ func (dlr *DirectoryListResponse) Directories() []string {
 func (dlr *DirectoryListResponse) FilesAndDirectories() []Path {
 	var entities []Path
 	lSchema := (PathList)(*dlr)
-	for _, path := range lSchema.Paths {
-		entities = append(entities, path)
-	}
+	// Assuming this file is not generated based on the azbfs swagger README which states generated files prefix = zz_generated.
+	entities = append(entities, lSchema.Paths...)
 	return entities
 }
 

azure-pipelines.yml

@@ -31,15 +31,6 @@ jobs:
         inputs:
           version: '1.19.2'
 
-      - script: |
-          curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s v1.46.2
-          echo 'Installation complete' 
-          ./bin/golangci-lint --version 
-          ./bin/golangci-lint run e2etest
-        displayName: 'Golang Lint Check - Linux'
-        workingDirectory: $(System.DefaultWorkingDirectory)
-        condition: eq(variables.type, 'linux')
-
       - script: |
           echo 'Running GO Vet'
           go vet