Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 75190d53ed | |||
| 8b8462bdc8 | |||
| 565a077b01 | |||
| dab7871cb4 | |||
| d9cacf6f62 | |||
| 67d835909f | |||
| ef3e6d5e87 | |||
| aade891129 | |||
| 7b42de67ca | |||
| dd2661fe14 | |||
| 98a4772f30 | |||
| fc23b6ebe9 |
@@ -31,7 +31,7 @@ jobs:
|
|||||||
model: gpt-5
|
model: gpt-5
|
||||||
- name: gpt
|
- name: gpt
|
||||||
token_secret: GPT_REVIEW_TOKEN
|
token_secret: GPT_REVIEW_TOKEN
|
||||||
model: gpt-5-mini
|
model: gpt-4.1
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- uses: actions/setup-go@v5
|
- uses: actions/setup-go@v5
|
||||||
@@ -49,5 +49,6 @@ jobs:
|
|||||||
LLM_MODEL: ${{ matrix.model }}
|
LLM_MODEL: ${{ matrix.model }}
|
||||||
CONVENTIONS_FILE: "CONVENTIONS.md"
|
CONVENTIONS_FILE: "CONVENTIONS.md"
|
||||||
PATTERNS_REPO: "rodin/go-patterns"
|
PATTERNS_REPO: "rodin/go-patterns"
|
||||||
PATTERNS_FILES: "README.md,docs/"
|
PATTERNS_FILES: "README.md,patterns/"
|
||||||
|
LLM_TIMEOUT: "600"
|
||||||
run: ./review-bot
|
run: ./review-bot
|
||||||
|
|||||||
@@ -0,0 +1,226 @@
|
|||||||
|
// Package budget manages LLM context window budgeting for review-bot.
|
||||||
|
//
|
||||||
|
// It estimates token usage and progressively trims context content to fit
|
||||||
|
// within model-specific limits. The trimming order (least important first):
|
||||||
|
// patterns → conventions → file context → diff truncation.
|
||||||
|
package budget
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"strings"
|
||||||
|
"unicode/utf8"
|
||||||
|
)
|
||||||
|
|
||||||
|
// modelLimit pairs a model name prefix with its context window size.
|
||||||
|
type modelLimit struct {
|
||||||
|
prefix string
|
||||||
|
limit int
|
||||||
|
}
|
||||||
|
|
||||||
|
// Known model context limits (in tokens), ordered longest-prefix-first
|
||||||
|
// for deterministic matching.
|
||||||
|
var modelLimits = []modelLimit{
|
||||||
|
{"claude-haiku-3.5-20241022", 200_000},
|
||||||
|
{"claude-sonnet-4-20250514", 200_000},
|
||||||
|
{"claude-opus-4-20250514", 200_000},
|
||||||
|
{"gpt-4.1-mini", 128_000},
|
||||||
|
{"gpt-5-mini", 200_000},
|
||||||
|
{"gpt-4.1", 128_000},
|
||||||
|
{"gpt-5", 200_000},
|
||||||
|
}
|
||||||
|
|
||||||
|
const defaultLimit = 128_000
|
||||||
|
|
||||||
|
// reserveTokens is headroom for the response generation.
|
||||||
|
const reserveTokens = 4_000
|
||||||
|
|
||||||
|
const diffTruncMarker = "\n\n... [diff truncated due to context limit] ..."
|
||||||
|
const diffTooLargeMarker = "... [diff too large for context window — review manually] ..."
|
||||||
|
const userMetaTruncMarker = "\n... [description truncated] ..."
|
||||||
|
|
||||||
|
// EstimateTokens estimates the number of tokens in a string.
|
||||||
|
// Uses the rough heuristic of ~4 bytes per token, which is
|
||||||
|
// conservative for English text and code.
|
||||||
|
func EstimateTokens(s string) int {
|
||||||
|
return len(s) / 4
|
||||||
|
}
|
||||||
|
|
||||||
|
// LimitForModel returns the context window size for the given model.
|
||||||
|
// Uses longest-prefix-first matching for deterministic results.
|
||||||
|
func LimitForModel(model string) int {
|
||||||
|
for _, ml := range modelLimits {
|
||||||
|
if model == ml.prefix || strings.HasPrefix(model, ml.prefix) {
|
||||||
|
return ml.limit
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return defaultLimit
|
||||||
|
}
|
||||||
|
|
||||||
|
// Sections holds the prompt content sections in trim priority order.
|
||||||
|
// When the total exceeds the budget, sections are trimmed from least
|
||||||
|
// important (Patterns) to most important (Diff).
|
||||||
|
type Sections struct {
|
||||||
|
SystemBase string // Core instructions (never trimmed)
|
||||||
|
Patterns string // Language patterns (trimmed first)
|
||||||
|
Conventions string // Repo conventions (trimmed second)
|
||||||
|
FileContext string // Full file content (trimmed third)
|
||||||
|
Diff string // The actual diff (trimmed last, only truncated)
|
||||||
|
UserMeta string // PR title, description, CI status (truncated only if base exceeds budget)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Result holds the trimmed content and metadata about what was dropped.
|
||||||
|
type Result struct {
|
||||||
|
SystemPrompt string
|
||||||
|
UserPrompt string
|
||||||
|
Trimmed []string // Human-readable descriptions of what was trimmed
|
||||||
|
EstTokens int // Estimated total tokens after trimming
|
||||||
|
}
|
||||||
|
|
||||||
|
// Fit trims sections to fit within the model's context limit.
|
||||||
|
// Returns the assembled prompts and a list of what was trimmed.
|
||||||
|
func Fit(model string, sections Sections) Result {
|
||||||
|
limit := LimitForModel(model) - reserveTokens
|
||||||
|
|
||||||
|
baseTokens := EstimateTokens(sections.SystemBase) + EstimateTokens(sections.UserMeta)
|
||||||
|
available := limit - baseTokens
|
||||||
|
if available < 0 {
|
||||||
|
// Base content alone exceeds budget. Truncate UserMeta (keep first ~1000 tokens).
|
||||||
|
if len(sections.UserMeta) > 4000 {
|
||||||
|
sections.UserMeta = truncateUTF8(sections.UserMeta, 4000) + userMetaTruncMarker
|
||||||
|
baseTokens = EstimateTokens(sections.SystemBase) + EstimateTokens(sections.UserMeta)
|
||||||
|
available = limit - baseTokens
|
||||||
|
}
|
||||||
|
if available < 0 {
|
||||||
|
available = 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Trimmable sections in priority order (first = dropped first)
|
||||||
|
type entry struct {
|
||||||
|
name string
|
||||||
|
content *string
|
||||||
|
}
|
||||||
|
entries := []entry{
|
||||||
|
{"patterns", §ions.Patterns},
|
||||||
|
{"conventions", §ions.Conventions},
|
||||||
|
{"file context", §ions.FileContext},
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if everything fits
|
||||||
|
totalTrimmable := EstimateTokens(sections.Diff)
|
||||||
|
for _, e := range entries {
|
||||||
|
totalTrimmable += EstimateTokens(*e.content)
|
||||||
|
}
|
||||||
|
|
||||||
|
var trimmed []string
|
||||||
|
if totalTrimmable > available {
|
||||||
|
// Trim from least important
|
||||||
|
for i := range entries {
|
||||||
|
tokens := EstimateTokens(*entries[i].content)
|
||||||
|
if tokens == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
trimmed = append(trimmed, fmt.Sprintf("%s (~%dK tokens)", entries[i].name, tokens/1000))
|
||||||
|
*entries[i].content = ""
|
||||||
|
|
||||||
|
// Recalculate
|
||||||
|
totalTrimmable = EstimateTokens(sections.Diff)
|
||||||
|
for _, e := range entries {
|
||||||
|
totalTrimmable += EstimateTokens(*e.content)
|
||||||
|
}
|
||||||
|
if totalTrimmable <= available {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// If still too large, truncate the diff
|
||||||
|
if totalTrimmable > available {
|
||||||
|
diffBudget := available
|
||||||
|
for _, e := range entries {
|
||||||
|
diffBudget -= EstimateTokens(*e.content)
|
||||||
|
}
|
||||||
|
if diffBudget < 0 {
|
||||||
|
diffBudget = 0
|
||||||
|
}
|
||||||
|
// Reserve space for truncation marker
|
||||||
|
markerBudget := EstimateTokens(diffTruncMarker)
|
||||||
|
effectiveBudget := diffBudget - markerBudget
|
||||||
|
if effectiveBudget < 0 {
|
||||||
|
effectiveBudget = 0
|
||||||
|
}
|
||||||
|
maxChars := effectiveBudget * 4
|
||||||
|
if maxChars < len(sections.Diff) {
|
||||||
|
removed := EstimateTokens(sections.Diff) - diffBudget
|
||||||
|
trimmed = append(trimmed, fmt.Sprintf("diff truncated (~%dK tokens removed)", removed/1000))
|
||||||
|
if maxChars > 0 {
|
||||||
|
if diffBudget >= markerBudget {
|
||||||
|
sections.Diff = truncateUTF8(sections.Diff, maxChars) + diffTruncMarker
|
||||||
|
} else {
|
||||||
|
sections.Diff = truncateUTF8(sections.Diff, maxChars)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
sections.Diff = diffTooLargeMarker
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
finalTokens := baseTokens
|
||||||
|
for _, e := range entries {
|
||||||
|
finalTokens += EstimateTokens(*e.content)
|
||||||
|
}
|
||||||
|
finalTokens += EstimateTokens(sections.Diff)
|
||||||
|
|
||||||
|
return buildResult(sections, trimmed, finalTokens)
|
||||||
|
}
|
||||||
|
|
||||||
|
func buildResult(s Sections, trimmed []string, estTokens int) Result {
|
||||||
|
var sys strings.Builder
|
||||||
|
sys.WriteString(s.SystemBase)
|
||||||
|
if s.Patterns != "" {
|
||||||
|
sys.WriteString("\n\n## Language Patterns & Idioms\n\nUse the following patterns as review criteria. Code that violates these established patterns is a finding:\n\n")
|
||||||
|
sys.WriteString(s.Patterns)
|
||||||
|
}
|
||||||
|
if s.Conventions != "" {
|
||||||
|
sys.WriteString("\n\n## Repository Conventions\n\nThe repository has the following coding conventions that must be respected:\n\n")
|
||||||
|
sys.WriteString(s.Conventions)
|
||||||
|
}
|
||||||
|
|
||||||
|
var usr strings.Builder
|
||||||
|
usr.WriteString(s.UserMeta)
|
||||||
|
if s.FileContext != "" {
|
||||||
|
usr.WriteString("\n### Full File Context (modified files)\n\n")
|
||||||
|
usr.WriteString(s.FileContext)
|
||||||
|
usr.WriteString("\n")
|
||||||
|
}
|
||||||
|
if s.Diff != "" {
|
||||||
|
usr.WriteString("\n### Diff (changes to review)\n\n```diff\n")
|
||||||
|
usr.WriteString(s.Diff)
|
||||||
|
usr.WriteString("\n```\n")
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(trimmed) > 0 {
|
||||||
|
usr.WriteString("\n⚠️ Note: Context was trimmed to fit model limits. Dropped: ")
|
||||||
|
usr.WriteString(strings.Join(trimmed, ", "))
|
||||||
|
usr.WriteString("\n")
|
||||||
|
}
|
||||||
|
|
||||||
|
return Result{
|
||||||
|
SystemPrompt: sys.String(),
|
||||||
|
UserPrompt: usr.String(),
|
||||||
|
Trimmed: trimmed,
|
||||||
|
EstTokens: estTokens,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// truncateUTF8 truncates s to at most maxBytes without splitting multi-byte
|
||||||
|
// UTF-8 characters. Returns a valid UTF-8 string of at most maxBytes bytes.
|
||||||
|
func truncateUTF8(s string, maxBytes int) string {
|
||||||
|
if len(s) <= maxBytes {
|
||||||
|
return s
|
||||||
|
}
|
||||||
|
for maxBytes > 0 && !utf8.RuneStart(s[maxBytes]) {
|
||||||
|
maxBytes--
|
||||||
|
}
|
||||||
|
return s[:maxBytes]
|
||||||
|
}
|
||||||
@@ -0,0 +1,203 @@
|
|||||||
|
package budget
|
||||||
|
|
||||||
|
import (
|
||||||
|
"strings"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestEstimateTokens(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
input string
|
||||||
|
want int
|
||||||
|
}{
|
||||||
|
{"", 0},
|
||||||
|
{"abcd", 1},
|
||||||
|
{"12345678", 2},
|
||||||
|
{strings.Repeat("x", 400), 100},
|
||||||
|
}
|
||||||
|
for _, tt := range tests {
|
||||||
|
got := EstimateTokens(tt.input)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("EstimateTokens(%d chars) = %d, want %d", len(tt.input), got, tt.want)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestLimitForModel(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
model string
|
||||||
|
want int
|
||||||
|
}{
|
||||||
|
{"gpt-4.1", 128_000},
|
||||||
|
{"gpt-5", 200_000},
|
||||||
|
{"gpt-5-mini", 200_000},
|
||||||
|
{"unknown-model", defaultLimit},
|
||||||
|
{"gpt-4.1-2026-01-01", 128_000}, // prefix match
|
||||||
|
}
|
||||||
|
for _, tt := range tests {
|
||||||
|
got := LimitForModel(tt.model)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("LimitForModel(%q) = %d, want %d", tt.model, got, tt.want)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_AllFits(t *testing.T) {
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "system instructions",
|
||||||
|
Patterns: "some patterns",
|
||||||
|
Conventions: "some conventions",
|
||||||
|
FileContext: "file content",
|
||||||
|
Diff: "diff content",
|
||||||
|
UserMeta: "PR: title\n",
|
||||||
|
}
|
||||||
|
result := Fit("gpt-5", s)
|
||||||
|
|
||||||
|
if len(result.Trimmed) != 0 {
|
||||||
|
t.Errorf("expected no trimming, got %v", result.Trimmed)
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.SystemPrompt, "some patterns") {
|
||||||
|
t.Error("expected patterns in system prompt")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.SystemPrompt, "some conventions") {
|
||||||
|
t.Error("expected conventions in system prompt")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.UserPrompt, "file content") {
|
||||||
|
t.Error("expected file context in user prompt")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_TrimsPatterns(t *testing.T) {
|
||||||
|
// Create content that exceeds 128K token budget for gpt-4.1
|
||||||
|
// Budget ≈ 128K - 4K reserve = 124K tokens = ~496K chars
|
||||||
|
// Fill patterns with enough to push over
|
||||||
|
bigPatterns := strings.Repeat("x", 500_000) // ~125K tokens
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "base",
|
||||||
|
Patterns: bigPatterns,
|
||||||
|
Conventions: "conventions",
|
||||||
|
FileContext: "files",
|
||||||
|
Diff: "diff",
|
||||||
|
UserMeta: "meta",
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
if len(result.Trimmed) == 0 {
|
||||||
|
t.Fatal("expected trimming")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.Trimmed[0], "patterns") {
|
||||||
|
t.Errorf("expected patterns to be trimmed first, got %v", result.Trimmed)
|
||||||
|
}
|
||||||
|
if strings.Contains(result.SystemPrompt, bigPatterns[:100]) {
|
||||||
|
t.Error("expected patterns to be removed from output")
|
||||||
|
}
|
||||||
|
// Conventions should survive
|
||||||
|
if !strings.Contains(result.SystemPrompt, "conventions") {
|
||||||
|
t.Error("expected conventions to survive after patterns trimmed")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_TrimsConventions(t *testing.T) {
|
||||||
|
// Patterns + conventions + diff all exceed budget even after patterns removed
|
||||||
|
big := strings.Repeat("y", 520_000) // ~130K tokens each (exceeds 124K budget even alone)
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "base",
|
||||||
|
Patterns: big,
|
||||||
|
Conventions: big,
|
||||||
|
FileContext: "files",
|
||||||
|
Diff: "diff",
|
||||||
|
UserMeta: "meta",
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
if len(result.Trimmed) < 2 {
|
||||||
|
t.Fatalf("expected at least 2 trimmed, got %v", result.Trimmed)
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.Trimmed[0], "patterns") {
|
||||||
|
t.Errorf("expected patterns trimmed first, got %s", result.Trimmed[0])
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.Trimmed[1], "conventions") {
|
||||||
|
t.Errorf("expected conventions trimmed second, got %s", result.Trimmed[1])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_TruncatesDiff(t *testing.T) {
|
||||||
|
// Only diff is huge, no patterns/conventions
|
||||||
|
hugeDiff := strings.Repeat("z", 600_000) // ~150K tokens > 128K limit
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "base",
|
||||||
|
Diff: hugeDiff,
|
||||||
|
UserMeta: "meta",
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
if len(result.Trimmed) == 0 {
|
||||||
|
t.Fatal("expected diff truncation")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.Trimmed[len(result.Trimmed)-1], "diff truncated") {
|
||||||
|
t.Errorf("expected diff truncation note, got %v", result.Trimmed)
|
||||||
|
}
|
||||||
|
if !strings.Contains(result.UserPrompt, "[diff truncated due to context limit]") {
|
||||||
|
t.Error("expected truncation marker in user prompt")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_PreservesNoteInOutput(t *testing.T) {
|
||||||
|
big := strings.Repeat("w", 500_000)
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "base",
|
||||||
|
Patterns: big,
|
||||||
|
Diff: "small diff",
|
||||||
|
UserMeta: "meta",
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
if !strings.Contains(result.UserPrompt, "⚠️ Note: Context was trimmed") {
|
||||||
|
t.Error("expected trimming note in user prompt")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
func TestFit_HugeUserMeta(t *testing.T) {
|
||||||
|
// UserMeta so large that base alone exceeds limit
|
||||||
|
// Use a unique marker past the truncation point
|
||||||
|
hugeDesc := strings.Repeat("d", 5000) + "UNIQUE_MARKER_PAST_TRUNCATION" + strings.Repeat("d", 595_000)
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: "base",
|
||||||
|
Diff: "small diff",
|
||||||
|
UserMeta: hugeDesc,
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
limit := LimitForModel("gpt-4.1") - reserveTokens
|
||||||
|
if result.EstTokens > limit {
|
||||||
|
t.Errorf("EstTokens %d exceeds limit %d", result.EstTokens, limit)
|
||||||
|
}
|
||||||
|
// Content past truncation point should not be present
|
||||||
|
if strings.Contains(result.UserPrompt, "UNIQUE_MARKER_PAST_TRUNCATION") {
|
||||||
|
t.Error("expected UserMeta to be truncated but found content past truncation point")
|
||||||
|
}
|
||||||
|
// Truncation marker should be present
|
||||||
|
if !strings.Contains(result.UserPrompt, "[description truncated]") {
|
||||||
|
t.Error("expected truncation marker in output")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFit_NeverExceedsLimit(t *testing.T) {
|
||||||
|
// All sections huge — verify final tokens never exceed limit
|
||||||
|
big := strings.Repeat("a", 200_000)
|
||||||
|
s := Sections{
|
||||||
|
SystemBase: strings.Repeat("s", 8000),
|
||||||
|
Patterns: big,
|
||||||
|
Conventions: big,
|
||||||
|
FileContext: big,
|
||||||
|
Diff: big,
|
||||||
|
UserMeta: strings.Repeat("m", 8000),
|
||||||
|
}
|
||||||
|
result := Fit("gpt-4.1", s)
|
||||||
|
|
||||||
|
limit := LimitForModel("gpt-4.1") - reserveTokens
|
||||||
|
if result.EstTokens > limit {
|
||||||
|
t.Errorf("EstTokens %d exceeds limit %d (trimmed: %v)", result.EstTokens, limit, result.Trimmed)
|
||||||
|
}
|
||||||
|
}
|
||||||
+20
-8
@@ -10,6 +10,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"gitea.weiker.me/rodin/review-bot/budget"
|
||||||
"gitea.weiker.me/rodin/review-bot/gitea"
|
"gitea.weiker.me/rodin/review-bot/gitea"
|
||||||
"gitea.weiker.me/rodin/review-bot/llm"
|
"gitea.weiker.me/rodin/review-bot/llm"
|
||||||
"gitea.weiker.me/rodin/review-bot/review"
|
"gitea.weiker.me/rodin/review-bot/review"
|
||||||
@@ -141,15 +142,26 @@ func main() {
|
|||||||
log.Printf("Loaded patterns from %s (%d bytes)", *patternsRepo, len(patterns))
|
log.Printf("Loaded patterns from %s (%d bytes)", *patternsRepo, len(patterns))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Step 7: Build prompts
|
// Step 7: Budget-aware prompt assembly
|
||||||
systemPrompt := review.BuildSystemPrompt(conventions, patterns)
|
sections := budget.Sections{
|
||||||
userPrompt := review.BuildUserPrompt(pr.Title, pr.Body, diff, fileContext, ciPassed, ciDetails)
|
SystemBase: review.BuildSystemBase(),
|
||||||
|
Patterns: patterns,
|
||||||
|
Conventions: conventions,
|
||||||
|
FileContext: fileContext,
|
||||||
|
Diff: diff,
|
||||||
|
UserMeta: review.BuildUserMeta(pr.Title, pr.Body, ciPassed, ciDetails),
|
||||||
|
}
|
||||||
|
budgetResult := budget.Fit(*llmModel, sections)
|
||||||
|
log.Printf("Token estimate: ~%dK (limit: %dK)", budgetResult.EstTokens/1000, budget.LimitForModel(*llmModel)/1000)
|
||||||
|
if len(budgetResult.Trimmed) > 0 {
|
||||||
|
log.Printf("Context trimmed: %v", budgetResult.Trimmed)
|
||||||
|
}
|
||||||
|
|
||||||
// Step 8: Call LLM
|
// Step 8: Call LLM
|
||||||
log.Printf("Sending to LLM (%s)...", *llmModel)
|
log.Printf("Sending to LLM (%s)...", *llmModel)
|
||||||
messages := []llm.Message{
|
messages := []llm.Message{
|
||||||
{Role: "system", Content: systemPrompt},
|
{Role: "system", Content: budgetResult.SystemPrompt},
|
||||||
{Role: "user", Content: userPrompt},
|
{Role: "user", Content: budgetResult.UserPrompt},
|
||||||
}
|
}
|
||||||
|
|
||||||
response, err := llmClient.Complete(ctx, messages)
|
response, err := llmClient.Complete(ctx, messages)
|
||||||
@@ -243,12 +255,12 @@ func fetchPatterns(ctx context.Context, client *gitea.Client, patternsRepo, patt
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
for filepath, content := range files {
|
for filePath, content := range files {
|
||||||
// Only include markdown and text files as patterns
|
// Only include markdown and text files as patterns
|
||||||
if !isPatternFile(filepath) {
|
if !isPatternFile(filePath) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
sb.WriteString(fmt.Sprintf("### %s/%s\n\n%s\n\n", repoRef, filepath, content))
|
sb.WriteString(fmt.Sprintf("### %s/%s\n\n%s\n\n", repoRef, filePath, content))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+38
-17
@@ -1,3 +1,6 @@
|
|||||||
|
// Package gitea provides a client for the Gitea API.
|
||||||
|
// It supports pull request operations, file content retrieval,
|
||||||
|
// and review submission.
|
||||||
package gitea
|
package gitea
|
||||||
|
|
||||||
import (
|
import (
|
||||||
@@ -56,8 +59,8 @@ type ChangedFile struct {
|
|||||||
|
|
||||||
// GetPullRequest fetches PR metadata.
|
// GetPullRequest fetches PR metadata.
|
||||||
func (c *Client) GetPullRequest(ctx context.Context, owner, repo string, number int) (*PullRequest, error) {
|
func (c *Client) GetPullRequest(ctx context.Context, owner, repo string, number int) (*PullRequest, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d", c.baseURL, owner, repo, number)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d", c.baseURL, owner, repo, number)
|
||||||
body, err := c.doGet(ctx, url)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("fetch PR: %w", err)
|
return nil, fmt.Errorf("fetch PR: %w", err)
|
||||||
}
|
}
|
||||||
@@ -70,8 +73,8 @@ func (c *Client) GetPullRequest(ctx context.Context, owner, repo string, number
|
|||||||
|
|
||||||
// GetPullRequestDiff fetches the unified diff for a PR.
|
// GetPullRequestDiff fetches the unified diff for a PR.
|
||||||
func (c *Client) GetPullRequestDiff(ctx context.Context, owner, repo string, number int) (string, error) {
|
func (c *Client) GetPullRequestDiff(ctx context.Context, owner, repo string, number int) (string, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d.diff", c.baseURL, owner, repo, number)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d.diff", c.baseURL, owner, repo, number)
|
||||||
body, err := c.doGet(ctx, url)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("fetch diff: %w", err)
|
return "", fmt.Errorf("fetch diff: %w", err)
|
||||||
}
|
}
|
||||||
@@ -80,8 +83,8 @@ func (c *Client) GetPullRequestDiff(ctx context.Context, owner, repo string, num
|
|||||||
|
|
||||||
// GetPullRequestFiles fetches the list of files changed in a PR.
|
// GetPullRequestFiles fetches the list of files changed in a PR.
|
||||||
func (c *Client) GetPullRequestFiles(ctx context.Context, owner, repo string, number int) ([]ChangedFile, error) {
|
func (c *Client) GetPullRequestFiles(ctx context.Context, owner, repo string, number int) ([]ChangedFile, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d/files", c.baseURL, owner, repo, number)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d/files", c.baseURL, owner, repo, number)
|
||||||
body, err := c.doGet(ctx, url)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("fetch PR files: %w", err)
|
return nil, fmt.Errorf("fetch PR files: %w", err)
|
||||||
}
|
}
|
||||||
@@ -94,8 +97,8 @@ func (c *Client) GetPullRequestFiles(ctx context.Context, owner, repo string, nu
|
|||||||
|
|
||||||
// GetCommitStatuses fetches CI statuses for a commit SHA.
|
// GetCommitStatuses fetches CI statuses for a commit SHA.
|
||||||
func (c *Client) GetCommitStatuses(ctx context.Context, owner, repo, sha string) ([]CommitStatus, error) {
|
func (c *Client) GetCommitStatuses(ctx context.Context, owner, repo, sha string) ([]CommitStatus, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/commits/%s/statuses", c.baseURL, owner, repo, sha)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/commits/%s/statuses", c.baseURL, owner, repo, sha)
|
||||||
body, err := c.doGet(ctx, url)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("fetch commit statuses: %w", err)
|
return nil, fmt.Errorf("fetch commit statuses: %w", err)
|
||||||
}
|
}
|
||||||
@@ -108,8 +111,8 @@ func (c *Client) GetCommitStatuses(ctx context.Context, owner, repo, sha string)
|
|||||||
|
|
||||||
// GetFileContent fetches a file from the default branch of a repo.
|
// GetFileContent fetches a file from the default branch of a repo.
|
||||||
func (c *Client) GetFileContent(ctx context.Context, owner, repo, filepath string) (string, error) {
|
func (c *Client) GetFileContent(ctx context.Context, owner, repo, filepath string) (string, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/raw/%s", c.baseURL, owner, repo, filepath)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/raw/%s", c.baseURL, owner, repo, escapePath(filepath))
|
||||||
body, err := c.doGet(ctx, url)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("fetch file %s: %w", filepath, err)
|
return "", fmt.Errorf("fetch file %s: %w", filepath, err)
|
||||||
}
|
}
|
||||||
@@ -118,7 +121,7 @@ func (c *Client) GetFileContent(ctx context.Context, owner, repo, filepath strin
|
|||||||
|
|
||||||
// GetFileContentRef fetches a file from a specific ref (branch/tag/sha) in a repo.
|
// GetFileContentRef fetches a file from a specific ref (branch/tag/sha) in a repo.
|
||||||
func (c *Client) GetFileContentRef(ctx context.Context, owner, repo, filepath, ref string) (string, error) {
|
func (c *Client) GetFileContentRef(ctx context.Context, owner, repo, filepath, ref string) (string, error) {
|
||||||
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/raw/%s?ref=%s", c.baseURL, owner, repo, filepath, url.QueryEscape(ref))
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/raw/%s?ref=%s", c.baseURL, owner, repo, escapePath(filepath), url.QueryEscape(ref))
|
||||||
body, err := c.doGet(ctx, reqURL)
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("fetch file %s@%s: %w", filepath, ref, err)
|
return "", fmt.Errorf("fetch file %s@%s: %w", filepath, ref, err)
|
||||||
@@ -129,7 +132,7 @@ func (c *Client) GetFileContentRef(ctx context.Context, owner, repo, filepath, r
|
|||||||
// PostReview submits a review to a PR.
|
// PostReview submits a review to a PR.
|
||||||
// event should be "APPROVED" or "REQUEST_CHANGES".
|
// event should be "APPROVED" or "REQUEST_CHANGES".
|
||||||
func (c *Client) PostReview(ctx context.Context, owner, repo string, number int, event, body string) error {
|
func (c *Client) PostReview(ctx context.Context, owner, repo string, number int, event, body string) error {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d/reviews", c.baseURL, owner, repo, number)
|
reqURL := fmt.Sprintf("%s/api/v1/repos/%s/%s/pulls/%d/reviews", c.baseURL, owner, repo, number)
|
||||||
|
|
||||||
payload := struct {
|
payload := struct {
|
||||||
Body string `json:"body"`
|
Body string `json:"body"`
|
||||||
@@ -144,7 +147,7 @@ func (c *Client) PostReview(ctx context.Context, owner, repo string, number int,
|
|||||||
return fmt.Errorf("marshal review payload: %w", err)
|
return fmt.Errorf("marshal review payload: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
req, err := http.NewRequestWithContext(ctx, "POST", url, bytes.NewReader(data))
|
req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL, bytes.NewReader(data))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("create review request: %w", err)
|
return fmt.Errorf("create review request: %w", err)
|
||||||
}
|
}
|
||||||
@@ -164,8 +167,8 @@ func (c *Client) PostReview(ctx context.Context, owner, repo string, number int,
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Client) doGet(ctx context.Context, url string) ([]byte, error) {
|
func (c *Client) doGet(ctx context.Context, reqURL string) ([]byte, error) {
|
||||||
req, err := http.NewRequestWithContext(ctx, "GET", url, nil)
|
req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@@ -184,6 +187,18 @@ func (c *Client) doGet(ctx context.Context, url string) ([]byte, error) {
|
|||||||
return io.ReadAll(resp.Body)
|
return io.ReadAll(resp.Body)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// escapePath escapes each segment of a relative file path for use in URLs.
|
||||||
|
// Slashes are preserved as path separators; other special characters are escaped.
|
||||||
|
// Input should be a relative path (no leading slash). Already-encoded segments
|
||||||
|
// will be double-encoded, which is the desired behavior for user-provided paths.
|
||||||
|
func escapePath(p string) string {
|
||||||
|
parts := strings.Split(p, "/")
|
||||||
|
for i, part := range parts {
|
||||||
|
parts[i] = url.PathEscape(part)
|
||||||
|
}
|
||||||
|
return strings.Join(parts, "/")
|
||||||
|
}
|
||||||
|
|
||||||
// ContentEntry represents a file or directory entry from the contents API.
|
// ContentEntry represents a file or directory entry from the contents API.
|
||||||
type ContentEntry struct {
|
type ContentEntry struct {
|
||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
@@ -192,9 +207,15 @@ type ContentEntry struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// ListContents lists files and directories at a given path in a repo.
|
// ListContents lists files and directories at a given path in a repo.
|
||||||
|
// Pass an empty path to list the repository root.
|
||||||
func (c *Client) ListContents(ctx context.Context, owner, repo, path string) ([]ContentEntry, error) {
|
func (c *Client) ListContents(ctx context.Context, owner, repo, path string) ([]ContentEntry, error) {
|
||||||
url := fmt.Sprintf("%s/api/v1/repos/%s/%s/contents/%s", c.baseURL, owner, repo, path)
|
var reqURL string
|
||||||
body, err := c.doGet(ctx, url)
|
if path == "" {
|
||||||
|
reqURL = fmt.Sprintf("%s/api/v1/repos/%s/%s/contents", c.baseURL, owner, repo)
|
||||||
|
} else {
|
||||||
|
reqURL = fmt.Sprintf("%s/api/v1/repos/%s/%s/contents/%s", c.baseURL, owner, repo, escapePath(path))
|
||||||
|
}
|
||||||
|
body, err := c.doGet(ctx, reqURL)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("list contents %s: %w", path, err)
|
return nil, fmt.Errorf("list contents %s: %w", path, err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -294,3 +294,27 @@ func TestGetAllFilesInPath_File(t *testing.T) {
|
|||||||
t.Errorf("unexpected content: %q", files["README.md"])
|
t.Errorf("unexpected content: %q", files["README.md"])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestEscapePath(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
input string
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{"simple", "src/main.go", "src/main.go"},
|
||||||
|
{"spaces", "my dir/my file.go", "my%20dir/my%20file.go"},
|
||||||
|
{"special chars", "path/file#1.txt", "path/file%231.txt"},
|
||||||
|
{"empty", "", ""},
|
||||||
|
{"single segment", "README.md", "README.md"},
|
||||||
|
{"nested deep", "a/b/c/d.md", "a/b/c/d.md"},
|
||||||
|
{"already encoded", "path/file%20name.go", "path/file%2520name.go"},
|
||||||
|
}
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
got := escapePath(tt.input)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("escapePath(%q) = %q, want %q", tt.input, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -1,3 +1,4 @@
|
|||||||
|
// Package llm provides a client for OpenAI-compatible chat completion APIs.
|
||||||
package llm
|
package llm
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
|||||||
+28
-4
@@ -1,3 +1,5 @@
|
|||||||
|
// Package review builds prompts for AI code review and parses LLM responses
|
||||||
|
// into structured review results.
|
||||||
package review
|
package review
|
||||||
|
|
||||||
import (
|
import (
|
||||||
@@ -5,8 +7,10 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
// BuildSystemPrompt constructs the system prompt for the LLM reviewer.
|
// BuildSystemBase returns the core system prompt instructions without
|
||||||
func BuildSystemPrompt(conventions, patterns string) string {
|
// patterns or conventions. Used by the budget package to separate
|
||||||
|
// trimmable from non-trimmable content.
|
||||||
|
func BuildSystemBase() string {
|
||||||
var sb strings.Builder
|
var sb strings.Builder
|
||||||
|
|
||||||
sb.WriteString("You are an expert code reviewer. Review the provided pull request diff carefully.\n\n")
|
sb.WriteString("You are an expert code reviewer. Review the provided pull request diff carefully.\n\n")
|
||||||
@@ -40,6 +44,15 @@ func BuildSystemPrompt(conventions, patterns string) string {
|
|||||||
sb.WriteString("- Line numbers should reference the new file line numbers from the diff headers.\n")
|
sb.WriteString("- Line numbers should reference the new file line numbers from the diff headers.\n")
|
||||||
sb.WriteString("- If the diff is empty or trivial (only formatting/whitespace), APPROVE with no findings.\n")
|
sb.WriteString("- If the diff is empty or trivial (only formatting/whitespace), APPROVE with no findings.\n")
|
||||||
|
|
||||||
|
return sb.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
// BuildSystemPrompt constructs the full system prompt with patterns and conventions.
|
||||||
|
// Deprecated: Use BuildSystemBase with budget.Fit for context-aware assembly.
|
||||||
|
func BuildSystemPrompt(conventions, patterns string) string {
|
||||||
|
var sb strings.Builder
|
||||||
|
sb.WriteString(BuildSystemBase())
|
||||||
|
|
||||||
if patterns != "" {
|
if patterns != "" {
|
||||||
sb.WriteString(fmt.Sprintf("\n\n## Language Patterns & Idioms\n\nUse the following patterns as review criteria. Code that violates these established patterns is a finding:\n\n%s\n", patterns))
|
sb.WriteString(fmt.Sprintf("\n\n## Language Patterns & Idioms\n\nUse the following patterns as review criteria. Code that violates these established patterns is a finding:\n\n%s\n", patterns))
|
||||||
}
|
}
|
||||||
@@ -51,8 +64,9 @@ func BuildSystemPrompt(conventions, patterns string) string {
|
|||||||
return sb.String()
|
return sb.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
// BuildUserPrompt constructs the user message with PR context.
|
// BuildUserMeta returns the PR metadata header (title, description, CI status)
|
||||||
func BuildUserPrompt(title, description, diff, fileContext string, ciPassed bool, ciDetails string) string {
|
// without the diff or file context. Used by the budget package.
|
||||||
|
func BuildUserMeta(title, description string, ciPassed bool, ciDetails string) string {
|
||||||
var sb strings.Builder
|
var sb strings.Builder
|
||||||
|
|
||||||
sb.WriteString(fmt.Sprintf("## Pull Request: %s\n\n", title))
|
sb.WriteString(fmt.Sprintf("## Pull Request: %s\n\n", title))
|
||||||
@@ -71,6 +85,16 @@ func BuildUserPrompt(title, description, diff, fileContext string, ciPassed bool
|
|||||||
sb.WriteString(fmt.Sprintf("CI Details: %s\n", ciDetails))
|
sb.WriteString(fmt.Sprintf("CI Details: %s\n", ciDetails))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return sb.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
// BuildUserPrompt constructs the user message with PR context.
|
||||||
|
// Deprecated: Use BuildUserMeta with budget.Fit for context-aware assembly.
|
||||||
|
func BuildUserPrompt(title, description, diff, fileContext string, ciPassed bool, ciDetails string) string {
|
||||||
|
var sb strings.Builder
|
||||||
|
|
||||||
|
sb.WriteString(BuildUserMeta(title, description, ciPassed, ciDetails))
|
||||||
|
|
||||||
if fileContext != "" {
|
if fileContext != "" {
|
||||||
sb.WriteString("\n### Full File Context (modified files)\n\n")
|
sb.WriteString("\n### Full File Context (modified files)\n\n")
|
||||||
sb.WriteString(fileContext)
|
sb.WriteString(fileContext)
|
||||||
|
|||||||
@@ -116,3 +116,43 @@ func TestBuildUserPrompt_WithoutFileContext(t *testing.T) {
|
|||||||
t.Error("should not include file context section when empty")
|
t.Error("should not include file context section when empty")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
func TestBuildSystemBase(t *testing.T) {
|
||||||
|
result := BuildSystemBase()
|
||||||
|
if result == "" {
|
||||||
|
t.Fatal("BuildSystemBase returned empty string")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result, "expert code reviewer") {
|
||||||
|
t.Error("expected reviewer role in system base")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result, "REQUEST_CHANGES") {
|
||||||
|
t.Error("expected verdict format in system base")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result, "JSON") {
|
||||||
|
t.Error("expected JSON output instruction in system base")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBuildUserMeta(t *testing.T) {
|
||||||
|
result := BuildUserMeta("Fix bug", "Some description", true, "all checks passed")
|
||||||
|
if !strings.Contains(result, "Fix bug") {
|
||||||
|
t.Error("expected title in user meta")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result, "Some description") {
|
||||||
|
t.Error("expected description in user meta")
|
||||||
|
}
|
||||||
|
if !strings.Contains(result, "PASSED") {
|
||||||
|
t.Error("expected CI PASSED status")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBuildUserMeta_CIFailed(t *testing.T) {
|
||||||
|
result := BuildUserMeta("Title", "", false, "test job failed")
|
||||||
|
if !strings.Contains(result, "FAILED") {
|
||||||
|
t.Error("expected CI FAILED status")
|
||||||
|
}
|
||||||
|
if strings.Contains(result, "Description") {
|
||||||
|
t.Error("expected no description section when empty")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user