1use std::mem::take;
2use std::time::Duration;
3
4use ropey::RopeSlice;
5use tree_sitter::Parser;
6
7use crate::config::LanguageLoader;
8use crate::{Error, LayerData, Syntax};
9
10impl Syntax {
11 pub fn update(
12 &mut self,
13 source: RopeSlice,
14 timeout: Duration,
15 edits: &[tree_sitter::InputEdit],
16 loader: &impl LanguageLoader,
17 ) -> Result<(), Error> {
18 if source.len_bytes() >= 512 * 1024 * 1024 {
22 return Err(Error::ExceededMaximumSize);
23 }
24
25 let mut queue = Vec::with_capacity(32);
26 let root_flags = &mut self.layer_mut(self.root).flags;
27 root_flags.touched = true;
29 root_flags.modified = true;
31 queue.push(self.root);
32
33 let mut parser = Parser::new();
34
35 while let Some(layer) = queue.pop() {
36 let layer_data = self.layer_mut(layer);
37 if layer_data.ranges.is_empty() {
38 continue;
40 }
41 if let Some(tree) = &mut layer_data.parse_tree {
42 if layer_data.flags.moved || layer_data.flags.modified {
43 for edit in edits.iter().rev() {
44 tree.edit(edit);
48 }
49 }
50 if layer_data.flags.modified {
51 layer_data.parse(&mut parser, source, timeout, loader)?;
53 }
54 } else {
55 layer_data.parse(&mut parser, source, timeout, loader)?;
57 }
58 self.run_injection_query(layer, edits, source, loader, |layer| queue.push(layer));
59 self.run_local_query(layer, source, loader);
60 }
61
62 if self.layer(self.root).parse_tree.is_none() {
63 return Err(Error::NoRootConfig);
64 }
65
66 self.prune_dead_layers();
67 Ok(())
68 }
69
70 fn prune_dead_layers(&mut self) {
72 self.layers
73 .retain(|_, layer| take(&mut layer.flags).touched);
74 }
75}
76
77impl LayerData {
78 fn parse(
79 &mut self,
80 parser: &mut Parser,
81 source: RopeSlice,
82 timeout: Duration,
83 loader: &impl LanguageLoader,
84 ) -> Result<(), Error> {
85 let Some(config) = loader.get_config(self.language) else {
86 return Ok(());
87 };
88 if let Err(err) = parser.set_grammar(config.grammar) {
89 return Err(Error::IncompatibleGrammar(self.language, err));
90 }
91 parser
92 .set_included_ranges(&self.ranges)
93 .map_err(|_| Error::InvalidRanges)?;
94
95 let tree = self.parse_tree.as_ref().filter(|tree| {
106 let included_ranges_range = self.ranges.first().map(|r| r.start_byte).unwrap_or(0)
107 ..self.ranges.last().map(|r| r.end_byte).unwrap_or(u32::MAX);
108 if included_ranges_range == (0..u32::MAX) {
111 return true;
112 }
113 let tree_range = tree.root_node().byte_range();
114 tree_range.start <= included_ranges_range.start
115 && tree_range.end >= included_ranges_range.end
116 });
117
118 let tree = parser
119 .parse_with_timeout(source, tree, timeout)
120 .ok_or(Error::Timeout)?;
121 self.parse_tree = Some(tree);
122 Ok(())
123 }
124}
125
126#[derive(Debug, PartialEq, Eq, Default, Clone)]
127pub(crate) struct LayerUpdateFlags {
128 pub reused: bool,
129 pub modified: bool,
130 pub moved: bool,
131 pub touched: bool,
132}