diff options
Diffstat (limited to 'crates/ra_analysis/src/module_map.rs')
-rw-r--r-- | crates/ra_analysis/src/module_map.rs | 286 |
1 files changed, 143 insertions, 143 deletions
diff --git a/crates/ra_analysis/src/module_map.rs b/crates/ra_analysis/src/module_map.rs index c77c5cec6..95a770ae7 100644 --- a/crates/ra_analysis/src/module_map.rs +++ b/crates/ra_analysis/src/module_map.rs | |||
@@ -1,157 +1,157 @@ | |||
1 | use std::sync::Arc; | 1 | use std::sync::Arc; |
2 | use crate::{ | 2 | use crate::{ |
3 | FileId, | 3 | FileId, |
4 | db::{ | 4 | db::{SyntaxDatabase}, |
5 | Query, QueryRegistry, QueryCtx, | ||
6 | file_set | ||
7 | }, | ||
8 | queries::file_syntax, | ||
9 | descriptors::{ModuleDescriptor, ModuleTreeDescriptor}, | 5 | descriptors::{ModuleDescriptor, ModuleTreeDescriptor}, |
10 | }; | 6 | }; |
11 | 7 | ||
12 | pub(crate) fn register_queries(reg: &mut QueryRegistry) { | 8 | salsa::query_group! { |
13 | reg.add(MODULE_DESCR, "MODULE_DESCR"); | 9 | pub(crate) trait ModulesDatabase: SyntaxDatabase { |
14 | reg.add(MODULE_TREE, "MODULE_TREE"); | 10 | fn module_tree(key: ()) -> Arc<ModuleTreeDescriptor> { |
15 | } | 11 | type ModuleTreeQuery; |
16 | |||
17 | pub(crate) fn module_tree(ctx: QueryCtx) -> Arc<ModuleTreeDescriptor> { | ||
18 | ctx.get(MODULE_TREE, ()) | ||
19 | } | ||
20 | |||
21 | const MODULE_DESCR: Query<FileId, ModuleDescriptor> = Query(30, |ctx, &file_id| { | ||
22 | let file = file_syntax(ctx, file_id); | ||
23 | ModuleDescriptor::new(file.ast()) | ||
24 | }); | ||
25 | |||
26 | const MODULE_TREE: Query<(), ModuleTreeDescriptor> = Query(31, |ctx, _| { | ||
27 | let file_set = file_set(ctx); | ||
28 | let mut files = Vec::new(); | ||
29 | for &file_id in file_set.0.iter() { | ||
30 | let module_descr = ctx.get(MODULE_DESCR, file_id); | ||
31 | files.push((file_id, module_descr)); | ||
32 | } | ||
33 | ModuleTreeDescriptor::new(files.iter().map(|(file_id, descr)| (*file_id, &**descr)), &file_set.1) | ||
34 | }); | ||
35 | |||
36 | #[cfg(test)] | ||
37 | mod tests { | ||
38 | use std::collections::HashMap; | ||
39 | use im; | ||
40 | use relative_path::{RelativePath, RelativePathBuf}; | ||
41 | use crate::{ | ||
42 | db::{Db}, | ||
43 | imp::FileResolverImp, | ||
44 | FileId, FileResolver, | ||
45 | }; | ||
46 | use super::*; | ||
47 | |||
48 | #[derive(Debug)] | ||
49 | struct FileMap(im::HashMap<FileId, RelativePathBuf>); | ||
50 | |||
51 | impl FileResolver for FileMap { | ||
52 | fn file_stem(&self, file_id: FileId) -> String { | ||
53 | self.0[&file_id].file_stem().unwrap().to_string() | ||
54 | } | 12 | } |
55 | fn resolve(&self, file_id: FileId, rel: &RelativePath) -> Option<FileId> { | 13 | fn module_descriptor(file_id: FileId) -> Arc<ModuleDescriptor> { |
56 | let path = self.0[&file_id].join(rel).normalize(); | 14 | type ModuleDescriptorQuery; |
57 | self.0.iter() | ||
58 | .filter_map(|&(id, ref p)| Some(id).filter(|_| p == &path)) | ||
59 | .next() | ||
60 | } | 15 | } |
61 | } | 16 | } |
17 | } | ||
62 | 18 | ||
63 | struct Fixture { | ||
64 | next_file_id: u32, | ||
65 | fm: im::HashMap<FileId, RelativePathBuf>, | ||
66 | db: Db, | ||
67 | } | ||
68 | |||
69 | impl Fixture { | ||
70 | fn new() -> Fixture { | ||
71 | Fixture { | ||
72 | next_file_id: 1, | ||
73 | fm: im::HashMap::new(), | ||
74 | db: Db::new(), | ||
75 | } | ||
76 | } | ||
77 | fn add_file(&mut self, path: &str, text: &str) -> FileId { | ||
78 | assert!(path.starts_with("/")); | ||
79 | let file_id = FileId(self.next_file_id); | ||
80 | self.next_file_id += 1; | ||
81 | self.fm.insert(file_id, RelativePathBuf::from(&path[1..])); | ||
82 | let mut new_state = self.db.state().clone(); | ||
83 | new_state.file_map.insert(file_id, Arc::new(text.to_string())); | ||
84 | new_state.file_resolver = FileResolverImp::new( | ||
85 | Arc::new(FileMap(self.fm.clone())) | ||
86 | ); | ||
87 | self.db = self.db.with_changes(new_state, &[file_id], true); | ||
88 | file_id | ||
89 | } | ||
90 | fn remove_file(&mut self, file_id: FileId) { | ||
91 | self.fm.remove(&file_id); | ||
92 | let mut new_state = self.db.state().clone(); | ||
93 | new_state.file_map.remove(&file_id); | ||
94 | new_state.file_resolver = FileResolverImp::new( | ||
95 | Arc::new(FileMap(self.fm.clone())) | ||
96 | ); | ||
97 | self.db = self.db.with_changes(new_state, &[file_id], true); | ||
98 | } | ||
99 | fn change_file(&mut self, file_id: FileId, new_text: &str) { | ||
100 | let mut new_state = self.db.state().clone(); | ||
101 | new_state.file_map.insert(file_id, Arc::new(new_text.to_string())); | ||
102 | self.db = self.db.with_changes(new_state, &[file_id], false); | ||
103 | } | ||
104 | fn check_parent_modules( | ||
105 | &self, | ||
106 | file_id: FileId, | ||
107 | expected: &[FileId], | ||
108 | queries: &[(&'static str, u64)] | ||
109 | ) { | ||
110 | let (tree, events) = self.db.trace_query(|ctx| module_tree(ctx)); | ||
111 | let actual = tree.parent_modules(file_id) | ||
112 | .into_iter() | ||
113 | .map(|link| link.owner(&tree)) | ||
114 | .collect::<Vec<_>>(); | ||
115 | assert_eq!(actual.as_slice(), expected); | ||
116 | let mut counts = HashMap::new(); | ||
117 | events.into_iter() | ||
118 | .for_each(|event| *counts.entry(event).or_insert(0) += 1); | ||
119 | for &(query_id, expected_count) in queries.iter() { | ||
120 | let actual_count = *counts.get(&query_id).unwrap_or(&0); | ||
121 | assert_eq!( | ||
122 | actual_count, | ||
123 | expected_count, | ||
124 | "counts for {} differ", | ||
125 | query_id, | ||
126 | ) | ||
127 | } | ||
128 | |||
129 | } | ||
130 | } | ||
131 | |||
132 | #[test] | ||
133 | fn test_parent_module() { | ||
134 | let mut f = Fixture::new(); | ||
135 | let foo = f.add_file("/foo.rs", ""); | ||
136 | f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
137 | |||
138 | let lib = f.add_file("/lib.rs", "mod foo;"); | ||
139 | f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | ||
140 | f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 0)]); | ||
141 | |||
142 | f.change_file(lib, ""); | ||
143 | f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
144 | |||
145 | f.change_file(lib, "mod foo;"); | ||
146 | f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | ||
147 | |||
148 | f.change_file(lib, "mod bar;"); | ||
149 | f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
150 | 19 | ||
151 | f.change_file(lib, "mod foo;"); | 20 | fn module_descriptor(db: &impl ModulesDatabase, file_id: FileId) -> Arc<ModuleDescriptor> { |
152 | f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | 21 | let file = db.file_syntax(file_id); |
22 | Arc::new(ModuleDescriptor::new(file.ast())) | ||
23 | } | ||
153 | 24 | ||
154 | f.remove_file(lib); | 25 | fn module_tree(db: &impl ModulesDatabase, (): ()) -> Arc<ModuleTreeDescriptor> { |
155 | f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 0)]); | 26 | let file_set = db.file_set(()); |
27 | let mut files = Vec::new(); | ||
28 | for &file_id in file_set.files.iter() { | ||
29 | let module_descr = db.module_descriptor(file_id); | ||
30 | files.push((file_id, module_descr)); | ||
156 | } | 31 | } |
32 | let res = ModuleTreeDescriptor::new(files.iter().map(|(file_id, descr)| (*file_id, &**descr)), &file_set.resolver); | ||
33 | Arc::new(res) | ||
157 | } | 34 | } |
35 | |||
36 | // #[cfg(test)] | ||
37 | // mod tests { | ||
38 | // use std::collections::HashMap; | ||
39 | // use im; | ||
40 | // use relative_path::{RelativePath, RelativePathBuf}; | ||
41 | // use { | ||
42 | // db::{Db}, | ||
43 | // imp::FileResolverImp, | ||
44 | // FileId, FileResolver, | ||
45 | // }; | ||
46 | // use super::*; | ||
47 | |||
48 | // #[derive(Debug)] | ||
49 | // struct FileMap(im::HashMap<FileId, RelativePathBuf>); | ||
50 | |||
51 | // impl FileResolver for FileMap { | ||
52 | // fn file_stem(&self, file_id: FileId) -> String { | ||
53 | // self.0[&file_id].file_stem().unwrap().to_string() | ||
54 | // } | ||
55 | // fn resolve(&self, file_id: FileId, rel: &RelativePath) -> Option<FileId> { | ||
56 | // let path = self.0[&file_id].join(rel).normalize(); | ||
57 | // self.0.iter() | ||
58 | // .filter_map(|&(id, ref p)| Some(id).filter(|_| p == &path)) | ||
59 | // .next() | ||
60 | // } | ||
61 | // } | ||
62 | |||
63 | // struct Fixture { | ||
64 | // next_file_id: u32, | ||
65 | // fm: im::HashMap<FileId, RelativePathBuf>, | ||
66 | // db: Db, | ||
67 | // } | ||
68 | |||
69 | // impl Fixture { | ||
70 | // fn new() -> Fixture { | ||
71 | // Fixture { | ||
72 | // next_file_id: 1, | ||
73 | // fm: im::HashMap::new(), | ||
74 | // db: Db::new(), | ||
75 | // } | ||
76 | // } | ||
77 | // fn add_file(&mut self, path: &str, text: &str) -> FileId { | ||
78 | // assert!(path.starts_with("/")); | ||
79 | // let file_id = FileId(self.next_file_id); | ||
80 | // self.next_file_id += 1; | ||
81 | // self.fm.insert(file_id, RelativePathBuf::from(&path[1..])); | ||
82 | // let mut new_state = self.db.state().clone(); | ||
83 | // new_state.file_map.insert(file_id, Arc::new(text.to_string())); | ||
84 | // new_state.file_resolver = FileResolverImp::new( | ||
85 | // Arc::new(FileMap(self.fm.clone())) | ||
86 | // ); | ||
87 | // self.db = self.db.with_changes(new_state, &[file_id], true); | ||
88 | // file_id | ||
89 | // } | ||
90 | // fn remove_file(&mut self, file_id: FileId) { | ||
91 | // self.fm.remove(&file_id); | ||
92 | // let mut new_state = self.db.state().clone(); | ||
93 | // new_state.file_map.remove(&file_id); | ||
94 | // new_state.file_resolver = FileResolverImp::new( | ||
95 | // Arc::new(FileMap(self.fm.clone())) | ||
96 | // ); | ||
97 | // self.db = self.db.with_changes(new_state, &[file_id], true); | ||
98 | // } | ||
99 | // fn change_file(&mut self, file_id: FileId, new_text: &str) { | ||
100 | // let mut new_state = self.db.state().clone(); | ||
101 | // new_state.file_map.insert(file_id, Arc::new(new_text.to_string())); | ||
102 | // self.db = self.db.with_changes(new_state, &[file_id], false); | ||
103 | // } | ||
104 | // fn check_parent_modules( | ||
105 | // &self, | ||
106 | // file_id: FileId, | ||
107 | // expected: &[FileId], | ||
108 | // queries: &[(&'static str, u64)] | ||
109 | // ) { | ||
110 | // let (tree, events) = self.db.trace_query(|ctx| module_tree(ctx)); | ||
111 | // let actual = tree.parent_modules(file_id) | ||
112 | // .into_iter() | ||
113 | // .map(|link| link.owner(&tree)) | ||
114 | // .collect::<Vec<_>>(); | ||
115 | // assert_eq!(actual.as_slice(), expected); | ||
116 | // let mut counts = HashMap::new(); | ||
117 | // events.into_iter() | ||
118 | // .for_each(|event| *counts.entry(event).or_insert(0) += 1); | ||
119 | // for &(query_id, expected_count) in queries.iter() { | ||
120 | // let actual_count = *counts.get(&query_id).unwrap_or(&0); | ||
121 | // assert_eq!( | ||
122 | // actual_count, | ||
123 | // expected_count, | ||
124 | // "counts for {} differ", | ||
125 | // query_id, | ||
126 | // ) | ||
127 | // } | ||
128 | |||
129 | // } | ||
130 | // } | ||
131 | |||
132 | // #[test] | ||
133 | // fn test_parent_module() { | ||
134 | // let mut f = Fixture::new(); | ||
135 | // let foo = f.add_file("/foo.rs", ""); | ||
136 | // f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
137 | |||
138 | // let lib = f.add_file("/lib.rs", "mod foo;"); | ||
139 | // f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | ||
140 | // f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 0)]); | ||
141 | |||
142 | // f.change_file(lib, ""); | ||
143 | // f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
144 | |||
145 | // f.change_file(lib, "mod foo;"); | ||
146 | // f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | ||
147 | |||
148 | // f.change_file(lib, "mod bar;"); | ||
149 | // f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 1)]); | ||
150 | |||
151 | // f.change_file(lib, "mod foo;"); | ||
152 | // f.check_parent_modules(foo, &[lib], &[("MODULE_DESCR", 1)]); | ||
153 | |||
154 | // f.remove_file(lib); | ||
155 | // f.check_parent_modules(foo, &[], &[("MODULE_DESCR", 0)]); | ||
156 | // } | ||
157 | // } | ||