Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1170e007d4 | ||
|
|
c85759d777 | ||
|
|
507773618b | ||
|
|
3bc243dd66 | ||
|
|
de93d44786 | ||
|
|
eb32c32063 |
170
fs.go
170
fs.go
@@ -29,88 +29,22 @@ type fileServer struct {
|
|||||||
fs.FS
|
fs.FS
|
||||||
}
|
}
|
||||||
|
|
||||||
func (fs fileServer) ServeGemini(ctx context.Context, w ResponseWriter, r *Request) {
|
func (fsys fileServer) ServeGemini(ctx context.Context, w ResponseWriter, r *Request) {
|
||||||
serveFile(w, r, fs, path.Clean(r.URL.Path), true)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ServeContent replies to the request using the content in the
|
|
||||||
// provided Reader. The main benefit of ServeContent over io.Copy
|
|
||||||
// is that it sets the MIME type of the response.
|
|
||||||
//
|
|
||||||
// ServeContent tries to deduce the type from name's file extension.
|
|
||||||
// The name is otherwise unused; it is never sent in the response.
|
|
||||||
func ServeContent(w ResponseWriter, r *Request, name string, content io.Reader) {
|
|
||||||
serveContent(w, name, content)
|
|
||||||
}
|
|
||||||
|
|
||||||
func serveContent(w ResponseWriter, name string, content io.Reader) {
|
|
||||||
// Detect mimetype from file extension
|
|
||||||
ext := path.Ext(name)
|
|
||||||
mimetype := mime.TypeByExtension(ext)
|
|
||||||
w.SetMediaType(mimetype)
|
|
||||||
io.Copy(w, content)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ServeFile responds to the request with the contents of the named file
|
|
||||||
// or directory.
|
|
||||||
//
|
|
||||||
// If the provided file or directory name is a relative path, it is interpreted
|
|
||||||
// relative to the current directory and may ascend to parent directories. If
|
|
||||||
// the provided name is constructed from user input, it should be sanitized
|
|
||||||
// before calling ServeFile.
|
|
||||||
//
|
|
||||||
// As a precaution, ServeFile will reject requests where r.URL.Path contains a
|
|
||||||
// ".." path element; this protects against callers who might unsafely use
|
|
||||||
// path.Join on r.URL.Path without sanitizing it and then use that
|
|
||||||
// path.Join result as the name argument.
|
|
||||||
//
|
|
||||||
// As another special case, ServeFile redirects any request where r.URL.Path
|
|
||||||
// ends in "/index.gmi" to the same path, without the final "index.gmi". To
|
|
||||||
// avoid such redirects either modify the path or use ServeContent.
|
|
||||||
//
|
|
||||||
// Outside of those two special cases, ServeFile does not use r.URL.Path for
|
|
||||||
// selecting the file or directory to serve; only the file or directory
|
|
||||||
// provided in the name argument is used.
|
|
||||||
func ServeFile(w ResponseWriter, r *Request, fsys fs.FS, name string) {
|
|
||||||
if containsDotDot(r.URL.Path) {
|
|
||||||
// Too many programs use r.URL.Path to construct the argument to
|
|
||||||
// serveFile. Reject the request under the assumption that happened
|
|
||||||
// here and ".." may not be wanted.
|
|
||||||
// Note that name might not contain "..", for example if code (still
|
|
||||||
// incorrectly) used path.Join(myDir, r.URL.Path).
|
|
||||||
w.WriteHeader(StatusBadRequest, "invalid URL path")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
serveFile(w, r, fsys, name, false)
|
|
||||||
}
|
|
||||||
|
|
||||||
func containsDotDot(v string) bool {
|
|
||||||
if !strings.Contains(v, "..") {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
for _, ent := range strings.FieldsFunc(v, isSlashRune) {
|
|
||||||
if ent == ".." {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
func isSlashRune(r rune) bool { return r == '/' || r == '\\' }
|
|
||||||
|
|
||||||
func serveFile(w ResponseWriter, r *Request, fsys fs.FS, name string, redirect bool) {
|
|
||||||
const indexPage = "/index.gmi"
|
const indexPage = "/index.gmi"
|
||||||
|
|
||||||
|
url := path.Clean(r.URL.Path)
|
||||||
|
|
||||||
// Redirect .../index.gmi to .../
|
// Redirect .../index.gmi to .../
|
||||||
if strings.HasSuffix(r.URL.Path, indexPage) {
|
if strings.HasSuffix(url, indexPage) {
|
||||||
w.WriteHeader(StatusPermanentRedirect, "./")
|
w.WriteHeader(StatusPermanentRedirect, strings.TrimSuffix(url, "index.gmi"))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
name := url
|
||||||
if name == "/" {
|
if name == "/" {
|
||||||
name = "."
|
name = "."
|
||||||
} else {
|
} else {
|
||||||
name = strings.Trim(name, "/")
|
name = strings.TrimPrefix(name, "/")
|
||||||
}
|
}
|
||||||
|
|
||||||
f, err := fsys.Open(name)
|
f, err := fsys.Open(name)
|
||||||
@@ -127,51 +61,89 @@ func serveFile(w ResponseWriter, r *Request, fsys fs.FS, name string, redirect b
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Redirect to canonical path
|
// Redirect to canonical path
|
||||||
if redirect {
|
if len(r.URL.Path) != 0 {
|
||||||
url := r.URL.Path
|
|
||||||
if stat.IsDir() {
|
if stat.IsDir() {
|
||||||
// Add trailing slash
|
target := url
|
||||||
if url[len(url)-1] != '/' {
|
if target != "/" {
|
||||||
w.WriteHeader(StatusPermanentRedirect, path.Base(url)+"/")
|
target += "/"
|
||||||
|
}
|
||||||
|
if len(r.URL.Path) != len(target) || r.URL.Path != target {
|
||||||
|
w.WriteHeader(StatusPermanentRedirect, target)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
} else {
|
} else if r.URL.Path[len(r.URL.Path)-1] == '/' {
|
||||||
// Remove trailing slash
|
// Remove trailing slash
|
||||||
if url[len(url)-1] == '/' {
|
w.WriteHeader(StatusPermanentRedirect, url)
|
||||||
w.WriteHeader(StatusPermanentRedirect, "../"+path.Base(url))
|
return
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if stat.IsDir() {
|
if stat.IsDir() {
|
||||||
// Redirect if the directory name doesn't end in a slash
|
|
||||||
url := r.URL.Path
|
|
||||||
if url[len(url)-1] != '/' {
|
|
||||||
w.WriteHeader(StatusRedirect, path.Base(url)+"/")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// Use contents of index.gmi if present
|
// Use contents of index.gmi if present
|
||||||
name = path.Join(name, indexPage)
|
name = path.Join(name, indexPage)
|
||||||
index, err := fsys.Open(name)
|
index, err := fsys.Open(name)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
defer index.Close()
|
defer index.Close()
|
||||||
istat, err := index.Stat()
|
f = index
|
||||||
if err == nil {
|
} else {
|
||||||
f = index
|
// Failed to find index file
|
||||||
stat = istat
|
dirList(w, f)
|
||||||
}
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if stat.IsDir() {
|
// Detect mimetype from file extension
|
||||||
// Failed to find index file
|
ext := path.Ext(name)
|
||||||
dirList(w, f)
|
mimetype := mime.TypeByExtension(ext)
|
||||||
|
w.SetMediaType(mimetype)
|
||||||
|
io.Copy(w, f)
|
||||||
|
}
|
||||||
|
|
||||||
|
// ServeFile responds to the request with the contents of the named file
|
||||||
|
// or directory. If the provided name is constructed from user input, it
|
||||||
|
// should be sanitized before calling ServeFile.
|
||||||
|
func ServeFile(w ResponseWriter, fsys fs.FS, name string) {
|
||||||
|
const indexPage = "/index.gmi"
|
||||||
|
|
||||||
|
// Ensure name is relative
|
||||||
|
if name == "/" {
|
||||||
|
name = "."
|
||||||
|
} else {
|
||||||
|
name = strings.TrimLeft(name, "/")
|
||||||
|
}
|
||||||
|
|
||||||
|
f, err := fsys.Open(name)
|
||||||
|
if err != nil {
|
||||||
|
w.WriteHeader(toGeminiError(err))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
defer f.Close()
|
||||||
|
|
||||||
|
stat, err := f.Stat()
|
||||||
|
if err != nil {
|
||||||
|
w.WriteHeader(toGeminiError(err))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
serveContent(w, name, f)
|
if stat.IsDir() {
|
||||||
|
// Use contents of index file if present
|
||||||
|
name = path.Join(name, indexPage)
|
||||||
|
index, err := fsys.Open(name)
|
||||||
|
if err == nil {
|
||||||
|
defer index.Close()
|
||||||
|
f = index
|
||||||
|
} else {
|
||||||
|
// Failed to find index file
|
||||||
|
dirList(w, f)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Detect mimetype from file extension
|
||||||
|
ext := path.Ext(name)
|
||||||
|
mimetype := mime.TypeByExtension(ext)
|
||||||
|
w.SetMediaType(mimetype)
|
||||||
|
io.Copy(w, f)
|
||||||
}
|
}
|
||||||
|
|
||||||
func dirList(w ResponseWriter, f fs.File) {
|
func dirList(w ResponseWriter, f fs.File) {
|
||||||
|
|||||||
@@ -31,7 +31,12 @@ func (w *logResponseWriter) SetMediaType(mediatype string) {
|
|||||||
|
|
||||||
func (w *logResponseWriter) Write(b []byte) (int, error) {
|
func (w *logResponseWriter) Write(b []byte) (int, error) {
|
||||||
if !w.wroteHeader {
|
if !w.wroteHeader {
|
||||||
w.WriteHeader(StatusSuccess, w.mediatype)
|
meta := w.mediatype
|
||||||
|
if meta == "" {
|
||||||
|
// Use default media type
|
||||||
|
meta = defaultMediaType
|
||||||
|
}
|
||||||
|
w.WriteHeader(StatusSuccess, meta)
|
||||||
}
|
}
|
||||||
n, err := w.rw.Write(b)
|
n, err := w.rw.Write(b)
|
||||||
w.Wrote += n
|
w.Wrote += n
|
||||||
|
|||||||
Reference in New Issue
Block a user