diff options
Diffstat (limited to 'weed/filer/client_operations.go')
| -rw-r--r-- | weed/filer/client_operations.go | 125 |
1 files changed, 0 insertions, 125 deletions
diff --git a/weed/filer/client_operations.go b/weed/filer/client_operations.go deleted file mode 100644 index 057fb4c66..000000000 --- a/weed/filer/client_operations.go +++ /dev/null @@ -1,125 +0,0 @@ -package filer - -import ( - "encoding/json" - "errors" - "fmt" - "net/url" - - "github.com/chrislusf/seaweedfs/weed/util" -) - -type ApiRequest struct { - Command string //"listFiles", "listDirectories", "getFileSize" - Directory string - FileName string - FileId string -} - -type ListFilesResult struct { - Files []FileEntry - Error string `json:"error,omitempty"` -} - -func ListFiles(server string, directory string, fileName string) (ret *ListFilesResult, err error) { - ret = new(ListFilesResult) - if err = call(server, ApiRequest{Command: "listFiles", Directory: directory, FileName: fileName}, ret); err == nil { - if ret.Error != "" { - return nil, errors.New(ret.Error) - } - return ret, nil - } - return nil, err -} - -type GetFileSizeResult struct { - Size uint64 - Error string `json:"error,omitempty"` -} - -func GetFileSize(server string, fileId string) (ret *GetFileSizeResult, err error) { - ret = new(GetFileSizeResult) - if err = call(server, ApiRequest{Command: "getFileSize", FileId: fileId}, ret); err == nil { - if ret.Error != "" { - return nil, errors.New(ret.Error) - } - return ret, nil - } - return nil, err -} - -type GetFileContentResult struct { - Content []byte - Error string `json:"error,omitempty"` -} - -func GetFileContent(server string, fileId string) (ret *GetFileContentResult, err error) { - ret = new(GetFileContentResult) - if err = call(server, ApiRequest{Command: "getFileContent", FileId: fileId}, ret); err == nil { - if ret.Error != "" { - return nil, errors.New(ret.Error) - } - return ret, nil - } - return nil, err -} - -type ListDirectoriesResult struct { - Directories []DirectoryName - Error string `json:"error,omitempty"` -} - -func ListDirectories(server string, directory string) (ret *ListDirectoriesResult, err error) { - ret = new(ListDirectoriesResult) - if err := call(server, ApiRequest{Command: "listDirectories", Directory: directory}, ret); err == nil { - if ret.Error != "" { - return nil, errors.New(ret.Error) - } - return ret, nil - } - return nil, err -} - -type LookupDirectoryEntryResult struct { - Found bool - FileId string - Error string `json:"error,omitempty"` -} - -func LookupDirectoryEntry(server string, directory string, name string) (ret *LookupDirectoryEntryResult, err error) { - ret = new(LookupDirectoryEntryResult) - if err := call(server, ApiRequest{Command: "lookupDirectoryEntry", Directory: directory, FileName: name}, ret); err == nil { - if ret.Error != "" { - return nil, errors.New(ret.Error) - } - return ret, nil - } - return nil, err -} - -func DeleteDirectoryOrFile(server string, path string, isDir bool) error { - destUrl := fmt.Sprintf("http://%s%s", server, path) - if isDir { - destUrl += "/?recursive=true" - } - return util.Delete(destUrl, "") -} - -func call(server string, request ApiRequest, ret interface{}) error { - b, err := json.Marshal(request) - if err != nil { - fmt.Println("error:", err) - return nil - } - values := make(url.Values) - values.Add("request", string(b)) - jsonBlob, err := util.Post("http://"+server+"/__api__", values) - if err != nil { - return err - } - err = json.Unmarshal(jsonBlob, ret) - if err != nil { - return err - } - return nil -} |
