Add command complete message

2 files changed, 58 insertions, 0 deletions

diff --git a/src/command_complete.zig b/src/command_complete.zig
new file mode 100644
index 0000000..5478547
--- /dev/null
+++ b/src/command_complete.zig
@@ -0,0 +1,56 @@
+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);
+}
diff --git a/src/main.zig b/src/main.zig
index 8c2aed9..4186377 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -10,6 +10,7 @@ const BackendKeyData = @import("backend_key_data.zig");
 const Query = @import("query.zig");
 const DataRow = @import("data_row.zig");
 const RowDescription = @import("row_description.zig");
+const CommandComplete = @import("command_complete.zig");
 const Conn = @import("conn.zig");
 
 pub const ProtocolError = error{
@@ -127,4 +128,5 @@ test {
     _ = Query;
     _ = DataRow;
     _ = RowDescription;
+    _ = CommandComplete;
 }