reply issue by email

custom/conf/app.example.ini

@@ -729,6 +729,24 @@ SENDMAIL_ARGS =
 ; Timeout for Sendmail
 SENDMAIL_TIMEOUT = 5m
 
+[mail_recive]
+ENABLED = false
+; Buffer length of channel, keep it as it is if you don't know what it is.
+READ_BUFFER_LEN = 100
+; email address to recive mail
+RECIVE_EMAIL = 
+; recive email box
+RECIVE_BOX = INBOX
+; Mail server
+; Gmail: imap.gmail.com:993
+; QQ: imap.qq.com:993
+HOST =
+USER =
+PASSWD =
+IS_TLS_ENABLED = true
+; delete mail after rode
+DELETE_RODE_MAIL = false
+
 [cache]
 ; if the cache enabled
 ENABLED = true

go.mod

@@ -32,6 +32,8 @@ require (
 	github.com/dlclark/regexp2 v1.4.0 // indirect
 	github.com/dustin/go-humanize v1.0.0
 	github.com/editorconfig/editorconfig-core-go/v2 v2.3.8
+	github.com/emersion/go-imap v1.0.6
+	github.com/emersion/go-message v0.13.0
 	github.com/emirpasic/gods v1.12.0
 	github.com/ethantkoenig/rupture v0.0.0-20181029165146-c3b3b810dc77
 	github.com/facebookgo/ensure v0.0.0-20160127193407-b4ab57deab51 // indirect

go.sum

@@ -281,6 +281,15 @@ github.com/eapache/queue v1.1.0/go.mod h1:6eCeP0CKFpHLu8blIFXhExK/dRa7WDZfr6jVFP
 github.com/editorconfig/editorconfig-core-go/v2 v2.3.8 h1:nq6QPrFjoI1QP9trhj+bsXoS8MSjhTgQXgTavA5zPbg=
 github.com/editorconfig/editorconfig-core-go/v2 v2.3.8/go.mod h1:z7TIMh40583cev3v8ei7V1RRPKeHQbttoa4Vm5/5u7g=
 github.com/edsrzf/mmap-go v1.0.0/go.mod h1:YO35OhQPt3KJa3ryjFM5Bs14WD66h8eGKpfaBNrHW5M=
+github.com/emersion/go-imap v1.0.6 h1:N9+o5laOGuntStBo+BOgfEB5evPsPD+K5+M0T2dctIc=
+github.com/emersion/go-imap v1.0.6/go.mod h1:yKASt+C3ZiDAiCSssxg9caIckWF/JG7ZQTO7GAmvicU=
+github.com/emersion/go-message v0.11.1/go.mod h1:C4jnca5HOTo4bGN9YdqNQM9sITuT3Y0K6bSUw9RklvY=
+github.com/emersion/go-message v0.13.0 h1:R4+CZv4Msxfk9tMaERjMkapdvdO2faWLuB5KHFsNLZE=
+github.com/emersion/go-message v0.13.0/go.mod h1:kYIioST9GDHte9/BRWgi93rpqbDuFftMjKSMaXS8ABo=
+github.com/emersion/go-sasl v0.0.0-20191210011802-430746ea8b9b h1:uhWtEWBHgop1rqEk2klKaxPAkVDCXexai6hSuRQ7Nvs=
+github.com/emersion/go-sasl v0.0.0-20191210011802-430746ea8b9b/go.mod h1:G/dpzLu16WtQpBfQ/z3LYiYJn3ZhKSGWn83fyoyQe/k=
+github.com/emersion/go-textwrapper v0.0.0-20160606182133-d0e65e56babe h1:40SWqY0zE3qCi6ZrtTf5OUdNm5lDnGnjRSq9GgmeTrg=
+github.com/emersion/go-textwrapper v0.0.0-20160606182133-d0e65e56babe/go.mod h1:aqO8z8wPrjkscevZJFVE1wXJrLpC5LtJG7fqLOsPb2U=
 github.com/emirpasic/gods v1.12.0 h1:QAUIPSaCu4G+POclxeqb3F+WPpdKqFGlw36+yOzGlrg=
 github.com/emirpasic/gods v1.12.0/go.mod h1:YfzfFFoVP/catgzJb4IKIqXjX78Ha8FMSDh3ymbK86o=
 github.com/envoyproxy/go-control-plane v0.6.9/go.mod h1:SBwIajubJHhxtWwsL9s8ss4safvEdbitLhGGK48rN6g=
@@ -761,6 +770,8 @@ github.com/markbates/goth v1.65.0 h1:IbXpMneUhqbxgJ8JP1Ghl8ghlAaVX66jWDAapU1KxqU
 github.com/markbates/goth v1.65.0/go.mod h1:65frybxoeSCfORin51KOKqAKbIh7wREIDvdCkdWj//4=
 github.com/markbates/oncer v0.0.0-20181203154359-bf2de49a0be2/go.mod h1:Ld9puTsIW75CHf65OeIOkyKbteujpZVXDpWK6YGZbxE=
 github.com/markbates/safe v1.0.1/go.mod h1:nAqgmRi7cY2nqMc92/bSEeQA+R4OheNU2T1kNSCBdG0=
+github.com/martinlindhe/base36 v1.0.0 h1:eYsumTah144C0A8P1T/AVSUk5ZoLnhfYFM3OGQxB52A=
+github.com/martinlindhe/base36 v1.0.0/go.mod h1:+AtEs8xrBpCeYgSLoY/aJ6Wf37jtBuR0s35750M27+8=
 github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
 github.com/mattn/go-colorable v0.1.1/go.mod h1:FuOcm+DKB9mbwrcAfNl7/TZVBZ6rcnceauSikq3lYCQ=
 github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE=

modules/cron/tasks_extended.go

@@ -11,6 +11,7 @@ import (
 	"code.gitea.io/gitea/models"
 	repo_module "code.gitea.io/gitea/modules/repository"
 	"code.gitea.io/gitea/modules/setting"
+	"code.gitea.io/gitea/services/imap"
 )
 
 func registerDeleteInactiveUsers() {
@@ -117,6 +118,16 @@ func registerRemoveRandomAvatars() {
 	})
 }
 
