OXYGENHUB
# 992467d31d26 oxygen / crates / oxy-core / src / tree.rs
28.0 KiB · Rust · last changed A cheaper tree view; history loads and snapshots timed finer 1 month ago source blame history raw
1
//! The tree graph: nodes, placements, and modes as atoms (spec §7.1, §7.2),
2
//! with tree conflict detection and path assignment (spec §9.2).
3
4
use crate::hash::ChangeHash;
5
use crate::ids::NodeId;
6
use crate::objects::{Mode, NodeKind, OpRef, TreeOp};
7
use std::collections::{BTreeMap, BTreeSet, HashMap, HashSet};
8
9
/// `(change, index into that change's tree_ops)`.
10
pub type OpKey = (ChangeHash, u32);
11
12
#[derive(Clone, Debug, PartialEq, Eq)]
13
pub struct Placement {
14
    pub node: NodeId,
15
    pub parent: NodeId,
16
    pub name: String,
17
}
18
19
#[derive(Clone, Debug, Default)]
20
pub struct TreeGraph {
21
    kinds: HashMap<NodeId, NodeKind>,
22
    introduced: HashMap<NodeId, ChangeHash>,
23
    placements: HashMap<OpKey, Placement>,
24
    modes: HashMap<OpKey, (NodeId, Mode)>,
25
    /// Placement atoms retired by `RemoveNode`/`Move`, and mode atoms retired
26
    /// by `SetMode`. Kept apart because `AddNode` introduces one of each
27
    /// under the same key.
28
    deleted_placements: HashMap<OpKey, BTreeSet<ChangeHash>>,
29
    deleted_modes: HashMap<OpKey, BTreeSet<ChangeHash>>,
30
    placements_of: HashMap<NodeId, BTreeSet<OpKey>>,
31
    modes_of: HashMap<NodeId, BTreeSet<OpKey>>,
32
}
33
34
#[derive(Clone, Debug, PartialEq, Eq)]
35
pub enum TreeConflict {
36
    /// Two live nodes share `(parent, name)`.
37
    Name {
38
        parent: NodeId,
39
        name: String,
40
        nodes: Vec<NodeId>,
41
    },
42
    /// One node has several live placements.
43
    MultiPlacement {
44
        node: NodeId,
45
        placements: Vec<OpKey>,
46
    },
47
    /// A live node's parent is not live.
48
    Orphan { node: NodeId, parent: NodeId },
49
    /// A directory is placed inside its own descendant.
50
    Cycle { node: NodeId },
51
    /// Several live mode atoms.
52
    Mode { node: NodeId, modes: Vec<Mode> },
53
}
54
55
/// A node as it appears in the working copy.
56
#[derive(Clone, Debug, PartialEq, Eq)]
57
pub struct TreeEntry {
58
    pub path: String,
59
    pub node: NodeId,
60
    pub kind: NodeKind,
61
    pub mode: Mode,
62
    /// The placement this entry materializes (for building `RemoveNode`/`Move`).
63
    pub placement: OpKey,
64
    /// The live mode atom (for building `SetMode`).
65
    pub mode_atom: Option<OpKey>,
66
}
67
68
#[derive(Clone, Debug, Default, PartialEq, Eq)]
69
pub struct TreeView {
70
    /// Path → entry, paths use `/` and have no leading slash; conflicted
71
    /// entries carry a `.oxy-conflict-<n>` suffix.
72
    pub entries: BTreeMap<String, TreeEntry>,
73
    pub conflicts: Vec<TreeConflict>,
74
}
75
76
impl TreeView {
77
    pub fn is_conflicted(&self) -> bool {
78
        !self.conflicts.is_empty()
79
    }
80
    pub fn by_node(&self) -> HashMap<NodeId, &TreeEntry> {
81
        self.entries.values().map(|e| (e.node, e)).collect()
82
    }
83
}
84
85
impl TreeGraph {
86
    pub fn new() -> Self {
87
        Self::default()
88
    }
89
90
    /// Apply tree op `index` of `change`; `OpRef` self references must already be resolved.
91
    pub fn apply(&mut self, change: ChangeHash, index: u32, op: &TreeOp) {
92
        let key = (change, index);
93
        match op {
94
            TreeOp::AddNode {
95
                node,
96
                kind,
97
                mode,
98
                parent,
99
                name,
100
            } => {
101
                self.kinds.insert(*node, *kind);
102
                self.introduced.insert(*node, change);
103
                self.placements.insert(
104
                    key,
105
                    Placement {
106
                        node: *node,
107
                        parent: *parent,
108
                        name: name.clone(),
109
                    },
110
                );
111
                self.placements_of.entry(*node).or_default().insert(key);
112
                if *kind != NodeKind::Dir {
113
                    self.modes.insert(key, (*node, *mode));
114
                    self.modes_of.entry(*node).or_default().insert(key);
115
                }
116
            }
117
            TreeOp::RemoveNode { placement, .. } => {
118
                self.deleted_placements
119
                    .entry(op_key(*placement))
120
                    .or_default()
121
                    .insert(change);
122
            }
123
            TreeOp::Move {
124
                node,
125
                old,
126
                parent,
127
                name,
128
            } => {
129
                self.deleted_placements
130
                    .entry(op_key(*old))
131
                    .or_default()
132
                    .insert(change);
133
                self.placements.insert(
134
                    key,
135
                    Placement {
136
                        node: *node,
137
                        parent: *parent,
138
                        name: name.clone(),
139
                    },
140
                );
141
                self.placements_of.entry(*node).or_default().insert(key);
142
            }
143
            TreeOp::SetMode { node, old, mode } => {
144
                self.deleted_modes
145
                    .entry(op_key(*old))
146
                    .or_default()
147
                    .insert(change);
148
                self.modes.insert(key, (*node, *mode));
149
                self.modes_of.entry(*node).or_default().insert(key);
150
            }
151
        }
152
    }
153
154
    fn placement_live(&self, k: &OpKey) -> bool {
155
        self.deleted_placements.get(k).is_none_or(|d| d.is_empty())
156
    }
157
    fn mode_live(&self, k: &OpKey) -> bool {
158
        self.deleted_modes.get(k).is_none_or(|d| d.is_empty())
159
    }
160
161
    pub fn kind(&self, node: &NodeId) -> Option<NodeKind> {
162
        if node.is_root() {
163
            Some(NodeKind::Dir)
164
        } else {
165
            self.kinds.get(node).copied()
166
        }
167
    }
168
169
    /// The change whose `AddNode` introduced `node`.
170
    pub fn introducer(&self, node: &NodeId) -> Option<ChangeHash> {
171
        self.introduced.get(node).copied()
172
    }
173
174
    pub fn placement(&self, k: &OpKey) -> Option<&Placement> {
175
        self.placements.get(k)
176
    }
177
178
    pub fn live_placements(&self, node: &NodeId) -> Vec<(OpKey, &Placement)> {
179
        self.placements_of
180
            .get(node)
181
            .into_iter()
182
            .flat_map(|ks| ks.iter())
183
            .filter(|k| self.placement_live(k))
184
            .filter_map(|k| self.placements.get(k).map(|p| (*k, p)))
185
            .collect()
186
    }
187
188
    pub fn live_modes(&self, node: &NodeId) -> Vec<(OpKey, Mode)> {
189
        self.modes_of
190
            .get(node)
191
            .into_iter()
192
            .flat_map(|ks| ks.iter())
193
            .filter(|k| self.mode_live(k))
194
            .filter_map(|k| self.modes.get(k).map(|(_, m)| (*k, *m)))
195
            .collect()
196
    }
197
198
    /// Every node that has at least one live placement.
199
    pub fn placed_nodes(&self) -> impl Iterator<Item = NodeId> + '_ {
200
        self.placements_of
201
            .keys()
202
            .copied()
203
            .filter(|n| !self.live_placements(n).is_empty())
204
    }
