command_fs_cat.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package shell
  2. import (
  3. "fmt"
  4. "io"
  5. "math"
  6. "github.com/chrislusf/seaweedfs/weed/filer2"
  7. "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
  8. "github.com/chrislusf/seaweedfs/weed/util"
  9. )
  10. func init() {
  11. Commands = append(Commands, &commandFsCat{})
  12. }
  13. type commandFsCat struct {
  14. }
  15. func (c *commandFsCat) Name() string {
  16. return "fs.cat"
  17. }
  18. func (c *commandFsCat) Help() string {
  19. return `stream the file content on to the screen
  20. fs.cat /dir/file_name
  21. `
  22. }
  23. func (c *commandFsCat) Do(args []string, commandEnv *CommandEnv, writer io.Writer) (err error) {
  24. path, err := commandEnv.parseUrl(findInputDirectory(args))
  25. if err != nil {
  26. return err
  27. }
  28. if commandEnv.isDirectory(path) {
  29. return fmt.Errorf("%s is a directory", path)
  30. }
  31. dir, name := util.FullPath(path).DirAndName()
  32. return commandEnv.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
  33. request := &filer_pb.LookupDirectoryEntryRequest{
  34. Name: name,
  35. Directory: dir,
  36. }
  37. respLookupEntry, err := filer_pb.LookupEntry(client, request)
  38. if err != nil {
  39. return err
  40. }
  41. return filer2.StreamContent(commandEnv.MasterClient, writer, respLookupEntry.Entry.Chunks, 0, math.MaxInt64)
  42. })
  43. }