omedusyo/minisql
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix typos

Browse source
This commit is contained in:
Yuriy Dupyn 2023-12-28 09:27:55 +01:00
parent 84d9fa2d50
commit eb8410718d
2 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
client/src/main.rs
View file

@ -11,9 +11,9 @@ use proto::writer::oneway::OneWayProtoWriter;
#[tokio::main] #[tokio::main]
async fn main() -> anyhow::Result<()> { async fn main() -> anyhow::Result<()> {
let add = "127.0.0.1:5432"; let addr = "127.0.0.1:5432";
let mut stream = TcpStream::connect(add).await?; let mut stream = TcpStream::connect(addr).await?;
let (reader, writer) = stream.split(); let (reader, writer) = stream.split();
let mut writer = ProtoWriter::new(BufWriter::new(writer)); let mut writer = ProtoWriter::new(BufWriter::new(writer));

5
server/src/main.rs
View file

@ -34,6 +34,7 @@ async fn handle_stream(mut stream: TcpStream) -> anyhow::Result<()> {
let mut reader = ProtoReader::new(BufReader::new(reader), 1024); let mut reader = ProtoReader::new(BufReader::new(reader), 1024);
let response = HandshakeResponse::new("minisql", 123, 123); let response = HandshakeResponse::new("minisql", 123, 123);
let request = do_server_handshake(&mut writer, &mut reader, response).await?; let request = do_server_handshake(&mut writer, &mut reader, response).await?;
println!("Handshake complete:\n{request:?}"); println!("Handshake complete:\n{request:?}");
@ -54,7 +55,7 @@ async fn handle_stream(mut stream: TcpStream) -> anyhow::Result<()> {
send_error_response(&mut writer, "Car not found").await?; send_error_response(&mut writer, "Car not found").await?;
} else if data.query.as_str().to_lowercase().contains("select") { } else if data.query.as_str().to_lowercase().contains("select") {
println!("Sending table"); println!("Sending table");
send_query_repsonse(&mut writer).await?; send_query_response(&mut writer).await?;
} else { } else {
println!("Sending empty query"); println!("Sending empty query");
send_empty_query(&mut writer).await?; send_empty_query(&mut writer).await?;
@ -144,7 +145,7 @@ async fn send_row_description(writer: &mut impl BackendProtoWriter) -> anyhow::R
Ok(()) Ok(())
} }
async fn send_query_repsonse(writer: &mut impl BackendProtoWriter) -> anyhow::Result<()> { async fn send_query_response(writer: &mut impl BackendProtoWriter) -> anyhow::Result<()> {
send_row_description(writer).await?; send_row_description(writer).await?;
write_row(writer, b"0", b"1337", b"auto").await?; write_row(writer, b"0", b"1337", b"auto").await?;