Compare commits
3
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d89caf4af2 | ||
|
|
d45a8243c8 | ||
|
|
d0334434c5 |
@@ -136,7 +136,11 @@ func (s *Scanner) Members(hasWork bool) ([]string, error) {
|
|||||||
return out, nil
|
return out, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// iterOrgRepos 產出 (org, repoName);空倉庫跳過(沒有內容可掃)。
|
// iterOrgRepos 產出 (org, repoName)。空倉庫(empty)**不**跳過:Gitea 允許
|
||||||
|
// 空倉庫持有 open issue(如「初始化項目」型工作),gitea.py 的
|
||||||
|
// for_all_repositories(list_my_followup_issues/for_all_organizations)
|
||||||
|
// 掃 issue 時不檢查 empty;只有 PR 掃描(iterOpenPulls)、stalled 與
|
||||||
|
// milestone overview 才跳過空倉庫。
|
||||||
func (s *Scanner) iterOrgRepos() ([][2]string, error) {
|
func (s *Scanner) iterOrgRepos() ([][2]string, error) {
|
||||||
orgs, err := s.Orgs()
|
orgs, err := s.Orgs()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -149,7 +153,7 @@ func (s *Scanner) iterOrgRepos() ([][2]string, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
for _, repo := range repos {
|
for _, repo := range repos {
|
||||||
if repo.Name == "" || repo.Empty {
|
if repo.Name == "" {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
out = append(out, [2]string{org, repo.Name})
|
out = append(out, [2]string{org, repo.Name})
|
||||||
|
|||||||
@@ -164,6 +164,51 @@ func TestNextLayerFallbackToIssue(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TestNextPicksIssueInEmptyRepo 回歸測試(#43):空倉庫(empty=true)中
|
||||||
|
// 分派給目前帳號的 open issue 應被第三層拾取——gitea.py 的
|
||||||
|
// for_all_repositories 掃 issue 不跳過空倉庫(「初始化項目」型工作)。
|
||||||
|
func TestNextPicksIssueInEmptyRepo(t *testing.T) {
|
||||||
|
s, fc := newTestScanner()
|
||||||
|
fc.repos["alterminal"] = []Repo{
|
||||||
|
{Name: "teai"},
|
||||||
|
{Name: "colony-tick-demo", Empty: true},
|
||||||
|
}
|
||||||
|
fc.issues["alterminal/colony-tick-demo"] = []Issue{
|
||||||
|
{
|
||||||
|
Number: 1, Title: "初始化項目", UpdatedAt: "2026-09-08T00:00:00Z",
|
||||||
|
Assignees: []User{*mkUser("alex")},
|
||||||
|
Repository: &Repository{FullName: "alterminal/colony-tick-demo"},
|
||||||
|
HTMLURL: "https://gitea.alterminal.com/alterminal/colony-tick-demo/issues/1",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
work, err := s.Next()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if work == nil || work.Type != "issue" || work.Number != 1 || work.Repo != "alterminal/colony-tick-demo" {
|
||||||
|
t.Errorf("應拾取空倉庫中的 issue #1,得到 %+v", work)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// TestMineIncludesEmptyRepoIssues 回歸測試(#43):mine 同樣不因倉庫為空而漏列。
|
||||||
|
func TestMineIncludesEmptyRepoIssues(t *testing.T) {
|
||||||
|
s, fc := newTestScanner()
|
||||||
|
fc.repos["alterminal"] = []Repo{
|
||||||
|
{Name: "teai"},
|
||||||
|
{Name: "colony-tick-demo", Empty: true},
|
||||||
|
}
|
||||||
|
fc.issues["alterminal/colony-tick-demo"] = []Issue{
|
||||||
|
{Number: 1, Title: "初始化項目", UpdatedAt: "2026-09-08T00:00:00Z", Assignees: []User{*mkUser("alex")}},
|
||||||
|
}
|
||||||
|
issues, err := s.Mine()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if len(issues) != 1 || issues[0].Num() != 1 {
|
||||||
|
t.Errorf("mine 應列出空倉庫中的 issue #1,得到 %d 件", len(issues))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestNextNone(t *testing.T) {
|
func TestNextNone(t *testing.T) {
|
||||||
s, _ := newTestScanner()
|
s, _ := newTestScanner()
|
||||||
work, err := s.Next()
|
work, err := s.Next()
|
||||||
|
|||||||
@@ -530,7 +530,11 @@ func considerIssue(src Source, org, repo string, issue Issue, comments []Comment
|
|||||||
case lastCommentBy == "":
|
case lastCommentBy == "":
|
||||||
reason = "no-commenter"
|
reason = "no-commenter"
|
||||||
}
|
}
|
||||||
if len(children) > 0 && anyOpen(children) {
|
if len(children) > 0 {
|
||||||
|
// 父追蹤項一律標 parent-tracking(agents #44,與 gitea.py 同步):
|
||||||
|
// 有 open 子項在推進時,父項留言閒置屬等待子項;子項全關閉時只剩
|
||||||
|
// 父項收尾(回報驗收並關閉),兩者都不是 assignee 停滯。統一標記
|
||||||
|
// 讓「父項收尾」規則能正確匹配,不退回通用原因(如 assignee-idle)。
|
||||||
reason = "parent-tracking"
|
reason = "parent-tracking"
|
||||||
}
|
}
|
||||||
item := Item{
|
item := Item{
|
||||||
@@ -606,15 +610,6 @@ func considerPull(src Source, org, repo string, pr PullRequest, comments []Comme
|
|||||||
return item, true
|
return item, true
|
||||||
}
|
}
|
||||||
|
|
||||||
func anyOpen(children []Child) bool {
|
|
||||||
for _, c := range children {
|
|
||||||
if c.State == "open" {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
// round1 舍入到小數一位(對應 Python round(x, 1))。
|
// round1 舍入到小數一位(對應 Python round(x, 1))。
|
||||||
// 經 strconv 的十進位正確舍入(半偶數),與 Python 的浮點 round 行為一致,
|
// 經 strconv 的十進位正確舍入(半偶數),與 Python 的浮點 round 行為一致,
|
||||||
// 避免 (x*10+0.5) 截斷在 .x5 邊界產生偏差。
|
// 避免 (x*10+0.5) 截斷在 .x5 邊界產生偏差。
|
||||||
|
|||||||
@@ -42,6 +42,9 @@ func (f *fakeSource) OrganizationRepositories(org string) ([]Repo, error) {
|
|||||||
func (f *fakeSource) OpenIssues(owner, repo string) ([]Issue, error) {
|
func (f *fakeSource) OpenIssues(owner, repo string) ([]Issue, error) {
|
||||||
var out []Issue
|
var out []Issue
|
||||||
for _, i := range f.issues[owner+"/"+repo] {
|
for _, i := range f.issues[owner+"/"+repo] {
|
||||||
|
if i.State == "closed" {
|
||||||
|
continue // 對齊真實 API:OpenIssues 只回 open;closed 條目僅供 TryGetIssue 解引用。
|
||||||
|
}
|
||||||
out = append(out, i)
|
out = append(out, i)
|
||||||
}
|
}
|
||||||
// 對齊真實 API:issues 依 id(=number)遞增回傳,消除 map 迭代隨機性。
|
// 對齊真實 API:issues 依 id(=number)遞增回傳,消除 map 迭代隨機性。
|
||||||
@@ -245,6 +248,46 @@ func TestScanStalledNudgeCooldown(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TestScanStalledParentWrapup(teai #47,同步 agents #44):子項全關閉的父追蹤項
|
||||||
|
// 不退回通用原因(assignee-idle),一律標 parent-tracking——「父項收尾」情境。
|
||||||
|
func TestScanStalledParentWrapup(t *testing.T) {
|
||||||
|
now := at(0)
|
||||||
|
// 父項 3 最後留言來自 assignee ceo(舊行為會誤標 assignee-idle);
|
||||||
|
// 唯一子項 7 已關閉,父子最後活動皆 5 小時前。
|
||||||
|
src := &fakeSource{
|
||||||
|
orgs: []string{"alterminal"},
|
||||||
|
repos: map[string][]Repo{"alterminal": repoWith("teai", true)},
|
||||||
|
issues: map[string]map[int64]Issue{
|
||||||
|
"alterminal/teai": {
|
||||||
|
3: {Number: 3, Title: "父", State: "open", Body: "子項:#7", CreatedAt: iso(-700), UpdatedAt: iso(-300), Assignees: []User{{UserName: "ceo"}}, Repository: &Repository{FullName: "alterminal/teai"}},
|
||||||
|
7: {Number: 7, Title: "子", State: "closed", CreatedAt: iso(-650), UpdatedAt: iso(-300), Repository: &Repository{FullName: "alterminal/teai"}},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
comments: map[string][]Comment{
|
||||||
|
"alterminal/teai/3": {{User: &User{UserName: "ceo"}, CreatedAt: iso(-300)}},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
got, err := ScanStalled(src, "admin", 4.0, now)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("ScanStalled: %v", err)
|
||||||
|
}
|
||||||
|
var parent *Item
|
||||||
|
for i := range got {
|
||||||
|
if got[i].Number == 3 {
|
||||||
|
parent = &got[i]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if parent == nil {
|
||||||
|
t.Fatalf("父項 3 應列入(5h 無活動),got %v", got)
|
||||||
|
}
|
||||||
|
if parent.Reason != "parent-tracking" {
|
||||||
|
t.Errorf("子項全關閉的父項 reason = %q, want parent-tracking", parent.Reason)
|
||||||
|
}
|
||||||
|
if len(parent.ChildActivity) == 0 {
|
||||||
|
t.Errorf("父項 3 應附 child_activity,got %v", parent.ChildActivity)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// TestScanStalledParentTracking 父追蹤項:子項活動計入 last_activity、reason 標記。
|
// TestScanStalledParentTracking 父追蹤項:子項活動計入 last_activity、reason 標記。
|
||||||
func TestScanStalledParentTracking(t *testing.T) {
|
func TestScanStalledParentTracking(t *testing.T) {
|
||||||
now := at(0)
|
now := at(0)
|
||||||
|
|||||||
Reference in New Issue
Block a user