diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-08 01:59:43 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-08 01:59:43 -0700 |
| commit | 43a69d20bf724cea371da88a02bfe0b2fa02a773 (patch) | |
| tree | e0229e8ac9f35cbda0de5f5043d512522b2d23c9 /weed/server/filer_server_handlers_api.go | |
| parent | 4936d6c342e16edd9ee37d2b2ec2c890287670d4 (diff) | |
| download | seaweedfs-43a69d20bf724cea371da88a02bfe0b2fa02a773.tar.xz seaweedfs-43a69d20bf724cea371da88a02bfe0b2fa02a773.zip | |
change filer API to gRPC
Diffstat (limited to 'weed/server/filer_server_handlers_api.go')
| -rw-r--r-- | weed/server/filer_server_handlers_api.go | 83 |
1 files changed, 0 insertions, 83 deletions
diff --git a/weed/server/filer_server_handlers_api.go b/weed/server/filer_server_handlers_api.go deleted file mode 100644 index 0fad5631d..000000000 --- a/weed/server/filer_server_handlers_api.go +++ /dev/null @@ -1,83 +0,0 @@ -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) - } - - glog.V(2).Infof("api request: %+v", apiRequest) - - switch apiRequest.Command { - case "lookupDirectoryEntry": - res := filer.LookupDirectoryEntryResult{} - res.Found, res.FileId, err = fs.filer.LookupDirectoryEntry(apiRequest.Directory, apiRequest.FileName) - if err != nil { - res.Error = err.Error() - } - writeJsonQuiet(w, r, http.StatusOK, res) - 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, 1000) - 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) - } -} |
