From ddc6bee3757d3e68a14fafdc47eb5d0a0ba923bb Mon Sep 17 00:00:00 2001 From: Martin Ashby Date: Sat, 23 Sep 2023 21:26:06 +0100 Subject: Got a working test connecting to postgres server and reading data. Added a couple more message types to facilitate this. --- src/authentication_ok.zig | 47 ----------------------------------------------- 1 file changed, 47 deletions(-) delete mode 100644 src/authentication_ok.zig (limited to 'src/authentication_ok.zig') diff --git a/src/authentication_ok.zig b/src/authentication_ok.zig deleted file mode 100644 index 0f0702b..0000000 --- a/src/authentication_ok.zig +++ /dev/null @@ -1,47 +0,0 @@ -const std = @import("std"); -const ProtocolError = @import("main.zig").ProtocolError; -const AuthType = @import("main.zig").AuthType; -const enum_from_int = @import("main.zig").enum_from_int; -const ClientError = @import("main.zig").ClientError; -const AuthenticationOk = @This(); -const ByteArrayList = std.ArrayList(u8); - -pub const Tag: u8 = 'R'; -pub const Type: AuthType = AuthType.AuthTypeCleartextPassword; - -pub fn read(_: std.mem.Allocator, b: []const u8) !AuthenticationOk { - if (b.len != 4) return ProtocolError.InvalidMessageLength; - - const auth_type = enum_from_int(AuthType, std.mem.readIntBig(u32, b[0..4])) orelse return ClientError.UnsupportedAuthType; - if (auth_type != Type) return ProtocolError.InvalidAuthType; - return .{}; -} - -pub fn write(_: AuthenticationOk, _: std.mem.Allocator, stream_writer: anytype) !void { - try stream_writer.writeByte(Tag); - try stream_writer.writeIntBig(u32, 8); - try stream_writer.writeIntBig(u32, @intFromEnum(Type)); -} - -pub fn deinit(_: *AuthenticationOk, _: std.mem.Allocator) void {} - -test "round trip" { - const allocator = std.testing.allocator; - var sm = AuthenticationOk{}; - 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 AuthenticationOk.read(allocator, buf); - defer sm2.deinit(allocator); -} -- cgit v1.2.3-ZIG