Skip to content

Commit

Permalink
refactor(context): Added a third, optional parameter for permissions …
Browse files Browse the repository at this point in the history
…to the SaveUploadedFile method. (#4068)
  • Loading branch information
haesuo566 committed Nov 3, 2024
1 parent c8a3adc commit 84b3770
Show file tree
Hide file tree
Showing 2 changed files with 52 additions and 2 deletions.
9 changes: 7 additions & 2 deletions context.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ package gin
import (
"errors"
"io"
"io/fs"
"log"
"math"
"mime/multipart"
Expand Down Expand Up @@ -677,14 +678,18 @@ func (c *Context) MultipartForm() (*multipart.Form, error) {
}

// SaveUploadedFile uploads the form file to specific dst.
func (c *Context) SaveUploadedFile(file *multipart.FileHeader, dst string) error {
func (c *Context) SaveUploadedFile(file *multipart.FileHeader, dst string, perm ...fs.FileMode) error {
src, err := file.Open()
if err != nil {
return err
}
defer src.Close()

if err = os.MkdirAll(filepath.Dir(dst), 0o750); err != nil {
if len(perm) <= 0 {
perm = append(perm, 0o750)
}

if err = os.MkdirAll(filepath.Dir(dst), perm[0]); err != nil {
return err
}

Expand Down
45 changes: 45 additions & 0 deletions context_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,14 @@ import (
"fmt"
"html/template"
"io"
"io/fs"
"mime/multipart"
"net"
"net/http"
"net/http/httptest"
"net/url"
"os"
"path/filepath"
"reflect"
"strings"
"sync"
Expand Down Expand Up @@ -154,6 +156,49 @@ func TestSaveUploadedCreateFailed(t *testing.T) {
require.Error(t, c.SaveUploadedFile(f, "/"))
}

func TestSaveUploadedFileWithPermission(t *testing.T) {
buf := new(bytes.Buffer)
mw := multipart.NewWriter(buf)
w, err := mw.CreateFormFile("file", "permission_test")
require.NoError(t, err)
_, err = w.Write([]byte("permission_test"))
require.NoError(t, err)
mw.Close()
c, _ := CreateTestContext(httptest.NewRecorder())
c.Request, _ = http.NewRequest("POST", "/", buf)
c.Request.Header.Set("Content-Type", mw.FormDataContentType())
f, err := c.FormFile("file")
require.NoError(t, err)
assert.Equal(t, "permission_test", f.Filename)

var mode fs.FileMode = 0o777
require.NoError(t, c.SaveUploadedFile(f, "permission_test", mode))

info, err := os.Stat(filepath.Dir("permission_test"))
require.NoError(t, err)

assert.Equal(t, info.Mode().Perm(), mode)
}

func TestSaveUploadedFileWithPermissionFailed(t *testing.T) {
buf := new(bytes.Buffer)
mw := multipart.NewWriter(buf)
w, err := mw.CreateFormFile("file", "permission_test")
require.NoError(t, err)
_, err = w.Write([]byte("permission_test"))
require.NoError(t, err)
mw.Close()
c, _ := CreateTestContext(httptest.NewRecorder())
c.Request, _ = http.NewRequest("POST", "/", buf)
c.Request.Header.Set("Content-Type", mw.FormDataContentType())
f, err := c.FormFile("file")
require.NoError(t, err)
assert.Equal(t, "permission_test", f.Filename)

var mode fs.FileMode = 0o666
require.Error(t, c.SaveUploadedFile(f, "test/permission_test", mode))
}

func TestContextReset(t *testing.T) {
router := New()
c := router.allocateContext(0)
Expand Down

0 comments on commit 84b3770

Please sign in to comment.