205
206
    /// Resolve the tree: assign paths, find conflicts.
207
    pub fn view(&self) -> TreeView {
208
        let mut view = TreeView::default();
209
210
        // Live placements grouped by parent.
211
        let mut children: HashMap<NodeId, Vec<(OpKey, &Placement)>> = HashMap::new();
212
        for (k, p) in &self.placements {
213
            if self.placement_live(k) {
214
                children.entry(p.parent).or_default().push((*k, p));
215
            }
216
        }
217
        for c in children.values_mut() {
218
            c.sort_by(|a, b| a.1.name.cmp(&b.1.name).then(a.0.cmp(&b.0)));
219
        }
220
221
        // Multi-placement and mode conflicts.
222
        let mut nodes: Vec<NodeId> = self.placements_of.keys().copied().collect();
223
        nodes.sort();
224
        let mut multi: HashSet<NodeId> = HashSet::new();
225
        // Each node's mode and the atom it comes from, for the entries.
226
        let mut modes: HashMap<NodeId, (Option<OpKey>, Mode)> = HashMap::new();
227
        for n in &nodes {
228
            let lp = self.live_placements(n);
229
            // One placement (nearly every node) cannot be in two places.
230
            if lp.len() > 1 {
231
                let distinct_places: BTreeSet<(&NodeId, &str)> = lp
232
                    .iter()
233
                    .map(|(_, p)| (&p.parent, p.name.as_str()))
234
                    .collect();
235
                if distinct_places.len() > 1 {
236
                    multi.insert(*n);
237
                    view.conflicts.push(TreeConflict::MultiPlacement {
238
                        node: *n,
239
                        placements: lp.iter().map(|(k, _)| *k).collect(),
240
                    });
241
                }
242
            }
243
            let lm = self.live_modes(n);
244
            if lm.len() > 1 {
245
                let distinct_modes: BTreeSet<Mode> = lm.iter().map(|(_, m)| *m).collect();
246
                if distinct_modes.len() > 1 {
247
                    view.conflicts.push(TreeConflict::Mode {
248
                        node: *n,
249
                        modes: distinct_modes.into_iter().collect(),
250
                    });
251
                }
252
            }
253
            let mode_atom = lm.iter().map(|(k, _)| *k).max();
254
            let mode = mode_atom
255
                .and_then(|k| self.modes.get(&k).map(|(_, m)| *m))
256
                .unwrap_or_default();
257
            modes.insert(*n, (mode_atom, mode));
258
        }
259
260
        // BFS from the root, assigning paths.
261
        let mut reached: HashSet<NodeId> = HashSet::new();
262
        reached.insert(NodeId::ROOT);
263
        let mut queue: Vec<(NodeId, String)> = vec![(NodeId::ROOT, String::new())];
264
        let mut on_path: HashSet<NodeId> = HashSet::new();
265
        while let Some((dir, dir_path)) = queue.pop() {
266
            let Some(kids) = children.get(&dir) else {
267
                continue;
268
            };
269
            // Name conflicts within this directory: the children are sorted
270
            // by name, so each name's group is a run of them.
271
            let mut groups: Vec<(&str, &[(OpKey, &Placement)])> = Vec::new();
272
            let mut start = 0;
273
            for i in 1..=kids.len() {
274
                if i == kids.len() || kids[i].1.name != kids[start].1.name {
275
                    groups.push((kids[start].1.name.as_str(), &kids[start..i]));
276
                    start = i;
277
                }
278
            }
279
            for (name, group) in groups {
280
                let distinct: BTreeSet<NodeId> = group.iter().map(|(_, p)| p.node).collect();
281
                if distinct.len() > 1 {
282
                    view.conflicts.push(TreeConflict::Name {
283
                        parent: dir,
284
                        name: name.to_string(),
285
                        nodes: distinct.iter().copied().collect(),
286
                    });
287
                }
288
                let suffixed = distinct.len() > 1;
289
                for (i, (k, p)) in group.iter().enumerate() {
290
                    let node = p.node;
291
                    if node == dir || on_path.contains(&node) {
292
                        view.conflicts.push(TreeConflict::Cycle { node });
293
                        continue;
294
                    }
295
                    let needs_suffix = suffixed || multi.contains(&node);
296
                    let leaf = if needs_suffix {
297
                        format!("{name}.oxy-conflict-{}", i + 1)
298
                    } else {
299
                        name.to_string()
300
                    };
301
                    let path = if dir_path.is_empty() {
302
                        leaf
303
                    } else {
304
                        format!("{dir_path}/{leaf}")
305
                    };
306
                    let kind = self.kind(&node).unwrap_or(NodeKind::File);
307
                    let (mode_atom, mode) = modes.get(&node).copied().unwrap_or_default();
308
                    view.entries.insert(
309
                        path.clone(),
310
                        TreeEntry {
311
                            path: path.clone(),
312
                            node,
313
                            kind,
314
                            mode,
315
                            placement: *k,
316
                            mode_atom,
317
                        },
318
                    );
319
                    if kind == NodeKind::Dir && reached.insert(node) {
320
                        on_path.insert(dir);
321
                        queue.push((node, path));
322
                    } else {
323
                        reached.insert(node);
324
                    }
325
                }
326
            }
327
        }
328
329
        // Nodes with live placements that were never reached: orphans or cycles.
330
        for n in &nodes {
331
            if reached.contains(n) {
332
                continue;
333
            }
334
            let lp = self.live_placements(n);
335
            if lp.is_empty() {
336
                continue;
337
            }
338
            let mut seen = HashSet::new();
339
            let mut cur = *n;
340
            let conflict = loop {
341
                if !seen.insert(cur) {
342
                    break TreeConflict::Cycle { node: *n };
343
                }
344
                let lp = self.live_placements(&cur);
345
                let Some((_, p)) = lp.first() else {
346
                    break TreeConflict::Orphan {
347
                        node: *n,
348
                        parent: cur,
349
                    };
350
                };
351
                if reached.contains(&p.parent) {
352
                    // Parent reached but this node was not: the parent is not a
353
                    // directory, so this is a name/kind problem surfaced as orphan.
354
                    break TreeConflict::Orphan {
355
                        node: *n,
356
                        parent: p.parent,
357
                    };
358
                }
359
                cur = p.parent;
360
            };
361
            if !view.conflicts.contains(&conflict) {
362
                view.conflicts.push(conflict);
363
            }
364
        }
365
        view
366
    }
