onevcs_testing/state.rs
1//! What a provider knows, in a shape a journey can write down and read back.
2//!
3//! One state type per interface, shared by both flavours of it — the in-memory
4//! provider and the file-backed one differ in where the state lives and in nothing
5//! else, so a scenario seeded for one is the same scenario for the other.
6
7use std::collections::{BTreeMap, BTreeSet};
8
9use serde::{Deserialize, Serialize};
10
11use onevcs::rules::{Approvals, Drafts};
12use onevcs::{
13 ChangeId, ChangeRequest, Check, CheckSource, CommentId, CommentKind, DraftReason, Error,
14 Identity, Landed, MergeOutcome, ReadCost, Recoverable, Result, Sha,
15};
16use onevcs::{MergePolicy, Publication, RequiredChecks, Session, SessionRequest, SessionToken};
17
18use crate::events;
19use crate::store::Checked;
20
21/// The version of the state document this build writes.
22///
23/// A file-backed state outlives the process that wrote it and is read by the next
24/// one, which makes it a stored contract like `onevcs`'s own registry document —
25/// and like that document, the version a document declares decides what is done
26/// with it rather than being guessed at. [`STATE_VERSION`] is the shape the goldens in
27/// `tests/golden/` hold, and those goldens are compared byte for byte, so a change
28/// to the document cannot reach a consumer without the diff saying so.
29///
30/// `2` was what both sides learned when publishing and closing a session came
31/// through the interface: [`VcsState::policy`], [`VcsState::closed_sessions`],
32/// [`VcsState::publications`], and [`HostState::titles`]. `3` is
33/// [`HostState::bodies`], the body a change request was opened with. `4` is the two
34/// fields a `Recoverable` gained inside [`VcsState::preserved`] — the live session
35/// holding a branch, and the lines it would land when it removes more than it adds.
36/// `5` is one more of those: whether the branch's work reached its base, and what
37/// says so. `6` is the two a `Check` gained inside [`HostState::checks`] — the
38/// commit the host attached that check to, and where the check is on the host. `7`
39/// is the two a draft change request needs — [`HostState::drafts`], the reason each
40/// change request was opened as a draft with, and [`HostState::made_ready`], the
41/// `ready_for_review` calls it took. `8` is the two an [`Identity`] inside
42/// [`VcsState::identities`] **lost** — `workflow` and `repo_type`, the registry's
43/// inferences from whether an origin had a host, which every decision they made now
44/// takes from the resolved publication policy instead. `9` is the draft reason inside
45/// [`HostState::drafts`] becoming one of two kinds and saying which — `kind` is
46/// `awaiting-release` or `held` — and [`HostState::described`], the descriptions a
47/// host was handed for a change request after it was opened. `10` is the failure
48/// vocabulary a publication's outcome inside [`VcsState::publications`] may name
49/// widening by one kind, `host-prerequisite` — no field moved, but a document naming
50/// it is one a version 9 build cannot read, and the version is how it says so. `11` is
51/// one more field a `Recoverable` gained inside [`VcsState::preserved`], the same way
52/// `4` and `5` were: where `onevcs preserve` put that branch on its identity's origin,
53/// and the commit the origin carries it at. `12` is the labels a session is opened
54/// with — [`VcsState::session_labels`], keyed by token the way its identity is — and
55/// the two fields a `Recoverable` gained inside [`VcsState::preserved`] to carry them:
56/// the session that answers for the row, and that session's labels. `13` is one more
57/// field a `Recoverable` gained there: the branch's retirement classification — whether
58/// it provably holds nothing beyond its base, was superseded by a retry that landed, or
59/// is kept, and the evidence for it. No provider here classifies a row, so a row this
60/// crate writes carries none; a scenario may seed one. `14` is the draft lifecycle:
61/// [`HostState::awaiting_checks`], the change requests opened as a draft while their
62/// required checks run, [`HostState::checks_after_lift`], the checks a host registers
63/// only once a change is lifted, and [`HostState::required_checks`], what the host
64/// says a merge into a base requires — beside [`VcsState::approvals`] and
65/// [`VcsState::drafts`], the two policy fields a provider's publication now routes
66/// the lifecycle on. A publication outcome inside [`VcsState::publications`] may also
67/// be `change-review-draft`. `15` is the field a `Session` gained inside
68/// [`VcsState::sessions`]: `conflict`, the merge a continued branch's session opened
69/// over and left in progress. No provider here merges a base into a branch, so a
70/// session this crate opens carries none; a scenario may seed one. `16` is the failure
71/// vocabulary a publication's outcome inside [`VcsState::publications`] may name
72/// widening by one kind, `cancelled`, the way `10` widened it — no field moved, but a
73/// document naming it is one a version 15 build cannot read. No provider here waits on
74/// anything, so a publication this crate runs is never cancelled; a scenario may seed
75/// one. `17` is the field a `Retirement` gained inside a row of
76/// [`VcsState::preserved`]: `cause`, the read that failed for a branch kept as
77/// `unknown`, which every retirement writes — `null` for every other reason. No
78/// provider here classifies a branch, so a row this crate writes carries none; a
79/// scenario may seed one. `18` is what the record of a gate run and of a landing needs
80/// from a host: the field a `Check` gained inside [`HostState::checks`] —
81/// `completed_at`, when the host says that run completed — and
82/// [`HostState::merge_times`], when each merge this host performed reached its base.
83///
84/// **Every change to the document is versioned, an added field included.** A field
85/// that only ever appears when it holds something is *compatible* — that is what
86/// [`OLDEST_READABLE_VERSION`] is for — but compatible is not the same as
87/// unremarkable: the version is how a consumer's checked-in scenario says which
88/// shape it was written against, and a document that gained a field without saying
89/// so leaves nothing able to tell "this build wrote no body" from "this document
90/// predates bodies". The two answers differ for exactly the journey this crate
91/// exists to support.
92/// `19` adds the recovery branch tip; older rows default it to `None`. `20` is the
93/// review feedback a host holds: [`HostState::review_comments`], each change
94/// request's comments of every kind, [`HostState::replies`], every reply this host
95/// posted, and [`HostState::review_charges`], what it charges a read. `21` is what a
96/// stack of drafts needs from a host while people merge some of them on it:
97/// [`HostState::closed`], the change requests closed without merging,
98/// [`HostState::deleted_branches`], the branches gone from the origin,
99/// [`HostState::head_checks`], each required check's state per head commit, and
100/// [`HostState::ledger`], every call the host answered with what GitHub charges for it.
101pub const STATE_VERSION: u32 = 21;
102
103/// The oldest document version this build reads.
104///
105/// Every version from here to [`STATE_VERSION`] is read and carried forward on the
106/// way in, which is how `onevcs`'s own registry document treats its older
107/// versions: what separates a readable older version from a refused one is whether
108/// its every field still means here what it meant there. `2` to `3` added a field
109/// and changed none, so a version 2 document reads as one whose change requests
110/// were opened with no body — which is what they were; `3` to `4` added two the same
111/// way, so a version 3 document reads as one whose preserved rows say nothing about a
112/// hold or a line count, which is what they said. `4` to `5` added one that every row
113/// answers rather than one that appears when it holds something, so a version 4
114/// document's rows are carried forward as the answer that list *was*: preserved work
115/// nobody published, which is work that did not land. `5` to `6` added two that
116/// appear only when they hold something, so a version 5 document's checks read as
117/// checks whose commit and address that build never recorded — which is what they
118/// were, and the one thing that must not be filled in from the change request's own
119/// head. `6` to `7` added two more of that kind, so a version 6 document reads as one
120/// whose change requests were opened before this crate could draft one — which is what
121/// they were: no draft reason recorded for any of them, and no lift ever asked for.
122/// `7` to `8` *removed* two from each identity, and a version 7 document reads past
123/// them: an identity is its origin and its gate here as it is in `onevcs`, and the two
124/// keys beside them are ones this build has no opinion on. `8` to `9` gave every
125/// draft reason a `kind`, and a reason written without one is read as the one kind
126/// there was — `awaiting-release`, whose four fields it carries unchanged — which is
127/// `drafts_of_any_version`'s whole job; the descriptions beside it are absent from a
128/// document written before them, which is the answer, since that build could describe
129/// nothing. `9` to `10` changed no field and no meaning: every failure kind a version 9
130/// document can hold is spelled here as it was there and means what it meant, so it
131/// reads unchanged and needs no carrying forward beyond its version. `10` to `11` added
132/// one that appears only when it holds something, so a version 10 document's preserved
133/// rows read as rows saying nothing about an origin — which is what they said, since
134/// that build had no verb that could put a branch on one. `11` to `12` added the
135/// labels, which appear only where a session was opened with some, and the two row
136/// fields that carry them, which a version 11 row reads as absent: a session nobody
137/// labelled, and a row that names no session — which is what that build's rows said,
138/// since it recorded neither. `12` to `13` added the row's retirement, which appears only
139/// where a row holds one, so a version 12 row reads as one nothing classified — which
140/// is what it was, since that build had no classification to record. `13` to `14`
141/// added fields that appear only when they hold something, so a version 13 document
142/// reads as one whose change requests were opened before the lifecycle drafted any,
143/// whose checks never change on a lift, whose host declares its required checks by
144/// the checks it was seeded with, and whose policy leaves approvals and drafts at
145/// their defaults — which is what that build published under. `14` to `15` added the
146/// session's conflict, which appears only where a session holds one, so a version 14
147/// document's sessions read as sessions that opened clean — which is what they were,
148/// since that build opened none over a merge. `15` to `16` changed no field and no
149/// meaning, as `9` to `10` did not: every failure kind a version 15 document can hold is
150/// spelled here as it was there, so it reads unchanged. `16` to `17` added the
151/// retirement's cause, which a version 16 retirement reads as `null` — which is what it
152/// said, since that build named no read that failed. `17` to `18` added two fields that
153/// appear only when they hold something, so a version 17 document's checks read as
154/// checks whose completion that build never recorded, and its merges as merges whose
155/// time it never recorded — which is what they were. `19` to `20` added three fields
156/// that appear only when they hold something, so a version 19 document reads as a
157/// host whose change requests carry no review feedback and that has posted no reply —
158/// which is what that build could hold. `20` to `21` added four more of that kind, so a
159/// version 20 document reads as a host on which nobody closed or deleted anything, whose
160/// checks are its change requests' own, and which has answered no call — which is what
161/// that build recorded.
162///
163/// `1` is refused rather than read for the opposite reason: it describes a provider
164/// that could not publish, and every session in it would read back as open — a
165/// wrong answer where a journey asserting on a session it had closed needs a
166/// refusal.
167pub const OLDEST_READABLE_VERSION: u32 = 2;
168
169/// Everything the repository side of a run knows about itself.
170///
171/// Every field is public and serializable, so a journey both seeds a scenario and
172/// asserts on what a run left behind. Everything but the version is omitted when
173/// it holds nothing, so a hand-written document names only the part of a scenario
174/// that matters — and a document written by a build that knew fewer fields still
175/// reads here.
176#[derive(Debug, Clone, Serialize, Deserialize)]
177#[serde(default)]
178pub struct VcsState {
179 /// The schema version this state was written at. A document that names none is
180 /// the one this build writes.
181 // llmlint: ignore[boundary_inputs_validated] deciding what to do with a version this
182 // build does not read is the whole of the check — and it is in `Checked::check` below,
183 // where a document is read, rather than here where serde only proves the shape.
184 pub version: u32,
185 /// The repository identities this provider can resolve. A
186 /// [`SessionRequest::repo`] naming none of them is refused, the way an
187 /// unregistered repository is.
188 #[serde(skip_serializing_if = "Vec::is_empty")]
189 pub identities: Vec<Identity>,
190 /// Every session opened or seeded, in the order they were opened.
191 #[serde(skip_serializing_if = "Vec::is_empty")]
192 pub sessions: Vec<Session>,
193 /// Which identity each session belongs to.
194 ///
195 /// Beyond the sketch this crate was specified from, and unavoidable: a
196 /// [`Session`] carries no identity, and a [`Recoverable`] must name one — so
197 /// preserving a session's branch could not answer the question `recoverable`
198 /// asks without this. `open_session` records it; nothing else writes it.
199 // llmlint: ignore[invalid_states_unrepresentable] an identity key is a `String`
200 // everywhere the crate this mirrors spells one — `Recoverable.identity`,
201 // `Identity.origin`, the registry document's own map key — and a newtype here would
202 // make a seeded state disagree with the types it is made of. Every value written to
203 // this map came out of `identity_of`, so it names an identity this provider holds.
204 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
205 pub session_identities: BTreeMap<SessionToken, String>,
206 /// The labels each session was opened with, for the sessions opened with any.
207 ///
208 /// Keyed by token the way [`session_identities`](Self::session_identities) is,
209 /// and for the same reason: a [`Session`] carries no labels, and both `session
210 /// holders` and every `recoverable` row report them. `open_session` records
211 /// them; nothing else writes it.
212 // llmlint: ignore[invalid_states_unrepresentable] keyed by session token, exactly as
213 // `session_identities` above is and for the same reason it gives.
214 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
215 pub session_labels: BTreeMap<SessionToken, BTreeMap<String, String>>,
216 /// Preserved work, newest last, as `recoverable` reports it.
217 ///
218 /// [`Recoverable`] rather than `PreservedBranch` — it *contains* the preserved
219 /// branch and adds the identity, the checkout, why the workstream stopped, and
220 /// the command that lands it, none of which are derivable from the branch
221 /// alone. One list rather than two that could disagree.
222 #[serde(skip_serializing_if = "Vec::is_empty")]
223 pub preserved: Vec<Recoverable>,
224 /// The sessions that have been closed. Every other session here is open.
225 ///
226 /// One way to say closed rather than two, so a scenario written by hand names
227 /// only the sessions whose lifecycle is not the one they were opened in.
228 // llmlint: ignore[invalid_states_unrepresentable] keyed by session token, exactly as
229 // `session_identities` above is and for the same reason: this document is a scenario
230 // somebody writes by hand, and a session is named once under `sessions` with the rest
231 // of the state keyed to it rather than nested inside a shape that could hold only one
232 // arrangement. A token here that names no opened session is refused in
233 // `Checked::check`, where the document is read — the same trust boundary every other
234 // cross-reference in it is checked at.
235 #[serde(skip_serializing_if = "BTreeSet::is_empty")]
236 pub closed_sessions: BTreeSet<SessionToken>,
237 /// The policy this provider publishes under.
238 ///
239 /// The answer a rules file gives the real implementation, which a provider has
240 /// none of — so a journey states it, and unset is the policy the contract's own
241 /// `default:` names ([`DEFAULT_PUBLICATION`](crate::DEFAULT_PUBLICATION)). A
242 /// per-run policy narrows it through [`MergePolicy::narrow`], which is the
243 /// rules system's rule rather than a restatement of it here.
244 #[serde(skip_serializing_if = "Option::is_none")]
245 pub policy: Option<MergePolicy>,
246 /// Whether this provider's changes need an approval, which is the other half of
247 /// what decides a green draft's ending: `change-open` with approvals required
248 /// keeps it for its user's review. Unset is the contract's own `default:`,
249 /// [`DEFAULT_APPROVALS`](crate::DEFAULT_APPROVALS).
250 #[serde(skip_serializing_if = "Option::is_none")]
251 pub approvals: Option<Approvals>,
252 /// The `drafts:` a rules file would give this provider's identity. Unset, and
253 /// each key it leaves unset, is the shipped default: the lifecycle on and the
254 /// early-lift warning on.
255 #[serde(skip_serializing_if = "Option::is_none")]
256 pub drafts: Option<Drafts>,
257 /// Every publication this provider performed, in the order it performed them.
258 ///
259 /// Both a record a journey asserts on and the answer to "has this session been
260 /// published already": a second publication of a session that landed has
261 /// nothing the base does not already carry, which is what the real
262 /// implementation reports for the same reason.
263 // llmlint: ignore[invalid_states_unrepresentable] this holds `onevcs::Publication`
264 // verbatim — the value `Vcs::publish` handed back, carrying its own session and branch
265 // — so a journey asserts on exactly what a caller would receive. A shape that made
266 // "this publication is of some other session's branch" unrepresentable could not hold
267 // that type, and would be a second spelling of the answer the crate next door already
268 // has. The cross-reference is checked in `Checked::check` instead, where the document
269 // is read.
270 #[serde(skip_serializing_if = "Vec::is_empty")]
271 pub publications: Vec<Publication>,
272}
273
274/// A repository side that knows nothing, at the version this build writes.
275impl Default for VcsState {
276 fn default() -> Self {
277 Self {
278 version: STATE_VERSION,
279 identities: Vec::new(),
280 sessions: Vec::new(),
281 session_identities: BTreeMap::new(),
282 session_labels: BTreeMap::new(),
283 preserved: Vec::new(),
284 closed_sessions: BTreeSet::new(),
285 policy: None,
286 approvals: None,
287 drafts: None,
288 publications: Vec::new(),
289 }
290 }
291}
292
293/// Everything the remote-host side of a run knows about itself.
294///
295/// Omitted-when-empty and versioned for the same reasons [`VcsState`] is.
296#[derive(Debug, Clone, Serialize, Deserialize)]
297#[serde(default)]
298pub struct HostState {
299 /// The schema version this state was written at. A document that names none is
300 /// the one this build writes.
301 // llmlint: ignore[boundary_inputs_validated] as on `VcsState::version`: the decision
302 // about an unreadable version is made in `Checked::check`, where the document is read.
303 pub version: u32,
304 /// Who the host says is calling. Empty is refused, exactly as a `gh` that
305 /// reports no authenticated user is.
306 // llmlint: ignore[invalid_states_unrepresentable] the interface this satisfies is
307 // `authenticated_user() -> Result<String>`, so the login is a `String` by contract and
308 // the one unusable value — a host that names nobody — is refused where it is read
309 // rather than made unrepresentable in a state a journey writes by hand.
310 pub authenticated_user: String,
311 /// Every change request that has been opened or seeded.
312 #[serde(skip_serializing_if = "Vec::is_empty")]
313 pub changes: Vec<ChangeRequest>,
314 /// The head branch each change request was opened from.
315 ///
316 /// Beyond the sketch, and unavoidable: [`ChangeRequest`] records only the base
317 /// it targets, and `find_changes` matches on the head as well.
318 // llmlint: ignore[invalid_states_unrepresentable] the matching `ChangeSpec.head` and
319 // `ChangeRequest.base` are `String` in the contract this mirrors, and a validated ref
320 // type here would disagree with them. Every value written to this map went through
321 // `addressable` in `open_change` first, which is the same refusal the real
322 // implementation makes at the same point.
323 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
324 pub heads: BTreeMap<ChangeId, String>,
325 /// The title each change request was opened under.
326 ///
327 /// Beyond the sketch, and for the same reason [`heads`](HostState::heads) is:
328 /// [`ChangeRequest`] records neither, and the title is what a publication's
329 /// commit subject becomes — so a journey asserting that the subject it asked
330 /// for is the one the host was given has nowhere else to read it.
331 // llmlint: ignore[invalid_states_unrepresentable] this records the `ChangeSpec.title`
332 // the contract fixes as a `String`, so a validated type here would disagree with the
333 // one it mirrors. `Subject` is not that type: it is `onevcs`'s rule for a *commit
334 // subject*, and a host's own limit is its own — spelling it here would
335 // refuse a seeded title a real host accepts, which is drift in the direction that
336 // looks like rigour. What the host itself refuses is a title that names nothing, and
337 // that is refused below and in `open_change`, at the boundary the value arrives at.
338 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
339 pub titles: BTreeMap<ChangeId, String>,
340 /// The body each change request was opened with, for the change requests that
341 /// were opened with one.
342 ///
343 /// Beside [`titles`](HostState::titles) and for its reason: the body is what a
344 /// caller passes on the `PublishRequest` and nothing else records it, so a
345 /// journey asserting that the body it drafted is the one the host was given has
346 /// nowhere else to read it. A change request with no entry was opened with no
347 /// body at all, which is what a publication nobody gave one does — the two are
348 /// different scenarios, and an empty string is the first rather than the second.
349 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
350 pub bodies: BTreeMap<ChangeId, String>,
351 /// The checks the host reports on each change request. A change with no entry
352 /// has no checks, which is what a repository with no CI reports.
353 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
354 pub checks: BTreeMap<ChangeId, Vec<Check>>,
355 /// The log the host hands over for a check, keyed by change request and then by
356 /// check name. Beyond the sketch: `check_log` is one of the six methods, and
357 /// without this the only log a journey could asssert on is a synthesized one.
358 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
359 pub check_logs: BTreeMap<ChangeId, BTreeMap<String, String>>,
360 /// The reason each change request that was opened as a **draft** was drafted
361 /// with, for the change requests that were.
362 ///
363 /// Beside [`bodies`](HostState::bodies) and for its reason: the reason is what a
364 /// caller passes on the `PublishRequest` and this is where a journey reads back
365 /// that the host was given it. A change with no entry is not a draft, which is
366 /// what every change request opened without one is.
367 ///
368 /// Nothing is refused about the reason itself here. Its shape — that every field
369 /// of it renders as the one line it is printed on — is `onevcs`'s own rule, and
370 /// it is applied where a publication takes one in, before any host is asked.
371 #[serde(
372 skip_serializing_if = "BTreeMap::is_empty",
373 deserialize_with = "drafts_of_any_version"
374 )]
375 pub drafts: BTreeMap<ChangeId, DraftReason>,
376 /// Every `ready_for_review` call this host has taken, in the order it took them
377 /// — the lifts it was asked to perform, never a request for a *reviewer*.
378 ///
379 /// A list rather than a set, and beyond the sketch for a reason a set could not
380 /// serve: lifting a draft is required to be *idempotent*, so what a journey
381 /// asserts is that a second publication asked the host for nothing — and only a
382 /// record of the calls themselves can say that. A change named here is not a
383 /// draft any more, whatever [`drafts`](HostState::drafts) says it was opened as.
384 #[serde(skip_serializing_if = "Vec::is_empty")]
385 pub made_ready: Vec<ChangeId>,
386 /// The change requests opened as a draft **while their required checks run** —
387 /// the lifecycle's draft, which no caller gave a reason for and so is not in
388 /// [`drafts`](HostState::drafts). A change named here is a draft until
389 /// [`made_ready`](HostState::made_ready) names it.
390 #[serde(skip_serializing_if = "BTreeSet::is_empty")]
391 pub awaiting_checks: BTreeSet<ChangeId>,
392 /// The checks the host reports on a change request once it has been lifted out of
393 /// its draft, in place of [`checks`](HostState::checks).
394 ///
395 /// What a repository whose workflow skips drafts looks like from outside: the
396 /// draft's checks are skipped or absent, and the run the lift triggers registers
397 /// after it. A change with no entry reports the same checks either side of a lift.
398 ///
399 /// A publication tells the run a lift triggered from the draft's by the run's own
400 /// identity, as it would on a real host: a check named here that the draft also
401 /// reported is a new run — running or settled — only where its
402 /// [`started_at`](Check::started_at) is one no draft-era run of that check reported. So seed a re-run with a start of its own — an entry repeating
403 /// the draft's start, or reporting none, is the draft's run still standing.
404 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
405 pub checks_after_lift: BTreeMap<ChangeId, Vec<Check>>,
406 /// What this host answers when asked which checks a merge into a base requires.
407 ///
408 /// Unset is a host whose branch protection names exactly the checks it was seeded
409 /// as required, on any change request — a complete answer, and an empty one where
410 /// none is seeded required. Seeded, it is the answer for every base: an empty
411 /// complete one is a repository declaring no required check, and one naming an
412 /// `unconsulted` source is the incomplete answer a narrower credential gets.
413 #[serde(skip_serializing_if = "Option::is_none")]
414 pub required_checks: Option<RequiredChecks>,
415 /// Every `describe_change` call this host has taken, in the order it took them:
416 /// which change request, the title it was handed when it was handed one, and the
417 /// body.
418 ///
419 /// The calls themselves, for the reason [`made_ready`](HostState::made_ready) is:
420 /// what a journey asks is what a closeout *wrote*, call by call, and the current
421 /// title and body — which each call also writes into
422 /// [`titles`](HostState::titles) and [`bodies`](HostState::bodies), so
423 /// `change_description` answers from the same record `open_change` wrote — can
424 /// only say where the description ended up.
425 #[serde(skip_serializing_if = "Vec::is_empty")]
426 pub described: Vec<Described>,
427 /// Which sources this host answers about its checks from, which is what the
428 /// real implementation reports alongside them.
429 ///
430 /// Unset is a credential allowed to read everything: the whole rollup, exactly
431 /// what a host with nothing to hide reports. A journey states a narrower set to
432 /// be the credential the real one meets in CI — a fine-grained token, which
433 /// cannot read check runs at all and sees GitHub Actions and nothing else — and
434 /// states an *empty* one to be a credential that can read no source at all,
435 /// which is a refusal rather than "no checks". Unset and empty are therefore
436 /// different scenarios, which is why this is an `Option` rather than a set whose
437 /// emptiness means "not stated".
438 #[serde(skip_serializing_if = "Option::is_none")]
439 pub check_sources: Option<BTreeSet<CheckSource>>,
440 /// What merging each change request did.
441 ///
442 /// Both a script and a record: an entry seeded here is what `merge` answers,
443 /// whatever the policy asks for — which is how a journey expresses a host that
444 /// queues or refuses — and a merge the policy decided is written back here.
445 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
446 pub merges: BTreeMap<ChangeId, MergeOutcome>,
447 /// When each merged change request reached its base, as this host spells the
448 /// moment — what `merge_time` answers.
449 ///
450 /// Written beside [`merges`](HostState::merges) whenever this host performs a
451 /// merge, at the moment it performs it, and seedable for a merge a journey
452 /// seeded: a host that merged on its own clock, earlier than anybody asked, is
453 /// exactly what a late merge's record must report the time of. A merged change
454 /// with no entry is one whose time this host cannot say.
455 // llmlint: ignore[invalid_states_unrepresentable] this mirrors the answer
456 // `RemoteHost::merge_time` gives, which the contract fixes as the host's own spelling
457 // in an `Option<String>`; a timestamp type here would disagree with the seam it
458 // answers. A value that is not an RFC3339 moment is refused in `check`, where the
459 // document is read, and every one this host writes is `events::timestamp`'s.
460 #[serde(skip_serializing_if = "BTreeMap::is_empty")]
461 pub merge_times: BTreeMap<ChangeId, String>,
462 /// Each change request's review feedback — review-thread comments, review
463 /// summaries and conversation comments — in the order it was posted.
464 ///
465 /// Both a script and a record: what a journey seeds here is what
466 /// `review_comments` reads, [`Host::add_comment`](crate::Host::add_comment),
467 /// [`Host::edit_comment`](crate::Host::edit_comment) and
468 /// [`Host::set_thread`](crate::Host::set_thread) move it as a reviewer would, and
469 /// every reply `reply_to_comment` posts is written back here beside them.
470 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
471 pub review_comments: BTreeMap<ChangeId, Vec<HostComment>>,
472 /// Every reply this host posted, in the order it posted them.
473 ///
474 /// The calls themselves, for the reason [`described`](HostState::described) is:
475 /// what a journey about idempotency asks is how many replies were *posted*, and
476 /// the comments a read returns can only say what is there now.
477 #[serde(default, skip_serializing_if = "Vec::is_empty")]
478 pub replies: Vec<Replied>,
479 /// What this host charges for each read of review feedback, one entry a read, in
480 /// order; a read with none left is charged the one GraphQL point a page that
481 /// `spike-review-loop` measured, and no REST request.
482 #[serde(default, skip_serializing_if = "Vec::is_empty")]
483 pub review_charges: Vec<ReadCost>,
484 /// The change requests closed without merging — by a person on the host, or because
485 /// the branch they target was deleted from under them.
486 #[serde(default, skip_serializing_if = "BTreeSet::is_empty")]
487 pub closed: BTreeSet<ChangeId>,
488 /// The branches gone from the origin: a merged change request's head a person
489 /// deleted. A closed change request targeting one reads `base_deleted`, and nothing
490 /// is retargeted onto one.
491 // llmlint: ignore[invalid_states_unrepresentable] branch names, as `heads` holds them;
492 // each is held to git's grammar in `check`, where the document is read.
493 #[serde(default, skip_serializing_if = "BTreeSet::is_empty")]
494 pub deleted_branches: BTreeSet<String>,
495 /// Each check's state on one head commit, in place of the change request's own
496 /// [`checks`](HostState::checks): what a host reports for a head pushed since, and
497 /// how a journey gives each change request of a stack its own verdict.
498 #[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
499 pub head_checks: BTreeMap<Sha, Vec<Check>>,
500 /// Every host call this host answered, in the order it answered them: the method,
501 /// the change requests it names and what GitHub charges the call the real host
502 /// sends — which is what a consumer sums over a whole review round.
503 #[serde(default, skip_serializing_if = "Vec::is_empty")]
504 pub ledger: Vec<HostCall>,
505}
506
507/// Every method a ledger entry may name: each `RemoteHost` method this host answers.
508/// `Host::called` refuses to record any other, and
509/// `the_ledger_records_a_call_to_every_method_the_host_interface_declares` holds this
510/// list equal to the trait's own declaration, read out of its source.
511pub(crate) const LEDGER_METHODS: &[&str] = &[
512 "authenticated_user",
513 "change_checks",
514 "change_description",
515 "change_standings",
516 "check_log",
517 "describe_change",
518 "find_changes",
519 "is_draft",
520 "merge",
521 "merge_time",
522 "merged_at",
523 "mergeability",
524 "open_change",
525 "ready_for_review",
526 "reopen_change",
527 "reply_to_comment",
528 "required_checks_on",
529 "retarget_change",
530 "review_comments",
531 "review_standings",
532 "visibility",
533];
534
535/// One host call a host answered, as its ledger records it.
536// llmlint: ignore[invalid_states_unrepresentable] `method` is the name of the
537// `RemoteHost` method that was called; `HostCall::checked` holds it to `LEDGER_METHODS`
538// where the document is read and where a call is recorded, and nothing reads a decision
539// out of the name.
540#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
541pub struct HostCall {
542 /// The `RemoteHost` method called, by its name.
543 pub method: String,
544 /// The change requests the call names, in the order it names them.
545 #[serde(default, skip_serializing_if = "Vec::is_empty")]
546 pub changes: Vec<ChangeId>,
547 /// What GitHub charges the call the real host sends.
548 pub charge: ReadCost,
549}
550
551impl HostCall {
552 /// Refuse an entry no call to this host could have written: a method it does not
553 /// answer, or a change request named by no identifier at all. A change request it
554 /// never opened is not refused — the real host charges a call it then refuses, and
555 /// so the ledger records one.
556 pub(crate) fn checked(&self) -> Result<()> {
557 if !LEDGER_METHODS.contains(&self.method.as_str()) {
558 return Err(Error::Invalid {
559 reason: format!(
560 "the call ledger records a call to {:?}, which is no method this host \
561 answers",
562 self.method
563 ),
564 });
565 }
566 if self.changes.iter().any(|id| id.0.trim().is_empty()) {
567 return Err(Error::Invalid {
568 reason: format!(
569 "the call ledger records a call to {:?} naming a change request with no \
570 identifier",
571 self.method
572 ),
573 });
574 }
575 Ok(())
576 }
577}
578
579/// One comment a host holds on a change request.
580///
581/// What `review_comments` answers a [`ReviewComment`](onevcs::ReviewComment) from:
582/// everything but `ours` and `reply_marker`, which are read out of the body exactly as
583/// the real host's are, and with the one thing a host keeps that a read does not
584/// show — when it last changed.
585// llmlint: ignore[invalid_states_unrepresentable] every text field is what the real host
586// reports as a string and `ReviewComment` carries as one; a seeded comment is the
587// journey's own scenario, and `check` refuses the two things no host could hold — an id
588// held twice, and a reply to a comment the change request does not carry.
589#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
590pub struct HostComment {
591 /// The host's id for it.
592 pub id: CommentId,
593 /// What kind it is, and — for a thread comment — its thread's flags.
594 pub kind: CommentKind,
595 /// Who wrote it.
596 pub author: String,
597 /// What it says.
598 pub body: String,
599 /// Where a person reads it.
600 pub url: String,
601 /// When it was written.
602 pub created_at: String,
603 /// When it last changed.
604 pub updated_at: String,
605 /// The comment it replies to in its thread.
606 #[serde(default, skip_serializing_if = "Option::is_none")]
607 pub in_reply_to: Option<CommentId>,
608 /// When, in this host's own count of changes to the change request's feedback, it
609 /// last changed — what a read marker is compared against. A seeded comment at `0`
610 /// is one every read from a marker has already seen.
611 #[serde(default)]
612 pub revision: u64,
613}
614
615/// One reply a host posted.
616#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
617pub struct Replied {
618 /// The change request it was posted on.
619 pub change: ChangeId,
620 /// The comment it was posted against.
621 pub comment: CommentId,
622 /// The idempotency key the call carried.
623 pub key: String,
624 /// The reply's own id.
625 pub reply: CommentId,
626 /// Whether it was posted in the comment's thread.
627 pub threaded: bool,
628}
629
630/// One description a host was handed for a change request after it was opened.
631///
632/// What `RemoteHost::describe_change` was given, verbatim: the title only where the
633/// call carried one, because a call that replaced the body alone left the title as
634/// it was, and a record that filled it in would say the caller wrote a title nobody
635/// wrote.
636// llmlint: ignore[invalid_states_unrepresentable] the title and body are the `&str`s the
637// seam hands over — a host places no shape on prose, and `onevcs`'s own `Subject` rule
638// was applied where the description was composed, before any host was asked.
639#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
640pub struct Described {
641 /// The change request the description was written to.
642 pub id: ChangeId,
643 /// The title the call replaced the change request's with, when it replaced one.
644 #[serde(default, skip_serializing_if = "Option::is_none")]
645 pub title: Option<String>,
646 /// The body the call replaced the change request's with.
647 pub body: String,
648}
649
650/// The `drafts` map of a document at any readable version.
651///
652/// A document written before version 9 spells a draft reason as the four fields of
653/// the one kind there was and no `kind` beside them; this build's reason is one of
654/// two kinds and says which. So a reason arriving without a `kind` is read as
655/// `awaiting-release` — exactly what it was — rather than refused, which is what
656/// keeps a consumer's checked-in scenario readable across the bump. A reason that
657/// *names* a kind is read as it names it, so nothing written by this build is
658/// reinterpreted.
659fn drafts_of_any_version<'de, D>(
660 deserializer: D,
661) -> std::result::Result<BTreeMap<ChangeId, DraftReason>, D::Error>
662where
663 D: serde::Deserializer<'de>,
664{
665 let raw: BTreeMap<ChangeId, serde_json::Map<String, serde_json::Value>> =
666 Deserialize::deserialize(deserializer)?;
667 raw.into_iter()
668 .map(|(id, mut fields)| {
669 fields
670 .entry("kind")
671 .or_insert_with(|| serde_json::Value::from("awaiting-release"));
672 serde_json::from_value::<DraftReason>(serde_json::Value::Object(fields))
673 .map(|reason| (id, reason))
674 .map_err(serde::de::Error::custom)
675 })
676 .collect()
677}
678
679/// Who a host with nothing seeded says is calling.
680///
681/// A host that answers nobody is refused by the real implementation, so a default
682/// state that answered nobody would be a provider that cannot run a publication
683/// until it is configured.
684pub const DEFAULT_AUTHENTICATED_USER: &str = "onevcs-testing";
685
686impl Default for HostState {
687 fn default() -> Self {
688 Self {
689 version: STATE_VERSION,
690 authenticated_user: DEFAULT_AUTHENTICATED_USER.to_owned(),
691 changes: Vec::new(),
692 heads: BTreeMap::new(),
693 titles: BTreeMap::new(),
694 bodies: BTreeMap::new(),
695 drafts: BTreeMap::new(),
696 made_ready: Vec::new(),
697 awaiting_checks: BTreeSet::new(),
698 checks_after_lift: BTreeMap::new(),
699 required_checks: None,
700 described: Vec::new(),
701 checks: BTreeMap::new(),
702 check_logs: BTreeMap::new(),
703 check_sources: None,
704 merges: BTreeMap::new(),
705 merge_times: BTreeMap::new(),
706 review_comments: BTreeMap::new(),
707 replies: Vec::new(),
708 review_charges: Vec::new(),
709 closed: BTreeSet::new(),
710 deleted_branches: BTreeSet::new(),
711 head_checks: BTreeMap::new(),
712 ledger: Vec::new(),
713 }
714 }
715}
716
717/// The identity a session request names, or the reason none of them is it.
718///
719/// Three ways to name one, mirroring what the registry accepts: the identity key
720/// itself, the `owner/name` tail of it, or the bare repository name.
721pub(crate) fn identity_of<'a>(state: &'a VcsState, origin_or_path: &str) -> Option<&'a Identity> {
722 let wanted = origin_or_path.trim_end_matches('/');
723 state
724 .identities
725 .iter()
726 .find(|identity| identity.origin == wanted)
727 .or_else(|| {
728 state.identities.iter().find(|identity| {
729 identity
730 .origin
731 .rsplit('/')
732 .next()
733 .is_some_and(|name| name == wanted)
734 || identity.origin.ends_with(&format!("/{wanted}"))
735 })
736 })
737}
738
739/// The known identities, as a refusal names them.
740pub(crate) fn known(state: &VcsState) -> String {
741 if state.identities.is_empty() {
742 return "this provider was seeded with no identities".to_owned();
743 }
744 let names: Vec<&str> = state
745 .identities
746 .iter()
747 .map(|identity| identity.origin.as_str())
748 .collect();
749 format!("it knows {}", names.join(", "))
750}
751
752/// The identity a session belongs to, or the reason this provider cannot say.
753///
754/// `open_session` records it and nothing else writes it, so a session that arrived
755/// in a hand-written scenario without one is refused here rather than published
756/// against a repository nobody named.
757pub(crate) fn identity_for(state: &VcsState, token: &SessionToken) -> Result<String> {
758 state
759 .session_identities
760 .get(token)
761 .cloned()
762 .ok_or_else(|| Error::Invalid {
763 reason: format!(
764 "this provider has no record of session {:?}, so it cannot say which identity \
765 its work belongs to",
766 token.0
767 ),
768 })
769}
770
771/// The session a token names.
772pub(crate) fn session_of<'a>(state: &'a VcsState, token: &SessionToken) -> Option<&'a Session> {
773 state
774 .sessions
775 .iter()
776 .find(|session| session.token == *token)
777}
778
779/// The branch a request asks for, or the one that is derived from the token.
780///
781/// `branch` and `branch_name` are two answers to one question — *continue this* and
782/// *cut one at this* — so a request naming both is refused here as the real
783/// implementation refuses it: that refusal is about the shape of the request rather
784/// than about anything a repository does, and a consumer proving it must meet the
785/// same answer on either side.
786///
787/// **What a provider deliberately does not do to `branch_name` is the rest**, and it
788/// is not approximated: the host's branch prefix is read out of an `onevcs` state
789/// root no provider has, and the first-free suffix is searched against an identity's
790/// checkouts and its origin, which a provider has neither of. So the name is taken as
791/// it was proposed and refused — naming it — where git would refuse it, rather than
792/// being sanitized by a second copy of a grammar that would then have to be held to
793/// the first. A consumer proving what the prefix, the sanitizer and the collision
794/// suffix do drives the real `onevcs`, which is where all three live.
795pub(crate) fn requested_branch(req: &SessionRequest, token: &SessionToken) -> Result<String> {
796 if let (Some(pinned), Some(proposed)) = (&req.branch, &req.branch_name) {
797 return Err(Error::Invalid {
798 reason: format!(
799 "this request names both a branch to continue ({pinned:?}) and a name to cut \
800 ({proposed:?}), which are two answers to one question"
801 ),
802 });
803 }
804 let name = req
805 .branch
806 .clone()
807 .or_else(|| req.branch_name.clone())
808 .unwrap_or_else(|| format!("onevcs/{}", token.0));
809 named_branch(&name, "the branch")?;
810 Ok(name)
811}
812
813/// A branch name, refused here if git would refuse it.
814///
815/// The real implementation asks `git check-ref-format`, which is the parser that
816/// decides; a provider with no git carries `git-check-ref-format(1)`'s rules
817/// instead. That is a restatement, so it is gated rather than trusted:
818/// `refs.rs` in the suite runs both this and git itself over a table of names
819/// and holds them to each other, because a copy of somebody else's grammar with
820/// no gate is a copy that drifts.
821///
822/// One deliberate difference, and the gate knows about it: a leading `-` is
823/// refused here even though git accepts it as a ref, because such a name reaches
824/// a command line as an option rather than as the branch it spells.
825pub(crate) fn named_branch(value: &str, what: &str) -> Result<()> {
826 // Rule 1 is per slash-separated component; the rest are about the whole name.
827 let components_usable = !value.is_empty()
828 && value.split('/').all(|component| {
829 !component.is_empty() && !component.starts_with('.') && !component.ends_with(".lock")
830 });
831 let usable = components_usable
832 && !value.starts_with('-')
833 && !value.contains("..")
834 && !value.contains("@{")
835 && !value.ends_with('.')
836 && !value.ends_with('/')
837 && !value.chars().any(|c| {
838 c.is_whitespace() || c.is_ascii_control() || c == '\u{7f}' || "~^:?*[\\".contains(c)
839 });
840 if !usable {
841 return Err(Error::Invalid {
842 reason: format!("{what} {value:?} is a name git would not accept"),
843 });
844 }
845 Ok(())
846}
847
848/// A label, refused here where the real implementation refuses one: a key is one or
849/// more of `A-Z`, `a-z`, `0-9`, `_` and `-`, and a value is one line. The same rule
850/// spelled twice on purpose, for the reason [`named_branch`] gives — a provider with
851/// no `onevcs` state root carries the grammar, and the journeys over both providers
852/// hold the two to each other.
853pub(crate) fn label_pair(key: &str, value: &str) -> Result<()> {
854 let key_usable = !key.is_empty()
855 && key
856 .chars()
857 .all(|c| c.is_ascii_alphanumeric() || c == '_' || c == '-');
858 if !key_usable {
859 return Err(Error::Invalid {
860 reason: format!(
861 "{key:?} is not a label key; a key is one or more of A-Z, a-z, 0-9, `_` and `-`"
862 ),
863 });
864 }
865 if value.contains('\n') {
866 return Err(Error::Invalid {
867 reason: format!(
868 "the value of label {key:?} holds a newline; a label's value is one line"
869 ),
870 });
871 }
872 Ok(())
873}
874
875/// A seeded repository side is refused if it holds a session nothing could act on.
876impl Checked for VcsState {
877 fn check(&self) -> Result<()> {
878 readable_version(self.version)?;
879 for session in &self.sessions {
880 // The token names a file under the state root, and a branch goes on to
881 // spell a ref; both arrive from whoever wrote the document.
882 if !events::is_safe_name(&session.token.0) {
883 return Err(Error::Invalid {
884 reason: format!("{:?} is not a session token", session.token.0),
885 });
886 }
887 named_branch(&session.branch, "the branch")?;
888 named_branch(&session.base, "the base")?;
889 }
890 for row in &self.preserved {
891 known_identity(self, &row.identity, "preserved work")?;
892 named_branch(&row.branch.branch, "the preserved branch")?;
893 named_branch(&row.branch.base, "the preserved branch's base")?;
894 // A hold that names a session is checked like the three below: a row
895 // held by a session nobody opened is the same fiction, and the costly one
896 // — it is the session an operator is told to wait for or close. A running
897 // publication holds a branch under no session and names none.
898 if let Some(token) = row.held_by.as_ref().and_then(|held| held.token.as_ref()) {
899 opened(self, token, "holding preserved work")?;
900 }
901 }
902 // Both of these name a session, so both are checked twice over: the token
903 // has to be a plain name, because it goes on to spell the file its stream is
904 // written in, and it has to name a session this state actually holds. A
905 // document that closes or publishes a session nobody opened describes a run
906 // that could not have happened, and answering `recoverable` or `session`
907 // from it would be answering from a fiction rather than refusing one.
908 for token in &self.closed_sessions {
909 opened(self, token, "closed")?;
910 }
911 for (token, labels) in &self.session_labels {
912 opened(self, token, "labelled")?;
913 for (key, value) in labels {
914 label_pair(key, value)?;
915 }
916 }
917 for (token, origin) in &self.session_identities {
918 opened(self, token, "given an identity")?;
919 // The value as well as the key: this is what `identity_for` answers with,
920 // and it goes on to spell the slug a change request is opened against and
921 // the label every one of that session's events carries. An identity this
922 // provider does not know is one it could not have opened the session for.
923 known_identity(self, origin, &format!("session {:?}", token.0))?;
924 }
925 for publication in &self.publications {
926 let session = opened(self, &publication.session, "published")?;
927 named_branch(&publication.branch, "the published branch")?;
928 // A publication of some other branch than the one the session is on is
929 // the same kind of fiction, and the harder one to spot afterwards: the
930 // branch is what a journey asserts the publication was of.
931 if publication.branch != session.branch {
932 return Err(Error::Invalid {
933 reason: format!(
934 "the publication of session {:?} names branch {:?}, but that session is \
935 on {:?}",
936 publication.session.0, publication.branch, session.branch
937 ),
938 });
939 }
940 }
941 Ok(())
942 }
943
944 /// Every field an older readable document could hold means here what it meant
945 /// there, and the two the repository side gained in version 4 are absent from one
946 /// written before them — which is the answer, since that build held no hold and
947 /// counted no lines.
948 ///
949 /// Version 5's field is the exception, and it is carried rather than left at its
950 /// default: a document written before it *listed preserved work nobody had
951 /// published*, which is the `no` this build spells out. Left at the default it
952 /// would read as "nothing here can say", and a consumer's checked-in scenario
953 /// would start reporting work it had always called unpublished as work that may
954 /// have landed.
955 fn carry_forward(&mut self) {
956 if self.version < 5 {
957 for row in &mut self.preserved {
958 row.landed = Landed::No;
959 }
960 }
961 self.version = STATE_VERSION;
962 }
963}
964
965/// Refuse a record kept about a change request this state does not hold.
966fn opened_change(state: &HostState, id: &ChangeId, what: &str) -> Result<()> {
967 if state.changes.iter().any(|change| change.id == *id) {
968 return Ok(());
969 }
970 Err(Error::Invalid {
971 reason: format!(
972 "{what} is recorded for change request {:?}, but no change request by that \
973 identifier was opened",
974 id.0
975 ),
976 })
977}
978
979/// Refuse an identity key this provider was not seeded with.
980fn known_identity(state: &VcsState, origin: &str, what: &str) -> Result<()> {
981 if state
982 .identities
983 .iter()
984 .any(|identity| identity.origin == origin)
985 {
986 return Ok(());
987 }
988 Err(Error::Invalid {
989 reason: format!(
990 "{what} belongs to identity {origin:?}, which this provider does not know; {}",
991 known(state)
992 ),
993 })
994}
995
996/// A change request's title, refused when it names nothing.
997///
998/// The one thing a real host refuses about a title, and the only one this provider
999/// may: how long a title may be is the host's own rule rather than `onevcs`'s
1000/// commit-subject rule, and a provider applying the stricter of the two would
1001/// refuse what the host it stands in for accepts.
1002pub(crate) fn titled(title: &str) -> Result<()> {
1003 if title.trim().is_empty() {
1004 return Err(Error::Invalid {
1005 reason: "a change request's title is blank, so it names no change".to_owned(),
1006 });
1007 }
1008 Ok(())
1009}
1010
1011/// The session a token names, refused when this state does not hold one.
1012fn opened<'a>(state: &'a VcsState, token: &SessionToken, what: &str) -> Result<&'a Session> {
1013 if !events::is_safe_name(&token.0) {
1014 return Err(Error::Invalid {
1015 reason: format!("{:?} is not a session token", token.0),
1016 });
1017 }
1018 session_of(state, token).ok_or_else(|| Error::Invalid {
1019 reason: format!(
1020 "session {:?} is {what} here, but no session by that token was opened",
1021 token.0
1022 ),
1023 })
1024}
1025
1026/// A seeded host side is refused if it holds a change nothing could address.
1027impl Checked for HostState {
1028 fn check(&self) -> Result<()> {
1029 readable_version(self.version)?;
1030 for change in &self.changes {
1031 named_branch(&change.base, "the base of a seeded change request")?;
1032 if change.id.0.is_empty() {
1033 return Err(Error::Invalid {
1034 reason: "a seeded change request carries no identifier".to_owned(),
1035 });
1036 }
1037 // The commit a change request's checks are reported against is the whole
1038 // evidence that a change reached anything, and the real implementation
1039 // refuses a host answer that names none rather than passing a blank one
1040 // through. A seeded one is refused for the same reason.
1041 if change.head_sha.0.trim().is_empty() {
1042 return Err(Error::Invalid {
1043 reason: format!(
1044 "the seeded change request {:?} names no commit its checks are \
1045 reported against",
1046 change.id.0
1047 ),
1048 });
1049 }
1050 }
1051 // Both of these are recorded *about* a change request, by `open_change` and
1052 // by nothing else, and both are read back by the id they are keyed under. An
1053 // entry for a change nobody opened is one no call could ever reach, so it is
1054 // refused rather than carried — unlike the checks, logs, and merge outcomes
1055 // below it, which a journey deliberately seeds for a change it has not
1056 // opened yet.
1057 for (id, head) in &self.heads {
1058 opened_change(self, id, "a head")?;
1059 named_branch(head, "the head of a seeded change request")?;
1060 }
1061 for (id, title) in &self.titles {
1062 opened_change(self, id, "a title")?;
1063 // The real host refuses a title that names nothing, so a seeded one is
1064 // refused for the same reason.
1065 titled(title)?;
1066 }
1067 for id in self.bodies.keys() {
1068 // Nothing is refused about the body itself: a host places no shape on
1069 // prose, and a change request opened with an empty one is a scenario.
1070 opened_change(self, id, "a body")?;
1071 }
1072 for (id, reason) in &self.drafts {
1073 opened_change(self, id, "a draft reason")?;
1074 // The publication rule the crate next door states, applied rather than
1075 // restated: a seeded reason no publication could have carried is refused
1076 // where the document is read, not answered from later.
1077 reason.checked()?;
1078 }
1079 for id in &self.made_ready {
1080 opened_change(self, id, "a lifted draft")?;
1081 }
1082 for id in &self.awaiting_checks {
1083 opened_change(self, id, "a draft awaiting its checks")?;
1084 }
1085 for described in &self.described {
1086 opened_change(self, &described.id, "a description")?;
1087 // The real host refuses a title that names nothing, so a seeded one is
1088 // refused for the same reason — and a body is prose, refused for nothing.
1089 if let Some(title) = &described.title {
1090 titled(title)?;
1091 }
1092 }
1093 // Review feedback is read by the change request it is keyed under, and a reply
1094 // names the comment it answers, so a comment on a change nobody opened, an id
1095 // held twice, or a reply to a comment that is not there is one no read could
1096 // answer as the real host would.
1097 for (id, comments) in &self.review_comments {
1098 opened_change(self, id, "review feedback")?;
1099 let mut held = BTreeSet::new();
1100 for comment in comments {
1101 if comment.id.0.trim().is_empty() || !held.insert(&comment.id) {
1102 return Err(Error::Invalid {
1103 reason: format!(
1104 "the review feedback seeded for change request {:?} holds the \
1105 comment id {:?} more than once, or an empty one",
1106 id.0, comment.id.0
1107 ),
1108 });
1109 }
1110 }
1111 for comment in comments {
1112 // A read hands these on as the RFC 3339 moments the contract promises.
1113 for (field, at) in [
1114 ("created_at", &comment.created_at),
1115 ("updated_at", &comment.updated_at),
1116 ] {
1117 if events::moment(at).is_none() {
1118 return Err(Error::Invalid {
1119 reason: format!(
1120 "comment {:?} on change request {:?} has {field} {at:?}, which \
1121 is not an RFC 3339 moment",
1122 comment.id.0, id.0
1123 ),
1124 });
1125 }
1126 }
1127 if let Some(answered) = &comment.in_reply_to {
1128 if !held.contains(answered) {
1129 return Err(Error::Invalid {
1130 reason: format!(
1131 "comment {:?} on change request {:?} replies to {:?}, which \
1132 that change request does not carry",
1133 comment.id.0, id.0, answered.0
1134 ),
1135 });
1136 }
1137 }
1138 }
1139 }
1140 for id in &self.closed {
1141 opened_change(self, id, "a closing")?;
1142 }
1143 for branch in &self.deleted_branches {
1144 named_branch(branch, "a deleted branch")?;
1145 }
1146 for call in &self.ledger {
1147 call.checked()?;
1148 }
1149 // A merge time is what `merge_time` answers and what a landing is recorded
1150 // with, so a seeded one that is not a moment is refused here, where the
1151 // document is read, rather than recorded as one.
1152 for (id, at) in &self.merge_times {
1153 if events::moment(at).is_none() {
1154 return Err(Error::Invalid {
1155 reason: format!(
1156 "the merge time seeded for change request {:?} is {at:?}, which is \
1157 not an RFC3339 moment",
1158 id.0
1159 ),
1160 });
1161 }
1162 }
1163 Ok(())
1164 }
1165
1166 /// A version 2 document held no bodies, and a version 5 document's checks named
1167 /// no commit; each reads as what it was — change requests opened with none, and
1168 /// checks whose head that build never recorded. There is nothing to fill in — an
1169 /// absent field is already that answer, and a check's commit is the one thing
1170 /// that must never be inferred — so this is the version and nothing else. The one
1171 /// carry a version 8 document needs, the `kind` its draft reasons lack, is done
1172 /// where those are read (`drafts_of_any_version`), because it is a fact about
1173 /// one value's shape rather than about the document.
1174 fn carry_forward(&mut self) {
1175 self.version = STATE_VERSION;
1176 }
1177}
1178
1179/// Refuse a document written at a version this build does not read.
1180///
1181/// Named rather than guessed at: a state whose shape is a later build's reads one
1182/// way here and another way where that version is understood, and for a seeded
1183/// scenario those two readings are two different tests. The refusal names the
1184/// range as well as the version, because "too old" and "too new" are two different
1185/// things to do about it — one is a document to re-seed, the other a build to
1186/// update.
1187fn readable_version(declared: u32) -> Result<()> {
1188 if !(OLDEST_READABLE_VERSION..=STATE_VERSION).contains(&declared) {
1189 return Err(Error::Invalid {
1190 reason: format!(
1191 "the document declares version {declared}; this build reads versions \
1192 {OLDEST_READABLE_VERSION} to {STATE_VERSION}"
1193 ),
1194 });
1195 }
1196 Ok(())
1197}