Skip to content

feat(harness): redesign r2 event interactions #71

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Grivn merged 7 commits into from
Jun 28, 2026
Merged

feat(harness): redesign r2 event interactions #71

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
d651608
feat(harness): introduce r2 event payload sections
Grivn Jun 27, 2026
b84cef9
feat(harness): migrate event packages to r2 sections
Grivn Jun 27, 2026
e87c7e1
feat(harness): expose r2 derived presentation events
Grivn Jun 27, 2026
38a03fc
feat(harness): add r2 short event commands
Grivn Jun 27, 2026
3d8686a
test(harness): migrate e2e flows to r2 payloads
Grivn Jun 27, 2026
5f1f1b2
test(harness): audit r2 payload shape in acceptance
Grivn Jun 27, 2026
2f8b163
fix(harness): back off github sync rate limits
Grivn Jun 27, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
44 changes: 33 additions & 11 deletions harness/cmd/mnemon-harness/acceptance.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ import (
"github.com/mnemon-dev/mnemon/harness/internal/app"
"github.com/mnemon-dev/mnemon/harness/internal/codexapp"
"github.com/mnemon-dev/mnemon/harness/internal/contract"
eventmodel "github.com/mnemon-dev/mnemon/harness/internal/event"
"github.com/mnemon-dev/mnemon/harness/internal/mnemond/access"
"github.com/mnemon-dev/mnemon/harness/internal/mnemond/presentation"
"github.com/mnemon-dev/mnemon/harness/internal/mnemond/state"
Expand Down Expand Up @@ -356,6 +357,13 @@ func runR1CodexAcceptance(ctx context.Context, opts r1CodexAcceptanceOptions) (r
addR1Assertion(&report, "A11 no assignment_status/assignment_expired", report.LedgerCounts["assignment_status"] == 0 && report.LedgerCounts["assignment_expired"] == 0, fmt.Sprintf("assignment_status=%d assignment_expired=%d", report.LedgerCounts["assignment_status"], report.LedgerCounts["assignment_expired"]))
addR1Assertion(&report, "A12 derived event render audit has provenance", report.DerivedEventAudit["with_provenance"] > 0 && report.DerivedEventAudit["with_body_digest"] > 0 && report.DerivedEventAudit["with_audit_id"] > 0, fmt.Sprintf("%+v", report.DerivedEventAudit))
addR1Assertion(&report, "A13 activation loop writes no governed event by itself", true, "runner wakes appservers with turns; governed events are emitted by appserver shell commands through control observe")
if obs, err := observeAcceptanceRun(runRoot, 1000); err == nil {
report.Observability = &obs
ok, detail := acceptedR2PayloadShapeAssertion(obs)
addR1Assertion(&report, "A14 accepted event payloads are R2 nested", ok, detail)
} else {
addR1Assertion(&report, "A14 accepted event payloads are R2 nested", false, err.Error())
}
if opts.SyncArm {
for i := range agents {
agents[i].server.Close()
Expand Down Expand Up @@ -773,8 +781,8 @@ func runR1CodexLocalScenario(ctx context.Context, opts r1CodexAcceptanceOptions,
runID := strings.ToLower(time.Now().UTC().Format("150405"))
for i := range agents {
prompt := fmt.Sprintf(`Follow the managed Mnemon GUIDE for %s.
Run a shell command that emits one agent_profile.write_candidate.observed event with external id profile-%02d-%s and payload fields:
actor=%q, focus="R1 real Codex cluster acceptance", context_advantages=["real Codex appserver %02d","workspace-local Mnemon hooks"], availability="available", ttl="30m", summary="Agent %02d is available for the R1 teamwork acceptance run".
Run a shell command that emits one agent_profile.write_candidate.observed event with external id profile-%02d-%s and payload:
{"rule":{"actor":%q,"availability":"available","ttl":"30m"},"narrative":{"focus":"R1 real Codex cluster acceptance","context_advantages":["real Codex appserver %02d","workspace-local Mnemon hooks"],"summary":"Agent %02d is available for the R1 teamwork acceptance run"}}
After the command succeeds, answer "profile done".`, agents[i].principal, i+1, runID, agents[i].principal, i+1, i+1)
answer, err := runR1Turn(&agents[i], prompt, opts.TurnTimeout)
appendAgentAnswer(report, agents[i].principal, answer)
Expand All @@ -800,8 +808,9 @@ Read current governed teamwork context with:
. .mnemon/harness/local/env.sh
mnemon-harness control render --addr "$MNEMON_CONTROL_ADDR" --principal "$MNEMON_CONTROL_PRINCIPAL" --token-file "$MNEMON_CONTROL_TOKEN_FILE" --intent teamwork.events --lifecycle remind --surface agent
Then emit a teamwork_signal.write_candidate.observed event with external id signal-%s and payload:
{"signal_id":%q,"scope":"r1/real-codex-cluster/local","statement":"Need another real Codex appserver to complete an R1 acceptance work item.","why_teamwork":"five fresh agent profiles are available; delegation verifies the R1 teamwork event loop","ttl":"30m","evidence":"real-codex-cluster acceptance"}
Then choose one teammate other than yourself and emit assignment.write_candidate.observed with external id assignment-%s, assignment_id %q, signal_ref %q, assignee set to that teammate principal, scope "r1/real-codex-cluster/local", expected_work "Inspect the R1 teamwork event loop and report whether the real appserver can act on the assignment.", expected_feedback "progress_digest with assignment_ref and evidence", ttl "20m", evidence "signal %s".
{"rule":{"signal_id":%q,"scope":"r1/real-codex-cluster/local","ttl":"30m"},"narrative":{"statement":"Need another real Codex appserver to complete an R1 acceptance work item.","why_teamwork":"five fresh agent profiles are available; delegation verifies the R1 teamwork event loop"},"refs":{"evidence_refs":["real-codex-cluster acceptance"]}}
Then choose one teammate other than yourself and emit assignment.write_candidate.observed with external id assignment-%s and payload:
{"rule":{"assignment_id":%q,"signal_ref":%q,"assignee":"<chosen teammate principal>","scope":"r1/real-codex-cluster/local","ttl":"20m"},"narrative":{"expected_work":"Inspect the R1 teamwork event loop and report whether the real appserver can act on the assignment.","expected_feedback":"progress_digest with assignment_ref and evidence"},"refs":{"evidence_refs":["signal %s"]}}
After both commands succeed, answer with the assignee principal only.`, runID, signalID, runID, assignID, signalID, signalID)
answer, err := runR1Turn(&starter, prompt, opts.TurnTimeout)
appendAgentAnswer(report, starter.principal, answer)
Expand Down Expand Up @@ -831,7 +840,7 @@ After both commands succeed, answer with the assignee principal only.`, runID, s
addR1Assertion(report, "A7 assignee gets work derived event by scoped render", strings.Contains(workPresentation.Body, "[mnemon:work]") && strings.Contains(workPresentation.Body, assignID), workPresentation.Body)

prompt = fmt.Sprintf(`Read your governed work context, do the assigned inspection in this workspace, then emit progress_digest.write_candidate.observed with external id progress-%s and payload:
{"assignment_ref":%q,"scope":"r1/real-codex-cluster/local","summary":"Real Codex appserver acted on the R1 assignment and confirmed the rendered work event was usable.","evidence":"rendered work event plus real appserver turn","changed_context":"assignee completed the delegated acceptance work","suggested_next":"starter should integrate the result"}
{"rule":{"assignment_ref":%q,"scope":"r1/real-codex-cluster/local","feedback_kind":"progress"},"narrative":{"summary":"Real Codex appserver acted on the R1 assignment and confirmed the rendered work event was usable.","changed_context":["assignee completed the delegated acceptance work"],"suggested_next":"starter should integrate the result"},"refs":{"evidence_refs":["rendered work event plus real appserver turn"]}}
After the command succeeds, answer "progress_digest done".`, runID, assignID)
answer, err = runR1Turn(&assigneeAgent, prompt, opts.TurnTimeout)
appendAgentAnswer(report, assigneeAgent.principal, answer)
Expand All @@ -853,7 +862,7 @@ After the command succeeds, answer "progress_digest done".`, runID, assignID)
expAssignee := agents[(starterIndex+1)%len(agents)].principal
prompt = fmt.Sprintf(`Emit one assignment.write_candidate.observed event that intentionally expires quickly.
Use external id assignment-expired-%s and payload:
{"assignment_id":%q,"assignee":%q,"scope":"r1/real-codex-cluster/ttl-expired","expected_work":"This assignment is intentionally left without progress to verify the render-derived expired event.","expected_feedback":"progress_digest if completed","ttl":"1s","evidence":"TTL branch acceptance"}
{"rule":{"assignment_id":%q,"assignee":%q,"scope":"r1/real-codex-cluster/ttl-expired","ttl":"1s"},"narrative":{"expected_work":"This assignment is intentionally left without progress to verify the render-derived expired event.","expected_feedback":"progress_digest if completed"},"refs":{"evidence_refs":["TTL branch acceptance"]}}
Do not emit progress_digest for this assignment. Answer "expired assignment written".`, runID, expID, expAssignee)
answer, err = runR1Turn(&starter, prompt, opts.TurnTimeout)
appendAgentAnswer(report, starter.principal, answer)
Expand Down Expand Up @@ -942,7 +951,7 @@ func runR1CodexSyncScenario(ctx context.Context, opts r1CodexAcceptanceOptions,

sourcePrompt := fmt.Sprintf(`This is the 6B Remote Workspace sync acceptance source turn.
Emit exactly one assignment.write_candidate.observed event into your Local Mnemon workspace using external id sync-assignment-%s and payload:
{"assignment_id":%q,"assignee":%q,"scope":"r1/real-codex-cluster/sync","expected_work":"Verify that a real Codex appserver received this assignment through Remote Workspace sync/import and can act from a local derived-event presentation.","expected_feedback":"progress_digest with assignment_ref and evidence","ttl":"20m","evidence":"6B accepted event sync/import"}
{"rule":{"assignment_id":%q,"assignee":%q,"scope":"r1/real-codex-cluster/sync","ttl":"20m"},"narrative":{"expected_work":"Verify that a real Codex appserver received this assignment through Remote Workspace sync/import and can act from a local derived-event presentation.","expected_feedback":"progress_digest with assignment_ref and evidence"},"refs":{"evidence_refs":["6B accepted event sync/import"]}}
Use the control observe command pattern from your developer instructions. Do not message the assignee directly. After the command succeeds, answer "sync assignment written".`, runID, assignmentID, target.principal)
answer, err := runR1Turn(&source.r1CodexAgent, sourcePrompt, opts.TurnTimeout)
appendSyncAgentAnswer(syncReport, source.principal, answer)
Expand All @@ -964,7 +973,7 @@ Use the control observe command pattern from your developer instructions. Do not

targetPrompt := fmt.Sprintf(`This is the 6B Remote Workspace sync acceptance target turn.
Read your current governed Mnemon context, then emit progress_digest.write_candidate.observed with external id sync-progress-%s and payload:
{"assignment_ref":%q,"scope":"r1/real-codex-cluster/sync","summary":"Target real Codex appserver received the assignment through Local Mnemon sync/import and acted from its own derived-event presentation.","evidence":"target local render work derived event after hub sync","changed_context":"6B target completed synced work","suggested_next":"source should integrate the synced progress"}
{"rule":{"assignment_ref":%q,"scope":"r1/real-codex-cluster/sync","feedback_kind":"progress"},"narrative":{"summary":"Target real Codex appserver received the assignment through Local Mnemon sync/import and acted from its own derived-event presentation.","changed_context":["6B target completed synced work"],"suggested_next":"source should integrate the synced progress"},"refs":{"evidence_refs":["target local render work derived event after hub sync"]}}
After the command succeeds, answer "sync progress written".`, runID, assignmentID)
answer, err = runR1Turn(&target.r1CodexAgent, targetPrompt, opts.TurnTimeout)
appendSyncAgentAnswer(syncReport, target.principal, answer)
Expand Down Expand Up @@ -1315,9 +1324,22 @@ func findAssignmentAssignee(controlURL string, agent r1CodexAgent, assignmentID
items, _ := content.Fields["items"].([]any)
for _, raw := range items {
item, _ := raw.(map[string]any)
if id, _ := item["assignment_id"].(string); id == assignmentID {
assignee, _ := item["assignee"].(string)
return assignee
if acceptanceItemString(item, "assignment_id") == assignmentID {
return acceptanceItemString(item, "assignee")
}
}
}
return ""
}

func acceptanceItemString(item map[string]any, key string) string {
if s, ok := item[key].(string); ok {
return s
}
for _, section := range []string{eventmodel.PayloadRuleKey, eventmodel.PayloadNarrativeKey, eventmodel.PayloadRefsKey} {
if m, ok := item[section].(map[string]any); ok {
if s, ok := m[key].(string); ok {
return s
}
}
}
Expand Down
3 changes: 3 additions & 0 deletions harness/cmd/mnemon-harness/acceptance_cluster_single_entrypoint.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -403,8 +403,11 @@ func runR1ClusterSingleEntrypointAcceptance(ctx context.Context, opts r1ClusterS
addR1ClusterAuditAssertions(&report, syncReport, actorCounts, finalAnswer, opts.WakeCycles)
if report.Observability != nil {
addR1Assertion(&report, "cluster observability sees strict topology", report.Observability.Topology.Mode == "per-hostagent-mnemond" && !report.Observability.Topology.SharedMnemond, fmt.Sprintf("mode=%s shared=%t mnemond=%d hub=%d", report.Observability.Topology.Mode, report.Observability.Topology.SharedMnemond, report.Observability.Topology.MnemondStores, report.Observability.Topology.MnemonhubStores))
ok, detail := acceptedR2PayloadShapeAssertion(*report.Observability)
addR1Assertion(&report, "cluster accepted event payloads are R2 nested", ok, detail)
} else {
addR1Assertion(&report, "cluster observability sees strict topology", false, "observe report unavailable")
addR1Assertion(&report, "cluster accepted event payloads are R2 nested", false, "observe report unavailable")
}

scenarioOK := len(report.Errors) == 0 && allR1AssertionsPassed(report.Assertions)
Expand Down
35 changes: 23 additions & 12 deletions harness/cmd/mnemon-harness/acceptance_github_mesh.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -278,8 +278,11 @@ func runR1GitHubMeshAcceptance(ctx context.Context, opts r1GitHubMeshAcceptanceO
report.Observability.Warnings = append(report.Observability.Warnings, warnings...)
}
report.Participants = r1ClusterParticipants(counts, report.Entrypoint)
ok, detail := acceptedR2PayloadShapeAssertion(obs)
addR1Assertion(&report, "github-mesh accepted event payloads are R2 nested", ok, detail)
} else {
addR1Error(&report, obsErr)
addR1Assertion(&report, "github-mesh accepted event payloads are R2 nested", false, obsErr.Error())
}
report.DerivedEventAudit = prodSimDerivedAudit(agents)
if len(agents) > 0 {
Expand Down Expand Up @@ -411,12 +414,16 @@ func (s *r1GitHubMeshRun) bootstrapProfiles() error {
for _, i := range active {
agent := &s.agents[i]
payload := taskSimJSON(map[string]any{
"actor": agent.principal,
"focus": fmt.Sprintf("GitHub mesh Remote Workspace acceptance node %s", agent.principal),
"context_advantages": []string{"isolated local mnemond", "github publication branch sync", "real Codex appserver turn"},
"availability": "available",
"ttl": "30m",
"summary": fmt.Sprintf("%s is available for GitHub mesh teamwork validation.", agent.principal),
"rule": map[string]any{
"actor": agent.principal,
"availability": "available",
"ttl": "30m",
},
"narrative": map[string]any{
"focus": fmt.Sprintf("GitHub mesh Remote Workspace acceptance node %s", agent.principal),
"context_advantages": []string{"isolated local mnemond", "github publication branch sync", "real Codex appserver turn"},
"summary": fmt.Sprintf("%s is available for GitHub mesh teamwork validation.", agent.principal),
},
})
prompt := fmt.Sprintf(`Emit exactly one agent_profile.write_candidate.observed event through your own Local Mnemon.
Use external id github-mesh-profile-%s-%s and payload:
Expand Down Expand Up @@ -988,12 +995,16 @@ func r1GitHubMeshProfileConvergenceTimeout(syncInterval time.Duration) time.Dura

func (s *r1GitHubMeshRun) emitJoinedProfile(agent *r1CodexSyncAgent, scenario string) error {
payload := taskSimJSON(map[string]any{
"actor": agent.principal,
"focus": fmt.Sprintf("Joined GitHub mesh task %s with fresh local context", scenario),
"context_advantages": []string{"late join backlog import", "github publication branch sync", "isolated local mnemond"},
"availability": "available",
"ttl": "30m",
"summary": fmt.Sprintf("%s joined during %s and can pick up governed work from imported context.", agent.principal, scenario),
"rule": map[string]any{
"actor": agent.principal,
"availability": "available",
"ttl": "30m",
},
"narrative": map[string]any{
"focus": fmt.Sprintf("Joined GitHub mesh task %s with fresh local context", scenario),
"context_advantages": []string{"late join backlog import", "github publication branch sync", "isolated local mnemond"},
"summary": fmt.Sprintf("%s joined during %s and can pick up governed work from imported context.", agent.principal, scenario),
},
})
prompt := fmt.Sprintf(`Emit exactly one agent_profile.write_candidate.observed event through your own Local Mnemon.
Use external id github-mesh-join-profile-%s-%s and payload:
Expand Down
Loading
Loading