package filemanager import ( "errors" "net/http" "regexp" "strings" rice "github.com/GeertJohan/go.rice" "golang.org/x/net/webdav" ) var ( // ErrDuplicated occurs when you try to create a user that already exists. ErrDuplicated = errors.New("Duplicated user") ) // FileManager is a file manager instance. It should be creating using the // 'New' function and not directly. type FileManager struct { *User assets *assets // prefixURL is a part of the URL that is already trimmed from the request URL before it // arrives to our handlers. It may be useful when using File Manager as a middleware // such as in caddy-filemanager plugin. It is only useful in certain situations. prefixURL string // baseURL is the path where the GUI will be accessible. It musn't end with // a trailing slash and mustn't contain prefixURL, if set. baseURL string // webDavURL is the path where the WebDAV will be accessible. It can be set to "" // in order to override the GUI and only use the WebDAV. It musn't end with // a trailing slash. webDavURL string // Users is a map with the different configurations for each user. Users map[string]*User // BeforeSave is a function that is called before saving a file. BeforeSave Command // AfterSave is a function that is called before saving a file. AfterSave Command } // Command is a command function. type Command func(r *http.Request, m *FileManager, u *User) error // User contains the configuration for each user. It should be created // using NewUser on a File Manager instance. type User struct { // scope is the physical path the user has access to. scope string // fileSystem is the virtual file system the user has access. fileSystem webdav.FileSystem // handler handles incoming requests to the WebDAV backend. handler *webdav.Handler // Rules is an array of access and deny rules. Rules []*Rule `json:"-"` // TODO: this MUST be done in another way StyleSheet string `json:"-"` // These indicate if the user can perform certain actions. AllowNew bool // Create files and folders AllowEdit bool // Edit/rename files AllowCommands bool // Execute commands // Commands is the list of commands the user can execute. Commands []string } // assets are the static and front-end assets, such as JS, CSS and HTML templates. type assets struct { templates *rice.Box css *rice.Box js *rice.Box } // Rule is a dissalow/allow rule. type Rule struct { // Regex indicates if this rule uses Regular Expressions or not. Regex bool // Allow indicates if this is an allow rule. Set 'false' to be a disallow rule. Allow bool // Path is the corresponding URL path for this rule. Path string // Regexp is the regular expression. Only use this when 'Regex' was set to true. Regexp *regexp.Regexp } // New creates a new File Manager instance with the needed // configuration to work. func New(scope string) *FileManager { m := &FileManager{ User: &User{ AllowCommands: true, AllowEdit: true, AllowNew: true, Commands: []string{}, Rules: []*Rule{}, }, Users: map[string]*User{}, BeforeSave: func(r *http.Request, m *FileManager, u *User) error { return nil }, AfterSave: func(r *http.Request, m *FileManager, u *User) error { return nil }, assets: &assets{ templates: rice.MustFindBox("./_assets/templates"), css: rice.MustFindBox("./_assets/css"), js: rice.MustFindBox("./_assets/js"), }, } m.SetScope(scope, "") m.SetBaseURL("/") m.SetWebDavURL("/webdav") return m } // RootURL returns the actual URL where // File Manager interface can be accessed. func (m FileManager) RootURL() string { return m.prefixURL + m.baseURL } // WebDavURL returns the actual URL // where WebDAV can be accessed. func (m FileManager) WebDavURL() string { return m.prefixURL + m.baseURL + m.webDavURL } // SetPrefixURL updates the prefixURL of a File // Manager object. func (m FileManager) SetPrefixURL(url string) { url = strings.TrimPrefix(url, "/") url = strings.TrimSuffix(url, "/") url = "/" + url m.prefixURL = strings.TrimSuffix(url, "/") } // SetBaseURL updates the baseURL of a File Manager // object. func (m *FileManager) SetBaseURL(url string) { url = strings.TrimPrefix(url, "/") url = strings.TrimSuffix(url, "/") url = "/" + url m.baseURL = strings.TrimSuffix(url, "/") } // SetWebDavURL updates the webDavURL of a File Manager // object and updates it's main handler. func (m *FileManager) SetWebDavURL(url string) { url = strings.TrimPrefix(url, "/") url = strings.TrimSuffix(url, "/") m.webDavURL = "/" + url // update base user webdav handler m.handler = &webdav.Handler{ Prefix: m.webDavURL, FileSystem: m.fileSystem, LockSystem: webdav.NewMemLS(), } // update other users' handlers to match // the new URL for _, u := range m.Users { u.handler = &webdav.Handler{ Prefix: m.webDavURL, FileSystem: u.fileSystem, LockSystem: webdav.NewMemLS(), } } } // SetScope updates a user scope and its virtual file system. // If the user string is blank, it will change the base scope. func (m *FileManager) SetScope(scope string, username string) error { var u *User if username == "" { u = m.User } else { var ok bool u, ok = m.Users[username] if !ok { return errors.New("Inexistent user") } } u.scope = strings.TrimSuffix(scope, "/") u.fileSystem = webdav.Dir(u.scope) u.handler = &webdav.Handler{ Prefix: m.webDavURL, FileSystem: u.fileSystem, LockSystem: webdav.NewMemLS(), } return nil } // NewUser creates a new user on a File Manager struct // which inherits its configuration from the main user. func (m *FileManager) NewUser(username string) error { if _, ok := m.Users[username]; ok { return ErrDuplicated } m.Users[username] = &User{ scope: m.User.scope, fileSystem: m.User.fileSystem, handler: m.User.handler, Rules: m.User.Rules, AllowNew: m.User.AllowNew, AllowEdit: m.User.AllowEdit, AllowCommands: m.User.AllowCommands, Commands: m.User.Commands, } return nil } // ServeHTTP determines if the request is for this plugin, and if all prerequisites are met. func (m *FileManager) ServeHTTP(w http.ResponseWriter, r *http.Request) (int, error) { var ( c = &requestContext{ fm: m, us: nil, fi: nil, } code int err error ) // Checks if the URL contains the baseURL. If so, it strips it. Otherwise, // it throws an error. if p := strings.TrimPrefix(r.URL.Path, m.baseURL); len(p) < len(r.URL.Path) { r.URL.Path = p } else { return http.StatusNotFound, nil } // Checks if the URL matches the Assets URL. Returns the asset if the // method is GET and Status Forbidden otherwise. if matchURL(r.URL.Path, assetsURL) { if r.Method == http.MethodGet { return serveAssets(c, w, r) } return http.StatusForbidden, nil } username, _, _ := r.BasicAuth() if _, ok := m.Users[username]; ok { c.us = m.Users[username] } else { c.us = m.User } // Checks if the request URL is for the WebDav server. if matchURL(r.URL.Path, m.webDavURL) { return serveWebDAV(c, w, r) } w.Header().Set("x-frame-options", "SAMEORIGIN") w.Header().Set("x-content-type", "nosniff") w.Header().Set("x-xss-protection", "1; mode=block") // Checks if the User is allowed to access this file if !c.us.Allowed(r.URL.Path) { if r.Method == http.MethodGet { return htmlError( w, http.StatusForbidden, errors.New("You don't have permission to access this page"), ) } return http.StatusForbidden, nil } if r.URL.Query().Get("search") != "" { return search(c, w, r) } if r.URL.Query().Get("command") != "" { return command(c, w, r) } if r.Method == http.MethodGet { var f *fileInfo // Obtains the information of the directory/file. f, err = getInfo(r.URL, m, c.us) if err != nil { if r.Method == http.MethodGet { return htmlError(w, code, err) } code = errorToHTTP(err, false) return code, err } c.fi = f // If it's a dir and the path doesn't end with a trailing slash, // redirect the user. if f.IsDir && !strings.HasSuffix(r.URL.Path, "/") { http.Redirect(w, r, m.RootURL()+r.URL.Path+"/", http.StatusTemporaryRedirect) return 0, nil } switch { case r.URL.Query().Get("download") != "": code, err = download(c, w, r) case !f.IsDir && r.URL.Query().Get("checksum") != "": code, err = checksum(c, w, r) case r.URL.Query().Get("raw") == "true" && !f.IsDir: http.ServeFile(w, r, f.Path) code, err = 0, nil case f.IsDir: code, err = serveListing(c, w, r) default: code, err = serveSingle(c, w, r) } if err != nil { code, err = htmlError(w, code, err) } return code, err } return http.StatusNotImplemented, nil } // Allowed checks if the user has permission to access a directory/file. func (u User) Allowed(url string) bool { var rule *Rule i := len(u.Rules) - 1 for i >= 0 { rule = u.Rules[i] if rule.Regex { if rule.Regexp.MatchString(url) { return rule.Allow } } else if strings.HasPrefix(url, rule.Path) { return rule.Allow } i-- } return true } // Scope returns the user scope. func (u User) Scope() string { return u.scope }