| | | 1 | | package app |
| | | 2 | | |
| | | 3 | | import ( |
| | | 4 | | "context" |
| | | 5 | | "fmt" |
| | | 6 | | |
| | | 7 | | "github.com/jedi-knights/go-semantic-release/internal/domain" |
| | | 8 | | "github.com/jedi-knights/go-semantic-release/internal/ports" |
| | | 9 | | ) |
| | | 10 | | |
| | | 11 | | // CommitAnalyzer analyzes commits since the last release. |
| | | 12 | | type CommitAnalyzer struct { |
| | | 13 | | git ports.GitRepository |
| | | 14 | | parser ports.CommitParser |
| | | 15 | | logger ports.Logger |
| | | 16 | | } |
| | | 17 | | |
| | | 18 | | // NewCommitAnalyzer creates a commit analyzer. |
| | | 19 | | func NewCommitAnalyzer(git ports.GitRepository, parser ports.CommitParser, logger ports.Logger) *CommitAnalyzer { |
| | | 20 | | return &CommitAnalyzer{git: git, parser: parser, logger: logger} |
| | | 21 | | } |
| | | 22 | | |
| | | 23 | | // Analyze retrieves and parses commits since the given tag hash. |
| | 5 | 24 | | func (a *CommitAnalyzer) Analyze(ctx context.Context, sinceHash string) ([]domain.Commit, error) { |
| | 5 | 25 | | rawCommits, err := a.git.CommitsSince(ctx, sinceHash) |
| | 1 | 26 | | if err != nil { |
| | 1 | 27 | | return nil, fmt.Errorf("fetching commits: %w", err) |
| | 1 | 28 | | } |
| | | 29 | | |
| | 4 | 30 | | a.logger.Debug("found raw commits", "count", len(rawCommits)) |
| | 4 | 31 | | |
| | 4 | 32 | | parsed := make([]domain.Commit, 0, len(rawCommits)) |
| | 4 | 33 | | for i := range rawCommits { |
| | 6 | 34 | | fullMessage := rawCommits[i].Message |
| | 1 | 35 | | if rawCommits[i].Body != "" { |
| | 1 | 36 | | fullMessage = rawCommits[i].Message + "\n\n" + rawCommits[i].Body |
| | 1 | 37 | | } |
| | | 38 | | |
| | 6 | 39 | | commit, err := a.parser.Parse(fullMessage) |
| | 1 | 40 | | if err != nil { |
| | 1 | 41 | | a.logger.Warn("skipping unparseable commit", "hash", rawCommits[i].Hash, "error", err) |
| | 1 | 42 | | continue |
| | | 43 | | } |
| | | 44 | | |
| | | 45 | | // Preserve git metadata from raw commit. |
| | 5 | 46 | | commit.Hash = rawCommits[i].Hash |
| | 5 | 47 | | commit.Author = rawCommits[i].Author |
| | 5 | 48 | | commit.AuthorEmail = rawCommits[i].AuthorEmail |
| | 5 | 49 | | commit.Date = rawCommits[i].Date |
| | 5 | 50 | | |
| | 5 | 51 | | // Populate changed files. |
| | 5 | 52 | | files, err := a.git.FilesChangedInCommit(ctx, rawCommits[i].Hash) |
| | 0 | 53 | | if err != nil { |
| | 0 | 54 | | a.logger.Warn("failed to get changed files", "hash", rawCommits[i].Hash, "error", err) |
| | 0 | 55 | | } |
| | 5 | 56 | | commit.FilesChanged = files |
| | 5 | 57 | | |
| | 5 | 58 | | parsed = append(parsed, commit) |
| | | 59 | | } |
| | | 60 | | |
| | 4 | 61 | | a.logger.Info("analyzed commits", "total", len(rawCommits), "parsed", len(parsed)) |
| | 4 | 62 | | return parsed, nil |
| | | 63 | | } |