+func registerImapFetchUnReadMails() {
+	RegisterTaskFatal("imap_fetch_mails", &BaseConfig{
+		Enabled:    setting.MailReciveService != nil,
+		RunAtStart: true,
+		Schedule:   "@every 5m",
+	}, func(ctx context.Context, _ *models.User, _ Config) error {
+		return imap.FetchAllUnReadMails()
+	})
+}
+
 func initExtendedTasks() {
 	registerDeleteInactiveUsers()
 	registerDeleteRepositoryArchives()
@@ -127,4 +138,5 @@ func initExtendedTasks() {
 	registerReinitMissingRepositories()
 	registerDeleteMissingRepositories()
 	registerRemoveRandomAvatars()
+	registerImapFetchUnReadMails()
 }

modules/setting/mail_recive.go

@@ -0,0 +1,46 @@
+// Copyright 2020 The Gitea Authors. All rights reserved.
+// Use of this source code is governed by a MIT-style
+// license that can be found in the LICENSE file.
+
+package setting
+
+import "code.gitea.io/gitea/modules/log"
+
+// MailReciver represents mail recive service.
+type MailReciver struct {
+	ReciveEmail string
+	ReciveBox   string
+	QueueLength int
+
+	Host         string
+	User, Passwd string
+	IsTLSEnabled bool
+
+	DeleteRodeMail bool
+}
+
+var (
+	// MailReciveService mail recive config
+	MailReciveService *MailReciver
+)
+
+func newMailReciveService() {
+	sec := Cfg.Section("mail_recive")
+	// Check mailer setting.
+	if !sec.Key("ENABLED").MustBool() {
+		return
+	}
+
+	MailReciveService = &MailReciver{
+		ReciveEmail:    sec.Key("RECIVE_EMAIL").String(),
+		ReciveBox:      sec.Key("RECIVE_BOX").MustString("INBOX"),
+		QueueLength:    sec.Key("READ_BUFFER_LEN").MustInt(100),
+		Host:           sec.Key("HOST").String(),
+		User:           sec.Key("USER").String(),
+		Passwd:         sec.Key("PASSWD").String(),
+		IsTLSEnabled:   sec.Key("IS_TLS_ENABLED").MustBool(true),
+		DeleteRodeMail: sec.Key("DELETE_RODE_MAIL").MustBool(false),
+	}
+
+	log.Info("Mail Recive Service Enabled")
+}

modules/setting/setting.go

@@ -1030,6 +1030,7 @@ func NewServices() {
 	newSessionService()
 	newCORSService()
 	newMailService()
+	newMailReciveService()
 	newRegisterMailService()
 	newNotifyMailService()
 	newWebhookService()

routers/init.go

@@ -32,6 +32,7 @@ import (
 	"code.gitea.io/gitea/modules/svg"
 	"code.gitea.io/gitea/modules/task"
 	"code.gitea.io/gitea/modules/webhook"
+	"code.gitea.io/gitea/services/imap"
 	"code.gitea.io/gitea/services/mailer"
 	mirror_service "code.gitea.io/gitea/services/mirror"
 	pull_service "code.gitea.io/gitea/services/pull"
@@ -63,6 +64,7 @@ func NewServices() {
 		log.Fatal("repository init failed: %v", err)
 	}
 	mailer.NewContext()
+	imap.NewContext()
 	_ = cache.NewContext()
 	notification.NewContext()
 }

services/imap/cron.go

@@ -0,0 +1,46 @@
+// Copyright 2020 The Gitea Authors. All rights reserved.
+// Use of this source code is governed by a MIT-style
+// license that can be found in the LICENSE file.
+
+package imap
+
+import (
+	"code.gitea.io/gitea/modules/setting"
+)
+
+var (
+	c *Client
+)
+
+// FetchAllUnReadMails fetch all unread mails
+func FetchAllUnReadMails() (err error) {
+	if c == nil {
+		c, err = NewImapClient(ClientInitOpt{
+			Addr:     setting.MailReciveService.Host,
+			UserName: setting.MailReciveService.User,
+			Passwd:   setting.MailReciveService.Passwd,
+			IsTLS:    setting.MailReciveService.IsTLSEnabled,
+		})
+		if err != nil {
+			return
+		}
+	}
+
+	if !mailReadQueue.IsEmpty() {
+		return
+	}
+
+	mails, err := c.GetUnReadMails(setting.MailReciveService.ReciveBox, 100)
+	if err != nil {
+		return
+	}
+
+	for _, mail := range mails {
+		err = mailReadQueue.Push(mail)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}