forked from Silverfish/proton-bridge
fix(GODT-2343): Only poll after send if sync is complete
This commit is contained in:
@ -287,12 +287,28 @@ func (conn *imapConnector) CreateMessage(
|
|||||||
} else if ok {
|
} else if ok {
|
||||||
conn.log.WithField("messageID", messageID).Warn("Message already sent")
|
conn.log.WithField("messageID", messageID).Warn("Message already sent")
|
||||||
|
|
||||||
message, err := conn.client.GetMessage(ctx, messageID)
|
// Query the server-side message.
|
||||||
|
full, err := conn.client.GetFullMessage(ctx, messageID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return imap.Message{}, nil, fmt.Errorf("failed to fetch message: %w", err)
|
return imap.Message{}, nil, fmt.Errorf("failed to fetch message: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return toIMAPMessage(message.MessageMetadata), nil, nil
|
// Build the message as it is on the server.
|
||||||
|
if err := safe.RLockRet(func() error {
|
||||||
|
return withAddrKR(conn.apiUser, conn.apiAddrs[full.AddressID], conn.vault.KeyPass(), func(_, addrKR *crypto.KeyRing) error {
|
||||||
|
var err error
|
||||||
|
|
||||||
|
if literal, err = message.BuildRFC822(addrKR, full.Message, full.AttData, defaultJobOpts()); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
})
|
||||||
|
}, conn.apiUserLock, conn.apiAddrsLock); err != nil {
|
||||||
|
return imap.Message{}, nil, fmt.Errorf("failed to build message: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return toIMAPMessage(full.MessageMetadata), literal, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
wantLabelIDs := []string{string(mailboxID)}
|
wantLabelIDs := []string{string(mailboxID)}
|
||||||
|
|||||||
@ -431,7 +431,9 @@ func (user *User) NewIMAPConnectors() (map[string]connector.Connector, error) {
|
|||||||
|
|
||||||
// SendMail sends an email from the given address to the given recipients.
|
// SendMail sends an email from the given address to the given recipients.
|
||||||
func (user *User) SendMail(authID string, from string, to []string, r io.Reader) error {
|
func (user *User) SendMail(authID string, from string, to []string, r io.Reader) error {
|
||||||
|
if user.vault.SyncStatus().IsComplete() {
|
||||||
defer user.goPollAPIEvents(true)
|
defer user.goPollAPIEvents(true)
|
||||||
|
}
|
||||||
|
|
||||||
if len(to) == 0 {
|
if len(to) == 0 {
|
||||||
return ErrInvalidRecipient
|
return ErrInvalidRecipient
|
||||||
|
|||||||
Reference in New Issue
Block a user