msgview/save: Adapt to already decoded reader
The functionality was broken since the decoding changes. This commit also simplifies the code (in my view) to make the application logic easier to follow. The docs are updated accordingly (the feature was poorly documented). As far as I am aware there should be no breaking changes (and is certainly still in the spec of the prior documentation)
This commit is contained in:
parent
ef029aa263
commit
5b3acb8034
2 changed files with 137 additions and 77 deletions
|
@ -1,11 +1,9 @@
|
||||||
package msgview
|
package msgview
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/base64"
|
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"mime/quotedprintable"
|
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
|
@ -15,6 +13,7 @@ import (
|
||||||
"github.com/mitchellh/go-homedir"
|
"github.com/mitchellh/go-homedir"
|
||||||
|
|
||||||
"git.sr.ht/~sircmpwn/aerc/commands"
|
"git.sr.ht/~sircmpwn/aerc/commands"
|
||||||
|
"git.sr.ht/~sircmpwn/aerc/models"
|
||||||
"git.sr.ht/~sircmpwn/aerc/widgets"
|
"git.sr.ht/~sircmpwn/aerc/widgets"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -34,102 +33,158 @@ func (Save) Complete(aerc *widgets.Aerc, args []string) []string {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (Save) Execute(aerc *widgets.Aerc, args []string) error {
|
func (Save) Execute(aerc *widgets.Aerc, args []string) error {
|
||||||
if len(args) == 1 {
|
opts, optind, err := getopt.Getopts(args, "fp")
|
||||||
return errors.New("Usage: :save [-p] <path>")
|
|
||||||
}
|
|
||||||
opts, optind, err := getopt.Getopts(args, "p")
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
var (
|
||||||
mkdirs bool
|
force bool
|
||||||
path string = strings.Join(args[optind:], " ")
|
createDirs bool
|
||||||
|
trailingSlash bool
|
||||||
)
|
)
|
||||||
|
|
||||||
for _, opt := range opts {
|
for _, opt := range opts {
|
||||||
switch opt.Option {
|
switch opt.Option {
|
||||||
|
case 'f':
|
||||||
|
force = true
|
||||||
case 'p':
|
case 'p':
|
||||||
mkdirs = true
|
createDirs = true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if defaultPath := aerc.Config().General.DefaultSavePath; defaultPath != "" {
|
|
||||||
path = defaultPath
|
|
||||||
}
|
|
||||||
|
|
||||||
mv := aerc.SelectedTab().(*widgets.MessageViewer)
|
defaultPath := aerc.Config().General.DefaultSavePath
|
||||||
p := mv.SelectedMessagePart()
|
// we either need a path or a defaultPath
|
||||||
|
if defaultPath == "" && len(args) == optind {
|
||||||
p.Store.FetchBodyPart(p.Msg.Uid, p.Msg.BodyStructure, p.Index, func(reader io.Reader) {
|
return errors.New("Usage: :save [-fp] <path>")
|
||||||
// email parts are encoded as 7bit (plaintext), quoted-printable, or base64
|
|
||||||
|
|
||||||
if strings.EqualFold(p.Part.Encoding, "base64") {
|
|
||||||
reader = base64.NewDecoder(base64.StdEncoding, reader)
|
|
||||||
} else if strings.EqualFold(p.Part.Encoding, "quoted-printable") {
|
|
||||||
reader = quotedprintable.NewReader(reader)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
var pathIsDir bool
|
// as a convenience we join with spaces, so that the user doesn't need to
|
||||||
if path[len(path)-1:] == "/" {
|
// quote filenames containing spaces
|
||||||
pathIsDir = true
|
path := strings.Join(args[optind:], " ")
|
||||||
|
|
||||||
|
// needs to be determined prior to calling filepath.Clean / filepath.Join
|
||||||
|
// it gets stripped by Clean.
|
||||||
|
// we auto generate a name if a directory was given
|
||||||
|
if len(path) > 0 {
|
||||||
|
trailingSlash = path[len(path)-1] == '/'
|
||||||
|
} else if len(defaultPath) > 0 && len(path) == 0 {
|
||||||
|
// empty path, so we might have a default that ends in a trailingSlash
|
||||||
|
trailingSlash = defaultPath[len(defaultPath)-1] == '/'
|
||||||
}
|
}
|
||||||
// Note: path expansion has to happen after test for trailing /,
|
|
||||||
// since it is stripped when path is expanded
|
// Absolute paths are taken as is so that the user can override the default
|
||||||
path, err := homedir.Expand(path)
|
// if they want to
|
||||||
|
if !isAbsPath(path) {
|
||||||
|
path = filepath.Join(defaultPath, path)
|
||||||
|
}
|
||||||
|
|
||||||
|
path, err = homedir.Expand(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
aerc.PushError(" " + err.Error())
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
pathinfo, err := os.Stat(path)
|
mv, ok := aerc.SelectedTab().(*widgets.MessageViewer)
|
||||||
if err == nil && pathinfo.IsDir() {
|
if !ok {
|
||||||
pathIsDir = true
|
return fmt.Errorf("SelectedTab is not a MessageViewer")
|
||||||
} else if os.IsExist(err) && pathIsDir {
|
|
||||||
aerc.PushError("The given directory is an existing file")
|
|
||||||
}
|
}
|
||||||
var (
|
pi := mv.SelectedMessagePart()
|
||||||
save_file string
|
|
||||||
save_dir string
|
|
||||||
)
|
|
||||||
if pathIsDir {
|
|
||||||
save_dir = path
|
|
||||||
if filename, ok := p.Part.DispositionParams["filename"]; ok {
|
|
||||||
save_file = filename
|
|
||||||
} else if filename, ok := p.Part.Params["name"]; ok {
|
|
||||||
save_file = filename
|
|
||||||
} else {
|
|
||||||
timestamp := time.Now().Format("2006-01-02-150405")
|
|
||||||
save_file = fmt.Sprintf("aerc_%v", timestamp)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
save_file = filepath.Base(path)
|
|
||||||
save_dir = filepath.Dir(path)
|
|
||||||
}
|
|
||||||
if _, err := os.Stat(save_dir); os.IsNotExist(err) {
|
|
||||||
if mkdirs {
|
|
||||||
os.MkdirAll(save_dir, 0755)
|
|
||||||
} else {
|
|
||||||
aerc.PushError("Target directory does not exist, use " +
|
|
||||||
":save with the -p option to create it")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
target := filepath.Clean(filepath.Join(save_dir, save_file))
|
|
||||||
|
|
||||||
f, err := os.Create(target)
|
if trailingSlash || isDirExists(path) {
|
||||||
|
filename := generateFilename(pi.Part)
|
||||||
|
path = filepath.Join(path, filename)
|
||||||
|
}
|
||||||
|
|
||||||
|
dir := filepath.Dir(path)
|
||||||
|
if createDirs && dir != "" {
|
||||||
|
err := os.MkdirAll(dir, 0755)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
aerc.PushError(" " + err.Error())
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if pathExists(path) && !force {
|
||||||
|
return fmt.Errorf("%q already exists and -f not given", path)
|
||||||
|
}
|
||||||
|
|
||||||
|
ch := make(chan error, 1)
|
||||||
|
pi.Store.FetchBodyPart(
|
||||||
|
pi.Msg.Uid, pi.Msg.BodyStructure, pi.Index, func(reader io.Reader) {
|
||||||
|
f, err := os.Create(path)
|
||||||
|
if err != nil {
|
||||||
|
ch <- err
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
|
|
||||||
_, err = io.Copy(f, reader)
|
_, err = io.Copy(f, reader)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
aerc.PushError(" " + err.Error())
|
ch <- err
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
ch <- nil
|
||||||
aerc.PushStatus("Saved to "+target, 10*time.Second)
|
|
||||||
})
|
})
|
||||||
|
|
||||||
|
// we need to wait for the callback prior to displaying a result
|
||||||
|
go func() {
|
||||||
|
err := <-ch
|
||||||
|
if err != nil {
|
||||||
|
aerc.PushError(fmt.Sprintf("Save failed: %v", err))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
aerc.PushStatus("Saved to "+path, 10*time.Second)
|
||||||
|
}()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//isDir returns true if path is a directory and exists
|
||||||
|
func isDirExists(path string) bool {
|
||||||
|
pathinfo, err := os.Stat(path)
|
||||||
|
if err != nil {
|
||||||
|
return false // we don't really care
|
||||||
|
}
|
||||||
|
if pathinfo.IsDir() {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
//pathExists returns true if path exists
|
||||||
|
func pathExists(path string) bool {
|
||||||
|
_, err := os.Stat(path)
|
||||||
|
if err != nil {
|
||||||
|
return false // we don't really care why it failed
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
//isAbsPath returns true if path given is anchored to / or . or ~
|
||||||
|
func isAbsPath(path string) bool {
|
||||||
|
if len(path) == 0 {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
switch path[0] {
|
||||||
|
case '/':
|
||||||
|
return true
|
||||||
|
case '.':
|
||||||
|
return true
|
||||||
|
case '~':
|
||||||
|
return true
|
||||||
|
default:
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// generateFilename tries to get the filename from the given part.
|
||||||
|
// if that fails it will fallback to a generated one based on the date
|
||||||
|
func generateFilename(part *models.BodyStructure) string {
|
||||||
|
var filename string
|
||||||
|
if fn, ok := part.DispositionParams["filename"]; ok {
|
||||||
|
filename = fn
|
||||||
|
} else if fn, ok := part.Params["name"]; ok {
|
||||||
|
filename = fn
|
||||||
|
} else {
|
||||||
|
timestamp := time.Now().Format("2006-01-02-150405")
|
||||||
|
filename = fmt.Sprintf("aerc_%v", timestamp)
|
||||||
|
}
|
||||||
|
return filename
|
||||||
|
}
|
||||||
|
|
|
@ -240,13 +240,18 @@ message list, the message in the message viewer, etc).
|
||||||
Saves the current message part in a temporary file and opens it
|
Saves the current message part in a temporary file and opens it
|
||||||
with the system handler.
|
with the system handler.
|
||||||
|
|
||||||
*save* [-p] <path>
|
*save* [-fp] <path>
|
||||||
Saves the current message part to the given path.
|
Saves the current message part to the given path.
|
||||||
|
If the path is not an absolute path, general.default-save-path will be
|
||||||
|
prepended to the path given.
|
||||||
|
If path ends in a trailing slash or if a folder exists on disc,
|
||||||
|
aerc assumes it to be a directory.
|
||||||
|
When passed a directory :save infers the filename from the mail part if
|
||||||
|
possible, or if that fails, uses "aerc_$DATE".
|
||||||
|
|
||||||
If no path is given but general.default-save-path is set, the
|
*-f*: Overwrite the destination whether or not it exists
|
||||||
file will be saved there.
|
|
||||||
|
|
||||||
*-p*: Make any directories in the path that do not exist
|
*-p*: Create any directories in the path that do not exist
|
||||||
|
|
||||||
*mark* [-atv]
|
*mark* [-atv]
|
||||||
Marks messages. Commands will execute on all marked messages instead of the
|
Marks messages. Commands will execute on all marked messages instead of the
|
||||||
|
|
Loading…
Reference in a new issue