Skip to main content

LspProvider

cgraph::fetch::lsp

Struct LspProvider 

Source 
pub struct LspProvider { /* private fields */ }

Implementations§

Source§

impl LspProvider

Source

pub async fn start(config: LspConfig) -> Result<Self>

Examples found in repository?
examples/lsp_workspace_symbols.rs (line 22)
7async fn main() -> Result<()> {
8    let mut args = env::args_os().skip(1);
9    let program = args
10        .next()
11        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?;
12    let query = args
13        .next()
14        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?
15        .into_string()
16        .map_err(|_| anyhow!("query must be valid UTF-8"))?;
17    let workspace_root = match args.next() {
18        Some(path) => PathBuf::from(path),
19        None => env::current_dir().context("failed to determine current directory")?,
20    };
21
22    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
23    tokio::time::sleep(Duration::from_secs(2)).await;
24    let symbols = lsp.workspace_symbols(&query).await?;
25
26    for symbol in symbols {
27        let line = symbol
28            .range
29            .map(|range| (range.start.line + 1).to_string())
30            .unwrap_or_else(|| "?".to_owned());
31        println!("{}\t{}:{line}", symbol.name, symbol.uri);
32    }
33
34    lsp.shutdown().await
35}
More examples
Hide additional examples
examples/lsp_hierarchy.rs (line 59)
14async fn main() -> Result<()> {
15    let mut args = env::args_os().skip(1);
16    let program = args.next().context(
17        "usage: lsp_hierarchy <SERVER> <call|type> <incoming|outgoing> <SYMBOL> [WORKSPACE]",
18    )?;
19    let kind = match utf8_arg(args.next(), "hierarchy kind")?.as_str() {
20        "call" => HierarchyKind::Call,
21        "type" => HierarchyKind::Type,
22        value => bail!("unknown hierarchy kind {value:?}; expected call or type"),
23    };
24    let direction = match utf8_arg(args.next(), "direction")?.as_str() {
25        "incoming" => HierarchyDirection::Incoming,
26        "outgoing" => HierarchyDirection::Outgoing,
27        value => bail!("unknown direction {value:?}; expected incoming or outgoing"),
28    };
29    let symbol = utf8_arg(args.next(), "symbol")?;
30    let workspace_root = match args.next() {
31        Some(path) => PathBuf::from(path),
32        None => env::current_dir().context("failed to determine current directory")?,
33    };
34    let location = match args.next() {
35        Some(file) => {
36            let file = PathBuf::from(file)
37                .canonicalize()
38                .context("failed to resolve source file")?;
39            let line = utf8_arg(args.next(), "one-based line")?
40                .parse::<u32>()
41                .context("line must be a positive integer")?;
42            let character = utf8_arg(args.next(), "one-based character")?
43                .parse::<u32>()
44                .context("character must be a positive integer")?;
45            if line == 0 || character == 0 {
46                bail!("line and character are one-based and must be positive");
47            }
48            let uri = Url::from_file_path(&file)
49                .map_err(|()| anyhow!("source file cannot be represented as a file URI"))?;
50            Some(SourceLocation {
51                uri: uri.to_string(),
52                line: Some(line - 1),
53                character: Some(character - 1),
54            })
55        }
56        None => None,
57    };
58
59    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
60    tokio::time::sleep(Duration::from_secs(12)).await;
61    let response = lsp
62        .hierarchy_client()
63        .query(HierarchyQuery {
64            symbol: SymbolIdentity {
65                symbol,
66                kind,
67                location,
68            },
69            direction,
70        })
71        .await;
72
73    let shutdown_result = lsp.shutdown().await;
74    let response = response?;
75    for child in response.children {
76        let location = child.location.map_or_else(
77            || "unknown location".to_owned(),
78            |location| {
79                format!(
80                    "{}:{}:{}",
81                    location.uri,
82                    location.line.unwrap_or(0) + 1,
83                    location.character.unwrap_or(0) + 1
84                )
85            },
86        );
87        println!("{}\t{location}", child.symbol);
88    }
89    shutdown_result
90}
Source

pub fn workspace_root(&self) -> &Path

Source

pub fn server_info(&self) -> Option<&ServerInfo>

