1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
// @generated by idiolect-codegen. do not edit.
// source: dev.idiolect.encounter
//! A signed record of a single lens invocation. Encounters are the emergent-channel primitive: they record that a translation occurred, with enough context for aggregators (observations) and correctors to reason about it. `use` is a structured ThUse (see dev.idiolect.theory.use) covering action/material/purpose/actor; narrative commentary lives in `annotations`.
#![allow(
missing_docs,
clippy::doc_markdown,
clippy::struct_excessive_bools,
clippy::derive_partial_eq_without_eq,
clippy::large_enum_variant
)]
use serde::{Deserialize, Serialize};
/// One invocation of a lens on a source, producing an output. The invoker asserts a purposeful invocation: structured `purpose` records the decision-relevant action/material/actor triple, resolvable against a community vocabulary.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Encounter {
/// Narrative notes from the invoking party. Human commentary; not consumed by machine matchers.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub annotations: Option<String>,
/// Structured grounding for the assertion. Useful when `holder` is a third party and the record must state on what basis the invocation is being attributed.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub basis: Option<crate::generated::dev::idiolect::defs::Basis>,
/// Open-enum outcome slug as assessed by the invoking party at record time. Resolved against `downstreamResultVocab` when present; `corrected` signals a follow-up correction record is expected or exists.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub downstream_result: Option<EncounterDownstreamResult>,
/// Vocabulary the `downstreamResult` slug resolves against.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub downstream_result_vocab: Option<crate::generated::dev::idiolect::defs::VocabRef>,
/// DID of the party the encounter is attributed to. Omit for first-party records (holder is implicit in the repo owner); set explicitly for third-party attestations such as a labeler recording someone else's invocation.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub holder: Option<idiolect_records::Did>,
/// Open-enum corpus-kind slug. Resolved against `kindVocab` when present; observers declare how they weight each kind.
pub kind: EncounterKind,
/// Vocabulary the `kind` slug resolves against.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub kind_vocab: Option<crate::generated::dev::idiolect::defs::VocabRef>,
/// The lens that was invoked.
pub lens: crate::generated::dev::idiolect::defs::LensRef,
/// When the lens invocation occurred. Distinct from the record's createdAt, which may be later.
pub occurred_at: idiolect_records::Datetime,
/// Optional content-addressed reference to the produced output.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub produced_output: Option<idiolect_records::Cid>,
/// Optional content-addressed reference to the source instance, when the publisher is willing to include it. Omit when visibility restricts publication of source data.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub source_instance: Option<idiolect_records::Cid>,
/// The source schema the lens translated from.
pub source_schema: crate::generated::dev::idiolect::defs::SchemaRef,
/// The target schema produced by the lens. Often implied by the lens; may be elided when unambiguous.
#[serde(default, skip_serializing_if = "Option::is_none")]
pub target_schema: Option<crate::generated::dev::idiolect::defs::SchemaRef>,
/// Structured record of the action performed, its material, its purpose, and its actor. Consumers match on action subsumption against the referenced vocabularies, not substring.
pub r#use: crate::generated::dev::idiolect::defs::Use,
pub visibility: crate::generated::dev::idiolect::defs::Visibility,
}
impl crate::Record for Encounter {
const NSID: &'static str = "dev.idiolect.encounter";
}
/// EncounterDownstreamResult. Open-enum slug; known values are kebab-cased; community-extended values pass through as `Other(String)`.
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum EncounterDownstreamResult {
Success,
Corrected,
Rejected,
Unknown,
/// Community-extended slug not present in the lexicon's
/// `knownValues`. Resolves through the sibling
/// `*Vocab` field on the containing record.
Other(String),
}
impl EncounterDownstreamResult {
/// Wire-form slug for this value. Known variants render
/// kebab-case; the fallback variant passes through verbatim.
#[must_use]
pub fn as_str(&self) -> &str {
match self {
Self::Success => "success",
Self::Corrected => "corrected",
Self::Rejected => "rejected",
Self::Unknown => "unknown",
Self::Other(s) => s.as_str(),
}
}
/// Whether this slug is subsumed by `ancestor` under the
/// `subsumed_by` relation in the supplied vocab. Reflexive:
/// every slug is subsumed by itself.
#[must_use]
pub fn is_subsumed_by(
&self,
vocab: &idiolect_records::vocab::VocabGraph,
ancestor: &str,
) -> bool {
vocab.is_subsumed_by(self.as_str(), ancestor)
}
/// Whether this slug satisfies a requirement of `target`
/// under the named `relation` in the supplied vocab.
/// Generalises `is_subsumed_by` to any directed relation
/// (e.g. `stronger_than`, `provides_at_least`,
/// `equivalent_to`). Reflexive: a slug satisfies itself.
#[must_use]
pub fn satisfies(
&self,
vocab: &idiolect_records::vocab::VocabGraph,
relation: &str,
target: &str,
) -> bool {
if self.as_str() == target {
return true;
}
vocab
.walk_relation(self.as_str(), relation, false)
.iter()
.any(|n| n == target)
}
/// Translate this slug across vocabularies via
/// `equivalent_to` edges. Returns the translated slug as
/// a target enum value when a translation exists, `None`
/// when no path is found (callers fall back to passing
/// the slug through verbatim, which is wire-compatible).
#[must_use]
pub fn translate_to<T: From<String>>(
&self,
src_vocab_uri: &str,
tgt_vocab_uri: &str,
registry: &idiolect_records::vocab::VocabRegistry,
) -> Option<T> {
registry
.translate(src_vocab_uri, tgt_vocab_uri, self.as_str())
.map(T::from)
}
}
impl From<String> for EncounterDownstreamResult {
fn from(s: String) -> Self {
match s.as_str() {
"success" => Self::Success,
"corrected" => Self::Corrected,
"rejected" => Self::Rejected,
"unknown" => Self::Unknown,
_ => Self::Other(s),
}
}
}
impl From<&str> for EncounterDownstreamResult {
fn from(s: &str) -> Self {
match s {
"success" => Self::Success,
"corrected" => Self::Corrected,
"rejected" => Self::Rejected,
"unknown" => Self::Unknown,
_ => Self::Other(s.to_owned()),
}
}
}
impl serde::Serialize for EncounterDownstreamResult {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
serializer.serialize_str(self.as_str())
}
}
impl<'de> serde::Deserialize<'de> for EncounterDownstreamResult {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
let s = String::deserialize(deserializer)?;
Ok(Self::from(s))
}
}
/// EncounterKind. Open-enum slug; known values are kebab-cased; community-extended values pass through as `Other(String)`.
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum EncounterKind {
InvocationLog,
Curated,
RoundtripVerified,
Production,
Adversarial,
/// Community-extended slug not present in the lexicon's
/// `knownValues`. Resolves through the sibling
/// `*Vocab` field on the containing record.
Other(String),
}
impl EncounterKind {
/// Wire-form slug for this value. Known variants render
/// kebab-case; the fallback variant passes through verbatim.
#[must_use]
pub fn as_str(&self) -> &str {
match self {
Self::InvocationLog => "invocation-log",
Self::Curated => "curated",
Self::RoundtripVerified => "roundtrip-verified",
Self::Production => "production",
Self::Adversarial => "adversarial",
Self::Other(s) => s.as_str(),
}
}
/// Whether this slug is subsumed by `ancestor` under the
/// `subsumed_by` relation in the supplied vocab. Reflexive:
/// every slug is subsumed by itself.
#[must_use]
pub fn is_subsumed_by(
&self,
vocab: &idiolect_records::vocab::VocabGraph,
ancestor: &str,
) -> bool {
vocab.is_subsumed_by(self.as_str(), ancestor)
}
/// Whether this slug satisfies a requirement of `target`
/// under the named `relation` in the supplied vocab.
/// Generalises `is_subsumed_by` to any directed relation
/// (e.g. `stronger_than`, `provides_at_least`,
/// `equivalent_to`). Reflexive: a slug satisfies itself.
#[must_use]
pub fn satisfies(
&self,
vocab: &idiolect_records::vocab::VocabGraph,
relation: &str,
target: &str,
) -> bool {
if self.as_str() == target {
return true;
}
vocab
.walk_relation(self.as_str(), relation, false)
.iter()
.any(|n| n == target)
}
/// Translate this slug across vocabularies via
/// `equivalent_to` edges. Returns the translated slug as
/// a target enum value when a translation exists, `None`
/// when no path is found (callers fall back to passing
/// the slug through verbatim, which is wire-compatible).
#[must_use]
pub fn translate_to<T: From<String>>(
&self,
src_vocab_uri: &str,
tgt_vocab_uri: &str,
registry: &idiolect_records::vocab::VocabRegistry,
) -> Option<T> {
registry
.translate(src_vocab_uri, tgt_vocab_uri, self.as_str())
.map(T::from)
}
}
impl From<String> for EncounterKind {
fn from(s: String) -> Self {
match s.as_str() {
"invocation-log" => Self::InvocationLog,
"curated" => Self::Curated,
"roundtrip-verified" => Self::RoundtripVerified,
"production" => Self::Production,
"adversarial" => Self::Adversarial,
_ => Self::Other(s),
}
}
}
impl From<&str> for EncounterKind {
fn from(s: &str) -> Self {
match s {
"invocation-log" => Self::InvocationLog,
"curated" => Self::Curated,
"roundtrip-verified" => Self::RoundtripVerified,
"production" => Self::Production,
"adversarial" => Self::Adversarial,
_ => Self::Other(s.to_owned()),
}
}
}
impl serde::Serialize for EncounterKind {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
serializer.serialize_str(self.as_str())
}
}
impl<'de> serde::Deserialize<'de> for EncounterKind {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
let s = String::deserialize(deserializer)?;
Ok(Self::from(s))
}
}