Function assertTaskRunEnqueuedPayload

internal/task/manager_test.go:7569–7614

(
	t *testing.T,
	payload hookspkg.TaskRunEnqueuedPayload,
	taskRecord Task,
	run Run,
	actor ActorContext,
)

}

func assertTaskRunEnqueuedPayload(
	t *testing.T,
	payload hookspkg.TaskRunEnqueuedPayload,
	taskRecord Task,
	run Run,
	actor ActorContext,
) {
	t.Helper()
	if payload.Event != hookspkg.HookTaskRunEnqueued {
		t.Fatalf("enqueued hook event = %q, want %q", payload.Event, hookspkg.HookTaskRunEnqueued)
	}
	if payload.Timestamp.IsZero() {
		t.Fatal("enqueued hook timestamp = zero, want dispatch timestamp")
	}
	if payload.IdempotencyKey != "" {
		t.Fatalf(
			"enqueued hook idempotency key = %q, want empty force-op key",
			payload.IdempotencyKey,
		)
	}
	coordinationChannelID := strings.TrimSpace(run.CoordinationChannelID)
	if coordinationChannelID == "" {
		coordinationChannelID = strings.TrimSpace(run.NetworkChannel)
	}
	want := hookspkg.TaskRunContext{
		TaskID:                strings.TrimSpace(run.TaskID),
		RunID:                 strings.TrimSpace(run.ID),
		WorkspaceID:           strings.TrimSpace(taskRecord.WorkspaceID),
		CoordinationChannelID: coordinationChannelID,
		NetworkChannel:        strings.TrimSpace(run.NetworkChannel),
		AgentName:             "",
		SessionID:             strings.TrimSpace(run.SessionID),
		ActorKind:             string(actor.Actor.Kind.Normalize()),
		ActorID:               strings.TrimSpace(actor.Actor.Ref),
		OriginKind:            string(actor.Origin.Kind.Normalize()),
		OriginRef:             strings.TrimSpace(actor.Origin.Ref),
		TaskStatus:            string(taskRecord.Status.Normalize()),
		RunStatus:             string(run.Status.Normalize()),
		Attempt:               run.Attempt,
		LeaseUntil:            run.LeaseUntil,
		Error:                 strings.TrimSpace(run.Error),
	}
	if payload.TaskRunContext != want {
		t.Fatalf("enqueued hook context = %#v, want %#v", payload.TaskRunContext, want)
	}
}

func TestManagerNetworkPeerEnqueueRunUsesOriginScopedIdempotency(t *testing.T) {
	t.Parallel()