fix(GODT-2683): Reduce validation checks when appending into Drafts

internal/session/handle_append.go

@@ -26,11 +26,22 @@ func (s *Session) handleAppend(ctx context.Context, tag string, cmd *command.App
 		return response.Bad(tag).WithError(err)
 	}
 
-	if err := rfc5322.ValidateMessageHeaderFields(cmd.Literal); err != nil {
-		return response.Bad(tag).WithError(err)
-	}
-
 	if err := s.state.AppendOnlyMailbox(ctx, nameUTF8, func(mailbox state.AppendOnlyMailbox, isSameMBox bool) error {
+		isDrafts, err := mailbox.IsDrafts(ctx)
+		if err != nil {
+			return err
+		}
+
+		if !isDrafts {
+			if err := rfc5322.ValidateMessageHeaderFields(cmd.Literal); err != nil {
+				return response.Bad(tag).WithError(err)
+			}
+		} else {
+			if err := rfc5322.ValidateMessageHeaderFieldsDrafts(cmd.Literal); err != nil {
+				return response.Bad(tag).WithError(err)
+			}
+		}
+
 		messageUID, err := mailbox.Append(ctx, cmd.Literal, flags, cmd.DateTime)
 		if err != nil {
 			if shouldReportIMAPCommandError(err) {

internal/state/mailbox.go

@@ -37,6 +37,7 @@ type AppendOnlyMailbox interface {
 	Append(ctx context.Context, literal []byte, flags imap.FlagSet, date time.Time) (imap.UID, error)
 	Flush(ctx context.Context, permitExpunge bool) ([]response.Response, error)
 	UIDValidity() imap.UID
+	IsDrafts(ctx context.Context) (bool, error)
 }
 
 func newMailbox(mbox *db.Mailbox, state *State, snap *snapshot) *Mailbox {
@@ -251,6 +252,15 @@ func (m *Mailbox) Append(ctx context.Context, literal []byte, flags imap.FlagSet
 	return uid, err
 }
 
+func (m *Mailbox) IsDrafts(ctx context.Context) (bool, error) {
+	attrs, err := m.Attributes(ctx)
+	if err != nil {
+		return false, err
+	}
+
+	return attrs.Contains(imap.AttrDrafts), nil
+}
+
 // Copy copies the messages represented by the given sequence set into the mailbox with the given name.
 // If the context is a UID context, the sequence set refers to message UIDs.
 // If no items are copied the response object will be nil.

rfc5322/validation.go

@@ -72,3 +72,27 @@ func ValidateMessageHeaderFields(literal []byte) error {
 
 	return nil
 }
+
+// ValidateMessageHeaderFieldsDrafts checks the headers of message to verify that at least a valid From header is
+// present.
+func ValidateMessageHeaderFieldsDrafts(literal []byte) error {
+	headerBytes, _ := rfc822.Split(literal)
+
+	header, err := rfc822.NewHeader(headerBytes)
+	if err != nil {
+		return err
+	}
+
+	// Check for from.
+	value := header.Get("From")
+	if len(value) == 0 {
+		return fmt.Errorf("%w: Required header field 'From' not found or empty", ErrInvalidMessage)
+	}
+
+	// Check if From is a multi address. If so, a sender filed must be present and non-empty.
+	if _, err := ParseAddressList(value); err != nil {
+		return fmt.Errorf("%w: failed to parse From header: %v", ErrInvalidMessage, err)
+	}
+
+	return nil
+}

tests/append_test.go

@@ -449,3 +449,37 @@ func TestGODT2007AppendInternalIDPresentOnDeletedMessage(t *testing.T) {
 		}
 	})
 }
+
+func TestAppendIntoDraftsWithFromOnly(t *testing.T) {
+	const (
+		literalWithFrom    = `From: Foo@bar`
+		literalWithoutFrom = `To: Foo@bar`
+		literalValid       = `From: Foo@bar
+Date: Wed, 26 Apr 2023 08:25:16 +0200
+`
+	)
+
+	runOneToOneTestClientWithAuth(t, defaultServerOptions(t), func(client *client.Client, s *testSession) {
+
+		s.mailboxCreatedWithAttributes("user", []string{"Drafts"}, imap.NewFlagSet(imap.AttrDrafts))
+		s.flush("user")
+
+		{
+			require.NoError(t, doAppendWithClient(client, "Drafts", literalWithFrom, time.Now()))
+			require.NoError(t, doAppendWithClient(client, "INBOX", literalValid, time.Now()))
+			require.Error(t, doAppendWithClient(client, "Drafts", literalWithoutFrom, time.Now()))
+			require.Error(t, doAppendWithClient(client, "INBOX", literalWithoutFrom, time.Now()))
+		}
+
+		{
+			status, err := client.Status("Drafts", []goimap.StatusItem{goimap.StatusMessages})
+			require.NoError(t, err)
+			require.Equal(t, uint32(1), status.Messages, "Expected message count does not match")
+		}
+		{
+			status, err := client.Status("INBOX", []goimap.StatusItem{goimap.StatusMessages})
+			require.NoError(t, err)
+			require.Equal(t, uint32(1), status.Messages, "Expected message count does not match")
+		}
+	})
+}