Sendmail command

cmd/admin.go

@@ -35,6 +35,7 @@ var (
 			subcmdRepoSyncReleases,
 			subcmdRegenerate,
 			subcmdAuth,
+			subcmdSendMail,
 		},
 	}
 
@@ -253,6 +254,33 @@ var (
 		Action: runAddOauth,
 		Flags:  oauthCLIFlags,
 	}
+
+	subcmdSendMail = cli.Command{
+		Name:   "sendmail",
+		Usage:  "Send a message to all users",
+		Action: runSendMail,
+		Flags: []cli.Flag{
+			cli.StringFlag{
+				Name:  "title",
+				Usage: `a title of a message`,
+				Value: "",
+			},
+			cli.StringFlag{
+				Name:  "content",
+				Usage: "a content of a message",
+				Value: "",
+			},
+			cli.BoolFlag{
+				Name:  "force,f",
+				Usage: "A flag to bypass a confirmation step",
+			},
+			cli.DurationFlag{
+				Name:  "timeout",
+				Usage: "A timeout of sending emails",
+				Value: 0,
+			},
+		},
+	}
 )
 
 func runChangePassword(c *cli.Context) error {

cmd/cmd.go

@@ -9,6 +9,7 @@ package cmd
 import (
 	"errors"
 	"fmt"
+	"strings"
 
 	"code.gitea.io/gitea/models"
 	"code.gitea.io/gitea/modules/setting"
@@ -32,6 +33,25 @@ func argsSet(c *cli.Context, args ...string) error {
 	return nil
 }
 
+// confirm waits for user input which confirms an action
+func confirm() (bool, error) {
+	var response string
+
+	_, err := fmt.Scanln(&response)
+	if err != nil {
+		return false, err
+	}
+
+	switch strings.ToLower(response) {
+	case "y", "yes":
+		return true, nil
+	case "n", "no":
+		return false, nil
+	default:
+		return false, errors.New(response + " isn't a correct confirmation string")
+	}
+}
+
 func initDB() error {
 	return initDBDisableConsole(false)
 }

cmd/mailer.go

@@ -0,0 +1,70 @@
+// 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 cmd
+
+import (
+	"errors"
+	"fmt"
+
+	"code.gitea.io/gitea/models"
+	"code.gitea.io/gitea/services/mailer"
+
+	"github.com/urfave/cli"
+)
+
+func runSendMail(c *cli.Context) error {
+	if err := argsSet(c, "title"); err != nil {
+		return err
+	}
+
+	if err := initDB(); err != nil {
+		return err
+	}
+
+	subject := c.String("title")
+	confirmSkiped := c.Bool("force")
+	body := c.String("content")
+	timeout := c.Duration("timeout")
+
+	if !confirmSkiped {
+		if len(body) == 0 {
+			fmt.Print("warning: Content is empty")
+		}
+
+		fmt.Print("Proceed with sending email? [Y/n] ")
+		isConfirmed, err := confirm()
+		if err != nil {
+			return err
+		} else if !isConfirmed {
+			fmt.Println("The mail was not sent")
+			return nil
+		}
+	}
+
+	var emails []string
+	err := models.IterateUser(func(user *models.User) error {
+		emails = append(emails, user.Email)
+		return nil
+	})
+	if err != nil {
+		return errors.New("Cann't find users")
+	}
+
+	fmt.Printf("Sending %d emails", len(emails))
+
+	mailer.NewContext()
+
+	for _, email := range emails {
+		msg := mailer.NewMessage([]string{email}, subject, body)
+		mailer.SendAsync(msg)
+	}
+
+	err = mailer.FlushMessages(timeout)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

services/mailer/mailer.go

@@ -335,6 +335,13 @@ func NewContext() {
 	go graceful.GetManager().RunWithShutdownFns(mailQueue.Run)
 }
 
+// FlushMessages a messages which were published to the mailQueue
+//
+// Function blocks until the queue become empty or an operation exceed timeout duration.
+func FlushMessages(timeout time.Duration) error {
+	return mailQueue.Flush(timeout)
+}
+
 // SendAsync send mail asynchronously
 func SendAsync(msg *Message) {
 	go func() {