Support for slackUserIdFromEmail slackUserIdsFromCommitters commands

README.md

@@ -88,6 +88,26 @@ Make sure to replace `your_access_token` with your actual Slack access token and
 If you provide an access token, it will use the Slack API to send the message.
 
 
+### Get Slack Id of a user from a Email ID
+```bash
+docker run --network host --rm \
+-e PLUGIN_ACCESS_TOKEN=your_access_token \
+-e [email protected] \
+plugins/slack
+```
+Output will be stored in the FOUND_SLACK_ID environment variable
+Make sure to replace `your_access_token` with your actual Slack access token and adjust
+
+### Get the Slack IDs of all commiters from a git repo
+```bash
+docker run --network host --rm \
+-e PLUGIN_ACCESS_TOKEN=your_access_token \
+-e PLUGIN_COMMITTER_LIST_GIT_PATH=/harness \
+plugins/slack
+```
+Output will be stored in the COMMITTER_SLACK_ID_LIST environment variable as comma separated values.
+Make sure to replace `your_access_token` with your actual Slack access token and adjust.
+
 ## Release Preparation
 
 Run the changelog generator.

docker/Dockerfile.linux.amd64

@@ -1,9 +1,11 @@
-FROM plugins/base:multiarch
+FROM alpine:3.20
 
 LABEL maintainer="Drone.IO Community <[email protected]>" \
   org.label-schema.name="Drone Slack" \
   org.label-schema.vendor="Drone.IO Community" \
   org.label-schema.schema-version="1.0"
 
+RUN apk add --no-cache git bash
+
 ADD release/linux/amd64/drone-slack /bin/
 ENTRYPOINT ["/bin/drone-slack"]

docker/Dockerfile.linux.arm64

@@ -1,9 +1,11 @@
-FROM plugins/base:multiarch
+FROM alpine:3.20
 
 LABEL maintainer="Drone.IO Community <[email protected]>" \
   org.label-schema.name="Drone Slack" \
   org.label-schema.vendor="Drone.IO Community" \
   org.label-schema.schema-version="1.0"
 
+RUN apk add --no-cache git bash
+
 ADD release/linux/arm64/drone-slack /bin/
 ENTRYPOINT ["/bin/drone-slack"]

main.go

