Merge branch 'sh-return-413-for-s3-artifact-uploads' into 'master'

Return 413 HTTP status for S3 uploads if max upload limit is reached

See merge request gitlab-org/gitlab-workhorse!655

changelogs/unreleased/sh-return-413-for-s3-artifact-uploads.yml

+---
+title: Return 413 HTTP status for S3 uploads if max upload limit is reached
+merge_request: 655
+author:
+type: fixed

internal/filestore/file_handler_test.go

@@ -293,6 +293,31 @@ func TestSaveFile(t *testing.T) {
 }
 
 func TestSaveFileWithS3WorkhorseClient(t *testing.T) {
+	tests := []struct {
+		name        string
+		objectSize  int64
+		maxSize     int64
+		expectedErr error
+	}{
+		{
+			name:       "known size with no limit",
+			objectSize: test.ObjectSize,
+		},
+		{
+			name:       "unknown size with no limit",
+			objectSize: -1,
+		},
+		{
+			name:        "unknown object size with limit",
+			objectSize:  -1,
+			maxSize:     test.ObjectSize - 1,
+			expectedErr: filestore.ErrEntityTooLarge,
+		},
+	}
+
+	for _, tc := range tests {
+		t.Run(tc.name, func(t *testing.T) {
+
 			s3Creds, s3Config, sess, ts := test.SetupS3(t, "")
 			defer ts.Close()
 
@@ -310,12 +335,20 @@ func TestSaveFileWithS3WorkhorseClient(t *testing.T) {
 					S3Credentials: s3Creds,
 					S3Config:      s3Config,
 				},
+				MaximumSize: tc.maxSize,
 			}
 
-	_, err := filestore.SaveFileFromReader(ctx, strings.NewReader(test.ObjectContent), test.ObjectSize, &opts)
-	require.NoError(t, err)
+			_, err := filestore.SaveFileFromReader(ctx, strings.NewReader(test.ObjectContent), tc.objectSize, &opts)
 
+			if tc.expectedErr == nil {
+				require.NoError(t, err)
 				test.S3ObjectExists(t, sess, s3Config, remoteObject, test.ObjectContent)
+			} else {
+				require.Equal(t, tc.expectedErr, err)
+				test.S3ObjectDoesNotExist(t, sess, s3Config, remoteObject)
+			}
+		})
+	}
 }
 
 func TestSaveFileWithAzureWorkhorseClient(t *testing.T) {

internal/objectstore/s3_object.go

@@ -6,6 +6,7 @@ import (
 	"time"
 
 	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/awserr"
 	"github.com/aws/aws-sdk-go/service/s3"
 	"github.com/aws/aws-sdk-go/service/s3/s3manager"
 	"gitlab.com/gitlab-org/labkit/log"
@@ -63,7 +64,8 @@ func (s *S3Object) Upload(ctx context.Context, r io.Reader) error {
 	_, err = uploader.UploadWithContext(ctx, input)
 	if err != nil {
 		log.WithError(err).Error("error uploading S3 session")
-		return err
+		// Get the root cause, such as ErrEntityTooLarge, so we can return the proper HTTP status code
+		return unwrapAWSError(err)
 	}
 
 	s.uploaded = true
@@ -106,3 +108,12 @@ func (s *S3Object) Delete() {
 		log.WithError(err).Error("error deleting S3 object", err)
 	}
 }
+
+// This is needed until https://github.com/aws/aws-sdk-go/issues/2820 is closed.
+func unwrapAWSError(e error) error {
+	if awsErr, ok := e.(awserr.Error); ok {
+		return unwrapAWSError(awsErr.OrigErr())
+	}
+
+	return e
+}

internal/objectstore/s3_object_test.go

@@ -3,6 +3,7 @@ package objectstore_test
 import (
 	"context"
 	"fmt"
+	"io"
 	"io/ioutil"
 	"os"
 	"path/filepath"
@@ -11,6 +12,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/aws/aws-sdk-go/aws/awserr"
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/s3"
 	"github.com/stretchr/testify/require"
@@ -21,6 +23,15 @@ import (
 	"gitlab.com/gitlab-org/gitlab-workhorse/internal/testhelper"
 )
 
+type failedReader struct {
+	io.Reader
+}
+
+func (r *failedReader) Read(p []byte) (int, error) {
+	origErr := fmt.Errorf("entity is too large")
+	return 0, awserr.New("Read", "read failed", origErr)
+}
+
 func TestS3ObjectUpload(t *testing.T) {
 	testCases := []struct {
 		encryption string
@@ -141,4 +152,23 @@ func TestS3ObjectUploadCancel(t *testing.T) {
 
 	_, err = object.Consume(ctx, strings.NewReader(test.ObjectContent), deadline)
 	require.Error(t, err)
+	require.Equal(t, "context canceled", err.Error())
+}
+
+func TestS3ObjectUploadLimitReached(t *testing.T) {
+	creds, config, _, ts := test.SetupS3(t, "")
+	defer ts.Close()
+
+	deadline := time.Now().Add(testTimeout)
+	tmpDir, err := ioutil.TempDir("", "workhorse-test-")
+	require.NoError(t, err)
+	defer os.Remove(tmpDir)
+
+	objectName := filepath.Join(tmpDir, "s3-test-data")
+	object, err := objectstore.NewS3Object(objectName, creds, config)
+	require.NoError(t, err)
+
+	_, err = object.Consume(context.Background(), &failedReader{}, deadline)
+	require.Error(t, err)
+	require.Equal(t, "entity is too large", err.Error())
 }