feat(cmdg): implement robust inline image rendering and non-blocking UI

.gitignore

@@ -4,3 +4,4 @@
 .envrc
 /cmdg
 /med
+/conductor/

cmd/cmdg/cmdg.go

@@ -60,11 +60,10 @@ var (
 	verbose         = flag.Bool("verbose", false, "Turn on verbose logging.")
 	shell           = flag.String("shell", "/bin/sh", "Shell to shell out to.")
 	versionFlag     = flag.Bool("version", false, "Show version and exit.")
-	lynx            = flag.String("lynx", "lynx", "HTML render binary.")
 	enableSign      = flag.Bool("sign", false, "Send signed emails by default.")
+	imageProtocol   = flag.String("image_protocol", "none", "Terminal image protocol (none, kitty, iterm2, auto).")
 
 	updateSender = flag.String("update_sender", "", `Update default sender address. E.g.: "John Doe" <john.doe@example.com>`)
-
 	conn *cmdg.CmdG
 
 	// Relative to configDir.
@@ -133,6 +132,9 @@ func run(ctx context.Context) error {
 		log.Errorf("Bailing due to error: %v", err)
 	}
 	log.Infof("MessageView returned, stopping keys")
+	if *imageProtocol != "none" {
+		cmdg.ClearImages(*imageProtocol)
+	}
 	keys.Stop()
 	log.Infof("Shutting down")
 	return nil
@@ -146,8 +148,7 @@ func main() {
 	syscall.Umask(0077)
 	flag.Parse()
 	cmdg.Version = version
-
-	cmdg.Lynx = *lynx
+	cmdg.PreferredImageProtocol = *imageProtocol
 
 	log.Infof("cmdg %s", version)
 

cmd/cmdg/compose.go

@@ -51,9 +51,7 @@ func getInput(ctx context.Context, prefill string, keys *input.Input) (string, e
 	// Stop UI.
 	keys.Stop()
 	defer func() {
-		if err := keys.Start(); err != nil {
-			log.Errorf("Failed to restart input: %v", err)
-		}
+		_ = keys.Start()
 	}()
 
 	cmd := exec.CommandContext(ctx, visualBinary, tmpf.Name())
@@ -272,11 +270,7 @@ func compose(ctx context.Context, conn *cmdg.CmdG, headOps []headOp, keys *input
 					break
 				}
 			}
-			/*
-				if a == "S" {
-					// TODO: also archive.
-				}
-			*/
+			// TODO: also archive if a == "S"
 			return nil
 		case "d":
 			st := time.Now()
@@ -293,7 +287,9 @@ func compose(ctx context.Context, conn *cmdg.CmdG, headOps []headOp, keys *input
 				break
 			}
 			if err != nil {
-				_ = dialog.Message("Failed to attach", fmt.Sprintf("Failed to attach file: %v", err), keys)
+				if err := dialog.Message("Failed to attach", fmt.Sprintf("Failed to attach file: %v", err), keys); err != nil {
+					log.Infof("Failed to show message: %v", err)
+				}
 			}
 			doEdit = false
 			attachments = append(attachments, f)
@@ -370,7 +366,7 @@ func chooseFile(ctx context.Context, keys *input.Input) (*file, error) {
 		// TODO: attach a ReadCloser?
 		b, err := ioutil.ReadFile(full)
 		if err != nil {
-			return nil, err
+			return nil, errors.Wrapf(err, "reading file %q", full)
 		}
 		return &file{
 			name:    fis[o.KeyInt].Name(),

cmd/cmdg/compose_test.go

@@ -23,9 +23,7 @@ type fakeSend struct {
 
 func (fs *fakeSend) bad(w http.ResponseWriter, f string, args ...interface{}) {
 	w.WriteHeader(http.StatusBadRequest)
-	if _, err := fmt.Fprintf(w, f, args...); err != nil {
-		fs.bad(w, "writing response failed: %v", err)
-	}
+	_, _ = fmt.Fprintf(w, f, args...)
 }
 
 func (fs *fakeSend) ServeHTTP(w http.ResponseWriter, r *http.Request) {
@@ -61,9 +59,7 @@ func (fs *fakeSend) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}
 	fs.msg = string(raw)
 	w.WriteHeader(http.StatusOK)
-	if _, err := fmt.Fprintf(w, `{ "id": "12345" }`); err != nil {
-		fs.bad(w, "failed to write reply: %v", err)
-	}
+	_, _ = fmt.Fprintf(w, `{ "id": "12345" }`)
 }
 
 // net.RoundTripper that rewrites requests to the local fake.
@@ -84,7 +80,7 @@ func (redir *redirector) RoundTrip(r *http.Request) (*http.Response, error) {
 }
 
 func crnl(s string) string {
-	return strings.ReplaceAll(s, "\n", "\r\n")
+	return strings.Replace(s, "\n", "\r\n", -1)
 }
 
 func TestSendMessage(t *testing.T) {
@@ -208,6 +204,36 @@ Content-Disposition: inline
 Content-Type: text/plain; charset="UTF-8"
 
 World
+--[a-z0-9]+--`)),
+		},
+		{
+			name: "With attachments",
+			msg:  "To: foo@bar.com\nSubject: hello\n\nWorld",
+			attachments: []*file{
+				{name: "test1.txt", content: []byte("content1")},
+				{name: "test2.txt", content: []byte("content2")},
+			},
+			matching: regexp.MustCompile(crnl(`MIME-Version: 1.0
+Subject: hello
+To: foo@bar.com
+Content-Type: multipart/mixed; boundary="[a-z0-9]+"
+Content-Disposition: inline
+
+--[a-z0-9]+
+Content-Disposition: inline
+Content-Type: text/plain; charset="UTF-8"
+
+World
+--[a-z0-9]+
+Content-Disposition: attachment; filename="test1.txt"
+Content-Type: application/octet-stream; name="test1.txt"
+
+content1
+--[a-z0-9]+
+Content-Disposition: attachment; filename="test2.txt"
+Content-Type: application/octet-stream; name="test2.txt"
+
+content2
 --[a-z0-9]+--`)),
 		},
 	}

cmd/cmdg/reply.go

@@ -89,8 +89,7 @@ func replyOrForward(ctx context.Context, conn *cmdg.CmdG, keys *input.Input, to,
 	prefill := strings.Join(headers, "\n") + "\n\n" + strings.Join(body, "\n")
 	refs, err := msg.GetReferences(ctx)
 	if err != nil {
-		// don't care
-		_ = err
+		log.Warningf("Failed to get references when replying: %v", err)
 	}
 
 	headOps := []headOp{

cmd/cmdg/reply_test.go

@@ -6,7 +6,6 @@ import (
 	"encoding/json"
 	"fmt"
 	"io/ioutil"
-	"log"
 	"net/http"
 	"net/http/httptest"
 	"net/url"
@@ -29,14 +28,13 @@ func (h *mockGmailHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			Raw string `json:"raw"`
 		}
 		if err := json.Unmarshal(content, &d); err != nil {
-			log.Fatalf("Failed to marshal: %v", err)
+			http.Error(w, err.Error(), http.StatusBadRequest)
+			return
 		}
 		raw, _ := base64.URLEncoding.DecodeString(d.Raw)
 		h.sentMsg = string(raw)
 		w.WriteHeader(http.StatusOK)
-		if _, err := fmt.Fprint(w, `{"id": "sent-123"}`); err != nil {
-			log.Fatalf("Failed to write reply: %v", err)
-		}
+		_, _ = fmt.Fprint(w, `{"id": "sent-123"}`)
 		return
 	}
 	if r.Method == "GET" && strings.Contains(r.URL.Path, "/messages/msg-123") && !strings.Contains(r.URL.Path, "/attachments") {
@@ -63,18 +61,14 @@ func (h *mockGmailHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 				},
 			},
 		}
-		if err := json.NewEncoder(w).Encode(msg); err != nil {
-			log.Fatalf("Failed to encode: %v", err)
-		}
+		_ = json.NewEncoder(w).Encode(msg)
 		return
 	}
 	if r.Method == "GET" && strings.Contains(r.URL.Path, "/attachments/att-123") {
 		att := &gmail.MessagePartBody{
 			Data: base64.URLEncoding.EncodeToString([]byte("attachment content")),
 		}
-		if err := json.NewEncoder(w).Encode(att); err != nil {
-			log.Fatalf("Failed to encode: %v", err)
-		}
+		_ = json.NewEncoder(w).Encode(att)
 		return
 	}
 	w.WriteHeader(http.StatusNotFound)

cmd/cmdg/view_messagelist.go

@@ -49,7 +49,6 @@ Press [enter] to exit
 )
 
 var (
-	//messageListReloadTime          = time.Minute
 	messageListReloadTimeout       = 40 * time.Second
 	messageListHistoryCheckTime    = 10 * time.Second
 	messageListHistoryCheckTimeout = 10 * time.Second
@@ -713,7 +712,7 @@ func (mv *MessageView) Run(ctx context.Context) error {
 			switch key {
 			case "?", input.F1:
 				if err := help(messageListViewHelp, mv.keys); err != nil {
-					log.Infof("help() failed: %v", err)
+					log.Errorf("Failed to show help: %v", err)
 				}
 			case input.Enter, input.Right:
 				if len(mv.messages) == 0 {