source: code/trunk/partage.go@ 13

package main

import (
        "fmt"
        "flag"
        "io"
        "io/ioutil"
        "net/http"
        "os"
        "path"
        "path/filepath"
        "html/template"

        "github.com/dustin/go-humanize"
)

type templatedata struct {
        Links []string
        Size string
        Maxsize string
}

var conf struct {
        bind     string
        baseuri  string
        filepath string
        rootdir  string
        templatedir string
        filectx  string
        maxsize  int64
}


func contenttype(f *os.File) string {
        buffer := make([]byte, 512)

        _, err := f.Read(buffer)
        if err != nil {
                return ""
        }

        mime := http.DetectContentType(buffer)

        return mime
}

func writefile(f *os.File, s io.ReadCloser, contentlength int64) int64 {
        buffer := make([]byte, 4096)
        eof := false
        sz := int64(0)

        defer f.Sync()

        for !eof {
                n, err := s.Read(buffer)
                if err != nil && err != io.EOF {
                        fmt.Println(err)
                        return -1
                } else if err == io.EOF {
                        eof = true
                }

                /* ensure we don't write more than expected */
                r := int64(n)
                if sz+r > contentlength {
                        r = contentlength - sz
                        eof = true
                }

                _, err = f.Write(buffer[:r])
                if err != nil {
                        fmt.Println(err)
                }
                sz += r
        }

        return sz
}

func servefile(f *os.File, w http.ResponseWriter) {
        buffer := make([]byte, 4096)

        mime := contenttype(f)
        w.Header().Set("Content-Type", mime)

        f.Seek(0, 0)
        for {
                n, err := f.Read(buffer)

                if err != nil {
                        if err == io.EOF {
                                if _, err := w.Write(buffer[:n]); err != nil {
                                        fmt.Println(err)
                                }
                                break
                        }
                        fmt.Println(err)
                        return
                }

                if _, err = w.Write(buffer[:n]); err != nil {
                        fmt.Println(err)
                }
        }
}

func servetemplate(w http.ResponseWriter, f string, d templatedata) {
        t, err := template.ParseFiles(conf.templatedir + "/" + f)
        if err != nil {
                w.WriteHeader(http.StatusInternalServerError)
                return
        }

        err = t.Execute(w, d)
        if err != nil {
                fmt.Println(err)
        }
}

func uploaderPut(w http.ResponseWriter, r *http.Request) {
        /* limit upload size */
        if r.ContentLength > conf.maxsize {
                w.WriteHeader(http.StatusRequestEntityTooLarge)
                w.Write([]byte("File is too big"))
        }

        tmp, _ := ioutil.TempFile(conf.filepath, "*"+path.Ext(r.URL.Path))
        f, err := os.Create(tmp.Name())
        if err != nil {
                fmt.Println(err)
                return
        }
        defer f.Close()

        if writefile(f, r.Body, r.ContentLength) < 0 {
                w.WriteHeader(http.StatusInternalServerError)
                return
        }

        resp := conf.baseuri + conf.filectx + filepath.Base(tmp.Name())
        w.Write([]byte(resp))
}

func uploaderPost(w http.ResponseWriter, r *http.Request) {
        /* read 32Mb at a time */
        r.ParseMultipartForm(32 << 20)

        links := []string{}
        for _, h := range r.MultipartForm.File["uck"] {
                if h.Size > conf.maxsize {
                        w.WriteHeader(http.StatusRequestEntityTooLarge)
                        w.Write([]byte("File is too big"))
                        return
                }

                post, err := h.Open()
                if err != nil {
                        w.WriteHeader(http.StatusInternalServerError)
                        return
                }
                defer post.Close()

                tmp, _ := ioutil.TempFile(conf.filepath, "*"+path.Ext(h.Filename))
                f, err := os.Create(tmp.Name())
                if err != nil {
                        w.WriteHeader(http.StatusInternalServerError)
                        return
                }
                defer f.Close()

                if writefile(f, post, h.Size) < 0 {
                        w.WriteHeader(http.StatusInternalServerError)
                        return
                }

                link := conf.baseuri + conf.filectx + filepath.Base(tmp.Name())
                links = append(links, link)
        }

        if (r.PostFormValue("output") == "html") {
                data := templatedata{ Links: links }
                servetemplate(w, "/upload.html", data)
                return
        } else {
                for _, link := range links {
                        w.Write([]byte(link + "\r\n"))
                }
        }
}

func uploaderGet(w http.ResponseWriter, r *http.Request) {
        // r.URL.Path is sanitized regarding "." and ".."
        filename := r.URL.Path
        if r.URL.Path == "/" || r.URL.Path == "/index" {
                data := templatedata{ Maxsize: humanize.IBytes(uint64(conf.maxsize))}
                servetemplate(w, "/index.html", data)
                return
        }

        f, err := os.Open(conf.rootdir + filename)
        if err != nil {
                w.WriteHeader(http.StatusNotFound)
                fmt.Println(err)
                return
        }
        defer f.Close()

        servefile(f, w)
}

func uploader(w http.ResponseWriter, r *http.Request) {
        switch r.Method {
        case "POST":
                uploaderPost(w, r)
        case "PUT":
                uploaderPut(w, r)
        case "GET":
                uploaderGet(w, r)
        }
}

func main() {
        flag.StringVar(&conf.bind,        "l", "0.0.0.0:8080", "Address to bind to (default: 0.0.0.0:8080)")
        flag.StringVar(&conf.baseuri,     "b", "http://127.0.0.1:8080", "Base URI to use for links (default: http://127.0.0.1:8080)")
        flag.StringVar(&conf.filepath,    "f", "/tmp", "Path to save files to (default: /tmp)")
        flag.StringVar(&conf.filectx,     "c", "/f/", "Context to serve files from (default: /f/)")
        flag.StringVar(&conf.rootdir,     "r", "./static", "Root directory (default: ./static)")
        flag.StringVar(&conf.templatedir, "t", "./templates", "Templates directory (default: ./templates)")
        flag.Int64Var(&conf.maxsize,      "s", 30064771072, "Maximum file size (default: 28Gib)")

        flag.Parse()

        http.HandleFunc("/", uploader)
        http.Handle(conf.filectx, http.StripPrefix(conf.filectx, http.FileServer(http.Dir(conf.filepath))))
        http.ListenAndServe("0.0.0.0:8080", nil)
}