reply issue by email

cmd/hook.go

@@ -218,9 +218,9 @@ Gitea or set your environment appropriately.`, "")
 		}
 	}
 
-	supportProcRecive := false
+	supportProcReceive := false
 	if git.CheckGitVersionAtLeast("2.29") == nil {
-		supportProcRecive = true
+		supportProcReceive = true
 	}
 
 	for scanner.Scan() {
@@ -241,9 +241,9 @@ Gitea or set your environment appropriately.`, "")
 		lastline++
 
 		// If the ref is a branch or tag, check if it's protected
-		// if supportProcRecive all ref should be checked because
+		// if supportProcReceive all ref should be checked because
 		// permission check was delayed
-		if supportProcRecive || strings.HasPrefix(refFullName, git.BranchPrefix) || strings.HasPrefix(refFullName, git.TagPrefix) {
+		if supportProcReceive || strings.HasPrefix(refFullName, git.BranchPrefix) || strings.HasPrefix(refFullName, git.TagPrefix) {
 			oldCommitIDs[count] = oldCommitID
 			newCommitIDs[count] = newCommitID
 			refFullNames[count] = refFullName

custom/conf/app.example.ini

@@ -1479,6 +1479,30 @@ PATH =
 ;; Timeout for Sendmail
 ;SENDMAIL_TIMEOUT = 5m
 
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;[mail_receive]
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;;
+;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 receive mail
+;RECEIVE_EMAIL = 
+;; receive email box
+;RECEIVE_BOX = INBOX
+;; Mail server
+;; Gmail: imap.gmail.com:993
+;; QQ: imap.qq.com:993
+;; Outlook: outlook.office365.com:993
+;HOST =
+;USER =
+;PASSWD =
+;IS_TLS_ENABLED = true
+;; delete mail after read
+;DELETE_READ_MAIL = false
+
 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 ;[cache]
@@ -1945,6 +1969,17 @@ PATH =
 ;SCHEDULE = @every 168h
 ;HTTP_ENDPOINT = https://dl.gitea.io/gitea/version.json
 
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;; fetch unread mails
+;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
+;[cron.imap_fetch_mails]
+;; when [mail_receive] is enabled, this will be enabled automatically as well
+;ENABLED = false
+;RUN_AT_START = false
+;NO_SUCCESS_NOTICE = false
+;SCHEDULE = @every 5m
+
 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
 ;; Git Operation timeout in seconds

go.mod

@@ -32,6 +32,8 @@ require (
 	github.com/djherbis/nio/v3 v3.0.1
 	github.com/dustin/go-humanize v1.0.0
 	github.com/editorconfig/editorconfig-core-go/v2 v2.4.2
+	github.com/emersion/go-imap v1.2.0
+	github.com/emersion/go-message v0.15.0
 	github.com/emirpasic/gods v1.12.0
 	github.com/ethantkoenig/rupture v1.0.0
 	github.com/gliderlabs/ssh v0.3.3

go.sum

@@ -286,6 +286,14 @@ github.com/editorconfig/editorconfig-core-go/v2 v2.4.2 h1:1lkDpSoAaFLrgYTVJ/eNCV
 github.com/editorconfig/editorconfig-core-go/v2 v2.4.2/go.mod h1:IXeWRVO4LZRoNunhHh/oP6BQvTs94nB2pNvbw32l8tQ=
 github.com/edsrzf/mmap-go v1.0.0/go.mod h1:YO35OhQPt3KJa3ryjFM5Bs14WD66h8eGKpfaBNrHW5M=
 github.com/elazarl/go-bindata-assetfs v1.0.1/go.mod h1:v+YaWX3bdea5J/mo8dSETolEo7R71Vk1u8bnjau5yw4=
+github.com/emersion/go-imap v1.2.0 h1:lyUQ3+EVM21/qbWE/4Ya5UG9r5+usDxlg4yfp3TgHFA=
+github.com/emersion/go-imap v1.2.0/go.mod h1:Qlx1FSx2FTxjnjWpIlVNEuX+ylerZQNFE5NsmKFSejY=
+github.com/emersion/go-message v0.15.0 h1:urgKGqt2JAc9NFJcgncQcohHdiYb803YTH9OQwHBHIY=
+github.com/emersion/go-message v0.15.0/go.mod h1:wQUEfE+38+7EW8p8aZ96ptg6bAb1iwdgej19uXASlE4=
+github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21 h1:OJyUGMJTzHTd1XQp98QTaHernxMYzRaOasRir9hUlFQ=
+github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21/go.mod h1:iL2twTeMvZnrg54ZoPDNfJaJaqy0xIQFuBdrLsmspwQ=
+github.com/emersion/go-textwrapper v0.0.0-20200911093747-65d896831594 h1:IbFBtwoTQyw0fIM5xv1HF+Y+3ZijDR839WMulgxCcUY=
+github.com/emersion/go-textwrapper v0.0.0-20200911093747-65d896831594/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=

models/fixtures/issue.yml

@@ -24,7 +24,6 @@
   created_unix: 946684810
   updated_unix: 978307190
 
-
 -
   id: 3
   repo_id: 1

models/issue.go

@@ -19,6 +19,7 @@ import (
 	"code.gitea.io/gitea/modules/base"
 	"code.gitea.io/gitea/modules/log"
 	"code.gitea.io/gitea/modules/references"
+	"code.gitea.io/gitea/modules/setting"
 	api "code.gitea.io/gitea/modules/structs"
 	"code.gitea.io/gitea/modules/timeutil"
 	"code.gitea.io/gitea/modules/util"
@@ -426,6 +427,22 @@ func (issue *Issue) HasLabel(labelID int64) bool {
 	return issue.hasLabel(db.GetEngine(db.DefaultContext), labelID)
 }
 
+// ReplyReference returns tokenized address to use for email reply headers
+func (issue *Issue) ReplyReference(key string) string {
+	var path string
+	if issue.IsPull {
+		path = "pulls"
+	} else {
+		path = "issues"
+	}
+
+	if len(key) > 0 {
+		return fmt.Sprintf("%s/%s/%d/%s@%s", issue.Repo.FullName(), path, issue.Index, key, setting.Domain)
+	}
+
+	return fmt.Sprintf("%s/%s/%d@%s", issue.Repo.FullName(), path, issue.Index, setting.Domain)
+}
+
 func (issue *Issue) addLabel(e db.Engine, label *Label, doer *User) error {
 	return newIssueLabel(e, issue, label, doer)
 }

models/issue_comment.go

@@ -21,6 +21,7 @@ import (
 	"code.gitea.io/gitea/modules/markup"
 	"code.gitea.io/gitea/modules/markup/markdown"
 	"code.gitea.io/gitea/modules/references"
+	"code.gitea.io/gitea/modules/setting"
 	"code.gitea.io/gitea/modules/structs"
 	"code.gitea.io/gitea/modules/timeutil"
 
@@ -713,6 +714,43 @@ func (c *Comment) LoadPushCommits() (err error) {
 	return err
 }
 
+// ReplyReference returns tokenized address to use for email reply headers
+func (c *Comment) ReplyReference(key string) string {
+	if err := c.LoadIssue(); err != nil {
+		log.Error("comment.LoadIssue(): %v", err)
+		return ""
+	}
+
+	if err := c.Issue.LoadRepo(); err != nil {
+		log.Error("Issue.LoadRepo(): %v", err)
+		return ""
+	}
+
+	var path string
+	if c.Issue.IsPull {
+		path = "pulls"
+	} else {
+		path = "issues"
+	}
+
+	if len(key) > 0 {
+		return fmt.Sprintf("%s/%s/%d/comment/%d/%s@%s",
+			c.Issue.Repo.FullName(),
+			path,
+			c.Issue.Index,
+			c.ID,
+			key,
+			setting.Domain)
+	}
+
+	return fmt.Sprintf("%s/%s/%d/comment/%d@%s",
+		c.Issue.Repo.FullName(),
+		path,
+		c.Issue.Index,
+		c.ID,
+		setting.Domain)
+}
+
 func createComment(e db.Engine, opts *CreateCommentOptions) (_ *Comment, err error) {
 	var LabelID int64
 	if opts.Label != nil {

models/notification.go

@@ -179,7 +179,7 @@ func CreateRepoTransferNotification(doer, newOwner *User, repo *Repository) erro
 
 // CreateOrUpdateIssueNotifications creates an issue notification
 // for each watcher, or updates it if already exists
-// receiverID > 0 just send to reciver, else send to all watcher
+// receiverID > 0 just send to receiver, else send to all watcher
 func CreateOrUpdateIssueNotifications(issueID, commentID, notificationAuthorID, receiverID int64) error {
 	sess := db.NewSession(db.DefaultContext)
 	defer sess.Close()

modules/base/tool.go

@@ -42,7 +42,7 @@ func EncodeSha1(str string) string {
 	return hex.EncodeToString(h.Sum(nil))
 }
 
-// EncodeSha256 string to sha1 hex value.
+// EncodeSha256 string to sha256 hex value.
 func EncodeSha256(str string) string {
 	h := sha256.New()
 	_, _ = h.Write([]byte(str))

modules/setting/mail_receive.go

@@ -0,0 +1,44 @@
+// Copyright 2021 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"
+
+// MailReceiver represents mail receive service.
+type MailReceiver struct {
+	ReceiveEmail   string
+	ReceiveBox     string
+	QueueLength    int
+	Host           string
+	User, Passwd   string
+	IsTLSEnabled   bool
+	DeleteReadMail bool
+}
+
+var (
+	// MailRecieveService mail receive config
+	MailRecieveService *MailReceiver
+)
+
+func newMailRecieveService() {
+	sec := Cfg.Section("mail_receive")
+	// Check mailer setting.
+	if !sec.Key("ENABLED").MustBool() {
+		return
+	}
+
+	MailRecieveService = &MailReceiver{
+		ReceiveEmail:   sec.Key("RECEIVE_EMAIL").String(),
+		ReceiveBox:     sec.Key("RECEIVE_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),
+		DeleteReadMail: sec.Key("DELETE_READ_MAIL").MustBool(false),
+	}
+
+	log.Info("Mail Receive Service Enabled")
+}

modules/setting/setting.go

@@ -1203,6 +1203,7 @@ func NewServices() {
 	newSessionService()
 	newCORSService()
 	newMailService()
+	newMailRecieveService()
 	newRegisterMailService()
 	newNotifyMailService()
 	newProxyService()

options/locale/locale_en-US.ini

@@ -2347,6 +2347,8 @@ dashboard.last_gc_pause = Last GC Pause
 dashboard.gc_times = GC Times
 dashboard.delete_old_actions = Delete all old actions from database
 dashboard.delete_old_actions.started = Delete all old actions from database started.
+dashboard.imap_fetch_mails = fetch unread mails
+dashboard.imap_fetch_mails.started = Started fetching unread mails.
 
 users.user_manage_panel = User Account Management
 users.new_account = Create User Account

routers/init.go

@@ -39,9 +39,10 @@ import (
 	"code.gitea.io/gitea/services/auth"
 	"code.gitea.io/gitea/services/auth/source/oauth2"
 	"code.gitea.io/gitea/services/cron"
+	"code.gitea.io/gitea/services/imap"
 	"code.gitea.io/gitea/services/mailer"
 	repo_migrations "code.gitea.io/gitea/services/migrations"
-	mirror_service "code.gitea.io/gitea/services/mirror"
+	"code.gitea.io/gitea/services/mirror"
 	pull_service "code.gitea.io/gitea/services/pull"
 	repo_service "code.gitea.io/gitea/services/repository"
 	"code.gitea.io/gitea/services/task"
@@ -118,6 +119,7 @@ func GlobalInit(ctx context.Context) {
 
 	InitGitServices()
 	mailer.NewContext()
+	imap.NewContext()
 	mustInit(cache.NewContext)
 	notification.NewContext()
 	mustInit(archiver.Init)
@@ -145,7 +147,7 @@ func GlobalInit(ctx context.Context) {
 	code_indexer.Init()
 	mustInit(stats_indexer.Init)
 
-	mirror_service.InitSyncMirrors()
+	mirror.InitSyncMirrors()
 	webhook.InitDeliverHooks()
 	mustInit(pull_service.Init)
 	mustInit(task.Init)

routers/private/hook_proc_receive.go

@@ -23,7 +23,7 @@ func HookProcReceive(ctx *gitea_context.PrivateContext) {
 		return
 	}
 
-	results := agit.ProcRecive(ctx, opts)
+	results := agit.ProcReceive(ctx, opts)
 	if ctx.Written() {
 		return
 	}

services/agit/agit.go

@@ -19,8 +19,8 @@ import (
 	pull_service "code.gitea.io/gitea/services/pull"
 )
 
-// ProcRecive handle proc receive work
-func ProcRecive(ctx *context.PrivateContext, opts *private.HookOptions) []private.HookProcReceiveRefResult {
+// ProcReceive handle proc receive work
+func ProcReceive(ctx *context.PrivateContext, opts *private.HookOptions) []private.HookProcReceiveRefResult {
 	// TODO: Add more options?
 	var (
 		topicBranch string

services/cron/tasks_extended.go

@@ -12,6 +12,7 @@ import (
 	repo_module "code.gitea.io/gitea/modules/repository"
 	"code.gitea.io/gitea/modules/setting"
 	"code.gitea.io/gitea/modules/updatechecker"
+	"code.gitea.io/gitea/services/imap"
 	repo_service "code.gitea.io/gitea/services/repository"
 )
 
@@ -133,6 +134,16 @@ func registerDeleteOldActions() {
 	})
 }
 
+func registerImapFetchUnreadMails() {
+	RegisterTaskFatal("imap_fetch_mails", &BaseConfig{
+		Enabled:    setting.MailRecieveService != nil,
+		RunAtStart: false,
+		Schedule:   "@every 5m",
+	}, func(ctx context.Context, _ *models.User, _ Config) error {
+		return imap.FetchAllUnreadMails()
+	})
+}
+
 func registerUpdateGiteaChecker() {
 	type UpdateCheckerConfig struct {
 		BaseConfig
@@ -163,4 +174,5 @@ func initExtendedTasks() {
 	registerRemoveRandomAvatars()
 	registerDeleteOldActions()
 	registerUpdateGiteaChecker()
+	registerImapFetchUnreadMails()
 }

services/imap/cron.go

@@ -0,0 +1,46 @@
+// Copyright 2021 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.MailRecieveService.Host,
+			UserName: setting.MailRecieveService.User,
+			Passwd:   setting.MailRecieveService.Passwd,
+			IsTLS:    setting.MailRecieveService.IsTLSEnabled,
+		})
+		if err != nil {
+			return
+		}
+	}
+
+	if mailReadQueue != nil && !mailReadQueue.IsEmpty() {
+		return
+	}
+
+	mails, err := c.GetUnreadMails(setting.MailRecieveService.ReceiveBox, 100)
+	if err != nil {
+		return
+	}
+
+	for _, mail := range mails {
+		err = mailReadQueue.Push(mail)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}