Compare commits

..

2 Commits

Author SHA1 Message Date
e09469d562 make address an argument 2023-11-27 15:53:57 -05:00
22b0f9037b switch to udp connection 2023-11-27 15:45:44 -05:00

View File

@ -1,43 +1,25 @@
use std::io::{BufRead, BufReader};
use std::net::TcpStream;
//const REQUEST: &str = "GET /sse HTTP/1.1\x0d\x0aHost: 192.168.1.10:8100\x0d\x0aUser-Agent: curl/8.4.0\x0d\x0aAccept: */*\x0d\x0a\x0d\x0a";
use std::env;
use std::io::Write;
use std::net::UdpSocket;
fn main() -> std::io::Result<()> {
//println!("Hello, world!");
//println!("str: {}", REQUEST);
//let mut stdout = std::io::stdout();
let stream = TcpStream::connect("192.168.1.10:10110")?;
//let mut buffer = vec![0_u8; 1024];
let mut buffer = BufReader::new(stream);
let mut current_line = String::new();
while let Ok(n) = buffer.read_line(&mut current_line) {
if n == 0 {
break;
let addr = match env::args().nth(1) {
Some(x) => x,
None => {
println!("Error no address");
return Ok(());
}
println!("{}", current_line);
current_line.clear();
};
let mut stdout = std::io::stdout();
let socket = UdpSocket::bind(addr)?;
let mut buf = [0_u8; 1024];
while let Ok((n_recv, _src)) = socket.recv_from(&mut buf) {
stdout.write_all(&buf[..n_recv])?;
}
//stream.write_all(REQUEST.as_bytes())?;
//let header_end = u32::from_ne_bytes(*b"\r\n\r\n");
//while let Ok(n) = stream.read(&mut buffer[4..]) {
// stdout.write_all(&buffer[4..4 + n])?;
//for i in (0..n).into_iter().step_by(2) {
// for i in 0..n {
// let value = u32::from_ne_bytes(buffer[i..i + 4].try_into().unwrap());
// if value == header_end {
// buffer.copy_within(i + 4..n, 0);
// break;
// }
// }
// buffer.copy_within(n..n + 4, 0);
//}
//stream.read(&mut buffer)
Ok(())
}