notifier/internal/gitea/gitea.go

// Package gitea maps Gitea webhook events to the DMs that should be sent.
package gitea

import (
	"encoding/json"
	"fmt"
	"log/slog"
	"strings"

	"git/palnet/slack-notifier/internal/notify"
)

type user struct {
	Login    string `json:"login"`
	Username string `json:"username"`
	Email    string `json:"email"`
}

func (u *user) login() string {
	if u == nil {
		return ""
	}
	if u.Login != "" {
		return u.Login
	}
	return u.Username
}

func (u *user) email() string {
	if u == nil {
		return ""
	}
	return u.Email
}

type pullRequest struct {
	Number    int    `json:"number"`
	Title     string `json:"title"`
	HTMLURL   string `json:"html_url"`
	Merged    bool   `json:"merged"`
	User      *user  `json:"user"`
	Assignee  *user  `json:"assignee"`
	Assignees []user `json:"assignees"`
}

type issue struct {
	Number    int    `json:"number"`
	Title     string `json:"title"`
	HTMLURL   string `json:"html_url"`
	User      *user  `json:"user"`
	Assignee  *user  `json:"assignee"`
	Assignees []user `json:"assignees"`
}

type comment struct {
	Body    string `json:"body"`
	HTMLURL string `json:"html_url"`
}

type review struct {
	Content string `json:"content"`
	Type    string `json:"type"`
}

type payload struct {
	Action     string `json:"action"`
	Number     int    `json:"number"`
	Repository struct {
		FullName string `json:"full_name"`
	} `json:"repository"`
	Sender            *user        `json:"sender"`
	PullRequest       *pullRequest `json:"pull_request"`
	Issue             *issue       `json:"issue"`
	Comment           *comment     `json:"comment"`
	Review            *review      `json:"review"`
	RequestedReviewer *user        `json:"requested_reviewer"`
}

func assigneesOf(single *user, list []user) []user {
	if len(list) > 0 {
		return list
	}
	if single != nil {
		return []user{*single}
	}
	return nil
}

// BuildNotifications turns a Gitea webhook (event header + raw JSON) into DMs.
func BuildNotifications(event string, body []byte) ([]notify.Notification, error) {
	var p payload
	if err := json.Unmarshal(body, &p); err != nil {
		return nil, err
	}

	repo := p.Repository.FullName
	sender := p.Sender.login()

	var notes []notify.Notification
	switch event {
	case "pull_request":
		notes = handlePullRequest(&p, repo, sender)
	case "issues":
		notes = handleIssues(&p, repo, sender)
	case "issue_comment":
		notes = handleIssueComment(&p, repo, sender)
	case "pull_request_review":
		notes = handlePullRequestReview(&p, repo, sender)
	default:
		slog.Info("gitea event not handled — ignored", "event", event)
		return nil, nil
	}

	return dedupe(notes), nil
}

func handlePullRequest(p *payload, repo, sender string) []notify.Notification {
	pr := p.PullRequest
	if pr == nil {
		return nil
	}
	tag := fmt.Sprintf("%s PR #%d", repo, pr.Number)
	body := fmt.Sprintf("<%s|%s>", pr.HTMLURL, pr.Title)
	var notes []notify.Notification

	switch p.Action {
	case "assigned":
		for _, u := range assigneesOf(pr.Assignee, pr.Assignees) {
			notes = append(notes, note(u.email(), u.login(),
				fmt.Sprintf("[%s] 담당자로 지정되었습니다", tag),
				"📌 PR 담당자 지정 — "+tag, body, "by "+sender))
		}
	case "review_requested":
		r := p.RequestedReviewer
		notes = append(notes, note(r.email(), r.login(),
			fmt.Sprintf("[%s] 리뷰 요청을 받았습니다", tag),
			"👀 리뷰 요청 — "+tag, body, "by "+sender))
	case "opened", "reopened":
		for _, u := range assigneesOf(pr.Assignee, pr.Assignees) {
			notes = append(notes, note(u.email(), u.login(),
				fmt.Sprintf("[%s] 담당 PR이 %s 되었습니다", tag, p.Action),
				fmt.Sprintf("🔀 PR %s — %s", p.Action, tag), body, "by "+sender))
		}
	case "closed":
		if pr.Merged {
			notes = append(notes, note(pr.User.email(), pr.User.login(),
				fmt.Sprintf("[%s] 작성한 PR이 머지되었습니다", tag),
				"✅ PR 머지됨 — "+tag, body, "by "+sender))
		}
	}
	return notes
}

