-
Notifications
You must be signed in to change notification settings - Fork 28
/
Copy pathupload.go
196 lines (173 loc) · 4.5 KB
/
upload.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
package live
import (
"context"
"errors"
"fmt"
"log"
"os"
)
const upKey = "uploads"
type UploadError struct {
additional string
err error
}
func (u *UploadError) Error() string {
if u.additional != "" {
return fmt.Sprintf("%s: %s", u.additional, u.err)
}
return fmt.Sprintf("%s", u.err)
}
func (u *UploadError) Unwrap() error {
return u.err
}
var (
ErrUploadNotFound = errors.New("uploads not found")
ErrUploadTooLarge = errors.New("upload too large")
ErrUploadNotAccepted = errors.New("upload not accepted")
ErrUploadTooManyFiles = errors.New("upload too many files")
ErrUploadMalformed = errors.New("upload malformed")
)
// UploadConfig describes an upload to accept on the socket.
type UploadConfig struct {
// The form input name to accept from.
Name string
// The max number of files to allow to be uploaded.
MaxFiles int
// The maximum size of all files to accept.
MaxSize int64
// Which type of files to accept.
Accept []string
}
// Upload describes an upload from the client.
type Upload struct {
Name string
Size int64
Type string
LastModified string
Errors []error
Progress float32
internalLocation string `json:"-"`
bytesRead int64 `json:"-"`
}
// File gets an open file reader.
func (u Upload) File() (*os.File, error) {
return os.Open(u.internalLocation)
}
// UploadContext the context which we render to templates.
type UploadContext map[string][]*Upload
// HasErrors does the upload context have any errors.
func (u UploadContext) HasErrors() bool {
for _, uploads := range u {
for _, u := range uploads {
if len(u.Errors) > 0 {
return true
}
}
}
return false
}
// UploadProgress tracks uploads and updates an upload
// object with progress.
type UploadProgress struct {
Upload *Upload
Engine Engine
Socket Socket
}
// Write interface to track progress of an upload.
func (u *UploadProgress) Write(p []byte) (n int, err error) {
n, err = len(p), nil
u.Upload.bytesRead += int64(n)
u.Upload.Progress = float32(u.Upload.bytesRead) / float32(u.Upload.Size)
render, err := RenderSocket(context.Background(), u.Engine, u.Socket)
if err != nil {
log.Println("error in upload progress:", err)
return
}
u.Socket.UpdateRender(render)
return
}
// ValidateUploads checks proposed uploads for errors, should be called
// in a validation check function.
func ValidateUploads(s Socket, p Params) {
s.ClearUploads()
input, ok := p[upKey].(map[string]interface{})
if !ok {
log.Println("warning:", ErrUploadNotFound)
return
}
for _, c := range s.UploadConfigs() {
uploads, ok := input[c.Name].([]interface{})
if !ok {
s.AssignUpload(c.Name, &Upload{Errors: []error{ErrUploadNotFound}})
continue
}
if len(uploads) > c.MaxFiles {
s.AssignUpload(c.Name, &Upload{Errors: []error{&UploadError{err: ErrUploadTooManyFiles}}})
}
for _, u := range uploads {
f, ok := u.(map[string]interface{})
if !ok {
s.AssignUpload(c.Name, &Upload{Errors: []error{&UploadError{err: ErrUploadNotFound}}})
continue
}
u := &Upload{
Name: mapString(f, "name"),
Size: int64(mapInt(f, "size")),
Type: mapString(f, "type"),
}
// Check size.
if u.Size > c.MaxSize {
u.Errors = append(u.Errors, &UploadError{err: ErrUploadTooLarge})
}
// Check Accept.
accepted := false
for _, a := range c.Accept {
if u.Type == a {
accepted = true
}
}
if !accepted {
u.Errors = append(u.Errors, &UploadError{err: ErrUploadNotAccepted})
}
s.AssignUpload(c.Name, u)
}
}
}
// ConsumeHandler callback type when uploads are consumed.
type ConsumeHandler func(u *Upload) error
// ConsumeUploads helper function to consume the staged uploads.
func ConsumeUploads(s Socket, name string, ch ConsumeHandler) []error {
errs := []error{}
all := s.Uploads()
uploads, ok := all[name]
if !ok {
return errs
}
for _, u := range uploads {
if err := ch(u); err != nil {
errs = append(errs, err)
}
s.ClearUpload(name, u)
}
return errs
}
// WithMaxUploadSize set the handler engine to have a maximum upload size.
func WithMaxUploadSize(size int64) EngineConfig {
return func(e Engine) error {
switch v := e.(type) {
case *BaseEngine:
v.MaxUploadSize = size
}
return nil
}
}
// WithUploadStagingLocation set the handler engine with a specific upload staging location.
func WithUploadStagingLocation(stagingLocation string) EngineConfig {
return func(e Engine) error {
switch v := e.(type) {
case *BaseEngine:
v.UploadStagingLocation = stagingLocation
}
return nil
}
}