This commit is contained in:
@@ -1,49 +1,47 @@
|
|||||||
from dataclasses import dataclass
|
from typing import List
|
||||||
from typing import Optional
|
|
||||||
|
|
||||||
from src.analyzers.git_repository import GitRepository
|
from src.analyzers.git_repository import GitRepository
|
||||||
from src.models.data_structures import RiskyCommitAnalysis
|
from src.models import RiskyCommitAnalysis
|
||||||
|
|
||||||
|
|
||||||
@dataclass
|
|
||||||
class RiskyCommitDetector:
|
class RiskyCommitDetector:
|
||||||
"""Detects risky commits."""
|
"""Detect risky and potentially problematic commits."""
|
||||||
|
|
||||||
repo: GitRepository
|
def __init__(
|
||||||
days: int
|
self,
|
||||||
|
repo: GitRepository,
|
||||||
|
days: int = 30,
|
||||||
|
large_commit_threshold: int = 500,
|
||||||
|
) -> None:
|
||||||
|
"""Initialize RiskyCommitDetector."""
|
||||||
|
self.repo = repo
|
||||||
|
self.days = days
|
||||||
|
self.large_commit_threshold = large_commit_threshold
|
||||||
|
|
||||||
def analyze(self) -> Optional[RiskyCommitAnalysis]:
|
def analyze(self) -> RiskyCommitAnalysis:
|
||||||
"""Detect risky commits."""
|
"""Detect risky commits."""
|
||||||
commits = self.repo.get_commits()
|
commits = self.repo.get_commits(since_days=self.days)
|
||||||
|
|
||||||
if not commits:
|
if not commits:
|
||||||
return None
|
return RiskyCommitAnalysis()
|
||||||
|
|
||||||
large_change_commits = []
|
large_commits = []
|
||||||
merge_commits = []
|
merge_commits = []
|
||||||
revert_commits = []
|
revert_commits = []
|
||||||
|
|
||||||
for commit in commits:
|
for commit in commits:
|
||||||
if commit.is_revert:
|
if commit.lines_changed_count >= self.large_commit_threshold:
|
||||||
revert_commits.append(commit)
|
large_commits.append(commit)
|
||||||
elif commit.is_merge:
|
|
||||||
|
if commit.is_merge:
|
||||||
merge_commits.append(commit)
|
merge_commits.append(commit)
|
||||||
|
|
||||||
threshold = 500
|
if "revert" in commit.message.lower():
|
||||||
if commit.lines_added + commit.lines_deleted > threshold:
|
revert_commits.append(commit)
|
||||||
large_change_commits.append(commit)
|
|
||||||
|
|
||||||
total_risky = len(large_change_commits) + len(merge_commits) + len(revert_commits)
|
|
||||||
risk_score = total_risky / max(1, len(commits)) * 100
|
|
||||||
|
|
||||||
return RiskyCommitAnalysis(
|
return RiskyCommitAnalysis(
|
||||||
total_risky_commits=total_risky,
|
large_commits=large_commits[:20],
|
||||||
large_change_commits=sorted(
|
|
||||||
large_change_commits,
|
|
||||||
key=lambda c: c.lines_added + c.lines_deleted,
|
|
||||||
reverse=True,
|
|
||||||
)[:20],
|
|
||||||
merge_commits=merge_commits[:20],
|
merge_commits=merge_commits[:20],
|
||||||
revert_commits=revert_commits[:20],
|
revert_commits=revert_commits[:20],
|
||||||
risk_score=risk_score,
|
total_risky=len(large_commits) + len(merge_commits) + len(revert_commits),
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user