func handleIssues(p *payload, repo, sender string) []notify.Notification {
	iss := p.Issue
	if iss == nil || p.Action != "assigned" {
		return nil
	}
	tag := fmt.Sprintf("%s 이슈 #%d", repo, iss.Number)
	body := fmt.Sprintf("<%s|%s>", iss.HTMLURL, iss.Title)
	var notes []notify.Notification
	for _, u := range assigneesOf(iss.Assignee, iss.Assignees) {
		notes = append(notes, note(u.email(), u.login(),
			fmt.Sprintf("[%s] 담당자로 지정되었습니다", tag),
			"📌 이슈 담당자 지정 — "+tag, body, "by "+sender))
	}
	return notes
}

func handleIssueComment(p *payload, repo, sender string) []notify.Notification {
	iss := p.Issue
	if iss == nil {
		return nil
	}
	tag := fmt.Sprintf("%s #%d", repo, iss.Number)
	url := iss.HTMLURL
	if p.Comment != nil && p.Comment.HTMLURL != "" {
		url = p.Comment.HTMLURL
	}
	snippet := ""
	if p.Comment != nil {
		snippet = strings.TrimSpace(p.Comment.Body)
		if len([]rune(snippet)) > 200 {
			snippet = string([]rune(snippet)[:200]) + "…"
		}
	}
	body := fmt.Sprintf("<%s|%s>\n> %s", url, iss.Title, snippet)

	// 담당자 + 작성자에게 알림. 단, 댓글 작성자 본인은 제외.
	recipients := assigneesOf(iss.Assignee, iss.Assignees)
	if iss.User != nil {
		recipients = append(recipients, *iss.User)
	}
	var notes []notify.Notification
	for _, u := range recipients {
		if u.email() == "" || u.login() == sender {
			continue
		}
		notes = append(notes, note(u.email(), u.login(),
			fmt.Sprintf("[%s] 새 댓글이 달렸습니다", tag),
			"💬 새 댓글 — "+tag, body, "by "+sender))
	}
	return notes
}

func handlePullRequestReview(p *payload, repo, sender string) []notify.Notification {
	pr := p.PullRequest
	if pr == nil {
		return nil
	}
	tag := fmt.Sprintf("%s PR #%d", repo, pr.Number)
	state := "리뷰"
	if p.Review != nil && p.Review.Type != "" {
		state = strings.TrimPrefix(p.Review.Type, "pull_request_review_")
	}
	body := fmt.Sprintf("<%s|%s>", pr.HTMLURL, pr.Title)
	if p.Review != nil && strings.TrimSpace(p.Review.Content) != "" {
		c := strings.TrimSpace(p.Review.Content)
		if len([]rune(c)) > 200 {
			c = string([]rune(c)[:200])
		}
		body += "\n> " + c
	}

	// 리뷰 결과는 PR 작성자에게 알림.
	return []notify.Notification{note(pr.User.email(), pr.User.login(),
		fmt.Sprintf("[%s] 리뷰가 등록되었습니다 (%s)", tag, state),
		"📝 리뷰 "+state+" — "+tag, body, "by "+sender)}
}

func note(email, login, text, title, body, context string) notify.Notification {
	return notify.Notification{
		Email:  email,
		Login:  login,
		Text:   text,
		Blocks: notify.SimpleBlocks(title, body, context),
	}
}

func dedupe(in []notify.Notification) []notify.Notification {
	seen := make(map[string]struct{})
	out := make([]notify.Notification, 0, len(in))
	for _, n := range in {
		if n.Email == "" && n.Login == "" {
			continue
		}
		key := n.Email + "|" + n.Login + "|" + n.Text
		if _, ok := seen[key]; ok {
			continue
		}
		seen[key] = struct{}{}
		out = append(out, n)
	}
	return out
}