package core:encoding/csv

Source

Error :: union {
	Reader_Error, 
	io.Error, 
}

Reader :: struct {
	// comma is the field delimiter
	// reader_init will set it to be ','
	// A "comma" must be a valid rune, nor can it be \r, \n, or the Unicode replacement character (0xfffd)
	comma:               rune,
	// comment, if not 0, is the comment character
	// Lines beginning with the comment character without a preceding whitespace are ignored
	comment:             rune,
	// fields_per_record is the number of expected fields per record
	//         if fields_per_record is >0, 'read' requires each record to have that field count
	//         if fields_per_record is  0, 'read' sets it to the field count in the first record
	//         if fields_per_record is <0, no check is made and records may have a variable field count
	fields_per_record:   int,
	// If trim_leading_space is true, leading whitespace in a field is ignored
	// This is done even if the field delimiter (comma), is whitespace
	trim_leading_space:  bool,
	// If lazy_quotes is true, a quote may appear in an unquoted field and a non-doubled quote may appear in a quoted field
	lazy_quotes:         bool,
	// multiline_fields, when set to true, will treat a field starting with a " as a multiline string
	// therefore, instead of reading until the next \n, it'll read until the next "
	multiline_fields:    bool,
	// reuse_record controls whether calls to 'read' may return a slice using the backing buffer
	// for performance
	// By default, each call to 'read' returns a newly allocated slice
	reuse_record:        bool,
	// reuse_record_buffer controls whether calls to 'read' clone the strings of each field or uses
	// the data stored in record buffer for performance
	// By default, each call to 'read' clones the strings of each field
	reuse_record_buffer: bool,
	// internal buffers
	r:                   bufio.Reader,
	line_count:          int,
	// current line being read in the CSV file
	raw_buffer:          [dynamic]u8,
	record_buffer:       [dynamic]u8,
	field_indices:       [dynamic]int,
	last_record:         [dynamic]string,
	sr:                  strings.Reader,
}

Reader_Error :: struct {
	kind:       Reader_Error_Kind,
	start_line: int,
	line:       int,
	column:     int,
	expected:   int,
	got:        int,
}

Reader_Error_Kind :: enum int {
	Bare_Quote, 
	Quote, 
	Field_Count, 
	Invalid_Delim, 
}

Writer :: struct {
	// Field delimiter (set to ',' with writer_init)
	comma:    rune,
	// if set to true, \r\n will be used as the line terminator
	use_crlf: bool,
	w:        io.Stream,
}

DEFAULT_RECORD_BUFFER_CAPACITY :: 256

reader_error_kind_string: [Reader_Error_Kind]string = …

is_io_error :: proc(err: Error, io_err: io.Error) -> bool {…}

read :: proc(r: ^Reader, allocator := context.allocator) -> (record: []string, err: Error) {…}

read_all :: proc(r: ^Reader, allocator := context.allocator) -> ([][]string, Error) {…}

read_all_from_string :: proc(input: string, records_allocator := context.allocator, buffer_allocator := context.allocator) -> ([][]string, Error) {…}

read_from_string :: proc(input: string, record_allocator := context.allocator, buffer_allocator := context.allocator) -> (record: []string, n: int, err: Error) {…}

reader_destroy :: proc(r: ^Reader) {…}

reader_init :: proc(reader: ^Reader, r: io.Stream, buffer_allocator := context.allocator) {…}

reader_init_with_string :: proc(reader: ^Reader, s: string, buffer_allocator := context.allocator) {…}

write :: proc(w: ^Writer, record: []string) -> io.Error {…}

write_all :: proc(w: ^Writer, records: [][]string) -> io.Error {…}

writer_flush :: proc(w: ^Writer) -> io.Error {…}

writer_init :: proc(writer: ^Writer, w: io.Stream) {…}