const std = @import("std"); const Header = @This(); content_length: usize, /// null implies "application/vscode-jsonrpc; charset=utf-8" content_type: ?[]const u8 = null, pub fn deinit(self: @This(), allocator: std.mem.Allocator) void { if (self.content_type) |ct| allocator.free(ct); } // Caller owns returned memory. pub fn parse(allocator: std.mem.Allocator, include_carriage_return: bool, reader: anytype) !Header { var r = Header{ .content_length = undefined, .content_type = null, }; errdefer r.deinit(allocator); var has_content_length = false; while (true) { const header = try reader.readUntilDelimiterAlloc(allocator, '\n', 0x100); defer allocator.free(header); if (include_carriage_return) { if (header.len == 0 or header[header.len - 1] != '\r') return error.MissingCarriageReturn; if (header.len == 1) break; } else { if (header.len == 0) break; } const header_name = header[0 .. std.mem.indexOf(u8, header, ": ") orelse return error.MissingColon]; const header_value = header[header_name.len + 2 .. header.len - @boolToInt(include_carriage_return)]; if (std.mem.eql(u8, header_name, "Content-Length")) { if (header_value.len == 0) return error.MissingHeaderValue; r.content_length = std.fmt.parseInt(usize, header_value, 10) catch return error.InvalidContentLength; has_content_length = true; } else if (std.mem.eql(u8, header_name, "Content-Type")) { r.content_type = try allocator.dupe(u8, header_value); } else { return error.UnknownHeader; } } if (!has_content_length) return error.MissingContentLength; return r; } pub fn write(header: Header, include_carriage_return: bool, writer: anytype) @TypeOf(writer).Error!void { const seperator: []const u8 = if (include_carriage_return) "\r\n" else "\n"; try writer.print("Content-Length: {}{s}", .{ header.content_length, seperator }); if (header.content_type) |content_type| { try writer.print("Content-Type: {s}{s}", .{ content_type, seperator }); } try writer.writeAll(seperator); }