diff options
Diffstat (limited to 'src/command_complete.zig')
-rw-r--r-- | src/command_complete.zig | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/src/command_complete.zig b/src/command_complete.zig deleted file mode 100644 index 5478547..0000000 --- a/src/command_complete.zig +++ /dev/null @@ -1,56 +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; -const FormatCode = @import("main.zig").FormatCode; - -pub const Tag: u8 = 'C'; - -const CommandComplete = @This(); - -command_tag: []const u8, -owned: bool = false, - -pub fn read(a: std.mem.Allocator, b: []const u8) !CommandComplete { - return .{ - .command_tag = try a.dupe(u8, b), - .owned = true, - }; -} - -pub fn write(self: CommandComplete, _: std.mem.Allocator, stream_writer: anytype) !void { - try stream_writer.writeByte(Tag); - try stream_writer.writeIntBig(u32, @as(u32, @intCast(4+self.command_tag.len))); - try stream_writer.writeAll(self.command_tag); -} - -pub fn deinit(self: *CommandComplete, a: std.mem.Allocator) void { - if (self.owned) a.free(self.command_tag); -} - -test "round trip" { - const allocator = std.testing.allocator; - var sm = CommandComplete{ - .command_tag = "foo", - }; - 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 CommandComplete.read(allocator, buf); - defer sm2.deinit(allocator); - - try std.testing.expectEqualStrings("foo", sm2.command_tag); -} |