You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
73 lines
2.0 KiB
73 lines
2.0 KiB
package weed_server
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"strconv"
|
|
|
|
"github.com/chrislusf/seaweedfs/weed/filer"
|
|
"github.com/chrislusf/seaweedfs/weed/glog"
|
|
"github.com/chrislusf/seaweedfs/weed/operation"
|
|
"github.com/chrislusf/seaweedfs/weed/util"
|
|
)
|
|
|
|
func (fs *FilerServer) apiHandler(w http.ResponseWriter, r *http.Request) {
|
|
request := r.FormValue("request")
|
|
apiRequest := filer.ApiRequest{}
|
|
|
|
err := json.Unmarshal([]byte(request), &apiRequest)
|
|
if err != nil {
|
|
glog.V(0).Infoln("failing to read request", r.RequestURI, request)
|
|
writeJsonError(w, r, http.StatusInternalServerError, err)
|
|
}
|
|
switch apiRequest.Command {
|
|
case "listDirectories":
|
|
res := filer.ListDirectoriesResult{}
|
|
res.Directories, err = fs.filer.ListDirectories(apiRequest.Directory)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
}
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
case "listFiles":
|
|
res := filer.ListFilesResult{}
|
|
res.Files, err = fs.filer.ListFiles(apiRequest.Directory, apiRequest.FileName, 100)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
}
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
case "getFileSize":
|
|
res := filer.GetFileSizeResult{}
|
|
server, err := operation.LookupFileId(fs.getMasterNode(), apiRequest.FileId)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
return
|
|
}
|
|
head, err := util.Head(server)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
return
|
|
}
|
|
res.Size, err = strconv.ParseUint(head.Get("Content-Length"), 10, 0)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
}
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
case "getFileContent":
|
|
res := filer.GetFileContentResult{}
|
|
server, err := operation.LookupFileId(fs.getMasterNode(), apiRequest.FileId)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
return
|
|
}
|
|
res.Content, err = util.Get(server)
|
|
if err != nil {
|
|
res.Error = err.Error()
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
return
|
|
}
|
|
writeJsonQuiet(w, r, http.StatusOK, res)
|
|
}
|
|
}
|