Kaiy Belist
39759db7c2
- Bridge Node Support: Added functionality to manage mail (send/receive) on remote nodes via a bridge node. Full transparent management requires a private key on the bridge, while the remote node can operate with only a public key. - End-to-End Encryption (E2EE): Integrated E2EE using age. Encryption and decryption occur strictly at the bridge level; node administrators cannot access message content. - New Addressing Schema: Transitioned from nodepub@yggmail to userpub@nodepub. - Key Adaptation: Implemented ed25519 to x25519 coordinate adaptation, allowing signing keys to be used for encryption. Changed - Address Encoding: Switched from hex16 to base32 for the address space. - Memory Optimization: Replaced direct memory allocations with streaming for mail processing to reduce RAM overhead. - Code Refactoring: Performed decomposition of the original inherited codebase to improve maintainability. Fixed - Mail Updates: Fixed the mail retrieval mechanism to ensure near-instant updates for incoming messages. Changes to be committed: modified: .gitignore modified: README.md modified: cmd/yggmail/main.go modified: go.mod modified: go.sum new file: internal/account/manager.go new file: internal/account/session.go modified: internal/imapserver/backend.go modified: internal/imapserver/imap.go modified: internal/imapserver/mailbox.go modified: internal/imapserver/notify.go modified: internal/imapserver/user.go new file: internal/notify/notify.go new file: internal/notify/remote/remote.go new file: internal/remote/client.go new file: internal/remote/handlers.go new file: internal/remote/io.go new file: internal/remote/server.go new file: internal/remote/sign.go new file: internal/remote/types/request.pb.go new file: internal/remote/types/request.proto new file: internal/remote/types/response.pb.go new file: internal/remote/types/response.proto new file: internal/shell/shell.go modified: internal/smtpsender/sender.go modified: internal/smtpserver/backend.go modified: internal/smtpserver/session_local.go modified: internal/smtpserver/session_remote.go modified: internal/smtpserver/smtp.go new file: internal/storage/filestore/filestore.go new file: internal/storage/local/storage.go new file: internal/storage/remote/mail.go new file: internal/storage/remote/mailbox.go new file: internal/storage/remote/queue.go new file: internal/storage/remote/storage.go new file: internal/storage/remote/watch.go modified: internal/storage/sqlite3/sqlite3.go new file: internal/storage/sqlite3/table_accounts.go modified: internal/storage/sqlite3/table_mailboxes.go modified: internal/storage/sqlite3/table_mails.go modified: internal/storage/sqlite3/table_queue.go modified: internal/storage/storage.go modified: internal/storage/types/types.go modified: internal/utils/address.go new file: internal/utils/age/age.go new file: internal/utils/age/bech32/bech32.go new file: internal/utils/crypt.go new file: internal/utils/e2ee/crypt.go new file: internal/utils/e2ee/e2ee_test.go new file: internal/utils/e2ee/msg.go new file: internal/utils/x25519.go modified: internal/welcome/welcome.go
110 lines
2.4 KiB
Go
110 lines
2.4 KiB
Go
/*
|
|
* Copyright (c) 2021 Neil Alexander
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
*/
|
|
|
|
package imapserver
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"log"
|
|
|
|
"github.com/emersion/go-imap"
|
|
"github.com/emersion/go-imap/backend"
|
|
"github.com/neilalexander/yggmail/internal/account"
|
|
"github.com/neilalexander/yggmail/internal/storage"
|
|
)
|
|
|
|
type User struct {
|
|
//backend *Backend
|
|
storage storage.Storage
|
|
username string
|
|
session *account.Session
|
|
conn *imap.ConnInfo
|
|
log *log.Logger
|
|
}
|
|
|
|
func (u *User) Username() string {
|
|
return u.session.Username()
|
|
}
|
|
|
|
func (u *User) ListMailboxes(subscribed bool) (mailboxes []backend.Mailbox, err error) {
|
|
names, err := u.storage.MailboxList(u.username, subscribed)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
for _, mailbox := range names {
|
|
mailboxes = append(mailboxes, &Mailbox{
|
|
storage: u.storage,
|
|
user: u,
|
|
name: mailbox,
|
|
})
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
func (u *User) GetMailbox(name string) (mailbox backend.Mailbox, err error) {
|
|
if name == "" {
|
|
return &Mailbox{
|
|
storage: u.storage,
|
|
user: u,
|
|
name: "",
|
|
}, nil
|
|
}
|
|
ok, _ := u.storage.MailboxSelect(u.username, name)
|
|
if !ok {
|
|
return nil, fmt.Errorf("mailbox %q not found", name)
|
|
}
|
|
return &Mailbox{
|
|
storage: u.storage,
|
|
user: u,
|
|
name: name,
|
|
}, nil
|
|
}
|
|
|
|
func (u *User) CreateMailbox(name string) error {
|
|
u.log.Printf("Creating mailbox '%s'...\n", name)
|
|
|
|
if e := u.storage.MailboxCreate(u.username, name); e != nil {
|
|
u.log.Printf("Error creating mailbox '%s': %v\n", name, e)
|
|
return e
|
|
}
|
|
|
|
u.log.Printf("Created mailbox '%s'\n", name)
|
|
return nil
|
|
}
|
|
|
|
func (u *User) DeleteMailbox(name string) error {
|
|
switch name {
|
|
case "INBOX", "Outbox", "Sent":
|
|
return errors.New("Cannot delete " + name)
|
|
default:
|
|
if e := u.storage.MailboxDelete(u.username, name); e != nil {
|
|
u.log.Printf("Error deleting mailbox '%s': %v\n", name, e)
|
|
return e
|
|
} else {
|
|
u.log.Printf("Deleted mailbox '%s'\n", name)
|
|
return e
|
|
}
|
|
}
|
|
}
|
|
|
|
func (u *User) RenameMailbox(existingName, newName string) error {
|
|
switch existingName {
|
|
case "INBOX", "Outbox", "Sent":
|
|
return errors.New("Cannot rename " + existingName)
|
|
default:
|
|
return u.storage.MailboxRename(u.username, existingName, newName)
|
|
}
|
|
}
|
|
|
|
func (u *User) Logout() error {
|
|
return nil
|
|
}
|