mirrors/maddy
1
0
Fork 0
mirror of https://github.com/foxcpp/maddy.git synced 2025-04-06 14:37:37 +03:00
Code Issues Projects Releases Packages Wiki Activity

Port existing functionality to go-imap v2

Browse source
This commit is contained in:
fox.cpp 2021-07-18 11:20:13 +03:00
parent ef63383248
commit 2e81d5a976
No known key found for this signature in database
GPG key ID: 5B991F6215D2FCC0
9 changed files with 102 additions and 210 deletions
Download patch file Download diff file Expand all files Collapse all files

17
internal/endpoint/imap/imap.go
View file

@ -57,7 +57,6 @@ type Endpoint struct {
listeners []net.Listener
Store module.Storage
updater imapbackend.BackendUpdater
tlsConfig *tls.Config
listenersWg sync.WaitGroup
@ -98,24 +97,12 @@ func (endp *Endpoint) Init(cfg *config.Map) error {
return err
}
var ok bool
endp.updater, ok = endp.Store.(imapbackend.BackendUpdater)
if !ok {
return fmt.Errorf("imap: storage module %T does not implement imapbackend.BackendUpdater", endp.Store)
}
if updBe, ok := endp.Store.(updatepipe.Backend); ok {
if err := updBe.EnableUpdatePipe(updatepipe.ModeReplicate); err != nil {
endp.Log.Error("failed to initialize updates pipe", err)
}
}
// Call Updates once at start, some storage backends initialize update
// channel lazily and may not generate updates at all unless it is called.
if endp.updater.Updates() == nil {
return fmt.Errorf("imap: failed to init backend: nil update channel")
}
addresses := make([]config.Endpoint, 0, len(endp.addrs))
for _, addr := range endp.addrs {
saddr, err := config.ParseEndpoint(addr)
@ -198,10 +185,6 @@ func (endp *Endpoint) setupListeners(addresses []config.Endpoint) error {
return nil
}
func (endp *Endpoint) Updates() <-chan imapbackend.Update {
return endp.updater.Updates()
}
func (endp *Endpoint) Name() string {
return "imap"
}