MCPcopy Create free account
hub / github.com/compozy/agh / seedDetachedHarnessRecoveryRunForTest

Function seedDetachedHarnessRecoveryRunForTest

internal/daemon/daemon_test.go:4579–4662  ·  view source on GitHub ↗
(
	t *testing.T,
	db harnessReentryStore,
	actor taskpkg.ActorContext,
	taskID string,
	runID string,
	summary string,
	completedAt time.Time,
)

Source from the content-addressed store, hash-verified

4577}
4578
4579func seedDetachedHarnessRecoveryRunForTest(
4580 t *testing.T,
4581 db harnessReentryStore,
4582 actor taskpkg.ActorContext,
4583 taskID string,
4584 runID string,
4585 summary string,
4586 completedAt time.Time,
4587) {
4588 t.Helper()
4589
4590 taskMetadata, err := marshalDetachedHarnessMetadata(detachedHarnessTaskMetadata{
4591 Schema: harnessDetachedMetadataSchema,
4592 Kind: harnessDetachedTaskMetadataKey,
4593 SubmissionKey: "submission-" + runID,
4594 Summary: summary,
4595 OwnerSessionID: "sess-owner",
4596 WakeTarget: detachedHarnessWakeTarget{
4597 SessionID: "sess-wake",
4598 SessionType: string(session.SessionTypeSystem),
4599 Channel: "builders",
4600 },
4601 })
4602 if err != nil {
4603 t.Fatalf("marshalDetachedHarnessMetadata(task) error = %v", err)
4604 }
4605 runMetadata, err := marshalDetachedHarnessMetadata(detachedHarnessRunMetadata{
4606 Schema: harnessDetachedMetadataSchema,
4607 Kind: harnessDetachedRunMetadataKey,
4608 SubmissionKey: "submission-" + runID,
4609 Summary: summary,
4610 OwnerSessionID: "sess-owner",
4611 WakeTarget: detachedHarnessWakeTarget{
4612 SessionID: "sess-wake",
4613 SessionType: string(session.SessionTypeSystem),
4614 Channel: "builders",
4615 },
4616 })
4617 if err != nil {
4618 t.Fatalf("marshalDetachedHarnessMetadata(run) error = %v", err)
4619 }
4620
4621 if err := db.CreateTask(testutil.Context(t), taskpkg.Task{
4622 ID: taskID,
4623 Scope: taskpkg.ScopeGlobal,
4624 Title: summary,
4625 Status: taskpkg.TaskStatusInProgress,
4626 CreatedBy: actor.Actor,
4627 Origin: actor.Origin,
4628 CreatedAt: completedAt.Add(-time.Minute),
4629 UpdatedAt: completedAt.Add(-time.Minute),
4630 Metadata: taskMetadata,
4631 }); err != nil {
4632 t.Fatalf("CreateTask(%q) error = %v", taskID, err)
4633 }
4634 if err := db.CreateTaskRun(testutil.Context(t), taskpkg.Run{
4635 ID: runID,
4636 TaskID: taskID,

Calls 6

ContextFunction · 0.92
CreateTaskMethod · 0.65
CreateTaskRunMethod · 0.65
CreateTaskEventMethod · 0.65
AddMethod · 0.45

Tested by

no test coverage detected