diff options
Diffstat (limited to 'weed/filer/read_write.go')
| -rw-r--r-- | weed/filer/read_write.go | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/weed/filer/read_write.go b/weed/filer/read_write.go index 286b073bf..548473116 100644 --- a/weed/filer/read_write.go +++ b/weed/filer/read_write.go @@ -9,6 +9,7 @@ import ( "io/ioutil" "math" "net/http" + "time" ) func ReadEntry(masterClient *wdclient.MasterClient, filerClient filer_pb.SeaweedFilerClient, dir, name string, byteBuffer *bytes.Buffer) error { @@ -71,3 +72,41 @@ func SaveAs(host string, port int, dir, name string, contentType string, byteBuf return nil } + +func SaveInsideFiler(client filer_pb.SeaweedFilerClient, dir, name string, content []byte) error { + + resp, err := filer_pb.LookupEntry(client, &filer_pb.LookupDirectoryEntryRequest{ + Directory: dir, + Name: name, + }) + + if err == filer_pb.ErrNotFound { + err = filer_pb.CreateEntry(client, &filer_pb.CreateEntryRequest{ + Directory: dir, + Entry: &filer_pb.Entry{ + Name: name, + IsDirectory: false, + Attributes: &filer_pb.FuseAttributes{ + Mtime: time.Now().Unix(), + Crtime: time.Now().Unix(), + FileMode: uint32(0644), + Collection: "", + Replication: "", + FileSize: uint64(len(content)), + }, + Content: content, + }, + }) + } else if err == nil { + entry := resp.Entry + entry.Content = content + entry.Attributes.Mtime = time.Now().Unix() + entry.Attributes.FileSize = uint64(len(content)) + err = filer_pb.UpdateEntry(client, &filer_pb.UpdateEntryRequest{ + Directory: dir, + Entry: entry, + }) + } + + return err +}
\ No newline at end of file |