367
}
368
369
impl TreeGraph {
370
    /// Serialize for a checkpoint.
371
    pub fn to_value(&self) -> crate::cbor::Value {
372
        use crate::cbor::Value;
373
        let opkey = |k: &OpKey| vec![Value::Bytes(k.0 .0.to_vec()), Value::Uint(k.1 as u64)];
374
        let deleters = |m: &HashMap<OpKey, BTreeSet<ChangeHash>>| {
375
            let mut ks: Vec<&OpKey> = m.keys().collect();
376
            ks.sort();
377
            Value::Array(
378
                ks.into_iter()
379
                    .map(|k| {
380
                        let mut v = opkey(k);
381
                        v.push(Value::Array(
382
                            m[k].iter().map(|d| Value::Bytes(d.0.to_vec())).collect(),
383
                        ));
384
                        Value::Array(v)
385
                    })
386
                    .collect(),
387
            )
388
        };
389
        let mut nodes: Vec<&NodeId> = self.kinds.keys().collect();
390
        nodes.sort();
391
        let mut pks: Vec<&OpKey> = self.placements.keys().collect();
392
        pks.sort();
393
        let mut mks: Vec<&OpKey> = self.modes.keys().collect();
394
        mks.sort();
395
        Value::map([
396
            (
397
                0,
398
                Value::Array(
399
                    nodes
400
                        .into_iter()
401
                        .map(|n| {
402
                            Value::Array(vec![
403
                                Value::Bytes(n.0.to_vec()),
404
                                Value::Uint(self.kinds[n].tag()),
405
                                self.introduced
406
                                    .get(n)
407
                                    .map(|h| Value::Bytes(h.0.to_vec()))
408
                                    .unwrap_or(Value::Null),
409
                            ])
410
                        })
411
                        .collect(),
412
                ),
413
            ),
414
            (
415
                1,
416
                Value::Array(
417
                    pks.into_iter()
418
                        .map(|k| {
419
                            let p = &self.placements[k];
420
                            let mut v = opkey(k);
421
                            v.extend([
422
                                Value::Bytes(p.node.0.to_vec()),
423
                                Value::Bytes(p.parent.0.to_vec()),
424
                                Value::Text(p.name.clone()),
425
                            ]);
426
                            Value::Array(v)
427
                        })
428
                        .collect(),
429
                ),
430
            ),
431
            (2, deleters(&self.deleted_placements)),
432
            (
433
                3,
434
                Value::Array(
435
                    mks.into_iter()
436
                        .map(|k| {
437
                            let (n, m) = &self.modes[k];
438
                            let mut v = opkey(k);
439
                            v.extend([Value::Bytes(n.0.to_vec()), Value::Uint(m.bits())]);
440
                            Value::Array(v)
441
                        })
442
                        .collect(),
443
                ),
444
            ),
445
            (4, deleters(&self.deleted_modes)),
446
        ])
447
    }
448
449
    pub fn from_value(v: &crate::cbor::Value) -> Result<TreeGraph, crate::objects::ObjectError> {
450
        use crate::objects::{array, bytes, field, map, oref, text, u32_, uint, ObjectError};
451
        let m = map(v, "tree graph")?;
452
        let node = |v: &crate::cbor::Value| {
453
            NodeId::from_slice(bytes(v, "node")?)
454
                .ok_or_else(|| ObjectError::Schema("node: expected 16 bytes".into()))
455
        };
456
        let opkey = |e: &[crate::cbor::Value]| -> Result<OpKey, ObjectError> {
457
            Ok((oref(&e[0], "op change")?, u32_(&e[1], "op index")?))
458
        };
459
        let mut g = TreeGraph::default();
460
        for n in array(field(m, 0, "nodes")?, "nodes")? {
461
            let e = array(n, "node entry")?;
462
            if e.len() != 3 {
463
                return Err(ObjectError::Schema("node entry: expected 3 fields".into()));
464
            }
465
            let id = node(&e[0])?;
466
            g.kinds
467
                .insert(id, NodeKind::from_tag(uint(&e[1], "kind")?)?);
468
            if !e[2].is_null() {
469
                g.introduced.insert(id, oref(&e[2], "introducer")?);
470
            }
471
        }
472
        for p in array(field(m, 1, "placements")?, "placements")? {
473
            let e = array(p, "placement")?;
474
            if e.len() != 5 {
475
                return Err(ObjectError::Schema("placement: expected 5 fields".into()));
476
            }
477
            let k = opkey(e)?;
478
            let pl = Placement {
479
                node: node(&e[2])?,
480
                parent: node(&e[3])?,
481
                name: text(&e[4], "name")?.to_owned(),
482
            };
483
            g.placements_of.entry(pl.node).or_default().insert(k);
484
            g.placements.insert(k, pl);
485
        }
486
        let deleters = |v: &crate::cbor::Value,
487
                        what: &str|
488
         -> Result<HashMap<OpKey, BTreeSet<ChangeHash>>, ObjectError> {
489
            let mut out = HashMap::new();
490
            for d in array(v, what)? {
491
                let e = array(d, what)?;
492
                if e.len() != 3 {
493
                    return Err(ObjectError::Schema(format!("{what}: expected 3 fields")));
494
                }
495
                out.insert(
496
                    opkey(e)?,
497
                    array(&e[2], "deleters")?
498
                        .iter()
499
                        .map(|x| oref(x, "deleter"))
500
                        .collect::<Result<BTreeSet<_>, _>>()?,
501
                );
502
            }
503
            Ok(out)
504
        };
505
        g.deleted_placements = deleters(field(m, 2, "deleted placements")?, "deleted placement")?;
506
        for md in array(field(m, 3, "modes")?, "modes")? {
507
            let e = array(md, "mode")?;
508
            if e.len() != 4 {
509
                return Err(ObjectError::Schema("mode: expected 4 fields".into()));
510
            }
511
            let k = opkey(e)?;
512
            let n = node(&e[2])?;
513
            g.modes
514
                .insert(k, (n, Mode::from_bits(uint(&e[3], "mode bits")?)?));
515
            g.modes_of.entry(n).or_default().insert(k);
516
        }
517
        g.deleted_modes = deleters(field(m, 4, "deleted modes")?, "deleted mode")?;
518
        Ok(g)
519
    }
520
}
521
522
pub fn op_key(r: OpRef) -> OpKey {
523
    (r.change, r.index)
524
}
525
526
#[cfg(test)]
527
mod tests {
528
    use super::*;
529
    use crate::hash::ObjectRef;
530
531
    fn h(n: u8) -> ChangeHash {
532
        ObjectRef([n; 32])
533
    }
534
    fn nid(n: u8) -> NodeId {
535
        NodeId([n; 16])
536
    }
537
    fn add(g: &mut TreeGraph, c: u8, i: u32, node: u8, kind: NodeKind, parent: NodeId, name: &str) {
538
        g.apply(
539
            h(c),
540
            i,
541
            &TreeOp::AddNode {
542
                node: nid(node),
543
                kind,
544
                mode: Mode::TEXT,
545
                parent,
546
                name: name.into(),
547
            },
548
        );
549
    }
550
    fn paths(v: &TreeView) -> Vec<String> {
551
        v.entries.keys().cloned().collect()
552
    }
553
554
    #[test]
555
    fn nested_paths_and_rename() {
556
        let mut g = TreeGraph::new();
557
        add(&mut g, 1, 0, 1, NodeKind::Dir, NodeId::ROOT, "src");
558
        add(&mut g, 1, 1, 2, NodeKind::File, nid(1), "main.rs");
559
        add(&mut g, 1, 2, 3, NodeKind::File, NodeId::ROOT, "README");
560
        let v = g.view();
561
        assert_eq!(paths(&v), ["README", "src", "src/main.rs"]);
562
        assert!(!v.is_conflicted());
563
564
        // Rename src/main.rs → src/lib.rs, move src → lib (subtree follows).
565
        g.apply(
566
            h(2),
567
            0,
568
            &TreeOp::Move {
569
                node: nid(2),
570
                old: OpRef {
571
                    change: h(1),
572
                    index: 1,
573
                },
574
                parent: nid(1),
575
                name: "lib.rs".into(),
576
            },
577
        );
578
        g.apply(
579
            h(2),
580
            1,
581
            &TreeOp::Move {
582
                node: nid(1),
583
                old: OpRef {
584
                    change: h(1),
585
                    index: 0,
586
                },
587
                parent: NodeId::ROOT,
588
                name: "lib".into(),
589
            },
590
        );
591
        let v = g.view();
592
        assert_eq!(paths(&v), ["README", "lib", "lib/lib.rs"]);
593
        assert_eq!(v.entries["lib/lib.rs"].placement, (h(2), 0));
594
595
        g.apply(
596
            h(3),
597
            0,
598
            &TreeOp::RemoveNode {
599
                node: nid(3),
600
                placement: OpRef {
601
                    change: h(1),
602
                    index: 2,
603
                },
604
            },
605
        );
606
        assert_eq!(paths(&g.view()), ["lib", "lib/lib.rs"]);
607
    }
608
609
    #[test]
610
    fn name_conflict_gets_suffixes() {
611
        let mut g = TreeGraph::new();
612
        add(&mut g, 1, 0, 1, NodeKind::File, NodeId::ROOT, "a.txt");
613
        add(&mut g, 2, 0, 2, NodeKind::File, NodeId::ROOT, "a.txt");
614
        let v = g.view();
615
        assert_eq!(paths(&v), ["a.txt.oxy-conflict-1", "a.txt.oxy-conflict-2"]);
616
        assert_eq!(
617
            v.conflicts,
618
            vec![TreeConflict::Name {
619
                parent: NodeId::ROOT,
620
                name: "a.txt".into(),
621
                nodes: vec![nid(1), nid(2)]
622
            }]
623
        );
624
    }
625
626
    #[test]
627
    fn concurrent_renames_are_multi_placement() {
628
        let mut g = TreeGraph::new();
629
        add(&mut g, 1, 0, 1, NodeKind::File, NodeId::ROOT, "a");
630
        g.apply(
631
            h(2),
632
            0,
633
            &TreeOp::Move {
634
                node: nid(1),
635
                old: OpRef {
636
                    change: h(1),
637
                    index: 0,
638
                },
639
                parent: NodeId::ROOT,
640
                name: "b".into(),
641
            },
642
        );
643
        g.apply(
644
            h(3),
645
            0,
646
            &TreeOp::Move {
647
                node: nid(1),
648
                old: OpRef {
649
                    change: h(1),
650
                    index: 0,
651
                },
652
                parent: NodeId::ROOT,
653
                name: "c".into(),
654
            },
655
        );
656
        let v = g.view();
657
        assert_eq!(paths(&v), ["b.oxy-conflict-1", "c.oxy-conflict-1"]);
658
        assert!(
659
            matches!(v.conflicts[0], TreeConflict::MultiPlacement { node, .. } if node == nid(1))
660
        );
661
    }
662
663
    #[test]
664
    fn orphan_and_cycle() {
665
        let mut g = TreeGraph::new();
666
        add(&mut g, 1, 0, 1, NodeKind::Dir, NodeId::ROOT, "d");
667
        add(&mut g, 1, 1, 2, NodeKind::File, nid(1), "f");
668
        // Concurrently: 2 removes d, 3 adds d/g.
669
        g.apply(
670
            h(2),
671
            0,
672
            &TreeOp::RemoveNode {
673
                node: nid(1),
674
                placement: OpRef {
675
                    change: h(1),
676
                    index: 0,
677
                },
678
            },
679
        );
680
        add(&mut g, 3, 0, 3, NodeKind::File, nid(1), "g");
681
        let v = g.view();
682
        assert_eq!(paths(&v), Vec::<String>::new());
683
        assert!(v.conflicts.contains(&TreeConflict::Orphan {
684
            node: nid(2),
685
            parent: nid(1)
686
        }));
687
        assert!(v.conflicts.contains(&TreeConflict::Orphan {
688
            node: nid(3),
689
            parent: nid(1)
690
        }));
691
692
        // Cycle: a/b, then concurrently move a under b and b under a's parent... simplest: move a into b.
693
        let mut g = TreeGraph::new();
694
        add(&mut g, 1, 0, 1, NodeKind::Dir, NodeId::ROOT, "a");
695
        add(&mut g, 1, 1, 2, NodeKind::Dir, nid(1), "b");
696
        g.apply(
697
            h(2),
698
            0,
699
            &TreeOp::Move {
700
                node: nid(1),
701
                old: OpRef {
702
                    change: h(1),
703
                    index: 0,
704
                },
705
                parent: nid(2),
706
                name: "a".into(),
707
            },
708
        );
709
        let v = g.view();
710
        assert!(
711
            v.conflicts
712
                .iter()
713
                .any(|c| matches!(c, TreeConflict::Cycle { .. })),
714
            "{:?}",
715
            v.conflicts
716
        );
717
    }
718
719
    #[test]
720
    fn serialization_round_trip() {
721
        let mut g = TreeGraph::new();
722
        add(&mut g, 1, 0, 1, NodeKind::Dir, NodeId::ROOT, "src");
723
        add(&mut g, 1, 1, 2, NodeKind::File, nid(1), "main.rs");
724
        g.apply(
725
            h(2),
726
            0,
727
            &TreeOp::Move {
728
                node: nid(2),
729
                old: OpRef {
730
                    change: h(1),
731
                    index: 1,
732
                },
733
                parent: nid(1),
734
                name: "lib.rs".into(),
735
            },
736
        );
737
        g.apply(
738
            h(3),
739
            0,
740
            &TreeOp::SetMode {
741
                node: nid(2),
742
                old: OpRef {
743
                    change: h(1),
744
                    index: 1,
745
                },
746
                mode: Mode {
747
                    exec: true,
748
                    opaque: false,
749
                },
750
            },
751
        );
752
        let bytes = crate::cbor::encode(&g.to_value());
753
        let back = TreeGraph::from_value(&crate::cbor::decode(&bytes).unwrap()).unwrap();
754
        assert_eq!(back.view(), g.view());
755
        assert_eq!(back.introducer(&nid(2)), Some(h(1)));
756
        assert_eq!(crate::cbor::encode(&back.to_value()), bytes);
757
    }
758
759
    #[test]
760
    fn mode_conflict_and_resolution() {
761
        let mut g = TreeGraph::new();
762
        add(&mut g, 1, 0, 1, NodeKind::File, NodeId::ROOT, "run.sh");
763
        g.apply(
764
            h(2),
765
            0,
766
            &TreeOp::SetMode {
767
                node: nid(1),
768
                old: OpRef {
769
                    change: h(1),
770
                    index: 0,
771
                },
772
                mode: Mode {
773
                    exec: true,
774
                    opaque: false,
775
                },
776
            },
777
        );
778
        g.apply(
779
            h(3),
780
            0,
781
            &TreeOp::SetMode {
782
                node: nid(1),
783
                old: OpRef {
784
                    change: h(1),
785
                    index: 0,
786
                },
787
                mode: Mode {
788
                    exec: false,
789
                    opaque: true,
790
                },
791
            },
792
        );
793
        let v = g.view();
794
        assert!(matches!(v.conflicts[0], TreeConflict::Mode { .. }));
795
        // Materialized with the greatest mode atom.
796
        assert_eq!(
797
            v.entries["run.sh"].mode,
798
            Mode {
799
                exec: false,
800
                opaque: true
801
            }
802
        );
803
        // The placement introduced by the same AddNode is unaffected.
804
        assert_eq!(v.entries["run.sh"].placement, (h(1), 0));
805
        // Resolution: retire both live mode atoms; identical live values do not conflict.
806
        g.apply(
807
            h(4),
808
            0,
809
            &TreeOp::SetMode {
810
                node: nid(1),
811
                old: OpRef {
812
                    change: h(2),
813
                    index: 0,
814
                },
815
                mode: Mode {
816
                    exec: true,
817
                    opaque: false,
818
                },
819
            },
820
        );
821
        g.apply(
822
            h(4),
823
            1,
824
            &TreeOp::SetMode {
825
                node: nid(1),
826
                old: OpRef {
827
                    change: h(3),
828
                    index: 0,
829
                },
830
                mode: Mode {
831
                    exec: true,
832
                    opaque: false,
833
                },
834
            },
835
        );
836
        let v = g.view();
837
        assert!(!v.is_conflicted(), "{:?}", v.conflicts);
838
        assert_eq!(
839
            v.entries["run.sh"].mode,
840
            Mode {
841
                exec: true,
842
                opaque: false
843
            }
844
        );
845
    }
846
}