aboutsummaryrefslogtreecommitdiff
path: root/plugins/base
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/base')
-rw-r--r--plugins/base/imap.go4
-rw-r--r--plugins/base/routes.go83
-rw-r--r--plugins/base/smtp.go47
3 files changed, 5 insertions, 129 deletions
diff --git a/plugins/base/imap.go b/plugins/base/imap.go
index 85cd428..c7718e9 100644
--- a/plugins/base/imap.go
+++ b/plugins/base/imap.go
@@ -96,7 +96,6 @@ type mailboxType int
const (
mailboxSent mailboxType = iota
- mailboxOutbox mailboxType = iota
mailboxDrafts
)
@@ -117,9 +116,6 @@ func getMailboxByType(conn *imapclient.Client, mboxType mailboxType) (*MailboxIn
case mailboxDrafts:
attr = imapspecialuse.Drafts
fallbackNames = []string{"Draft", "Drafts"}
- case mailboxOutbox:
- attr = ""
- fallbackNames = []string{"Outbox"}
}
var attrMatched bool
diff --git a/plugins/base/routes.go b/plugins/base/routes.go
index c4ab492..6ffdcf6 100644
--- a/plugins/base/routes.go
+++ b/plugins/base/routes.go
@@ -2,7 +2,6 @@ package alpsbase
import (
"bytes"
- "context"
"fmt"
"io"
"io/ioutil"
@@ -13,7 +12,6 @@ import (
"strings"
"git.sr.ht/~emersion/alps"
- "git.sr.ht/~sircmpwn/dowork"
"github.com/emersion/go-imap"
imapmove "github.com/emersion/go-imap-move"
imapclient "github.com/emersion/go-imap/client"
@@ -80,7 +78,6 @@ type IMAPBaseRenderData struct {
Mailboxes []MailboxInfo
Mailbox *MailboxStatus
Inbox *MailboxStatus
- Outbox *MailboxStatus
}
type MailboxRenderData struct {
@@ -95,7 +92,6 @@ type CategorizedMailboxes struct {
Common struct {
Inbox *MailboxInfo
Drafts *MailboxInfo
- Outbox *MailboxInfo
Sent *MailboxInfo
Junk *MailboxInfo
Trash *MailboxInfo
@@ -131,11 +127,6 @@ func newIMAPBaseRenderData(ctx *alps.Context,
return err
}
}
- if mboxName == "Outbox" {
- outbox = active
- } else {
- outbox, _ = getMailboxStatus(c, "Outbox")
- }
return nil
})
if err != nil {
@@ -146,7 +137,6 @@ func newIMAPBaseRenderData(ctx *alps.Context,
mmap := map[string]**MailboxInfo{
"INBOX": &categorized.Common.Inbox,
"Drafts": &categorized.Common.Drafts,
- "Outbox": &categorized.Common.Outbox,
"Sent": &categorized.Common.Sent,
"Junk": &categorized.Common.Junk,
"Trash": &categorized.Common.Trash,
@@ -497,68 +487,9 @@ type composeOptions struct {
// Send message, append it to the Sent mailbox, mark the original message as
// answered
func submitCompose(ctx *alps.Context, msg *OutgoingMessage, options *composeOptions) error {
- msg.Ref(3)
-
- err := ctx.Session.DoIMAP(func(c *imapclient.Client) error {
- // (disregard error, we don't care if Outbox already existed)
- c.Create("Outbox")
-
- if _, err := appendMessage(c, msg, mailboxOutbox); err != nil {
- return err
- }
-
- msg.Unref()
- return nil
- })
- if err != nil {
- return fmt.Errorf("failed to save message to outbox: %v", err)
- }
-
- task := work.NewTask(func(_ context.Context) error {
- err := ctx.Session.DoSMTP(func (c *smtp.Client) error {
- return sendMessage(c, msg)
- })
- if err != nil {
- ctx.Logger().Printf("Error sending email: %v\n", err)
- }
- return err
- }).Retries(5).After(func(_ context.Context, task *work.Task) {
- ctx.Logger().Printf("email sent: %v", task.Result())
- if task.Result() == nil {
- // Remove from outbox
- err := ctx.Session.DoIMAP(func(c *imapclient.Client) error {
- if err := ensureMailboxSelected(c, "Outbox"); err != nil {
- return err
- }
- uids, err := c.UidSearch(&imap.SearchCriteria{
- Header: map[string][]string{
- "Message-Id": []string{msg.MessageID},
- },
- })
- if err != nil {
- return fmt.Errorf("UID SEARCH failed: %v", err)
- }
- if len(uids) == 1 {
- if err = deleteMessage(c, "Outbox", uids[0]); err != nil {
- return err
- }
- } else {
- ctx.Logger().Errorf(
- "Unexpectedly found multiple results in outbox for message ID %s",
- msg.MessageID)
- }
- return nil
- })
- if err != nil {
- ctx.Logger().Errorf("Error removing message from outbox: %v", err)
- }
- } else {
- ctx.Logger().Errorf("Message delivery failed with error %v", err)
- }
-
- msg.Unref()
+ err := ctx.Session.DoSMTP(func (c *smtp.Client) error {
+ return sendMessage(c, msg)
})
- err = ctx.Server.Queue.Enqueue(task)
if err != nil {
if _, ok := err.(alps.AuthError); ok {
return echo.NewHTTPError(http.StatusForbidden, err)
@@ -579,8 +510,6 @@ func submitCompose(ctx *alps.Context, msg *OutgoingMessage, options *composeOpti
if _, err := appendMessage(c, msg, mailboxSent); err != nil {
return err
}
- msg.Unref()
-
if draft := options.Draft; draft != nil {
if err := deleteMessage(c, draft.Mailbox, draft.Uid); err != nil {
return err
@@ -685,11 +614,9 @@ func handleCompose(ctx *alps.Context, msg *OutgoingMessage, options *composeOpti
if attachment == nil {
return fmt.Errorf("Unable to retrieve message attachment %s from session", uuid)
}
- msg.Attachments = append(msg.Attachments, &refcountedAttachment{
- attachment.File,
- attachment.Form,
- 0,
- })
+ msg.Attachments = append(msg.Attachments,
+ &formAttachment{attachment.File})
+ defer attachment.Form.RemoveAll()
}
if saveAsDraft {
diff --git a/plugins/base/smtp.go b/plugins/base/smtp.go
index 40967dc..14bff07 100644
--- a/plugins/base/smtp.go
+++ b/plugins/base/smtp.go
@@ -53,37 +53,6 @@ func (att *formAttachment) Filename() string {
return att.FileHeader.Filename
}
-type refcountedAttachment struct {
- *multipart.FileHeader
- *multipart.Form
- refs int
-}
-
-func (att *refcountedAttachment) Open() (io.ReadCloser, error) {
- return att.FileHeader.Open()
-}
-
-func (att *refcountedAttachment) MIMEType() string {
- // TODO: retain params, e.g. "charset"?
- t, _, _ := mime.ParseMediaType(att.FileHeader.Header.Get("Content-Type"))
- return t
-}
-
-func (att *refcountedAttachment) Filename() string {
- return att.FileHeader.Filename
-}
-
-func (att *refcountedAttachment) Ref(n int) {
- att.refs += n
-}
-
-func (att *refcountedAttachment) Unref() {
- att.refs -= 1
- if att.refs == 0 {
- att.Form.RemoveAll()
- }
-}
-
type imapAttachment struct {
Mailbox string
Uid uint32
@@ -211,22 +180,6 @@ func (msg *OutgoingMessage) WriteTo(w io.Writer) error {
return nil
}
-func (msg *OutgoingMessage) Ref(n int) {
- for _, a := range msg.Attachments {
- if a, ok := a.(*refcountedAttachment); ok {
- a.Ref(n)
- }
- }
-}
-
-func (msg *OutgoingMessage) Unref() {
- for _, a := range msg.Attachments {
- if a, ok := a.(*refcountedAttachment); ok {
- a.Unref()
- }
- }
-}
-
func sendMessage(c *smtp.Client, msg *OutgoingMessage) error {
if err := c.Mail(msg.From, nil); err != nil {
return fmt.Errorf("MAIL FROM failed: %v", err)
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-21 21:48:18 +0000