diff options
Diffstat (limited to 'src/query.zig')
-rw-r--r-- | src/query.zig | 55 |
1 files changed, 0 insertions, 55 deletions
diff --git a/src/query.zig b/src/query.zig deleted file mode 100644 index 8f07b5f..0000000 --- a/src/query.zig +++ /dev/null @@ -1,55 +0,0 @@ -const std = @import("std"); -const log = std.log.scoped(.pgz); -const ByteArrayList = std.ArrayList(u8); -const ProtocolError = @import("main.zig").ProtocolError; -const ClientError = @import("main.zig").ClientError; -const enum_from_int = @import("main.zig").enum_from_int; - -pub const Tag: u8 = 'Q'; - -const Query = @This(); - -string: []const u8, -owned: bool = false, - -pub fn read(a: std.mem.Allocator, b: []const u8) !Query { - return .{ - .string = try a.dupe(u8, b[0..(b.len-1)]), // Drop the null terminator - .owned = true, - }; -} - -pub fn write(self: Query, _: std.mem.Allocator, stream_writer: anytype) !void { - try stream_writer.writeByte(Tag); - try stream_writer.writeIntBig(u32, @as(u32, @intCast(self.string.len+5))); - try stream_writer.writeAll(self.string); - try stream_writer.writeByte(0); -} - -pub fn deinit(self: *Query, a: std.mem.Allocator) void { - if (self.owned) a.free(self.string); -} - -test "round trip" { - const allocator = std.testing.allocator; - var sm = Query{ - .string = "Hello", - }; - defer sm.deinit(allocator); - - var bal = ByteArrayList.init(allocator); - defer bal.deinit(); - try sm.write(allocator, bal.writer()); - - var fbs = std.io.fixedBufferStream(bal.items); - var reader = fbs.reader(); - const tag = try reader.readByte(); - try std.testing.expectEqual(Tag, tag); - const len = try reader.readIntBig(u32); - const buf = try allocator.alloc(u8, len - 4); - defer allocator.free(buf); - try reader.readNoEof(buf); - var sm2 = try Query.read(allocator, buf); - defer sm2.deinit(allocator); - try std.testing.expectEqualStrings("Hello", sm2.string); -} |