bump transfer.sh-web dep

Dockerfile

@@ -18,7 +18,7 @@ ARG PUID=5000 \
     PGID=5000 \
     RUNAS
 
-RUN mkdir -p /tmp/useradd /tmp/empty && \
+RUN mkdir -p /tmp/useradd && \
     if [ ! -z "$RUNAS" ]; then \
     echo "${RUNAS}:x:${PUID}:${PGID}::/nonexistent:/sbin/nologin" >> /tmp/useradd/passwd && \
     echo "${RUNAS}:!:::::::" >> /tmp/useradd/shadow && \
@@ -29,7 +29,6 @@ FROM scratch AS final
 LABEL maintainer="Andrea Spacca <andrea.spacca@gmail.com>"
 ARG RUNAS
 
-COPY --from=build /tmp/empty /tmp
 COPY --from=build /tmp/useradd/* /etc/
 COPY --from=build --chown=${RUNAS}  /go/bin/transfersh /go/bin/transfersh
 COPY --from=build /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/ca-certificates.crt

README.md

@@ -12,7 +12,7 @@ The service at transfersh.com is of unknown origin and reported as cloud malware
 
 ### Upload:
 ```bash
-$ curl -v --upload-file ./hello.txt https://transfer.sh/hello.txt
+$ curl --upload-file ./hello.txt https://transfer.sh/hello.txt
 ```
 
 ### Encrypt & Upload:
@@ -53,9 +53,8 @@ $ curl --upload-file ./hello.txt https://transfer.sh/hello.txt -H "Max-Days: 1"
 
 The URL used to request the deletion of a file and returned as a response header.
 ```bash
-curl -sD - --upload-file ./hello.txt https://transfer.sh/hello.txt | grep -i -E 'transfer\.sh|x-url-delete'
-x-url-delete: https://transfer.sh/hello.txt/BAYh0/hello.txt/PDw0NHPcqU
-https://transfer.sh/hello.txt/BAYh0/hello.txt
+curl -sD - --upload-file ./hello https://transfer.sh/hello.txt | grep 'X-Url-Delete'
+X-Url-Delete: https://transfer.sh/hello.txt/BAYh0/hello.txt/PDw0NHPcqU
 ```
 
 ## Examples
@@ -295,7 +294,7 @@ transfer()
     local curl_output
     local awk_output
 
-    du -c -k -L "${file_array[@]}" >&2
+    du --total --block-size="K" --dereference "${file_array[@]}" >&2
     # be compatible with "bash"
     if [[ "${ZSH_NAME}" == "zsh" ]]
     then

cmd/cmd.go

@@ -473,9 +473,9 @@ func New() *Cmd {
 			chunkSize := c.Int("gdrive-chunk-size") * 1024 * 1024
 
 			if clientJSONFilepath := c.String("gdrive-client-json-filepath"); clientJSONFilepath == "" {
-				panic("gdrive-client-json-filepath not set.")
+				panic("client-json-filepath not set.")
 			} else if localConfigPath := c.String("gdrive-local-config-path"); localConfigPath == "" {
-				panic("gdrive-local-config-path not set.")
+				panic("local-config-path not set.")
 			} else if basedir := c.String("basedir"); basedir == "" {
 				panic("basedir not set.")
 			} else if store, err := storage.NewGDriveStorage(clientJSONFilepath, localConfigPath, basedir, chunkSize, logger); err != nil {

go.mod

@@ -3,8 +3,7 @@ module github.com/dutchcoders/transfer.sh
 go 1.15
 
 require (
-	cloud.google.com/go/compute v1.18.0 // indirect
-	cloud.google.com/go/compute/metadata v0.2.3 // indirect
+	cloud.google.com/go v0.77.0 // indirect
 	github.com/PuerkitoBio/ghost v0.0.0-20160324114900-206e6e460e14
 	github.com/VojtechVitek/ratelimit v0.0.0-20160722140851-dc172bc0f6d2
 	github.com/aws/aws-sdk-go v1.37.14
@@ -16,8 +15,6 @@ require (
 	github.com/fatih/color v1.10.0
 	github.com/garyburd/redigo v1.6.2 // indirect
 	github.com/golang/gddo v0.0.0-20210115222349-20d68f94ee1f
-	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
-	github.com/googleapis/enterprise-certificate-proxy v0.2.2 // indirect
 	github.com/gorilla/handlers v1.5.1
 	github.com/gorilla/mux v1.8.0
 	github.com/gorilla/securecookie v1.1.1 // indirect
@@ -27,13 +24,12 @@ require (
 	github.com/skip2/go-qrcode v0.0.0-20200617195104-da1b6568686e
 	github.com/tomasen/realip v0.0.0-20180522021738-f0c99a92ddce
 	github.com/urfave/cli v1.22.5
+	go.opencensus.io v0.22.6 // indirect
 	golang.org/x/crypto v0.0.0-20220131195533-30dcbda58838
-	golang.org/x/net v0.6.0 // indirect
-	golang.org/x/oauth2 v0.5.0
-	google.golang.org/api v0.109.0
-	google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc // indirect
-	google.golang.org/grpc v1.53.0 // indirect
-	google.golang.org/protobuf v1.28.1 // indirect
+	golang.org/x/net v0.0.0-20220513224357-95641704303c // indirect
+	golang.org/x/oauth2 v0.0.0-20210218202405-ba52d332ba99
+	google.golang.org/api v0.40.0
+	google.golang.org/genproto v0.0.0-20210218151259-fe80b386bf06 // indirect
 	gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15
 	storj.io/common v0.0.0-20220405183405-ffdc3ab808c6
 	storj.io/uplink v1.8.2

server/handlers.go

@@ -36,6 +36,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"github.com/dutchcoders/transfer.sh/server/storage"
 	"html"
 	htmlTemplate "html/template"
 	"io"
@@ -53,8 +54,6 @@ import (
 	textTemplate "text/template"
 	"time"
 
-	"github.com/dutchcoders/transfer.sh/server/storage"
-
 	web "github.com/dutchcoders/transfer.sh-web"
 	"github.com/gorilla/mux"
 	"github.com/microcosm-cc/bluemonday"
@@ -152,7 +151,7 @@ func (s *Server) previewHandler(w http.ResponseWriter, r *http.Request) {
 		templatePath = "download.markdown.html"
 
 		var reader io.ReadCloser
-		if reader, _, err = s.storage.Get(r.Context(), token, filename, nil); err != nil {
+		if reader, _, err = s.storage.Get(r.Context(), token, filename); err != nil {
 			http.Error(w, err.Error(), http.StatusInternalServerError)
 			return
 		}
@@ -461,7 +460,7 @@ func (s *Server) putHandler(w http.ResponseWriter, r *http.Request) {
 
 	contentLength := r.ContentLength
 
-	defer storage.CloseCheck(r.Body)
+	defer storage.CloseCheck(r.Body.Close)
 
 	file, err := ioutil.TempFile(s.tempPath, "transfer-")
 	defer s.cleanTmpFile(file)
@@ -693,8 +692,8 @@ func (s *Server) checkMetadata(ctx context.Context, token, filename string, incr
 
 	var metadata metadata
 
-	r, _, err := s.storage.Get(ctx, token, fmt.Sprintf("%s.metadata", filename), nil)
-	defer storage.CloseCheck(r)
+	r, _, err := s.storage.Get(ctx, token, fmt.Sprintf("%s.metadata", filename))
+	defer storage.CloseCheck(r.Close)
 
 	if err != nil {
 		return metadata, err
@@ -729,8 +728,8 @@ func (s *Server) checkDeletionToken(ctx context.Context, deletionToken, token, f
 
 	var metadata metadata
 
-	r, _, err := s.storage.Get(ctx, token, fmt.Sprintf("%s.metadata", filename), nil)
-	defer storage.CloseCheck(r)
+	r, _, err := s.storage.Get(ctx, token, fmt.Sprintf("%s.metadata", filename))
+	defer storage.CloseCheck(r.Close)
 
 	if s.storage.IsNotExist(err) {
 		return errors.New("metadata doesn't exist")
@@ -807,8 +806,8 @@ func (s *Server) zipHandler(w http.ResponseWriter, r *http.Request) {
 			continue
 		}
 
-		reader, _, err := s.storage.Get(r.Context(), token, filename, nil)
-		defer storage.CloseCheck(reader)
+		reader, _, err := s.storage.Get(r.Context(), token, filename)
+		defer storage.CloseCheck(reader.Close)
 
 		if err != nil {
 			if s.storage.IsNotExist(err) {
@@ -861,10 +860,10 @@ func (s *Server) tarGzHandler(w http.ResponseWriter, r *http.Request) {
 	commonHeader(w, tarfilename)
 
 	gw := gzip.NewWriter(w)
-	defer storage.CloseCheck(gw)
+	defer storage.CloseCheck(gw.Close)
 
 	zw := tar.NewWriter(gw)
-	defer storage.CloseCheck(zw)
+	defer storage.CloseCheck(zw.Close)
 
 	for _, key := range strings.Split(files, ",") {
 		key = resolveKey(key, s.proxyPath)
@@ -877,8 +876,8 @@ func (s *Server) tarGzHandler(w http.ResponseWriter, r *http.Request) {
 			continue
 		}
 
-		reader, contentLength, err := s.storage.Get(r.Context(), token, filename, nil)
-		defer storage.CloseCheck(reader)
+		reader, contentLength, err := s.storage.Get(r.Context(), token, filename)
+		defer storage.CloseCheck(reader.Close)
 
 		if err != nil {
 			if s.storage.IsNotExist(err) {
@@ -922,7 +921,7 @@ func (s *Server) tarHandler(w http.ResponseWriter, r *http.Request) {
 	commonHeader(w, tarfilename)
 
 	zw := tar.NewWriter(w)
-	defer storage.CloseCheck(zw)
+	defer storage.CloseCheck(zw.Close)
 
 	for _, key := range strings.Split(files, ",") {
 		key = resolveKey(key, s.proxyPath)
@@ -935,8 +934,8 @@ func (s *Server) tarHandler(w http.ResponseWriter, r *http.Request) {
 			continue
 		}
 
-		reader, contentLength, err := s.storage.Get(r.Context(), token, filename, nil)
-		defer storage.CloseCheck(reader)
+		reader, contentLength, err := s.storage.Get(r.Context(), token, filename)
+		defer storage.CloseCheck(reader.Close)
 
 		if err != nil {
 			if s.storage.IsNotExist(err) {
@@ -1001,10 +1000,6 @@ func (s *Server) headHandler(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set("Connection", "close")
 	w.Header().Set("X-Remaining-Downloads", remainingDownloads)
 	w.Header().Set("X-Remaining-Days", remainingDays)
-
-	if s.storage.IsRangeSupported() {
-		w.Header().Set("Accept-Ranges", "bytes")
-	}
 }
 
 func (s *Server) getHandler(w http.ResponseWriter, r *http.Request) {
@@ -1022,16 +1017,9 @@ func (s *Server) getHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	var rng *storage.Range
-	if r.Header.Get("Range") != "" {
-		rng = storage.ParseRange(r.Header.Get("Range"))
-	}
-
 	contentType := metadata.ContentType
-	reader, contentLength, err := s.storage.Get(r.Context(), token, filename, rng)
-	defer storage.CloseCheck(reader)
-
-	rdr := io.Reader(reader)
+	reader, contentLength, err := s.storage.Get(r.Context(), token, filename)
+	defer storage.CloseCheck(reader.Close)
 
 	if s.storage.IsNotExist(err) {
 		http.Error(w, http.StatusText(http.StatusNotFound), http.StatusNotFound)
@@ -1041,30 +1029,18 @@ func (s *Server) getHandler(w http.ResponseWriter, r *http.Request) {
 		http.Error(w, "Could not retrieve file.", http.StatusInternalServerError)
 		return
 	}
-	if rng != nil {
-		cr := rng.ContentRange()
-		if cr != "" {
-			w.Header().Set("Accept-Ranges", "bytes")
-			w.Header().Set("Content-Range", cr)
-			if rng.Limit > 0 {
-				rdr = io.LimitReader(reader, int64(rng.Limit))
-			}
-		}
-	}
 
 	var disposition string
 
 	if action == "inline" {
 		disposition = "inline"
 		/*
-			metadata.ContentType is unable to determine the type of the content,
-			metadata.ContentType is unable to determine the type of the content,
-			metadata.ContentType is unable to determine the type of the content,
-			So add text/plain in this case to fix XSS related issues/
+		metadata.ContentType is unable to determine the type of the content, 
+		So add text/plain in this case to fix XSS related issues/
 		*/
 		if strings.TrimSpace(contentType) == "" {
-			contentType = "text/plain"
-		}
+		      contentType = "text/plain"
+		 }
 	} else {
 		disposition = "attachment"
 	}