Source

pub fn take_status_receiver( &mut self, ) -> Option<UnboundedReceiver<LspStatusUpdate>>

Source

pub fn workspace_symbol_client(&self) -> WorkspaceSymbolClient

Source

pub fn hierarchy_client(&self) -> HierarchyClient

Examples found in repository?
examples/lsp_hierarchy.rs (line 62)
14async fn main() -> Result<()> {
15    let mut args = env::args_os().skip(1);
16    let program = args.next().context(
17        "usage: lsp_hierarchy <SERVER> <call|type> <incoming|outgoing> <SYMBOL> [WORKSPACE]",
18    )?;
19    let kind = match utf8_arg(args.next(), "hierarchy kind")?.as_str() {
20        "call" => HierarchyKind::Call,
21        "type" => HierarchyKind::Type,
22        value => bail!("unknown hierarchy kind {value:?}; expected call or type"),
23    };
24    let direction = match utf8_arg(args.next(), "direction")?.as_str() {
25        "incoming" => HierarchyDirection::Incoming,
26        "outgoing" => HierarchyDirection::Outgoing,
27        value => bail!("unknown direction {value:?}; expected incoming or outgoing"),
28    };
29    let symbol = utf8_arg(args.next(), "symbol")?;
30    let workspace_root = match args.next() {
31        Some(path) => PathBuf::from(path),
32        None => env::current_dir().context("failed to determine current directory")?,
33    };
34    let location = match args.next() {
35        Some(file) => {
36            let file = PathBuf::from(file)
37                .canonicalize()
38                .context("failed to resolve source file")?;
39            let line = utf8_arg(args.next(), "one-based line")?
40                .parse::<u32>()
41                .context("line must be a positive integer")?;
42            let character = utf8_arg(args.next(), "one-based character")?
43                .parse::<u32>()
44                .context("character must be a positive integer")?;
45            if line == 0 || character == 0 {
46                bail!("line and character are one-based and must be positive");
47            }
48            let uri = Url::from_file_path(&file)
49                .map_err(|()| anyhow!("source file cannot be represented as a file URI"))?;
50            Some(SourceLocation {
51                uri: uri.to_string(),
52                line: Some(line - 1),
53                character: Some(character - 1),
54            })
55        }
56        None => None,
57    };
58
59    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
60    tokio::time::sleep(Duration::from_secs(12)).await;
61    let response = lsp
62        .hierarchy_client()
63        .query(HierarchyQuery {
64            symbol: SymbolIdentity {
65                symbol,
66                kind,
67                location,
68            },
69            direction,
70        })
71        .await;
72
73    let shutdown_result = lsp.shutdown().await;
74    let response = response?;
75    for child in response.children {
76        let location = child.location.map_or_else(
77            || "unknown location".to_owned(),
78            |location| {
79                format!(
80                    "{}:{}:{}",
81                    location.uri,
82                    location.line.unwrap_or(0) + 1,
83                    location.character.unwrap_or(0) + 1
84                )
85            },
86        );
87        println!("{}\t{location}", child.symbol);
88    }
89    shutdown_result
90}
Source

pub async fn workspace_symbols( &self, query: &str, ) -> Result<Vec<WorkspaceSymbolMatch>>

Examples found in repository?
examples/lsp_workspace_symbols.rs (line 24)
7async fn main() -> Result<()> {
8    let mut args = env::args_os().skip(1);
9    let program = args
10        .next()
11        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?;
12    let query = args
13        .next()
14        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?
15        .into_string()
16        .map_err(|_| anyhow!("query must be valid UTF-8"))?;
17    let workspace_root = match args.next() {
18        Some(path) => PathBuf::from(path),
19        None => env::current_dir().context("failed to determine current directory")?,
20    };
21
22    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
23    tokio::time::sleep(Duration::from_secs(2)).await;
24    let symbols = lsp.workspace_symbols(&query).await?;
25
26    for symbol in symbols {
27        let line = symbol
28            .range
29            .map(|range| (range.start.line + 1).to_string())
30            .unwrap_or_else(|| "?".to_owned());
31        println!("{}\t{}:{line}", symbol.name, symbol.uri);
32    }
33
34    lsp.shutdown().await
35}
Source

