nvim-rs 0.9.2

A library for writing neovim rpc clients
Documentation 
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

//! How to handle cleanup logic with access to the handler's data. See
//! src/examples/handler_drop.rs for documentation.
use nvim_rs::{
  compat::tokio::Compat, create::tokio as create, Handler, Neovim, Value,
};

use tokio::process::{ChildStdin, Command};

use async_trait::async_trait;

use std::{
  fs::File,
  io::Write,
  ops::Drop,
  sync::{Arc, Mutex},
};

const OUTPUT_FILE: &str = "handler_drop.txt";
const NVIMPATH: &str = "neovim/build/bin/nvim";

#[derive(Clone)]
struct NeovimHandler {
  buf: Arc<Mutex<Vec<String>>>,
}

#[async_trait]
impl Handler for NeovimHandler {
  type Writer = Compat<ChildStdin>;

  async fn handle_notify(
    &self,
    name: String,
    args: Vec<Value>,
    req: Neovim<Compat<ChildStdin>>,
  ) {
    match name.as_ref() {
      "nvim_buf_lines_event" => {
        // This can be made more efficient by taking ownership appropriately,
        // but we skip this in this example
        for s in args[4]
          .as_array()
          .unwrap()
          .iter()
          .map(|s| s.as_str().unwrap())
        {
          self.buf.lock().unwrap().push(s.to_owned());
        }
        // shut down after the first event
        let chan = req.get_api_info().await.unwrap()[0].as_i64().unwrap();
        let close = format!("call chanclose({})", chan);
        // this will always return an EOF error, so let's just ignore that here
        let _ = req.command(&close).await;
      }
      _ => {}
    }
  }
}

impl Drop for NeovimHandler {
  fn drop(&mut self) {
    let mut file = File::create(OUTPUT_FILE).unwrap();

    for line in self.buf.lock().unwrap().iter() {
      writeln!(file, "{}", line).unwrap();
    }
  }
}

#[tokio::main]
async fn main() {
  let handler = NeovimHandler {
    buf: Arc::new(Mutex::new(vec![])),
  };

  let (nvim, io_handle, _child) = create::new_child_cmd(
    Command::new(NVIMPATH)
      .args(&["-u", "NONE", "--embed", "--headless"])
      .env("NVIM_LOG_FILE", "nvimlog"),
    handler,
  )
  .await
  .unwrap();


  let curbuf = nvim.get_current_buf().await.unwrap();
  if !curbuf.attach(false, vec![]).await.unwrap() {
    return;
  }
  curbuf
    .set_lines(0, 0, false, vec!["xyz".into(), "abc".into()])
    .await
    .unwrap();

  // The call will return an error because the channel is closed, so we
  // need to explicitely ignore it rather than unwrap it.
  let _ = io_handle.await;
}