@@ -1079,15 +1055,32 @@ func (s *Server) getHandler(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set("X-Remaining-Downloads", remainingDownloads)
 	w.Header().Set("X-Remaining-Days", remainingDays)
 
-	if rng != nil && rng.ContentRange() != "" {
-		w.WriteHeader(http.StatusPartialContent)
-	}
-
 	if disposition == "inline" && canContainsXSS(contentType) {
 		reader = ioutil.NopCloser(bluemonday.UGCPolicy().SanitizeReader(reader))
 	}
 
-	if _, err = io.Copy(w, rdr); err != nil {
+	if w.Header().Get("Range") != "" || strings.HasPrefix(metadata.ContentType, "video") || strings.HasPrefix(metadata.ContentType, "audio") {
+		file, err := ioutil.TempFile(s.tempPath, "range-")
+		defer s.cleanTmpFile(file)
+
+		if err != nil {
+			s.logger.Printf("%s", err.Error())
+			http.Error(w, "Error occurred copying to output stream", http.StatusInternalServerError)
+			return
+		}
+
+		_, err = io.Copy(file, reader)
+		if err != nil {
+			s.logger.Printf("%s", err.Error())
+			http.Error(w, "Error occurred copying to output stream", http.StatusInternalServerError)
+			return
+		}
+
+		http.ServeContent(w, r, filename, time.Now(), file)
+		return
+	}
+
+	if _, err = io.Copy(w, reader); err != nil {
 		s.logger.Printf("%s", err.Error())
 		http.Error(w, "Error occurred copying to output stream", http.StatusInternalServerError)
 		return

server/server.go

@@ -537,34 +537,32 @@ func (s *Server) Run() {
 	)
 
 	if !s.TLSListenerOnly {
+		srvr := &http.Server{
+			Addr:    s.ListenerString,
+			Handler: h,
+		}
+
 		listening = true
-		s.logger.Printf("starting to listen on: %v\n", s.ListenerString)
+		s.logger.Printf("listening on port: %v\n", s.ListenerString)
 
 		go func() {
-			srvr := &http.Server{
-				Addr:    s.ListenerString,
-				Handler: h,
-			}
-
-			if err := srvr.ListenAndServe(); err != nil {
-				s.logger.Fatal(err)
-			}
+			_ = srvr.ListenAndServe()
 		}()
 	}
 
 	if s.TLSListenerString != "" {
 		listening = true
-		s.logger.Printf("starting to listen for TLS on: %v\n", s.TLSListenerString)
+		s.logger.Printf("listening on port: %v\n", s.TLSListenerString)
 
 		go func() {
-			srvr := &http.Server{
+			s := &http.Server{
 				Addr:      s.TLSListenerString,
 				Handler:   h,
 				TLSConfig: s.tlsConfig,
 			}
 
-			if err := srvr.ListenAndServeTLS("", ""); err != nil {
-				s.logger.Fatal(err)
+			if err := s.ListenAndServeTLS("", ""); err != nil {
+				panic(err)
 			}
 		}()
 	}

server/storage/common.go

@@ -4,95 +4,13 @@ import (
 	"context"
 	"fmt"
 	"io"
-	"strconv"
 	"time"
-
-	"regexp"
 )
 
-type Range struct {
-	Start        uint64
-	Limit        uint64
-	contentRange string
-}
-
-// Range Reconstructs Range header and returns it
-func (r *Range) Range() string {
-	if r.Limit > 0 {
-		return fmt.Sprintf("bytes=%d-%d", r.Start, r.Start+r.Limit-1)
-	} else {
-		return fmt.Sprintf("bytes=%d-", r.Start)
-	}
-}
-
-// AcceptLength Tries to accept given range
-// returns newContentLength if range was satisfied, otherwise returns given contentLength
-func (r *Range) AcceptLength(contentLength uint64) (newContentLength uint64) {
-	newContentLength = contentLength
-	if r.Limit == 0 {
-		r.Limit = newContentLength - r.Start
-	}
-	if contentLength < r.Start {
-		return
-	}
-	if r.Limit > contentLength-r.Start {
-		return
-	}
-	r.contentRange = fmt.Sprintf("bytes %d-%d/%d", r.Start, r.Start+r.Limit-1, contentLength)
-	newContentLength = r.Limit
-	return
-}
-
-func (r *Range) SetContentRange(cr string) {
-	r.contentRange = cr
-}
-
-// Returns accepted Content-Range header. If range wasn't accepted empty string is returned
-func (r *Range) ContentRange() string {
-	return r.contentRange
-}
-
-var rexp *regexp.Regexp = regexp.MustCompile(`^bytes=([0-9]+)-([0-9]*)$`)
-
-// Parses HTTP Range header and returns struct on success
-// only bytes=start-finish supported
-func ParseRange(rng string) *Range {
-	if rng == "" {
-		return nil
-	}
-
-	matches := rexp.FindAllStringSubmatch(rng, -1)
-	if len(matches) != 1 || len(matches[0]) != 3 {
-		return nil
-	}
-	if len(matches[0][0]) != len(rng) || len(matches[0][1]) == 0 {
-		return nil
-	}
-
-	start, err := strconv.ParseUint(matches[0][1], 10, 64)
-	if err != nil {
-		return nil
-	}
-
-	if len(matches[0][2]) == 0 {
-		return &Range{Start: start, Limit: 0}
-	}
-
-	finish, err := strconv.ParseUint(matches[0][2], 10, 64)
-	if err != nil {
-		return nil
-	}
-	if finish < start || finish+1 < finish {
-		return nil
-	}
-
-	return &Range{Start: start, Limit: finish - start + 1}
-}
-
 // Storage is the interface for storage operation
 type Storage interface {
 	// Get retrieves a file from storage
-	Get(ctx context.Context, token string, filename string, rng *Range) (reader io.ReadCloser, contentLength uint64, err error)
+	Get(ctx context.Context, token string, filename string) (reader io.ReadCloser, contentLength uint64, err error)
 	// Head retrieves content length of a file from storage
 	Head(ctx context.Context, token string, filename string) (contentLength uint64, err error)
 	// Put saves a file on storage
@@ -103,18 +21,13 @@ type Storage interface {
 	IsNotExist(err error) bool
 	// Purge cleans up the storage
 	Purge(ctx context.Context, days time.Duration) error
-	// Whether storage supports Get with Range header
-	IsRangeSupported() bool
+
 	// Type returns the storage type
 	Type() string
 }
 
-func CloseCheck(c io.Closer) {
-	if c == nil {
-		return
-	}
-
-	if err := c.Close(); err != nil {
+func CloseCheck(f func() error) {
+	if err := f(); err != nil {
 		fmt.Println("Received close error:", err)
 	}
 }

server/storage/gdrive.go

@@ -194,7 +194,7 @@ func (s *GDrive) Head(ctx context.Context, token string, filename string) (conte
 }
 
 // Get retrieves a file from storage
-func (s *GDrive) Get(ctx context.Context, token string, filename string, rng *Range) (reader io.ReadCloser, contentLength uint64, err error) {
+func (s *GDrive) Get(ctx context.Context, token string, filename string) (reader io.ReadCloser, contentLength uint64, err error) {
 	var fileID string
 	fileID, err = s.findID(filename, token)
 	if err != nil {
@@ -213,24 +213,12 @@ func (s *GDrive) Get(ctx context.Context, token string, filename string, rng *Ra
 
 	contentLength = uint64(fi.Size)
 
-	fileGetCall := s.service.Files.Get(fileID)
-	if rng != nil {
-		header := fileGetCall.Header()
-		header.Set("Range", rng.Range())
-	}
-
 	var res *http.Response
-	res, err = fileGetCall.Context(ctx).Download()
+	res, err = s.service.Files.Get(fileID).Context(ctx).Download()
 	if err != nil {
 		return
 	}
 
-	if rng != nil {
-		reader = res.Body
-		rng.AcceptLength(contentLength)
-		return
-	}
-
 	reader = res.Body
 
 	return
@@ -308,6 +296,7 @@ func (s *GDrive) Put(ctx context.Context, token string, filename string, reader
 			Name:     token,
 			Parents:  []string{s.rootID},
 			MimeType: gDriveDirectoryMimeType,
+			Size:     int64(contentLength),
 		}
 
 		di, err := s.service.Files.Create(dir).Fields("id").Do()
@@ -334,8 +323,6 @@ func (s *GDrive) Put(ctx context.Context, token string, filename string, reader
 	return nil
 }
 
-func (s *GDrive) IsRangeSupported() bool { return true }
-
 // Retrieve a token, saves the token, then returns the generated client.
 func getGDriveClient(ctx context.Context, config *oauth2.Config, localConfigPath string, logger *log.Logger) *http.Client {
 	tokenFile := filepath.Join(localConfigPath, gDriveTokenJSONFile)
@@ -369,7 +356,7 @@ func getGDriveTokenFromWeb(ctx context.Context, config *oauth2.Config, logger *l
 // Retrieves a token from a local file.
 func gDriveTokenFromFile(file string) (*oauth2.Token, error) {
 	f, err := os.Open(file)
-	defer CloseCheck(f)
+	defer CloseCheck(f.Close)
 	if err != nil {
 		return nil, err
 	}
@@ -382,7 +369,7 @@ func gDriveTokenFromFile(file string) (*oauth2.Token, error) {
 func saveGDriveToken(path string, token *oauth2.Token, logger *log.Logger) {
 	logger.Printf("Saving credential file to: %s\n", path)
 	f, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0600)
-	defer CloseCheck(f)
+	defer CloseCheck(f.Close)
 	if err != nil {
 		logger.Fatalf("Unable to cache oauth token: %v", err)
 	}

server/storage/local.go

@@ -42,16 +42,13 @@ func (s *LocalStorage) Head(_ context.Context, token string, filename string) (c
 }
 
 // Get retrieves a file from storage
-func (s *LocalStorage) Get(_ context.Context, token string, filename string, rng *Range) (reader io.ReadCloser, contentLength uint64, err error) {
+func (s *LocalStorage) Get(_ context.Context, token string, filename string) (reader io.ReadCloser, contentLength uint64, err error) {
 	path := filepath.Join(s.basedir, token, filename)
 
-	var file *os.File
-
 	// content type , content length
-	if file, err = os.Open(path); err != nil {
+	if reader, err = os.Open(path); err != nil {
 		return
 	}
-	reader = file
 
 	var fi os.FileInfo
 	if fi, err = os.Lstat(path); err != nil {
@@ -59,12 +56,6 @@ func (s *LocalStorage) Get(_ context.Context, token string, filename string, rng
 	}
 
 	contentLength = uint64(fi.Size())
-	if rng != nil {
-		contentLength = rng.AcceptLength(contentLength)
-		if _, err = file.Seek(int64(rng.Start), 0); err != nil {
-			return
-		}
-	}
 
 	return
 }
@@ -122,7 +113,7 @@ func (s *LocalStorage) Put(_ context.Context, token string, filename string, rea
 	}
 
 	f, err = os.OpenFile(filepath.Join(path, filename), os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0600)
-	defer CloseCheck(f)
+	defer CloseCheck(f.Close)
 
 	if err != nil {
 		return err
@@ -134,5 +125,3 @@ func (s *LocalStorage) Put(_ context.Context, token string, filename string, rea
 
 	return nil
 }
-
-func (s *LocalStorage) IsRangeSupported() bool { return true }

server/storage/s3.go

@@ -90,7 +90,7 @@ func (s *S3Storage) IsNotExist(err error) bool {
 }
 
 // Get retrieves a file from storage
-func (s *S3Storage) Get(ctx context.Context, token string, filename string, rng *Range) (reader io.ReadCloser, contentLength uint64, err error) {
+func (s *S3Storage) Get(ctx context.Context, token string, filename string) (reader io.ReadCloser, contentLength uint64, err error) {
 	key := fmt.Sprintf("%s/%s", token, filename)
 
 	getRequest := &s3.GetObjectInput{
@@ -98,10 +98,6 @@ func (s *S3Storage) Get(ctx context.Context, token string, filename string, rng
 		Key:    aws.String(key),
 	}
 
-	if rng != nil {
-		getRequest.Range = aws.String(rng.Range())
-	}
-
 	response, err := s.s3.GetObjectWithContext(ctx, getRequest)
 	if err != nil {
 		return
@@ -110,9 +106,6 @@ func (s *S3Storage) Get(ctx context.Context, token string, filename string, rng
 	if response.ContentLength != nil {
 		contentLength = uint64(*response.ContentLength)
 	}
-	if rng != nil && response.ContentRange != nil {
-		rng.SetContentRange(*response.ContentRange)
-	}
 
 	reader = response.Body
 	return
@@ -176,8 +169,6 @@ func (s *S3Storage) Put(ctx context.Context, token string, filename string, read
 	return
 }
 
-func (s *S3Storage) IsRangeSupported() bool { return true }
-
 func getAwsSession(accessKey, secretKey, region, endpoint string, forcePathStyle bool) *session.Session {
 	return session.Must(session.NewSession(&aws.Config{
 		Region:           aws.String(region),

server/storage/storj.go

@@ -78,18 +78,12 @@ func (s *StorjStorage) Head(ctx context.Context, token string, filename string)
 }
 
 // Get retrieves a file from storage
-func (s *StorjStorage) Get(ctx context.Context, token string, filename string, rng *Range) (reader io.ReadCloser, contentLength uint64, err error) {
+func (s *StorjStorage) Get(ctx context.Context, token string, filename string) (reader io.ReadCloser, contentLength uint64, err error) {
 	key := storj.JoinPaths(token, filename)
 
 	s.logger.Printf("Getting file %s from Storj Bucket", filename)
 
 	options := uplink.DownloadOptions{}
-	if rng != nil {
-		options.Offset = int64(rng.Start)
-		if rng.Limit > 0 {
-			options.Length = int64(rng.Limit)
-		}
-	}
 
 	download, err := s.project.DownloadObject(fpath.WithTempData(ctx, "", true), s.bucket.Name, key, &options)
 	if err != nil {
@@ -97,9 +91,6 @@ func (s *StorjStorage) Get(ctx context.Context, token string, filename string, r
 	}
 
 	contentLength = uint64(download.Info().System.ContentLength)
-	if rng != nil {
-		contentLength = rng.AcceptLength(contentLength)
-	}
 
 	reader = download
 	return
@@ -155,8 +146,6 @@ func (s *StorjStorage) Put(ctx context.Context, token string, filename string, r
 	return err
 }
 
-func (s *StorjStorage) IsRangeSupported() bool { return true }
-
 // IsNotExist indicates if a file doesn't exist on storage
 func (s *StorjStorage) IsNotExist(err error) bool {
 	return errors.Is(err, uplink.ErrObjectNotFound)