|
|
@@ -3,6 +3,7 @@ package goimap
|
|
|
import (
|
|
|
"bufio"
|
|
|
"crypto/tls"
|
|
|
+ "encoding/base64"
|
|
|
"errors"
|
|
|
"fmt"
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
@@ -122,6 +123,557 @@ func (s *Server) Stop() {
|
|
|
s.stop <- true
|
|
|
}
|
|
|
|
|
|
+func (s *Server) authenticate(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if args == "LOGIN" {
|
|
|
+ write(conn, "+ VXNlciBOYW1lAA=="+eol, "")
|
|
|
+ line, err2 := reader.ReadString('\n')
|
|
|
+ if err2 != nil {
|
|
|
+ if conn != nil {
|
|
|
+ _ = conn.Close()
|
|
|
+ }
|
|
|
+ session.Conn = nil
|
|
|
+ session.IN_IDLE = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ account, err := base64.StdEncoding.DecodeString(line)
|
|
|
+ if err != nil {
|
|
|
+ showBad(conn, "Data Error.", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ write(conn, "+ UGFzc3dvcmQA"+eol, "")
|
|
|
+ line, err = reader.ReadString('\n')
|
|
|
+ if err2 != nil {
|
|
|
+ if conn != nil {
|
|
|
+ _ = conn.Close()
|
|
|
+ }
|
|
|
+ session.Conn = nil
|
|
|
+ session.IN_IDLE = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ password, err := base64.StdEncoding.DecodeString(line)
|
|
|
+ res := s.Action.Login(session, string(account), string(password))
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ showBad(conn, "Unsupported AUTHENTICATE mechanism.", nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) capability(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ res := s.Action.CapaBility(session)
|
|
|
+ if res.Type == BAD {
|
|
|
+ write(conn, fmt.Sprintf("* BAD %s%s", res.Message, eol), nub)
|
|
|
+ } else {
|
|
|
+ ret := "*"
|
|
|
+ for _, command := range res.Data {
|
|
|
+ ret += " " + command
|
|
|
+ }
|
|
|
+ ret += eol
|
|
|
+ write(conn, ret, nub)
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) create(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "CREATE", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Create(session, args)
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) delete(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "DELETE", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Delete(session, args)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) rename(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "RENAME", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.Split(args, " ")
|
|
|
+ res := s.Action.Rename(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) list(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "LIST", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.Split(args, " ")
|
|
|
+ dt[0] = strings.Trim(dt[0], `"`)
|
|
|
+ dt[1] = strings.Trim(dt[1], `"`)
|
|
|
+ res := s.Action.List(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSuccWithData(conn, res.Data, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) append(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ log.Debugf("Append: %+v", args)
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) cselect(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Select(session, args)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSuccWithData(conn, res.Data, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) fetch(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader, uid bool) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "FETCH", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.SplitN(args, " ", 2)
|
|
|
+ res := s.Action.Fetch(session, dt[0], dt[1], uid)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSuccWithData(conn, res.Data, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) store(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "RENAME", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.Split(args, " ")
|
|
|
+ res := s.Action.Store(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) cclose(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ res := s.Action.Close(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) expunge(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Expunge(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) examine(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "EXAMINE", nub)
|
|
|
+ }
|
|
|
+ res := s.Action.Examine(session, args)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) unsubscribe(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "UNSUBSCRIBE", nub)
|
|
|
+ } else {
|
|
|
+ res := s.Action.UnSubscribe(session, args)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) lsub(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "LSUB", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.Split(args, " ")
|
|
|
+ res := s.Action.LSub(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) status(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "STATUS", nub)
|
|
|
+ } else {
|
|
|
+ var mailBox string
|
|
|
+ var params []string
|
|
|
+ if strings.HasPrefix(args, `"`) {
|
|
|
+ dt := strings.Split(args, `"`)
|
|
|
+ if len(dt) >= 3 {
|
|
|
+ mailBox = dt[1]
|
|
|
+ }
|
|
|
+ dt[2] = strings.Trim(dt[2], "() ")
|
|
|
+ params = strings.Split(dt[2], " ")
|
|
|
+ } else {
|
|
|
+ dt := strings.SplitN(args, " ", 2)
|
|
|
+ dt[0] = strings.ReplaceAll(dt[0], `"`, "")
|
|
|
+ dt[1] = strings.Trim(dt[1], "()")
|
|
|
+ mailBox = dt[0]
|
|
|
+ params = strings.Split(dt[1], " ")
|
|
|
+ }
|
|
|
+
|
|
|
+ res := s.Action.Status(session, mailBox, params)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSuccWithData(conn, res.Data, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) check(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Check(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) search(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "SEARCH", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.SplitN(args, " ", 2)
|
|
|
+ res := s.Action.Search(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) copy(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "COPY", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.SplitN(args, " ", 2)
|
|
|
+ res := s.Action.Copy(session, dt[0], dt[1])
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) noop(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ res := s.Action.Noop(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) login(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "LOGIN", nub)
|
|
|
+ } else {
|
|
|
+ dt := strings.SplitN(args, " ", 2)
|
|
|
+ res := s.Action.Login(session, strings.Trim(dt[0], `"`), strings.Trim(dt[1], `"`))
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) logout(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ res := s.Action.Logout(session)
|
|
|
+ write(conn, "* BYE PMail Server logging out"+eol, nub)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ if conn != nil {
|
|
|
+ _ = conn.Close()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) unselect(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ res := s.Action.Unselect(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) subscribe(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if args == "" {
|
|
|
+ paramsErr(conn, "SUBSCRIBE", nub)
|
|
|
+ } else {
|
|
|
+ res := s.Action.Subscribe(session, args)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) idle(session *Session, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ if session.Status != AUTHORIZED {
|
|
|
+ showBad(conn, "Need Login", nub)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ session.IN_IDLE = true
|
|
|
+ res := s.Action.IDLE(session)
|
|
|
+ if res.Type == SUCCESS {
|
|
|
+ write(conn, "+ idling"+eol, nub)
|
|
|
+ } else if res.Type == BAD {
|
|
|
+ showBad(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) custom(session *Session, cmd string, args string, nub string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ res := s.Action.Custom(session, cmd, args)
|
|
|
+ if res.Type == BAD {
|
|
|
+ write(conn, fmt.Sprintf("* BAD %s %s", res.Message, eol), nub)
|
|
|
+ } else if res.Type == NO {
|
|
|
+ showNo(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ if len(res.Data) == 0 {
|
|
|
+ showSucc(conn, res.Message, nub)
|
|
|
+ } else {
|
|
|
+ ret := ""
|
|
|
+ for _, re := range res.Data {
|
|
|
+ ret += fmt.Sprintf("%s%s", re, eol)
|
|
|
+ }
|
|
|
+ ret += "." + eol
|
|
|
+ write(conn, fmt.Sprintf(ret), nub)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (s *Server) doCommand(session *Session, rawLine string, conn net.Conn, reader *bufio.Reader) {
|
|
|
+ nub, cmd, args := getCommand(rawLine)
|
|
|
+ log.Debugf("Imap Input:\t %s", rawLine)
|
|
|
+ if cmd != "IDLE" {
|
|
|
+ session.IN_IDLE = false
|
|
|
+ }
|
|
|
+
|
|
|
+ switch cmd {
|
|
|
+ case "":
|
|
|
+ if conn != nil {
|
|
|
+ conn.Close()
|
|
|
+ conn = nil
|
|
|
+ }
|
|
|
+ break
|
|
|
+
|
|
|
+ case "AUTHENTICATE":
|
|
|
+ s.authenticate(session, args, nub, conn, reader)
|
|
|
+ case "CAPABILITY":
|
|
|
+ s.capability(session, rawLine, nub, conn, reader)
|
|
|
+ case "CREATE":
|
|
|
+ s.create(session, args, nub, conn, reader)
|
|
|
+ case "DELETE":
|
|
|
+ s.delete(session, args, nub, conn, reader)
|
|
|
+ case "RENAME":
|
|
|
+ s.rename(session, args, nub, conn, reader)
|
|
|
+ case "LIST":
|
|
|
+ s.list(session, args, nub, conn, reader)
|
|
|
+ case "APPEND":
|
|
|
+ s.append(session, args, nub, conn, reader)
|
|
|
+ case "SELECT":
|
|
|
+ s.cselect(session, args, nub, conn, reader)
|
|
|
+ case "FETCH":
|
|
|
+ s.fetch(session, args, nub, conn, reader, false)
|
|
|
+ case "UID FETCH":
|
|
|
+ s.fetch(session, args, nub, conn, reader, true)
|
|
|
+ case "STORE":
|
|
|
+ s.store(session, args, nub, conn, reader)
|
|
|
+ case "CLOSE":
|
|
|
+ s.cclose(session, args, nub, conn, reader)
|
|
|
+ case "EXPUNGE":
|
|
|
+ s.expunge(session, args, nub, conn, reader)
|
|
|
+ case "EXAMINE":
|
|
|
+ s.examine(session, args, nub, conn, reader)
|
|
|
+ case "SUBSCRIBE":
|
|
|
+ s.subscribe(session, args, nub, conn, reader)
|
|
|
+ case "UNSUBSCRIBE":
|
|
|
+ s.unsubscribe(session, args, nub, conn, reader)
|
|
|
+ case "LSUB":
|
|
|
+ s.lsub(session, args, nub, conn, reader)
|
|
|
+ case "STATUS":
|
|
|
+ s.status(session, args, nub, conn, reader)
|
|
|
+ case "CHECK":
|
|
|
+ s.check(session, args, nub, conn, reader)
|
|
|
+ case "SEARCH":
|
|
|
+ s.search(session, args, nub, conn, reader)
|
|
|
+ case "COPY":
|
|
|
+ s.copy(session, args, nub, conn, reader)
|
|
|
+ case "NOOP":
|
|
|
+ s.noop(session, args, nub, conn, reader)
|
|
|
+ case "LOGIN":
|
|
|
+ s.login(session, args, nub, conn, reader)
|
|
|
+ case "LOGOUT":
|
|
|
+ s.logout(session, args, nub, conn, reader)
|
|
|
+ case "UNSELECT":
|
|
|
+ s.unselect(session, args, nub, conn, reader)
|
|
|
+ case "IDLE":
|
|
|
+ s.idle(session, args, nub, conn, reader)
|
|
|
+ default:
|
|
|
+ s.custom(session, cmd, args, nub, conn, reader)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
func (s *Server) handleClient(conn net.Conn) {
|
|
|
slog.Debug("Imap conn")
|
|
|
|
|
|
@@ -159,7 +711,7 @@ func (s *Server) handleClient(conn net.Conn) {
|
|
|
}
|
|
|
|
|
|
reader := bufio.NewReader(conn)
|
|
|
- write(conn, `* OK [CAPABILITY IMAP4 IMAP4rev1 AUTH=PLAIN AUTH=LOGIN] PMail Server ready`, "")
|
|
|
+ write(conn, fmt.Sprintf(`* OK [CAPABILITY IMAP4 IMAP4rev1 AUTH=LOGIN] PMail Server ready%s`, eol), "")
|
|
|
|
|
|
for {
|
|
|
rawLine, err := reader.ReadString('\n')
|
|
|
@@ -173,316 +725,7 @@ func (s *Server) handleClient(conn net.Conn) {
|
|
|
}
|
|
|
session.AliveTime = time.Now()
|
|
|
|
|
|
- nub, cmd, args := getCommand(rawLine)
|
|
|
- log.Debugf("Imap Input:\t %s", rawLine)
|
|
|
- if cmd != "IDLE" {
|
|
|
- session.IN_IDLE = false
|
|
|
- }
|
|
|
-
|
|
|
- switch cmd {
|
|
|
- case "":
|
|
|
- if conn != nil {
|
|
|
- conn.Close()
|
|
|
- conn = nil
|
|
|
- }
|
|
|
- break
|
|
|
-
|
|
|
- case "CAPABILITY":
|
|
|
- commands, err := s.Action.CapaBility(session)
|
|
|
- if err != nil {
|
|
|
- write(conn, fmt.Sprintf("* BAD %s%s", err.Error(), eol), nub)
|
|
|
- } else {
|
|
|
- ret := "*"
|
|
|
- for _, command := range commands {
|
|
|
- ret += " " + command
|
|
|
- }
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, nub)
|
|
|
- }
|
|
|
-
|
|
|
- case "CREATE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "CREATE", nub)
|
|
|
- break
|
|
|
- }
|
|
|
- err := s.Action.Create(session, args)
|
|
|
- output(conn, nub, err)
|
|
|
- case "DELETE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "DELETE", nub)
|
|
|
- break
|
|
|
- }
|
|
|
- err := s.Action.Delete(session, args)
|
|
|
- output(conn, nub, err)
|
|
|
- case "RENAME":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "RENAME", nub)
|
|
|
- } else {
|
|
|
- dt := strings.Split(args, " ")
|
|
|
- err := s.Action.Rename(session, dt[0], dt[1])
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
- case "LIST":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "LIST", nub)
|
|
|
- } else {
|
|
|
- dt := strings.Split(args, " ")
|
|
|
- dt[0] = strings.ReplaceAll(dt[0], `"`, "")
|
|
|
- rets, err := s.Action.List(session, dt[0], dt[1])
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- ret := ""
|
|
|
- for _, str := range rets {
|
|
|
- ret += str + eol
|
|
|
- }
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, nub)
|
|
|
- }
|
|
|
- }
|
|
|
- case "APPEND":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- log.Debugf("Append: %+v", args)
|
|
|
- case "SELECT":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- ret, err := s.Action.Select(session, args)
|
|
|
- args = strings.ReplaceAll(args, `"`, "")
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- for _, s2 := range ret {
|
|
|
- write(conn, s2, nub)
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- case "FETCH":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "RENAME", nub)
|
|
|
- } else {
|
|
|
- dt := strings.Split(args, " ")
|
|
|
- ret, err := s.Action.Fetch(session, dt[0], dt[1])
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, ret)
|
|
|
- }
|
|
|
- }
|
|
|
- case "STORE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "RENAME", nub)
|
|
|
- } else {
|
|
|
- dt := strings.Split(args, " ")
|
|
|
- err := s.Action.Store(session, dt[0], dt[1])
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
- case "CLOSE":
|
|
|
- err := s.Action.Close(session)
|
|
|
- output(conn, nub, err)
|
|
|
- case "EXPUNGE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- err := s.Action.Expunge(session)
|
|
|
- output(conn, nub, err)
|
|
|
- case "EXAMINE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "EXAMINE", nub)
|
|
|
- }
|
|
|
- err := s.Action.Examine(session, args)
|
|
|
- output(conn, nub, err)
|
|
|
- case "SUBSCRIBE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "SUBSCRIBE", nub)
|
|
|
- } else {
|
|
|
- err := s.Action.Subscribe(session, args)
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
- case "UNSUBSCRIBE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "UNSUBSCRIBE", nub)
|
|
|
- } else {
|
|
|
- err := s.Action.UnSubscribe(session, args)
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
- case "LSUB":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "LSUB", nub)
|
|
|
- } else {
|
|
|
- dt := strings.Split(args, " ")
|
|
|
- rets, err := s.Action.LSub(session, dt[0], dt[1])
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- ret := ""
|
|
|
- for _, str := range rets {
|
|
|
- ret += str + eol
|
|
|
- }
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, nub)
|
|
|
- }
|
|
|
- }
|
|
|
- case "STATUS":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "STATUS", nub)
|
|
|
- } else {
|
|
|
- dt := strings.SplitN(args, " ", 2)
|
|
|
- dt[0] = strings.ReplaceAll(dt[0], `"`, "")
|
|
|
- dt[1] = strings.Trim(dt[1], "()")
|
|
|
- params := strings.Split(dt[1], " ")
|
|
|
-
|
|
|
- ret, err := s.Action.Status(session, dt[0], params)
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, nub)
|
|
|
- }
|
|
|
- }
|
|
|
- case "CHECK":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- err := s.Action.Check(session)
|
|
|
- output(conn, nub, err)
|
|
|
- case "SEARCH":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "SEARCH", nub)
|
|
|
- } else {
|
|
|
- dt := strings.SplitN(args, " ", 2)
|
|
|
- ret, err := s.Action.Search(session, dt[0], dt[1])
|
|
|
- if err != nil {
|
|
|
- showBad(conn, err, nub)
|
|
|
- } else {
|
|
|
- write(conn, ret, nub)
|
|
|
- showSucc(conn, nub)
|
|
|
- }
|
|
|
- }
|
|
|
- case "COPY":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "COPY", nub)
|
|
|
- } else {
|
|
|
- dt := strings.SplitN(args, " ", 2)
|
|
|
- err := s.Action.Copy(session, dt[0], dt[1])
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
-
|
|
|
- case "NOOP":
|
|
|
- err := s.Action.Noop(session)
|
|
|
- output(conn, nub, err)
|
|
|
- case "LOGIN":
|
|
|
- if args == "" {
|
|
|
- paramsErr(conn, "LOGIN", nub)
|
|
|
- } else {
|
|
|
- dt := strings.SplitN(args, " ", 2)
|
|
|
- err := s.Action.Login(session, dt[0], dt[1])
|
|
|
- output(conn, nub, err)
|
|
|
- }
|
|
|
- case "LOGOUT":
|
|
|
- err := s.Action.Logout(session)
|
|
|
- write(conn, "* BYE PMail Server logging out", nub)
|
|
|
- output(conn, nub, err)
|
|
|
- if conn != nil {
|
|
|
- _ = conn.Close()
|
|
|
- }
|
|
|
- case "UNSELECT":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- err := s.Action.Unselect(session)
|
|
|
- output(conn, nub, err)
|
|
|
- case "IDLE":
|
|
|
- if session.Status != AUTHORIZED {
|
|
|
- showBad(conn, errors.New("Need Login"), nub)
|
|
|
- break
|
|
|
- }
|
|
|
- session.IN_IDLE = true
|
|
|
- err := s.Action.IDLE(session)
|
|
|
- if err != nil {
|
|
|
- write(conn, fmt.Sprintf("+ idling%s", eol), nub)
|
|
|
- } else {
|
|
|
- showBad(conn, err, nub)
|
|
|
- }
|
|
|
- default:
|
|
|
- rets, err := s.Action.Custom(session, cmd, args)
|
|
|
- if err != nil {
|
|
|
- write(conn, fmt.Sprintf("* BAD %s %s", err.Error(), eol), nub)
|
|
|
- } else {
|
|
|
- if len(rets) == 0 {
|
|
|
- write(conn, fmt.Sprintf("%s OK %s", nub, eol), nub)
|
|
|
- } else if len(rets) == 1 {
|
|
|
- write(conn, fmt.Sprintf("%s OK %s%s", nub, rets[0], eol), nub)
|
|
|
- } else {
|
|
|
- ret := fmt.Sprintf("%s OK %s", nub, eol)
|
|
|
- for _, re := range rets {
|
|
|
- ret += fmt.Sprintf("%s%s", re, eol)
|
|
|
- }
|
|
|
- ret += "." + eol
|
|
|
- write(conn, fmt.Sprintf(ret), nub)
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
+ s.doCommand(session, rawLine, conn, reader)
|
|
|
|
|
|
}
|
|
|
}
|
|
|
@@ -495,15 +738,18 @@ func getCommand(line string) (string, string, string) {
|
|
|
return "", "", ""
|
|
|
}
|
|
|
|
|
|
- for i, s := range cmd {
|
|
|
- cmd[i] = s
|
|
|
- }
|
|
|
-
|
|
|
if len(cmd) == 3 {
|
|
|
- return strings.ToTitle(cmd[0]), strings.ToTitle(cmd[1]), cmd[2]
|
|
|
+ if strings.ToTitle(cmd[1]) == "UID" {
|
|
|
+ args := strings.SplitN(cmd[2], " ", 2)
|
|
|
+ if len(args) >= 2 {
|
|
|
+ return cmd[0], strings.ToTitle(cmd[1]) + " " + strings.ToTitle(args[0]), args[1]
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return cmd[0], strings.ToTitle(cmd[1]), cmd[2]
|
|
|
}
|
|
|
|
|
|
- return strings.ToTitle(cmd[0]), strings.ToTitle(cmd[1]), ""
|
|
|
+ return cmd[0], strings.ToTitle(cmd[1]), ""
|
|
|
}
|
|
|
|
|
|
func getSafeArg(args []string, nr int) string {
|
|
|
@@ -513,24 +759,37 @@ func getSafeArg(args []string, nr int) string {
|
|
|
return ""
|
|
|
}
|
|
|
|
|
|
-func showSucc(w io.Writer, nub string) {
|
|
|
- write(w, fmt.Sprintf("%s OK success %s", nub, eol), nub)
|
|
|
+func showSucc(w io.Writer, msg, nub string) {
|
|
|
+ if msg == "" {
|
|
|
+ write(w, fmt.Sprintf("%s OK success %s", nub, eol), nub)
|
|
|
+ } else {
|
|
|
+ write(w, fmt.Sprintf("%s %s %s", nub, msg, eol), nub)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func showSuccWithData(w io.Writer, data []string, msg string, nub string) {
|
|
|
+ content := ""
|
|
|
+ for _, datum := range data {
|
|
|
+ content += fmt.Sprintf("%s%s", datum, eol)
|
|
|
+ }
|
|
|
+ content += fmt.Sprintf("%s OK %s%s", nub, msg, eol)
|
|
|
+ write(w, content, nub)
|
|
|
}
|
|
|
|
|
|
-func showBad(w io.Writer, err error, nub string) {
|
|
|
- if err == nil {
|
|
|
- write(w, fmt.Sprintf("* BAD %s", eol), nub)
|
|
|
+func showBad(w io.Writer, err string, nub string) {
|
|
|
+ if nub == "" {
|
|
|
+ nub = "*"
|
|
|
+ }
|
|
|
+
|
|
|
+ if err == "" {
|
|
|
+ write(w, fmt.Sprintf("%s BAD %s", nub, eol), nub)
|
|
|
return
|
|
|
}
|
|
|
- write(w, fmt.Sprintf("* BAD %s%s", err.Error(), eol), nub)
|
|
|
+ write(w, fmt.Sprintf("%s BAD %s%s", nub, err, eol), nub)
|
|
|
}
|
|
|
|
|
|
-func output(w io.Writer, nub string, err error) {
|
|
|
- if err != nil {
|
|
|
- showBad(w, err, nub)
|
|
|
- } else {
|
|
|
- showSucc(w, nub)
|
|
|
- }
|
|
|
+func showNo(w io.Writer, msg string, nub string) {
|
|
|
+ write(w, fmt.Sprintf("%s NO %s%s", nub, msg, eol), nub)
|
|
|
}
|
|
|
|
|
|
func paramsErr(w io.Writer, commend string, nub string) {
|
|
|
@@ -538,7 +797,9 @@ func paramsErr(w io.Writer, commend string, nub string) {
|
|
|
}
|
|
|
|
|
|
func write(w io.Writer, content string, nub string) {
|
|
|
- content = strings.ReplaceAll(content, "$$NUM", nub)
|
|
|
+ if !strings.HasSuffix(content, eol) {
|
|
|
+ log.Errorf("Error:返回结尾错误 %s", content)
|
|
|
+ }
|
|
|
log.Debugf("Imap Out:\t |%s", content)
|
|
|
fmt.Fprintf(w, content)
|
|
|
}
|
jinnrry