pub async fn shutdown(self) -> Result<()>

Examples found in repository?
examples/lsp_workspace_symbols.rs (line 34)
7async fn main() -> Result<()> {
8    let mut args = env::args_os().skip(1);
9    let program = args
10        .next()
11        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?;
12    let query = args
13        .next()
14        .context("usage: lsp_workspace_symbols <SERVER> <QUERY> [WORKSPACE]")?
15        .into_string()
16        .map_err(|_| anyhow!("query must be valid UTF-8"))?;
17    let workspace_root = match args.next() {
18        Some(path) => PathBuf::from(path),
19        None => env::current_dir().context("failed to determine current directory")?,
20    };
21
22    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
23    tokio::time::sleep(Duration::from_secs(2)).await;
24    let symbols = lsp.workspace_symbols(&query).await?;
25
26    for symbol in symbols {
27        let line = symbol
28            .range
29            .map(|range| (range.start.line + 1).to_string())
30            .unwrap_or_else(|| "?".to_owned());
31        println!("{}\t{}:{line}", symbol.name, symbol.uri);
32    }
33
34    lsp.shutdown().await
35}
More examples
Hide additional examples
examples/lsp_hierarchy.rs (line 73)
14async fn main() -> Result<()> {
15    let mut args = env::args_os().skip(1);
16    let program = args.next().context(
17        "usage: lsp_hierarchy <SERVER> <call|type> <incoming|outgoing> <SYMBOL> [WORKSPACE]",
18    )?;
19    let kind = match utf8_arg(args.next(), "hierarchy kind")?.as_str() {
20        "call" => HierarchyKind::Call,
21        "type" => HierarchyKind::Type,
22        value => bail!("unknown hierarchy kind {value:?}; expected call or type"),
23    };
24    let direction = match utf8_arg(args.next(), "direction")?.as_str() {
25        "incoming" => HierarchyDirection::Incoming,
26        "outgoing" => HierarchyDirection::Outgoing,
27        value => bail!("unknown direction {value:?}; expected incoming or outgoing"),
28    };
29    let symbol = utf8_arg(args.next(), "symbol")?;
30    let workspace_root = match args.next() {
31        Some(path) => PathBuf::from(path),
32        None => env::current_dir().context("failed to determine current directory")?,
33    };
34    let location = match args.next() {
35        Some(file) => {
36            let file = PathBuf::from(file)
37                .canonicalize()
38                .context("failed to resolve source file")?;
39            let line = utf8_arg(args.next(), "one-based line")?
40                .parse::<u32>()
41                .context("line must be a positive integer")?;
42            let character = utf8_arg(args.next(), "one-based character")?
43                .parse::<u32>()
44                .context("character must be a positive integer")?;
45            if line == 0 || character == 0 {
46                bail!("line and character are one-based and must be positive");
47            }
48            let uri = Url::from_file_path(&file)
49                .map_err(|()| anyhow!("source file cannot be represented as a file URI"))?;
50            Some(SourceLocation {
51                uri: uri.to_string(),
52                line: Some(line - 1),
53                character: Some(character - 1),
54            })
55        }
56        None => None,
57    };
58
59    let lsp = LspProvider::start(LspConfig::new(program, workspace_root)).await?;
60    tokio::time::sleep(Duration::from_secs(12)).await;
61    let response = lsp
62        .hierarchy_client()
63        .query(HierarchyQuery {
64            symbol: SymbolIdentity {
65                symbol,
66                kind,
67                location,
68            },
69            direction,
70        })
71        .await;
72
73    let shutdown_result = lsp.shutdown().await;
74    let response = response?;
75    for child in response.children {
76        let location = child.location.map_or_else(
77            || "unknown location".to_owned(),
78            |location| {
79                format!(
80                    "{}:{}:{}",
81                    location.uri,
82                    location.line.unwrap_or(0) + 1,
83                    location.character.unwrap_or(0) + 1
84                )
85            },
86        );
87        println!("{}\t{location}", child.symbol);
88    }
89    shutdown_result
90}

Trait Implementations§

Source§

impl Debug for LspProvider

Source§

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more