nudge.go

package nudge

import (
	"context"
	"fmt"
	"log"

	"github.com/mterwill/jira-slack-nudge/pkg/jira"
	"github.com/mterwill/jira-slack-nudge/pkg/slack"
)

const (
	maxIssues        = 10
	defaultConfigURL = "https://github.com/mterwill/jira-slack-nudge"
)

// Config is a 1:1 JIRA:Slack integration
type Config struct {
	PrefixMessage   string `yaml:"prefix_message"`
	SlackWebhookURL string `yaml:"slack_webhook_url"`
	JQL             string `yaml:"jql"`
	SkipSendEmpty   bool   `yaml:"skip_send_empty"`
}

// Nudge stores global JIRA config
type Nudge struct {
	jiraServer   string
	jiraUsername string
	jiraPassword string
	configURL    string
}

// New creates a new Nudge
func New(jiraServer, jiraUsername, jiraPassword, configURL string) *Nudge {
	if configURL == "" {
		configURL = defaultConfigURL
	}

	return &Nudge{jiraServer, jiraUsername, jiraPassword, configURL}
}

// Run finds JIRA issues matching a given JQL and post the result to Slack.
func (n *Nudge) Run(ctx context.Context, c *Config) error {
	j := jira.New(n.jiraServer, n.jiraUsername, n.jiraPassword)
	resp, err := j.FindIssues(ctx, c.JQL)
	if err != nil {
		return err
	}

	if len(resp.Issues) == 0 && c.SkipSendEmpty {
		log.Printf("Found no results for JQL `%s` and Config.SkipSendEmpty is on.", c.JQL)
		return nil
	}

	var blocks []*slack.Block

	blocks = append(blocks, &slack.Block{
		Type: slack.BlockTypeSection,
		Text: &slack.Text{
			Type: slack.BlockTextTypeMarkdown,
			Text: c.PrefixMessage,
		},
	})

	if len(resp.Issues) == 0 {
		blocks = append(blocks, &slack.Block{
			Type: slack.BlockTypeSection,
			Text: &slack.Text{
				Type: slack.BlockTextTypeMarkdown,
				Text: "_No issues found matching filter._",
			},
		})
	} else {
		for i, issue := range resp.Issues {
			if i > maxIssues {
				break
			}

			blocks = append(blocks, &slack.Block{
				Type: slack.BlockTypeSection,
				Text: &slack.Text{
					Type: slack.BlockTextTypeMarkdown,
					Text: fmt.Sprintf(
						"• *<%s|%s>* %s (status: `%s`, assignee: `%s`)",
						j.LinkForIssue(&issue),
						issue.Key,
						issue.Fields.Summary,
						issue.Fields.Status.Name,
						issue.Assignee(),
					),
				},
			})
		}
	}

	if resp.Total > maxIssues {
		blocks = append(blocks, &slack.Block{
			Type: slack.BlockTypeSection,
			Text: &slack.Text{
				Type: slack.BlockTextTypeMarkdown,
				Text: fmt.Sprintf("_showing %d of %d total results._", maxIssues, resp.Total),
			},
		})
	}

	blocks = append(blocks, &slack.Block{
		Type: slack.BlockTypeDivider,
	})

	blocks = append(blocks, &slack.Block{
		Type: slack.BlockTypeSection,
		Text: &slack.Text{
			Type: slack.BlockTextTypeMarkdown,
			Text: fmt.Sprintf("This message was generated by <%s|jira-slack-nudge> using the JQL: ```%s```", n.configURL, c.JQL),
		},
	})

	s := slack.New(c.SlackWebhookURL)
	err = s.PostMessage(ctx, &slack.Message{
		Blocks: blocks,
	})

	if err != nil {
		return err
	}

	return nil
}