weichen/Agent-System
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

merge: candidate gate-e1a fixture fixes into local_dev

Browse Source
This commit is contained in:
weichen
2026-09-24 00:49:43 +00:00
parent f8ad688359 c51fb5e22f
commit c4008bf8f3
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.doc/ops/CURRENT.md
+1
View File
@@ -18,6 +18,7 @@
| owner | task | branch | worktree | mutex | status |
|---|---|---|---|---|---|
| Cursor | gate-e1a-unique-project-name-2026-09-24 | fix/gate-e1a-unique-project-name-2026-09-24 | .worktrees/gate-e1a-unique-project-name-2026-09-24 | docnotify | in_progress |
| Cursor | gate-unhook-docquery-2026-09-24 | fix/gate-unhook-docquery-2026-09-24 | .worktrees/gate-unhook-docquery-2026-09-24 | server+docquery | in_progress |
| Cursor | integrate-jev-assist-land-2026-09-24 | feature/integrate-jev-assist-land-2026-09-24 | .worktrees/integrate-jev-assist-land-2026-09-24 | git:dev | done |
| Cursor | integrate-codegraph-fixup2-2026-09-24 | feature/integrate-codegraph-fixup2-2026-09-24 | (removed) | git:dev | done |
internal/app/docnotify/e1a_pg_test.go
+6 -3
View File
@@ -142,7 +142,10 @@ func TestE1A_NotifyFixtureThirtyAuthzAndRollbackTx_PG(t *testing.T) {
for i := 0; i < nFix; i++ {
docID := fmt.Sprintf("e1a30_%s_%d", suffix, i)
seedDoc(t, ctx, pool, docID, projectID, userID)
env := approvedEnv(fmt.Sprintf("%s-%d", suffix, i), docID, projectID, int64(i+1))
// Each doc is its own aggregate; version must start at 1 (or 0) so the
// consumer checkpoint gap rule does not block siblings (version i+1
// would only be claimable after head reaches i on the SAME aggregate).
env := approvedEnv(fmt.Sprintf("%s-%d", suffix, i), docID, projectID, 1)
appendEnv(t, ctx, pool, env, []string{events.ConsumerNotify})
ids = append(ids, env.EventID)
}
@@ -222,7 +225,7 @@ func TestE1A_NotifyFixtureThirtyAuthzAndRollbackTx_PG(t *testing.T) {
}
// same-tx rollback: handle+ack then rollback leaves no extra row
missingDoc := approvedEnv("missing-"+suffix, "no-such-doc-"+suffix, projectID, 99)
missingDoc := approvedEnv("missing-"+suffix, "no-such-doc-"+suffix, projectID, 1)
appendEnv(t, ctx, pool, missingDoc, []string{events.ConsumerNotify})
if _, err := d.RunOnce(ctx, events.ConsumerNotify); err != nil {
t.Fatal(err)
@@ -302,7 +305,7 @@ func seedUserProject(t *testing.T, ctx context.Context, pool *pgxpool.Pool, suff
if err := pool.QueryRow(ctx, `INSERT INTO users (account_id, name, role) VALUES ($1,'A','engineer') RETURNING id`, "e1a-"+suffix).Scan(&userID); err != nil {
t.Fatal(err)
}
if err := pool.QueryRow(ctx, `INSERT INTO projects (code, name, status) VALUES ($1,$2,'active') RETURNING id`, "e1a-"+suffix, "e1a").Scan(&projectID); err != nil {
if err := pool.QueryRow(ctx, `INSERT INTO projects (code, name, status) VALUES ($1,$2,'active') RETURNING id`, "e1a-"+suffix, "e1a-"+suffix).Scan(&projectID); err != nil {
t.Fatal(err)
}
return userID, projectID