about summary refs log tree commit diff
path: root/src/layer3.rs
blob: 7521c0dc81bdaf4548df7ad012d2e2dd451dd040 (plain)
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
pub struct Tcp<'p> {
	src: u16,
	dst: u16,
	payload: &'p [u8],
}

impl<'p> Tcp<'p> {
	pub fn new(buffer: &'p [u8]) -> Self {
		let src = u16::from_be_bytes([buffer[0], buffer[1]]);
		let dst = u16::from_be_bytes([buffer[2], buffer[3]]);
		let data_offset = (buffer[12].to_be() & 0b1111_0000) >> 4;
		// Offset is number of 32-bit words
		let true_offset = data_offset as usize * 4;

		Self {
			src,
			dst,
			payload: &buffer[true_offset..],
		}
	}

	pub fn source_port(&self) -> u16 {
		self.src
	}

	pub fn destination_port(&self) -> u16 {
		self.dst
	}

	pub fn payload(&self) -> &[u8] {
		self.payload
	}
}

pub struct Udp<'p> {
	src: u16,
	dst: u16,
	payload: &'p [u8],
}

impl<'p> Udp<'p> {
	pub fn new(buffer: &'p [u8]) -> Self {
		let src = u16::from_be_bytes([buffer[0], buffer[1]]);
		let dst = u16::from_be_bytes([buffer[2], buffer[3]]);
		let _len = u16::from_be_bytes([buffer[4], buffer[5]]);

		Self {
			src,
			dst,
			payload: &buffer[8..],
		}
	}

	pub fn source_port(&self) -> u16 {
		self.src
	}

	pub fn destination_port(&self) -> u16 {
		self.dst
	}

	pub fn payload(&self) -> &[u8] {
		self.payload
	}
}