hexedtech/codemp
3
0
Fork 0
mirror of https://github.com/hexedtech/codemp.git synced 2024-11-22 07:14:50 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: some temporary fixes to make it compile

Browse source
This commit is contained in:
əlemi 2022-07-31 13:47:55 +02:00
parent f854b902a1
commit 7a4e69377d
1 changed files with 34 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
src/client/nvim/mod.rs
View file

@ -6,7 +6,7 @@ use nvim_rs::{compat::tokio::Compat, Handler, Neovim};
use nvim_rs::create::tokio::new_parent;
use tonic::transport::Channel;
use crate::proto::{SessionRequest, workspace_client::WorkspaceClient};
use crate::proto::{WorkspaceRequest, workspace_client::WorkspaceClient};
#[derive(Clone)]
pub struct NeovimHandler {
@ -44,53 +44,56 @@ impl Handler for NeovimHandler {
}
let buf = neovim.get_current_buf().await.unwrap();
let content = buf.get_lines(0, buf.line_count().await.unwrap(), false).await.unwrap().join("\n");
let request = tonic::Request::new(SessionRequest {
session_key: args[0].to_string(), content: Some(content),
let request = tonic::Request::new(WorkspaceRequest {
session_key: args[0].to_string(),
});
let mut c = self.client.clone();
let resp = c.create(request).await.unwrap().into_inner();
if resp.accepted {
Ok(Value::from(resp.session_key))
} else {
Err(Value::from("[!] rejected"))
}
Err(Value::from("[!] Unimplemented"))
// let resp = c.create(request).await.unwrap().into_inner();
// if resp.accepted {
// Ok(Value::from(resp.session_key))
// } else {
// Err(Value::from("[!] rejected"))
// }
},
"sync" => {
if args.len() < 1 {
return Err(Value::from("[!] no session key"));
}
let buf = neovim.get_current_buf().await.unwrap();
let request = tonic::Request::new(SessionRequest {
session_key: args[0].to_string(), content: None,
let request = tonic::Request::new(WorkspaceRequest {
session_key: args[0].to_string(),
});
let mut c = self.client.clone();
let resp = c.sync(request).await.unwrap().into_inner();
if let Some(content) = resp.content {
buf.set_lines(
0,
buf.line_count().await.unwrap(),
false,
content.split("\n").map(|s| s.to_string()).collect()
).await.unwrap();
Ok(Value::from(""))
} else {
Err(Value::from("[!] no content"))
}
Err(Value::from("[!] Unimplemented"))
// let resp = c.sync(request).await.unwrap().into_inner();
// if let Some(content) = resp.content {
// buf.set_lines(
// 0,
// buf.line_count().await.unwrap(),
// false,
// content.split("\n").map(|s| s.to_string()).collect()
// ).await.unwrap();
// Ok(Value::from(""))
// } else {
// Err(Value::from("[!] no content"))
// }
},
"leave" => {
if args.len() < 1 {
return Err(Value::from("[!] no session key"));
}
let request = tonic::Request::new(SessionRequest {
session_key: args[0].to_string(), content: None,
let request = tonic::Request::new(WorkspaceRequest {
session_key: args[0].to_string(),
});
let mut c = self.client.clone();
let resp = c.leave(request).await.unwrap().into_inner();
if resp.accepted {
Ok(Value::from(format!("closed session #{}", resp.session_key)))
} else {
Err(Value::from("[!] could not close session"))
}
Err(Value::from("[!] Unimplemented"))
// let resp = c.leave(request).await.unwrap().into_inner();
// if resp.accepted {
// Ok(Value::from(format!("closed session #{}", resp.session_key)))
// } else {
// Err(Value::from("[!] could not close session"))
// }
},
_ => {
eprintln!("[!] unexpected call");