Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d545abe392 | |||
| 10ef451c20 | |||
| 39f3326674 |
@@ -1,37 +0,0 @@
|
|||||||
# Dev Loop Health Check — 2026-05-14 23:33 UTC
|
|
||||||
|
|
||||||
## Status: ✅ OPTIMAL
|
|
||||||
|
|
||||||
### Test Results
|
|
||||||
- All packages: **PASS** ✅
|
|
||||||
- Test count: 150+ tests across:
|
|
||||||
- `./cmd/review-bot`: review, persona, schema, LLM routing
|
|
||||||
- `./internal/gitea`: Gitea client, URL validation, SSRF defense
|
|
||||||
- `./internal/github`: GitHub client, API routing
|
|
||||||
- `./review`: persona loading, file content fetching, review logic
|
|
||||||
|
|
||||||
### Recent Activity
|
|
||||||
1. **Tests added:** GetTimelineReviewCommentIDForReview, GetAllFilesInPath, fetchFileContext, fetchPatterns, persona edge cases
|
|
||||||
2. **Code quality:** `go fmt`, `go mod tidy` clean
|
|
||||||
3. **Branches:** All worktrees cleaned up, working on `review-bot-fixes` (in sync with origin/main)
|
|
||||||
|
|
||||||
### Current HEAD
|
|
||||||
- SHA: `b534247`
|
|
||||||
- Message: `[dev-loop] Update TODO.md with current cycle status and coverage metrics`
|
|
||||||
- Time: Clean, no uncommitted changes
|
|
||||||
|
|
||||||
### Next Phase Priorities
|
|
||||||
1. **PR Submission (#132+)** — Enable review-bot to create PRs (3–5 days)
|
|
||||||
2. **GitHub Enterprise Support** — Enterprise URL patterns, token scopes (2–3 days)
|
|
||||||
3. **Performance & Observability** — Metrics, load testing, audit logging (5–7 days)
|
|
||||||
|
|
||||||
### System Health
|
|
||||||
- ✅ All tests passing
|
|
||||||
- ✅ No warnings or lint issues
|
|
||||||
- ✅ Code is clean and organized
|
|
||||||
- ✅ Ready for next development cycle
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
**Next check:** ~6:10 AM UTC (May 15)
|
|
||||||
**Action:** Ready for issue creation or new feature work
|
|
||||||
@@ -1,151 +1,79 @@
|
|||||||
## Dev Loop: review-bot — Continuous Health Monitor
|
## Dev Loop: review-bot — 2026-05-14 20:10 UTC
|
||||||
|
|
||||||
### Current Cycle: 2026-05-14 23:11 UTC ✅
|
### Latest: ✅ STABLE STATE — REPO HEALTH COMPLETE
|
||||||
|
- **Last action:** health check; verified tests pass, repo clean, no action needed
|
||||||
**Repository Status:** OPTIMAL
|
- **Repository:** Clean, all merges complete, no open issues/PRs
|
||||||
- Main: `6f02cef` (clean, all tests pass)
|
- **Main branch:** Up to date with origin/main
|
||||||
- Working tree: clean
|
- **Test suite:** All passing (cached)
|
||||||
- Build: ✅ successful
|
|
||||||
- Vet: ✅ clean
|
|
||||||
- Test suite: ALL PASS
|
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## Latest Delivered: Test Coverage Sprint 2026-05-14 ✅
|
## Repository Status
|
||||||
|
|
||||||
### Coverage Improvements
|
### ✅ Merged to main (recent):
|
||||||
|
- issue-123 (IP-level SSRF defense) — 6 commits, main at 4440823
|
||||||
|
- issue-125 (VCS_URL rename + deprecation) — merged
|
||||||
|
- issue-124 (multi-arch binary support) — merged
|
||||||
|
- issue-120 (GitHub Actions + VCS abstraction) — merged
|
||||||
|
- issue-121 (VCS host type detection for binary download) — merged
|
||||||
|
|
||||||
22 new tests added across 4 packages:
|
### 🧹 Cleanup COMPLETE:
|
||||||
|
- ✅ Removed old worktrees (issue-123, review-bot-issue-125)
|
||||||
| Package | Before | After | Delta |
|
- ✅ Test suite passes (all packages)
|
||||||
|---------|--------|-------|-------|
|
- ✅ No TODO/FIXME in code except expected GitHub client notes
|
||||||
| cmd/review-bot | 37.6% | 46.1% | +8.5% |
|
- ✅ No open issues or pull requests
|
||||||
| gitea | 80.0% | 85.2% | +5.2% |
|
- ✅ Dependencies up to date
|
||||||
| github | 79.9% | 86.3% | +6.4% |
|
|
||||||
| review | 91.5% | 92.0% | +0.5% |
|
|
||||||
|
|
||||||
**What was tested:**
|
|
||||||
- `fetchFileContext`: empty, removed files, content fetching, error recovery, context cancellation
|
|
||||||
- `fetchPatterns`: empty repo, all files, specific files, invalid format, errors, multiple repos
|
|
||||||
- `LoadPersona`: nonexistent file, non-regular file (directory), oversized file
|
|
||||||
- `CapitalizeFirst`: RuneError (invalid UTF-8)
|
|
||||||
- `GetTimelineReviewCommentIDForReview` (gitea): 4 cases including user+body matching
|
|
||||||
- `GetAllFilesInPath` (github): directory listing, 404 fallback, recursive subdirectory
|
|
||||||
|
|
||||||
**Commits:** `fccfdd2`, `6f02cef`
|
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## Repository Status Post-Merge
|
## Current Feature Completeness
|
||||||
|
|
||||||
### Main Branch
|
✅ **Core Capabilities:**
|
||||||
- Commit: `9f3f321`
|
|
||||||
- Status: ✅ All systems healthy
|
|
||||||
|
|
||||||
### Recent Merged PRs
|
|
||||||
| PR | Issue | Title | Status |
|
|
||||||
|---|---|---|---|
|
|
||||||
| #131 | #130 | GitHub API methods & VCS routing | ✅ MERGED |
|
|
||||||
| #129 | #123 | IP-level SSRF defense | ✅ MERGED |
|
|
||||||
| #128 | #125 | VCS_URL deprecation & renaming | ✅ MERGED |
|
|
||||||
| #127 | #124 | Multi-arch binary support | ✅ MERGED |
|
|
||||||
| #126 | #120 | GitHub Actions composite action | ✅ MERGED |
|
|
||||||
|
|
||||||
### Recent Direct Commits
|
|
||||||
| SHA | Description | Date |
|
|
||||||
|-----|-------------|------|
|
|
||||||
| `fccfdd2` | [dev-loop] fetchFileContext/fetchPatterns/persona tests | 2026-05-14 |
|
|
||||||
| `6f02cef` | [dev-loop] GetTimelineReviewCommentIDForReview/GetAllFilesInPath tests | 2026-05-14 |
|
|
||||||
|
|
||||||
### Closed Issues
|
|
||||||
- #130, #123, #125, #124, #120
|
|
||||||
|
|
||||||
### Open Issues
|
|
||||||
- None blocking; backlog tracked in Gitea project board
|
|
||||||
|
|
||||||
### Worktrees
|
|
||||||
- All cleaned up; no stale branches
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## Feature Completeness Summary
|
|
||||||
|
|
||||||
### ✅ Core Functionality
|
|
||||||
- Multi-provider LLM support (OpenAI, Anthropic, SAP AI Core)
|
- Multi-provider LLM support (OpenAI, Anthropic, SAP AI Core)
|
||||||
- Gitea PR review (mature, proven)
|
- Gitea PR integration with structured reviews
|
||||||
- **NEW: GitHub PR review (fully implemented)**
|
|
||||||
- VCS abstraction (Gitea/GitHub transparent routing)
|
|
||||||
- SSRF defense with IP-level validation
|
- SSRF defense with IP-level validation
|
||||||
- Multi-architecture binary deployment
|
- VCS abstraction (Gitea/GitHub support)
|
||||||
|
- Multi-architecture binary support
|
||||||
|
- GitHub Actions composite action
|
||||||
|
|
||||||
### ✅ Review Quality
|
✅ **Recent Security Work:**
|
||||||
- Structured reviews with code snippets
|
- RFC6598 CGN range detection
|
||||||
- LLM-driven analysis
|
- IP fallback dialing for local endpoint rejection
|
||||||
- Persona-based customization
|
- URL validation for SSRF prevention
|
||||||
- Context awareness
|
|
||||||
|
|
||||||
### ✅ Security
|
✅ **Code Quality:**
|
||||||
- RFC6598 CGN detection
|
- Comprehensive test coverage (all packages tested)
|
||||||
- HTTPS enforcement
|
- Consistent error handling with context propagation
|
||||||
- Redirect safety
|
- Secure credential handling (unexported fields)
|
||||||
- Credential handling (no logs, no reflection leaks)
|
- Concurrency-safe designs
|
||||||
- URL validation for VCS API access
|
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## Next Phase: Backlog Priorities
|
## Next Priority Actions
|
||||||
|
|
||||||
### Priority 1: PR Submission
|
### Phase 2: Feature Exploration (NEXT SESSION)
|
||||||
**Issue:** #132+ (create)
|
- Scan code for potential improvements per REVIEW.md findings
|
||||||
**Goal:** Enable review-bot to create PRs (not just post reviews)
|
- Assess performance under load
|
||||||
**Scope:** PR creation flow, commit logic, test coverage
|
- Review REVIEW.md findings for targeted fixes
|
||||||
**Est. Time:** 3–5 days
|
- Consider backlog items from design docs
|
||||||
**Impact:** Enable automated improvements, fix suggestions with diff context
|
|
||||||
|
|
||||||
### Priority 2: GitHub Enterprise Support
|
### Phase 3: Optional Enhancements (BACKLOG)
|
||||||
**Goal:** Explicit testing & routing for GitHub Enterprise
|
- Address REVIEW.md context propagation findings (if prioritized)
|
||||||
**Gap:** Enterprise URL patterns, /api/v3 suffix handling, token scopes
|
- Additional LLM provider support
|
||||||
**Scope:** Tests, URL routing, documentation
|
- Enhanced context detection
|
||||||
**Est. Time:** 2–3 days
|
- Custom report formats
|
||||||
**Impact:** Enable enterprise customers, reduce integration risk
|
- Webhook management improvements
|
||||||
|
|
||||||
### Priority 3: Performance & Observability
|
|
||||||
**Areas:**
|
|
||||||
- Load testing under concurrent reviews
|
|
||||||
- Metrics collection (review latency, LLM token usage, API call counts)
|
|
||||||
- Audit logging for compliance workflows
|
|
||||||
- Dashboard (review history, metrics, team analytics)
|
|
||||||
**Est. Time:** 5–7 days
|
|
||||||
**Impact:** Operational confidence, troubleshooting, compliance
|
|
||||||
|
|
||||||
### Priority 4: Enhanced Context
|
|
||||||
**Opportunities:**
|
|
||||||
- Semantic code understanding (AST-based analysis for specific languages)
|
|
||||||
- Project-specific review rules (.review-bot.yaml in repo root)
|
|
||||||
- Team-level customization
|
|
||||||
**Est. Time:** 7–10 days
|
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## Dev Loop Schedule
|
## Worktrees Status
|
||||||
|
All old worktrees cleaned up. Ready for new issue work.
|
||||||
- **Interval:** 4 hours
|
|
||||||
- **Next check:** ~6:10 AM UTC (May 15)
|
|
||||||
- **Health:** ✅ Optimal — all systems running
|
|
||||||
- **Status:** Ready for next phase work
|
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## Metadata
|
## Dev-Loop Metadata
|
||||||
|
- **Repo:** /home/ubuntu/review-bot
|
||||||
| Key | Value |
|
- **Main branch SHA:** ed3a5dd (last commit)
|
||||||
|---|---|
|
- **Cron ID:** 5342ac81-4bbc-4e4c-a123-347a7788d50c
|
||||||
| Repo | `/home/ubuntu/review-bot` |
|
- **Scheduled:** Every 4 hours
|
||||||
| Main SHA | `6f02cef` |
|
- **Last health check:** 2026-05-14 20:10 UTC (✅ all healthy)
|
||||||
| Last update | 2026-05-14 23:11 UTC |
|
|
||||||
| Status | All systems optimal |
|
|
||||||
| Next phase | PR submission or GitHub Enterprise support |
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
**Summary:** review-bot now supports both GitHub and Gitea PR reviews with a unified abstraction layer. All tests pass, code is clean, security is approved. Ready to move to PR submission or GitHub Enterprise support in the next cycle.
|
|
||||||
|
|||||||
@@ -157,6 +157,7 @@ func TestFit_PreservesNoteInOutput(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
func TestFit_HugeUserMeta(t *testing.T) {
|
func TestFit_HugeUserMeta(t *testing.T) {
|
||||||
// UserMeta so large that base alone exceeds limit
|
// UserMeta so large that base alone exceeds limit
|
||||||
// Use a unique marker past the truncation point
|
// Use a unique marker past the truncation point
|
||||||
|
|||||||
@@ -10,7 +10,6 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"gitea.weiker.me/rodin/review-bot/gitea"
|
"gitea.weiker.me/rodin/review-bot/gitea"
|
||||||
"gitea.weiker.me/rodin/review-bot/github"
|
|
||||||
"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"
|
||||||
)
|
)
|
||||||
@@ -160,85 +159,3 @@ func TestIntegration_PostAndCleanup(t *testing.T) {
|
|||||||
t.Logf("Warning: could not delete test review %d: %v", posted.ID, err)
|
t.Logf("Warning: could not delete test review %d: %v", posted.ID, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestIntegration_GitHub_PostAndVerifyReview exercises the full VCS routing path
|
|
||||||
// for GitHub when INTEGRATION_GITHUB_TOKEN and INTEGRATION_GITHUB_REPO are set.
|
|
||||||
// It verifies that the GitHub adapter is selected via VCS_TYPE=github and that
|
|
||||||
// PostReview succeeds against a real GitHub PR.
|
|
||||||
//
|
|
||||||
// Required environment variables:
|
|
||||||
//
|
|
||||||
// INTEGRATION_GITHUB_TOKEN - GitHub personal access token with repo access
|
|
||||||
// INTEGRATION_GITHUB_REPO - owner/repo with an open PR (e.g. Rodin-AI/review-bot)
|
|
||||||
// INTEGRATION_GITHUB_PR - PR number to test against
|
|
||||||
//
|
|
||||||
// The test skips gracefully when these variables are absent.
|
|
||||||
func TestIntegration_GitHub_PostAndVerifyReview(t *testing.T) {
|
|
||||||
githubToken := os.Getenv("INTEGRATION_GITHUB_TOKEN")
|
|
||||||
githubRepo := os.Getenv("INTEGRATION_GITHUB_REPO")
|
|
||||||
prNumStr := os.Getenv("INTEGRATION_GITHUB_PR")
|
|
||||||
|
|
||||||
if githubToken == "" || githubRepo == "" || prNumStr == "" {
|
|
||||||
t.Skip("INTEGRATION_GITHUB_TOKEN, INTEGRATION_GITHUB_REPO, and INTEGRATION_GITHUB_PR not set, skipping")
|
|
||||||
}
|
|
||||||
|
|
||||||
prNumber, err := strconv.Atoi(prNumStr)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("Invalid PR number %q: %v", prNumStr, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
parts := strings.SplitN(githubRepo, "/", 2)
|
|
||||||
if len(parts) != 2 || parts[0] == "" || parts[1] == "" {
|
|
||||||
t.Fatalf("Invalid repo format %q, expected owner/repo", githubRepo)
|
|
||||||
}
|
|
||||||
owner, repoName := parts[0], parts[1]
|
|
||||||
|
|
||||||
ctx := context.Background()
|
|
||||||
ghClient := github.NewClient(githubToken, "https://api.github.com")
|
|
||||||
|
|
||||||
// Verify adapter selection: GetAuthenticatedUser must succeed.
|
|
||||||
user, err := ghClient.GetAuthenticatedUser(ctx)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("GetAuthenticatedUser: %v — check INTEGRATION_GITHUB_TOKEN", err)
|
|
||||||
}
|
|
||||||
t.Logf("Authenticated as: %s", user)
|
|
||||||
|
|
||||||
// Verify PR is accessible via GitHub adapter.
|
|
||||||
pr, err := ghClient.GetPullRequest(ctx, owner, repoName, prNumber)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("GetPullRequest: %v", err)
|
|
||||||
}
|
|
||||||
t.Logf("PR: %s (sha: %s)", pr.Title, pr.Head.Sha)
|
|
||||||
|
|
||||||
// Post a COMMENT review — does not require PR approval permissions.
|
|
||||||
sentinel := "<!-- review-bot:integration-test -->"
|
|
||||||
testBody := "# Integration Test Review (GitHub)\n\nThis is an automated integration test.\n\n" + sentinel
|
|
||||||
posted, err := ghClient.PostReview(ctx, owner, repoName, prNumber, "COMMENT", testBody, "", nil)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("PostReview: %v", err)
|
|
||||||
}
|
|
||||||
t.Logf("Posted review ID: %d", posted.ID)
|
|
||||||
|
|
||||||
// Verify the review appears in ListReviews.
|
|
||||||
reviews, err := ghClient.ListReviews(ctx, owner, repoName, prNumber)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("ListReviews: %v", err)
|
|
||||||
}
|
|
||||||
found := false
|
|
||||||
for _, r := range reviews {
|
|
||||||
if r.ID == posted.ID && strings.Contains(r.Body, sentinel) {
|
|
||||||
found = true
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if !found {
|
|
||||||
t.Errorf("posted review ID %d not found in ListReviews output", posted.ID)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Attempt cleanup — GitHub does not allow deleting submitted reviews,
|
|
||||||
// so this is expected to fail with ErrCannotDeleteSubmittedReview (422).
|
|
||||||
// Log it as informational only.
|
|
||||||
if err := ghClient.DeleteReview(ctx, owner, repoName, prNumber, posted.ID); err != nil {
|
|
||||||
t.Logf("Note: DeleteReview returned (expected for submitted GitHub reviews): %v", err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -901,3 +901,5 @@ func shouldSkipStaleReview(evaluatedSHA, currentSHA string) bool {
|
|||||||
}
|
}
|
||||||
return evaluatedSHA != currentSHA
|
return evaluatedSHA != currentSHA
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
+2
-321
@@ -2,9 +2,7 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"context"
|
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"os"
|
"os"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
@@ -12,7 +10,6 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"gitea.weiker.me/rodin/review-bot/review"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestValidateReviewerName(t *testing.T) {
|
func TestValidateReviewerName(t *testing.T) {
|
||||||
@@ -633,48 +630,6 @@ func TestEvaluateCIStatus(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestGithubAPIURL(t *testing.T) {
|
|
||||||
tests := []struct {
|
|
||||||
name string
|
|
||||||
input string
|
|
||||||
want string
|
|
||||||
}{
|
|
||||||
{
|
|
||||||
name: "empty string defaults to api.github.com",
|
|
||||||
input: "",
|
|
||||||
want: "https://api.github.com",
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "github.com maps to api.github.com",
|
|
||||||
input: "https://github.com",
|
|
||||||
want: "https://api.github.com",
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "github.com with trailing slash maps to api.github.com",
|
|
||||||
input: "https://github.com/",
|
|
||||||
want: "https://api.github.com",
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "GHES host gets /api/v3 suffix",
|
|
||||||
input: "https://ghe.example.com",
|
|
||||||
want: "https://ghe.example.com/api/v3",
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "GHES concur domain does not map to api.github.com",
|
|
||||||
input: "https://github.concur.com",
|
|
||||||
want: "https://github.concur.com/api/v3",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
for _, tt := range tests {
|
|
||||||
t.Run(tt.name, func(t *testing.T) {
|
|
||||||
got := githubAPIURL(tt.input)
|
|
||||||
if got != tt.want {
|
|
||||||
t.Errorf("githubAPIURL(%q) = %q, want %q", tt.input, got, tt.want)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestEnvOrDefault(t *testing.T) {
|
func TestEnvOrDefault(t *testing.T) {
|
||||||
// Test with unset env var
|
// Test with unset env var
|
||||||
os.Unsetenv("TEST_ENV_OR_DEFAULT_UNSET")
|
os.Unsetenv("TEST_ENV_OR_DEFAULT_UNSET")
|
||||||
@@ -1015,7 +970,7 @@ func TestMainSubprocess_InvalidProvider(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// cleanEnv returns environ without any GITEA/LLM/REVIEWER/VCS env vars that would
|
// cleanEnv returns environ without any GITEA/LLM/REVIEWER env vars that would
|
||||||
// interfere with testing missing-flag scenarios.
|
// interfere with testing missing-flag scenarios.
|
||||||
func cleanEnv() []string {
|
func cleanEnv() []string {
|
||||||
var env []string
|
var env []string
|
||||||
@@ -1030,8 +985,7 @@ func cleanEnv() []string {
|
|||||||
strings.HasPrefix(key, "CONVENTIONS_"),
|
strings.HasPrefix(key, "CONVENTIONS_"),
|
||||||
strings.HasPrefix(key, "SYSTEM_PROMPT_"),
|
strings.HasPrefix(key, "SYSTEM_PROMPT_"),
|
||||||
strings.HasPrefix(key, "PATTERNS_"),
|
strings.HasPrefix(key, "PATTERNS_"),
|
||||||
strings.HasPrefix(key, "UPDATE_"),
|
strings.HasPrefix(key, "UPDATE_"):
|
||||||
strings.HasPrefix(key, "VCS_"):
|
|
||||||
continue
|
continue
|
||||||
default:
|
default:
|
||||||
env = append(env, e)
|
env = append(env, e)
|
||||||
@@ -1110,276 +1064,3 @@ func TestShouldSkipStaleReview(t *testing.T) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ============================================================
|
|
||||||
// Mock vcsClient for unit tests
|
|
||||||
// ============================================================
|
|
||||||
|
|
||||||
// mockVCSClient is a minimal mock of vcsClient for testing helper functions.
|
|
||||||
// Only the methods exercised by the test code need implementations; all others
|
|
||||||
// panic with a clear message to catch accidental calls.
|
|
||||||
type mockVCSClient struct {
|
|
||||||
fileContents map[string]string // key: "owner/repo/ref/path"
|
|
||||||
fileContentsErr map[string]error // key same as above → error to return
|
|
||||||
dirContents map[string][]review.ContentEntry
|
|
||||||
dirContentsErr map[string]error
|
|
||||||
allFiles map[string]map[string]string // key: "owner/repo/path"
|
|
||||||
allFilesErr map[string]error
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) key(owner, repo, extra string) string {
|
|
||||||
return owner + "/" + repo + "/" + extra
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetPullRequest(ctx context.Context, owner, repo string, number int) (*vcsPullRequest, error) {
|
|
||||||
panic("GetPullRequest not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetPullRequestDiff(ctx context.Context, owner, repo string, number int) (string, error) {
|
|
||||||
panic("GetPullRequestDiff not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetPullRequestFiles(ctx context.Context, owner, repo string, number int) ([]vcsChangedFile, error) {
|
|
||||||
panic("GetPullRequestFiles not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetCommitStatuses(ctx context.Context, owner, repo, sha string) ([]vcsCommitStatus, error) {
|
|
||||||
panic("GetCommitStatuses not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetFileContent(ctx context.Context, owner, repo, filepath string) (string, error) {
|
|
||||||
panic("GetFileContent not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetFileContentRef(ctx context.Context, owner, repo, path, ref string) (string, error) {
|
|
||||||
k := m.key(owner, repo, ref+"/"+path)
|
|
||||||
if err, ok := m.fileContentsErr[k]; ok {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
if content, ok := m.fileContents[k]; ok {
|
|
||||||
return content, nil
|
|
||||||
}
|
|
||||||
return "", fmt.Errorf("HTTP 404: not found")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) ListContents(ctx context.Context, owner, repo, path string) ([]review.ContentEntry, error) {
|
|
||||||
k := m.key(owner, repo, path)
|
|
||||||
if err, ok := m.dirContentsErr[k]; ok {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
if entries, ok := m.dirContents[k]; ok {
|
|
||||||
return entries, nil
|
|
||||||
}
|
|
||||||
return nil, fmt.Errorf("HTTP 404: not found")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetAllFilesInPath(ctx context.Context, owner, repo, path string) (map[string]string, error) {
|
|
||||||
k := m.key(owner, repo, path)
|
|
||||||
if err, ok := m.allFilesErr[k]; ok {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
if files, ok := m.allFiles[k]; ok {
|
|
||||||
return files, nil
|
|
||||||
}
|
|
||||||
return nil, fmt.Errorf("HTTP 404: not found")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) PostReview(ctx context.Context, owner, repo string, number int, event, body, commitID string, comments []vcsReviewComment) (*vcsReview, error) {
|
|
||||||
panic("PostReview not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) ListReviews(ctx context.Context, owner, repo string, number int) ([]vcsReview, error) {
|
|
||||||
panic("ListReviews not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) DeleteReview(ctx context.Context, owner, repo string, number int, reviewID int64) error {
|
|
||||||
panic("DeleteReview not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) GetAuthenticatedUser(ctx context.Context) (string, error) {
|
|
||||||
panic("GetAuthenticatedUser not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockVCSClient) RequestReviewer(ctx context.Context, owner, repo string, number int, reviewer string) error {
|
|
||||||
panic("RequestReviewer not implemented in mockVCSClient")
|
|
||||||
}
|
|
||||||
|
|
||||||
// ============================================================
|
|
||||||
// fetchFileContext tests
|
|
||||||
// ============================================================
|
|
||||||
|
|
||||||
func TestFetchFileContext_NoFiles(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{}
|
|
||||||
got := fetchFileContext(ctx, client, "owner", "repo", "main", nil)
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string for no files, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchFileContext_SkipsRemovedFiles(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{}
|
|
||||||
files := []vcsChangedFile{
|
|
||||||
{Filename: "gone.go", Status: "removed"},
|
|
||||||
}
|
|
||||||
got := fetchFileContext(ctx, client, "owner", "repo", "main", files)
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string for removed file, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchFileContext_FetchesModifiedFiles(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
fileContents: map[string]string{
|
|
||||||
"owner/repo/main/foo.go": "package main\n\nfunc main() {}\n",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
files := []vcsChangedFile{
|
|
||||||
{Filename: "foo.go", Status: "modified"},
|
|
||||||
}
|
|
||||||
got := fetchFileContext(ctx, client, "owner", "repo", "main", files)
|
|
||||||
if !strings.Contains(got, "--- foo.go ---") {
|
|
||||||
t.Errorf("expected file header in output, got: %q", got)
|
|
||||||
}
|
|
||||||
if !strings.Contains(got, "package main") {
|
|
||||||
t.Errorf("expected file content in output, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchFileContext_ContinuesOnError(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
fileContents: map[string]string{
|
|
||||||
"owner/repo/main/good.go": "package good\n",
|
|
||||||
},
|
|
||||||
fileContentsErr: map[string]error{
|
|
||||||
"owner/repo/main/bad.go": fmt.Errorf("network error"),
|
|
||||||
},
|
|
||||||
}
|
|
||||||
files := []vcsChangedFile{
|
|
||||||
{Filename: "bad.go", Status: "modified"},
|
|
||||||
{Filename: "good.go", Status: "modified"},
|
|
||||||
}
|
|
||||||
got := fetchFileContext(ctx, client, "owner", "repo", "main", files)
|
|
||||||
// bad.go fails, good.go should still be included
|
|
||||||
if strings.Contains(got, "bad.go") {
|
|
||||||
t.Errorf("should not include failed file, got: %q", got)
|
|
||||||
}
|
|
||||||
if !strings.Contains(got, "good.go") {
|
|
||||||
t.Errorf("should include successful file, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchFileContext_RespectsContextCancellation(t *testing.T) {
|
|
||||||
ctx, cancel := context.WithCancel(context.Background())
|
|
||||||
cancel() // Cancel immediately
|
|
||||||
|
|
||||||
client := &mockVCSClient{
|
|
||||||
fileContents: map[string]string{
|
|
||||||
"owner/repo/main/foo.go": "package foo\n",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
files := []vcsChangedFile{
|
|
||||||
{Filename: "foo.go", Status: "modified"},
|
|
||||||
}
|
|
||||||
got := fetchFileContext(ctx, client, "owner", "repo", "main", files)
|
|
||||||
// With cancelled context, the loop breaks before fetching
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string with cancelled context, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// ============================================================
|
|
||||||
// fetchPatterns tests
|
|
||||||
// ============================================================
|
|
||||||
|
|
||||||
func TestFetchPatterns_EmptyRepo(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{}
|
|
||||||
got := fetchPatterns(ctx, client, "", "")
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string for empty patternsRepo, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchPatterns_SingleRepoAllFiles(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
allFiles: map[string]map[string]string{
|
|
||||||
"rodin/patterns/": {
|
|
||||||
"patterns/go.md": "# Go patterns\n\nUse interfaces.",
|
|
||||||
"patterns/binary": "binary data",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
got := fetchPatterns(ctx, client, "rodin/patterns", "")
|
|
||||||
if !strings.Contains(got, "# Go patterns") {
|
|
||||||
t.Errorf("expected markdown content, got: %q", got)
|
|
||||||
}
|
|
||||||
// Binary file should be excluded
|
|
||||||
if strings.Contains(got, "binary data") {
|
|
||||||
t.Errorf("binary file should be excluded, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchPatterns_SpecificFiles(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
allFiles: map[string]map[string]string{
|
|
||||||
"rodin/patterns/go.md": {
|
|
||||||
"go.md": "# Go idioms\n",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
got := fetchPatterns(ctx, client, "rodin/patterns", "go.md")
|
|
||||||
if !strings.Contains(got, "# Go idioms") {
|
|
||||||
t.Errorf("expected go idioms content, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchPatterns_SkipsInvalidRepo(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{}
|
|
||||||
// "badrepo" has no slash, should be skipped
|
|
||||||
got := fetchPatterns(ctx, client, "badrepo", "")
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string for invalid repo format, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchPatterns_ContinuesOnFetchError(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
allFilesErr: map[string]error{
|
|
||||||
"owner/repo/": fmt.Errorf("server error"),
|
|
||||||
},
|
|
||||||
}
|
|
||||||
// Should not panic; should return empty string
|
|
||||||
got := fetchPatterns(ctx, client, "owner/repo", "")
|
|
||||||
if got != "" {
|
|
||||||
t.Errorf("expected empty string on fetch error, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestFetchPatterns_MultipleRepos(t *testing.T) {
|
|
||||||
ctx := context.Background()
|
|
||||||
client := &mockVCSClient{
|
|
||||||
allFiles: map[string]map[string]string{
|
|
||||||
"org/go-patterns/": {
|
|
||||||
"idioms.md": "# Go idioms\n",
|
|
||||||
},
|
|
||||||
"org/elixir-patterns/": {
|
|
||||||
"pipes.md": "# Elixir pipes\n",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
got := fetchPatterns(ctx, client, "org/go-patterns, org/elixir-patterns", "")
|
|
||||||
if !strings.Contains(got, "# Go idioms") {
|
|
||||||
t.Errorf("expected Go idioms content, got: %q", got)
|
|
||||||
}
|
|
||||||
if !strings.Contains(got, "# Elixir pipes") {
|
|
||||||
t.Errorf("expected Elixir pipes content, got: %q", got)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -971,7 +971,6 @@ func TestDoGet_RespectsContextCancellation(t *testing.T) {
|
|||||||
t.Errorf("attempts = %d, expected 1 before context cancel during backoff", attempts)
|
t.Errorf("attempts = %d, expected 1 before context cancel during backoff", attempts)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// mockTransport is a test helper that returns errors for the first N calls,
|
// mockTransport is a test helper that returns errors for the first N calls,
|
||||||
// then delegates to a real server.
|
// then delegates to a real server.
|
||||||
type mockTransport struct {
|
type mockTransport struct {
|
||||||
@@ -1420,80 +1419,3 @@ func TestNewSafeHTTPClient_PreservesDefaultTransportSettings(t *testing.T) {
|
|||||||
t.Error("DialContext is nil; expected safeDialContext")
|
t.Error("DialContext is nil; expected safeDialContext")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestGetTimelineReviewCommentIDForReview(t *testing.T) {
|
|
||||||
const reviewID = int64(42)
|
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case "/api/v1/repos/owner/repo/pulls/5/reviews/42":
|
|
||||||
w.Write([]byte(`{"body": "The review body <!-- review-bot:sonnet -->", "user": {"login": "sonnet-review"}}`))
|
|
||||||
case "/api/v1/repos/owner/repo/issues/5/timeline":
|
|
||||||
w.Write([]byte(`[
|
|
||||||
{"id": 100, "type": "comment", "body": "unrelated", "user": {"login": "sonnet-review"}},
|
|
||||||
{"id": 200, "type": "review", "body": "The review body <!-- review-bot:sonnet -->", "user": {"login": "sonnet-review"}}
|
|
||||||
]`))
|
|
||||||
default:
|
|
||||||
t.Errorf("unexpected path: %s", r.URL.Path)
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer server.Close()
|
|
||||||
|
|
||||||
client := NewTestClient(server.URL, "test-token")
|
|
||||||
id, err := client.GetTimelineReviewCommentIDForReview(context.Background(), "owner", "repo", 5, reviewID)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("GetTimelineReviewCommentIDForReview() error = %v", err)
|
|
||||||
}
|
|
||||||
if id != 200 {
|
|
||||||
t.Errorf("got id=%d, want 200", id)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetTimelineReviewCommentIDForReview_ReviewFetchError(t *testing.T) {
|
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
w.Write([]byte(`{"message":"not found"}`))
|
|
||||||
}))
|
|
||||||
defer server.Close()
|
|
||||||
|
|
||||||
client := NewTestClient(server.URL, "test-token")
|
|
||||||
_, err := client.GetTimelineReviewCommentIDForReview(context.Background(), "owner", "repo", 5, 99)
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error for missing review, got nil")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetTimelineReviewCommentIDForReview_EmptyBody(t *testing.T) {
|
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
w.Write([]byte(`{"body": "", "user": {"login": "bot"}}`))
|
|
||||||
}))
|
|
||||||
defer server.Close()
|
|
||||||
|
|
||||||
client := NewTestClient(server.URL, "test-token")
|
|
||||||
_, err := client.GetTimelineReviewCommentIDForReview(context.Background(), "owner", "repo", 5, 42)
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error for empty body, got nil")
|
|
||||||
}
|
|
||||||
if !strings.Contains(err.Error(), "empty body") {
|
|
||||||
t.Errorf("error = %q, want to contain 'empty body'", err.Error())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetTimelineReviewCommentIDForReview_NotFoundInTimeline(t *testing.T) {
|
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case "/api/v1/repos/owner/repo/pulls/5/reviews/42":
|
|
||||||
w.Write([]byte(`{"body": "review content <!-- review-bot:sonnet -->", "user": {"login": "bot"}}`))
|
|
||||||
default:
|
|
||||||
// Timeline returns events that don't match (different user)
|
|
||||||
w.Write([]byte(`[{"id": 1, "type": "review", "body": "review content <!-- review-bot:sonnet -->", "user": {"login": "other-user"}}]`))
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer server.Close()
|
|
||||||
|
|
||||||
client := NewTestClient(server.URL, "test-token")
|
|
||||||
_, err := client.GetTimelineReviewCommentIDForReview(context.Background(), "owner", "repo", 5, 42)
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error when review not found in timeline, got nil")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1130,98 +1130,3 @@ func TestEscapePath_SpecialChars(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestGetAllFilesInPath_DirectoryWithFiles(t *testing.T) {
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case "/repos/owner/repo/contents/patterns":
|
|
||||||
// Directory listing
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`[{"name":"go.md","path":"patterns/go.md","type":"file"}]`))
|
|
||||||
case "/repos/owner/repo/contents/patterns/go.md":
|
|
||||||
// GitHub file response with base64 content
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`{"name":"go.md","path":"patterns/go.md","type":"file","encoding":"base64","content":"IyBHbyBwYXR0ZXJucwo="}`))
|
|
||||||
default:
|
|
||||||
t.Errorf("unexpected path: %s", r.URL.Path)
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer srv.Close()
|
|
||||||
|
|
||||||
c := NewClient("tok", srv.URL, AllowInsecureHTTPForTest())
|
|
||||||
files, err := c.GetAllFilesInPath(context.Background(), "owner", "repo", "patterns")
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("unexpected error: %v", err)
|
|
||||||
}
|
|
||||||
if len(files) != 1 {
|
|
||||||
t.Fatalf("len(files) = %d, want 1", len(files))
|
|
||||||
}
|
|
||||||
if files["patterns/go.md"] != "# Go patterns\n" {
|
|
||||||
t.Errorf("unexpected content: %q", files["patterns/go.md"])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetAllFilesInPath_404FallsBackToFile(t *testing.T) {
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case "/repos/owner/repo/contents/README.md":
|
|
||||||
// ListContents returns 404 for file paths
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
w.Write([]byte(`{"message":"Not Found"}`))
|
|
||||||
default:
|
|
||||||
t.Errorf("unexpected path: %s", r.URL.Path)
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer srv.Close()
|
|
||||||
|
|
||||||
c := NewClient("tok", srv.URL, AllowInsecureHTTPForTest())
|
|
||||||
// GetFileContent also goes to /contents/ — this will 404 too.
|
|
||||||
// The function should return the path-not-found error.
|
|
||||||
_, err := c.GetAllFilesInPath(context.Background(), "owner", "repo", "README.md")
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error when both dir and file 404, got nil")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetAllFilesInPath_DirectoryWithSubdir(t *testing.T) {
|
|
||||||
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
switch r.URL.Path {
|
|
||||||
case "/repos/owner/repo/contents/src":
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`[
|
|
||||||
{"name":"main.go","path":"src/main.go","type":"file"},
|
|
||||||
{"name":"sub","path":"src/sub","type":"dir"}
|
|
||||||
]`))
|
|
||||||
case "/repos/owner/repo/contents/src/main.go":
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`{"name":"main.go","path":"src/main.go","type":"file","encoding":"base64","content":"cGFja2FnZSBtYWluCg=="}`))
|
|
||||||
case "/repos/owner/repo/contents/src/sub":
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`[{"name":"util.go","path":"src/sub/util.go","type":"file"}]`))
|
|
||||||
case "/repos/owner/repo/contents/src/sub/util.go":
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
w.Write([]byte(`{"name":"util.go","path":"src/sub/util.go","type":"file","encoding":"base64","content":"cGFja2FnZSBzdWIK"}`))
|
|
||||||
default:
|
|
||||||
t.Errorf("unexpected path: %s", r.URL.Path)
|
|
||||||
w.WriteHeader(http.StatusNotFound)
|
|
||||||
}
|
|
||||||
}))
|
|
||||||
defer srv.Close()
|
|
||||||
|
|
||||||
c := NewClient("tok", srv.URL, AllowInsecureHTTPForTest())
|
|
||||||
files, err := c.GetAllFilesInPath(context.Background(), "owner", "repo", "src")
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("unexpected error: %v", err)
|
|
||||||
}
|
|
||||||
if len(files) != 2 {
|
|
||||||
t.Fatalf("len(files) = %d, want 2: %v", len(files), files)
|
|
||||||
}
|
|
||||||
if files["src/main.go"] != "package main\n" {
|
|
||||||
t.Errorf("src/main.go content unexpected: %q", files["src/main.go"])
|
|
||||||
}
|
|
||||||
if files["src/sub/util.go"] != "package sub\n" {
|
|
||||||
t.Errorf("src/sub/util.go content unexpected: %q", files["src/sub/util.go"])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -210,6 +210,7 @@ func TestWithTimeout(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
func TestComplete_Anthropic_Success(t *testing.T) {
|
func TestComplete_Anthropic_Success(t *testing.T) {
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
if r.URL.Path != "/messages" {
|
if r.URL.Path != "/messages" {
|
||||||
|
|||||||
@@ -957,51 +957,3 @@ func TestYAMLMergeKeyDepthCheck(t *testing.T) {
|
|||||||
t.Errorf("error = %q, want to contain 'depth'", err.Error())
|
t.Errorf("error = %q, want to contain 'depth'", err.Error())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestLoadPersona_NonexistentFile(t *testing.T) {
|
|
||||||
_, err := LoadPersona("/tmp/nonexistent-persona-file-xyz.yaml")
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error for nonexistent file, got nil")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoadPersona_NotARegularFile(t *testing.T) {
|
|
||||||
// Use a directory as the path — directories are not regular files.
|
|
||||||
dir := t.TempDir()
|
|
||||||
_, err := LoadPersona(dir)
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error for directory path, got nil")
|
|
||||||
}
|
|
||||||
if !strings.Contains(err.Error(), "not a regular file") {
|
|
||||||
t.Errorf("error = %q, want to contain 'not a regular file'", err.Error())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoadPersona_OversizedFile(t *testing.T) {
|
|
||||||
dir := t.TempDir()
|
|
||||||
path := filepath.Join(dir, "big.yaml")
|
|
||||||
// Write a file larger than MaxPersonaFileSize
|
|
||||||
data := make([]byte, MaxPersonaFileSize+1)
|
|
||||||
for i := range data {
|
|
||||||
data[i] = 'x'
|
|
||||||
}
|
|
||||||
if err := os.WriteFile(path, data, 0644); err != nil {
|
|
||||||
t.Fatalf("failed to create test file: %v", err)
|
|
||||||
}
|
|
||||||
_, err := LoadPersona(path)
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("expected error for oversized file, got nil")
|
|
||||||
}
|
|
||||||
if !strings.Contains(err.Error(), "exceeds maximum size") {
|
|
||||||
t.Errorf("error = %q, want to contain 'exceeds maximum size'", err.Error())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestCapitalizeFirst_RuneError(t *testing.T) {
|
|
||||||
// An invalid UTF-8 byte sequence should return the original string unchanged.
|
|
||||||
invalid := string([]byte{0xFF, 0xFE})
|
|
||||||
got := CapitalizeFirst(invalid)
|
|
||||||
if got != invalid {
|
|
||||||
t.Errorf("CapitalizeFirst(%q) = %q, want original %q", invalid, got, invalid)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -117,6 +117,7 @@ func TestBuildUserPrompt_WithoutFileContext(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
func TestBuildSystemBase(t *testing.T) {
|
func TestBuildSystemBase(t *testing.T) {
|
||||||
result := BuildSystemBase()
|
result := BuildSystemBase()
|
||||||
if result == "" {
|
if result == "" {
|
||||||
|
|||||||
Reference in New Issue
Block a user