@@ -3,11 +3,10 @@ package main
 import (
 	"errors"
 	"fmt"
-	"log"
-	"os"
-
 	"github.com/joho/godotenv"
 	"github.com/urfave/cli"
+	"log"
+	"os"
 )
 
 var (
@@ -16,6 +15,7 @@ var (
 )
 
 func main() {
+
 	app := cli.NewApp()
 	app.Name = "slack plugin"
 	app.Usage = "slack plugin"
@@ -239,6 +239,16 @@ func main() {
 			Usage:  "fail build on error",
 			EnvVar: "PLUGIN_FAIL_ON_ERROR",
 		},
+		cli.StringFlag{
+			Name:   "slack_id_of",
+			Usage:  "slack id required for the user email id",
+			EnvVar: "PLUGIN_SLACK_ID_OF",
+		},
+		cli.StringFlag{
+			Name:   "committer_list_git_path",
+			Usage:  "git repo path holding the committers email id to fetch slack IDs from",
+			EnvVar: "PLUGIN_COMMITTER_LIST_GIT_PATH",
+		},
 	}
 
 	if _, err := os.Stat("/run/drone/env"); err == nil {
@@ -299,11 +309,13 @@ func run(c *cli.Context) error {
 			CustomTemplate: c.String("custom.template"),
 			Message:        c.String("message"),
 			// File upload attributes
-			FilePath:       c.String("filepath"),
-			FileName:       c.String("filename"),
-			Title:          c.String("title"),
-			InitialComment: c.String("initial_comment"),
-			FailOnError:    c.Bool("fail_on_error"),
+			FilePath:             c.String("filepath"),
+			FileName:             c.String("filename"),
+			Title:                c.String("title"),
+			InitialComment:       c.String("initial_comment"),
+			FailOnError:          c.Bool("fail_on_error"),
+			SlackIdOf:            c.String("slack_id_of"),
+			CommitterListGitPath: c.String("committer_list_git_path"),
 		},
 	}
 

plugin.go

@@ -5,7 +5,9 @@ import (
 	"encoding/json"
 	"fmt"
 	"os"
+	"os/exec"
 	"path/filepath"
+	"runtime"
 	"strings"
 	textTemplate "text/template"
 
@@ -77,6 +79,10 @@ type (
 		InitialComment string
 		Title          string
 		FailOnError    bool
+		// Get Slack ID of the user by email
+		SlackIdOf string
+		// Git path to get list of committer emails
+		CommitterListGitPath string
 	}
 
 	Job struct {
@@ -122,6 +128,14 @@ func (p Plugin) Exec() error {
 		return p.UploadFile()
 	}
 
+	if p.Config.SlackIdOf != "" {
+		return GetSlackIdFromEmail(&p)
+	}
+
+	if p.Config.CommitterListGitPath != "" {
+		return GetSlackIdsOfCommitters(&p)
+	}
+
 	// Determine the channel
 	if p.Config.Recipient != "" {
 		channel = prepend("@", p.Config.Recipient)
@@ -482,3 +496,99 @@ func prepend(prefix, s string) string {
 
 	return s
 }
+
+func GetSlackIdsOfCommitters(p *Plugin) error {
+	if p.Config.CommitterListGitPath == DefaultWorkspace {
+		p.Config.CommitterListGitPath = os.Getenv("DRONE_WORKSPACE")
+	}
+
+	emails, err := getGitEmails(p.Config.CommitterListGitPath)
+	if err != nil {
+		return fmt.Errorf("failed to get git emails: %w", err)
+	}
+	var slackIdsList []string
+	for _, email := range emails {
+		slackId, err := getSlackUserIDByEmail(p.Config.AccessToken, email)
+		if err != nil {
+			//log.Printf("Failed to get Slack ID for email %s: %s\n", email, err.Error())
+			continue
+		}
+
+		slackIdsList = append(slackIdsList, slackId)
+	}
+	slackIdsListStr := strings.Join(slackIdsList, ",")
+	err = WriteEnvToOutputFile("COMMITTER_SLACK_ID_LIST", slackIdsListStr)
+	if err != nil {
+		return fmt.Errorf("failed to write git emails to output file: %w", err)
+	}
+	return nil
+}
+
+func GetSlackIdFromEmail(p *Plugin) error {
+
+	slackId, err := getSlackUserIDByEmail(p.Config.AccessToken, p.Config.SlackIdOf)
+	if err != nil {
+		return fmt.Errorf("failed to get Slack ID by email: %w", err)
+	}
+	err = WriteEnvToOutputFile("FOUND_SLACK_ID", slackId)
+	if err != nil {
+		return fmt.Errorf("failed to write Slack ID to output file: %w", err)
+	}
+	return nil
+}
+
+func getSlackUserIDByEmail(accessToken, email string) (string, error) {
+	api := slack.New(accessToken)
+	if api == nil {
+		return "", fmt.Errorf("failed to create Slack client")
+	}
+
+	user, err := api.GetUserByEmail(email)
+	if err != nil {
+		return "", fmt.Errorf("failed to get user by email: %w", err)
+	}
+
+	return user.ID, nil
+}
+
+func getGitCommittersCommand(dir string) *exec.Cmd {
+	if runtime.GOOS == "windows" {
+		gitLogCmd := "git log --format='%ae' | Sort-Object | Get-Unique"
+		return exec.Command("powershell", "-Command", gitLogCmd)
+	}
+	return exec.Command("bash", "-c", "set -e; git log --format='%ae' | sort | uniq")
+}
+
+func getGitEmails(dir string) ([]string, error) {
+	var emailList []string
+
+	cmd := getGitCommittersCommand(dir)
+	cmd.Dir = dir
+
+	var out bytes.Buffer
+	cmd.Stdout = &out
+	cmd.Stderr = &out
+
+	if err := cmd.Run(); err != nil {
+		fmt.Println("Error: ", err)
+		return emailList, fmt.Errorf("failed to execute git command: %v\nOutput: %s", err, out.String())
+	}
+
+	return cleanupAndSplitEmails(out.String()), nil
+}
+
+func cleanupAndSplitEmails(emailString string) []string {
+	lines := strings.Fields(emailString)
+	var cleanedEmails []string
+	for _, line := range lines {
+		email := strings.TrimSpace(line)
+		if email != "" {
+			cleanedEmails = append(cleanedEmails, email)
+		}
+	}
+	return cleanedEmails
+}
+
+const (
+	DefaultWorkspace = "DRONE_WORKSPACE"
+)