Skip to main content

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