13 "github.com/uber-go/zap"
15 "src.bluestatic.org/mailpopbox/pop3"
18 func runPOP3Server(config Config, log zap.Logger) <-chan ServerControlMessage {
21 controlChan: make(chan ServerControlMessage),
22 log: log.With(zap.String("server", "pop3")),
25 return server.controlChan
28 type pop3Server struct {
30 controlChan chan ServerControlMessage
34 func (server *pop3Server) run() {
35 for _, s := range server.config.Servers {
36 if err := os.Mkdir(s.MaildropPath, 0700); err != nil && !os.IsExist(err) {
37 server.log.Error("failed to open maildrop", zap.Error(err))
38 server.controlChan <- ServerControlFatalError
42 l, err := server.newListener()
44 server.controlChan <- ServerControlFatalError
48 connChan := make(chan net.Conn)
49 go RunAcceptLoop(l, connChan, server.log)
51 reloadChan := CreateReloadSignal()
56 server.log.Info("restarting server")
58 server.controlChan <- ServerControlRestart
60 case conn, ok := <-connChan:
62 go pop3.AcceptConnection(conn, server, server.log)
64 server.controlChan <- ServerControlFatalError
71 func (server *pop3Server) newListener() (net.Listener, error) {
72 tlsConfig, err := server.config.GetTLSConfig()
74 server.log.Error("failed to configure TLS", zap.Error(err))
78 addr := fmt.Sprintf(":%d", server.config.POP3Port)
79 server.log.Info("starting server", zap.String("address", addr))
83 l, err = net.Listen("tcp", addr)
85 l, err = tls.Listen("tcp", addr, tlsConfig)
88 server.log.Error("listen", zap.Error(err))
95 func (server *pop3Server) Name() string {
96 return server.config.Hostname
99 func (server *pop3Server) OpenMailbox(user, pass string) (pop3.Mailbox, error) {
100 for _, s := range server.config.Servers {
101 if user == MailboxAccount+s.Domain && pass == s.MailboxPassword {
102 return server.openMailbox(s.MaildropPath)
105 return nil, errors.New("permission denied")
108 func (server *pop3Server) openMailbox(maildrop string) (*mailbox, error) {
109 files, err := ioutil.ReadDir(maildrop)
111 // TODO: hide error, log instead
116 messages: make([]message, 0, len(files)),
120 for _, file := range files {
126 filename: path.Join(maildrop, file.Name()),
130 mb.messages = append(mb.messages, msg)
137 type mailbox struct {
141 type message struct {
148 func (m message) UniqueID() string {
150 return path.Base(m.filename[:l-len(".msg")])
153 func (m message) ID() int {
157 func (m message) Size() int {
161 func (m message) Deleted() bool {
165 func (mb *mailbox) ListMessages() ([]pop3.Message, error) {
166 msgs := make([]pop3.Message, len(mb.messages))
167 for i := 0; i < len(mb.messages); i++ {
168 msgs[i] = &mb.messages[i]
173 func (mb *mailbox) GetMessage(id int) pop3.Message {
174 if id > len(mb.messages) {
177 return &mb.messages[id-1]
180 func (mb *mailbox) Retrieve(msg pop3.Message) (io.ReadCloser, error) {
181 filename := msg.(*message).filename
182 return os.Open(filename)
185 func (mb *mailbox) Delete(msg pop3.Message) error {
186 msg.(*message).deleted = true
190 func (mb *mailbox) Close() error {
191 for _, message := range mb.messages {
193 os.Remove(message.filename)
199 func (mb *mailbox) Reset() {
200 for i, _ := range mb.messages {
201 mb.messages[i].deleted = false