forked from Silverfish/proton-bridge
7a192d50db
Incoming messages which arrive into labels we know during sync are now presented to the IMAP clients. We also allow messages to be deleted while syncing if deleted on other clients. Other operations such as moving, marking messages as read and label operations need to be considered in a follow up patch as they are far more complex.
83 lines
2.3 KiB
Go
83 lines
2.3 KiB
Go
// Copyright (c) 2023 Proton AG
|
|
//
|
|
// This file is part of Proton Mail Bridge.
|
|
//
|
|
// Proton Mail Bridge is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// Proton Mail Bridge is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with Proton Mail Bridge. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
package imapservice
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/ProtonMail/go-proton-api"
|
|
"github.com/ProtonMail/proton-bridge/v3/internal/logging"
|
|
"github.com/ProtonMail/proton-bridge/v3/internal/services/userevents"
|
|
)
|
|
|
|
func (s *Service) newSyncEventHandler() userevents.EventHandler {
|
|
return userevents.EventHandler{
|
|
RefreshHandler: s,
|
|
AddressHandler: s,
|
|
UserHandler: s,
|
|
LabelHandler: nil,
|
|
MessageHandler: &syncMessageEventHandler{service: s},
|
|
UsedSpaceHandler: nil,
|
|
UserSettingsHandler: nil,
|
|
}
|
|
}
|
|
|
|
type syncMessageEventHandler struct {
|
|
service *Service
|
|
}
|
|
|
|
func (s syncMessageEventHandler) HandleMessageEvents(ctx context.Context, events []proton.MessageEvent) error {
|
|
s.service.log.Debug("handling message events (sync)")
|
|
for _, event := range events {
|
|
//nolint:exhaustive
|
|
switch event.Action {
|
|
case proton.EventCreate:
|
|
updates, err := onMessageCreated(
|
|
logging.WithLogrusField(ctx, "action", "create message (sync)"),
|
|
s.service,
|
|
event.Message,
|
|
true,
|
|
)
|
|
if err != nil {
|
|
reportError(s.service.reporter, s.service.log, "Failed to apply create message event", err)
|
|
return fmt.Errorf("failed to handle create message event: %w", err)
|
|
}
|
|
|
|
if err := waitOnIMAPUpdates(ctx, updates); err != nil {
|
|
return err
|
|
}
|
|
|
|
case proton.EventDelete:
|
|
updates := onMessageDeleted(
|
|
logging.WithLogrusField(ctx, "action", "delete message (sync)"),
|
|
s.service,
|
|
event,
|
|
)
|
|
|
|
if err := waitOnIMAPUpdates(ctx, updates); err != nil {
|
|
return fmt.Errorf("failed to handle delete message event in gluon: %w", err)
|
|
}
|
|
default:
|
|
continue
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|