candidate.py 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173
  1. """Application-owned candidate content behind framework-owned immutable references."""
  2. from __future__ import annotations
  3. from typing import Any, Literal, Protocol, runtime_checkable
  4. from pydantic import Field, model_validator
  5. from cyber_agent.application.models import ApplicationModel, ApplicationRef, canonical_json
  6. from cyber_agent.core.artifacts import ArtifactRef
  7. from cyber_agent.core.task_contract import TaskContractRef
  8. MAX_CANDIDATES_PER_ROOT = 256
  9. MAX_CANDIDATE_OPERATIONS_PER_ROOT = 2_048
  10. class CandidatePointer(ApplicationModel):
  11. candidate_id: str = Field(min_length=1, max_length=200)
  12. revision: int = Field(ge=1)
  13. class CandidateRef(CandidatePointer):
  14. schema_version: Literal[1] = 1
  15. application_ref: ApplicationRef
  16. root_trace_id: str = Field(min_length=1)
  17. owner_trace_id: str = Field(min_length=1)
  18. task_contract_ref: TaskContractRef
  19. artifact_ref: ArtifactRef
  20. parent_refs: tuple[CandidatePointer, ...] = ()
  21. created_at_sequence: int = Field(ge=0)
  22. @model_validator(mode="after")
  23. def validate_parent_refs(self) -> "CandidateRef":
  24. identities = [
  25. (item.candidate_id, item.revision)
  26. for item in self.parent_refs
  27. ]
  28. if len(identities) != len(set(identities)):
  29. raise ValueError("CandidateRef parent_refs must be unique")
  30. if (self.candidate_id, self.revision) in set(identities):
  31. raise ValueError("CandidateRef cannot reference itself")
  32. return self
  33. class CandidateVersionRequest(ApplicationModel):
  34. operation_id: str = Field(min_length=1, max_length=300)
  35. application_ref: ApplicationRef
  36. root_trace_id: str = Field(min_length=1)
  37. owner_trace_id: str = Field(min_length=1)
  38. uid: str | None = None
  39. candidate_id: str = Field(min_length=1, max_length=200)
  40. revision: int = Field(ge=1)
  41. task_contract_ref: TaskContractRef
  42. parent_refs: tuple[CandidatePointer, ...] = ()
  43. content: Any
  44. @model_validator(mode="after")
  45. def validate_content(self) -> "CandidateVersionRequest":
  46. canonical_json(self.content)
  47. return self
  48. class CandidateAdoptionRequest(ApplicationModel):
  49. operation_id: str = Field(min_length=1, max_length=300)
  50. candidate_ref: CandidateRef
  51. class CandidateAdoptionReceipt(ApplicationModel):
  52. operation_id: str = Field(min_length=1, max_length=300)
  53. external_id: str = Field(min_length=1, max_length=500)
  54. committed: bool = True
  55. @runtime_checkable
  56. class CandidateRepository(Protocol):
  57. async def put_version(
  58. self,
  59. request: CandidateVersionRequest,
  60. ) -> ArtifactRef: ...
  61. async def load_version(self, candidate_ref: CandidateRef) -> Any: ...
  62. async def merge(
  63. self,
  64. request: CandidateVersionRequest,
  65. ) -> ArtifactRef: ...
  66. async def commit_adoption(
  67. self,
  68. request: CandidateAdoptionRequest,
  69. ) -> CandidateAdoptionReceipt: ...
  70. class CandidateLifecycleRecord(ApplicationModel):
  71. operation_id: str = Field(min_length=1, max_length=300)
  72. candidate: CandidatePointer
  73. state: Literal[
  74. "proposed",
  75. "adoption_pending",
  76. "adopted",
  77. "discarded",
  78. "adoption_failed",
  79. ]
  80. effective_at_sequence: int = Field(ge=0)
  81. reason: str | None = Field(default=None, max_length=2_000)
  82. receipt: CandidateAdoptionReceipt | None = None
  83. class CandidateOperationRecord(ApplicationModel):
  84. operation_id: str = Field(min_length=1, max_length=300)
  85. operation: Literal["create", "fork", "merge", "adopt", "discard"]
  86. input_hash: str = Field(pattern=r"^[0-9a-f]{64}$")
  87. status: Literal["pending", "completed", "failed"] = "pending"
  88. candidate: CandidatePointer | None = None
  89. error: str | None = Field(default=None, max_length=2_000)
  90. class CandidateLedger(ApplicationModel):
  91. schema_version: Literal[1] = 1
  92. candidates: tuple[CandidateRef, ...] = ()
  93. lifecycle: tuple[CandidateLifecycleRecord, ...] = ()
  94. operations: tuple[CandidateOperationRecord, ...] = ()
  95. validations: tuple[dict[str, Any], ...] = ()
  96. @model_validator(mode="after")
  97. def validate_ledger(self) -> "CandidateLedger":
  98. if len(self.candidates) > MAX_CANDIDATES_PER_ROOT:
  99. raise ValueError("Candidate ledger candidate limit exceeded")
  100. if len(self.operations) > MAX_CANDIDATE_OPERATIONS_PER_ROOT:
  101. raise ValueError("Candidate ledger operation limit exceeded")
  102. identities = [
  103. (item.candidate_id, item.revision)
  104. for item in self.candidates
  105. ]
  106. if len(identities) != len(set(identities)):
  107. raise ValueError("Candidate ledger contains duplicate revisions")
  108. operation_ids = [item.operation_id for item in self.operations]
  109. if len(operation_ids) != len(set(operation_ids)):
  110. raise ValueError("Candidate ledger contains duplicate operation IDs")
  111. known = set(identities)
  112. for candidate in self.candidates:
  113. for parent in candidate.parent_refs:
  114. parent_key = (parent.candidate_id, parent.revision)
  115. if parent_key not in known:
  116. raise ValueError("Candidate ledger contains an unknown parent")
  117. if (
  118. parent.candidate_id == candidate.candidate_id
  119. and parent.revision >= candidate.revision
  120. ):
  121. raise ValueError("Candidate lineage references a future revision")
  122. return self
  123. def candidate(self, pointer: CandidatePointer) -> CandidateRef:
  124. for item in self.candidates:
  125. if (
  126. item.candidate_id == pointer.candidate_id
  127. and item.revision == pointer.revision
  128. ):
  129. return item
  130. raise ValueError(
  131. f"Candidate revision not found: {pointer.candidate_id}@{pointer.revision}"
  132. )
  133. def current_state(self, pointer: CandidatePointer) -> str | None:
  134. state = None
  135. for item in self.lifecycle:
  136. if (
  137. item.candidate.candidate_id == pointer.candidate_id
  138. and item.candidate.revision == pointer.revision
  139. ):
  140. state = item.state
  141. return state