aboutsummaryrefslogtreecommitdiff
path: root/src/server/reader.odin
blob: b8843de3e6093d5985d042f67552b9f157bb36f2 (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
package server

import "core:os"
import "core:mem"
import "core:strings"

ReaderFn :: proc(_: rawptr, _: []byte) -> (int, int);

Reader :: struct {
	reader_fn:      ReaderFn,
	reader_context: rawptr,
}

make_reader :: proc(reader_fn: ReaderFn, reader_context: rawptr) -> Reader {
	return Reader {reader_context = reader_context, reader_fn = reader_fn};
}

read_u8 :: proc(reader: ^Reader) -> (u8, bool) {

	value: [1]byte;

	read, err := reader.reader_fn(reader.reader_context, value[:]);

	if (err != 0 || read != 1) {
		return 0, false;
	}

	return value[0], true;
}

read_until_delimiter :: proc(reader: ^Reader, delimiter: u8, builder: ^strings.Builder) -> bool {

	for true {

		value, success := read_u8(reader);

		if (!success) {
			return false;
		}

		strings.write_byte(builder, value);

		if (value == delimiter) {
			break;
		}
	}

	return true;
}

read_sized :: proc(reader: ^Reader, data: []u8) -> bool {

	read, err := reader.reader_fn(reader.reader_context, data);

	if (err != 0 || read != len(data)) {
		return false;
	}

	return true;
}