1
0

fs_transport.go 768 B

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package main
  2. import (
  3. "fmt"
  4. "net/http"
  5. )
  6. type fsTransport struct {
  7. fs http.Dir
  8. }
  9. func newFsTransport() fsTransport {
  10. return fsTransport{fs: http.Dir(conf.LocalFileSystemRoot)}
  11. }
  12. func (t fsTransport) RoundTrip(req *http.Request) (resp *http.Response, err error) {
  13. f, err := t.fs.Open(req.URL.Path)
  14. if err != nil {
  15. return nil, err
  16. }
  17. fi, err := f.Stat()
  18. if err != nil {
  19. return nil, err
  20. }
  21. if fi.IsDir() {
  22. return nil, fmt.Errorf("%s is a directory", req.URL.Path)
  23. }
  24. return &http.Response{
  25. Status: "200 OK",
  26. StatusCode: 200,
  27. Proto: "HTTP/1.0",
  28. ProtoMajor: 1,
  29. ProtoMinor: 0,
  30. Header: make(http.Header),
  31. ContentLength: fi.Size(),
  32. Body: f,
  33. Close: true,
  34. Request: req,
  35. }, nil
  36. }