65 lines
2.0 KiB
Zig
65 lines
2.0 KiB
Zig
const std = @import("std");
|
|
const hexdump = @import("./hexdump.zig");
|
|
const testing = std.testing;
|
|
|
|
const log = std.log.scoped(.libipc_util);
|
|
const Message = @import("./message.zig").Message;
|
|
|
|
/// A VERY LIGHT and INCOMPLETE way of decoding URI.
|
|
/// DO NOT USE IT UNLESS YOU KNOW WHAT TO EXPECT.
|
|
pub const URI = struct {
|
|
protocol: []const u8,
|
|
address: []const u8,
|
|
path: []const u8,
|
|
|
|
const Self = @This();
|
|
|
|
pub fn read(uri_to_decode: []const u8) Self {
|
|
var protocolit = std.mem.split(u8, uri_to_decode, "://");
|
|
const protocol = protocolit.first();
|
|
|
|
var addressit = std.mem.split(u8, protocolit.next().?, "/");
|
|
const address = addressit.first();
|
|
|
|
const path = addressit.rest();
|
|
|
|
return Self{ .protocol = protocol, .address = address, .path = path };
|
|
}
|
|
};
|
|
|
|
test "URI simple decoding" {
|
|
const uri = URI.read("tcp://127.0.0.1:8000/some-path");
|
|
try testing.expectEqualSlices(u8, uri.protocol, "tcp");
|
|
try testing.expectEqualSlices(u8, uri.address, "127.0.0.1:8000");
|
|
try testing.expectEqualSlices(u8, uri.path, "some-path");
|
|
}
|
|
|
|
pub fn print_buffer(header: []const u8, buffer: []const u8) void {
|
|
var hexbuf: [4000]u8 = undefined;
|
|
var hexfbs = std.io.fixedBufferStream(&hexbuf);
|
|
const hexwriter = hexfbs.writer();
|
|
hexdump.hexdump(hexwriter, header, buffer) catch unreachable;
|
|
log.debug("{s}", .{hexfbs.getWritten()});
|
|
}
|
|
|
|
pub fn print_message(header: []const u8, m: Message) void {
|
|
print_buffer(header, m.payload);
|
|
}
|
|
|
|
pub fn print_eq(expected: anytype, obj: anytype) !void {
|
|
var buffer: [4096]u8 = undefined;
|
|
var fbs = std.io.fixedBufferStream(&buffer);
|
|
var writer = fbs.writer();
|
|
|
|
try writer.print("{}", .{obj});
|
|
|
|
// typing workaround
|
|
var secbuffer: [4096]u8 = undefined;
|
|
var secfbs = std.io.fixedBufferStream(&secbuffer);
|
|
var secwriter = secfbs.writer();
|
|
|
|
try secwriter.print("{s}", .{expected});
|
|
|
|
try testing.expectEqualSlices(u8, secfbs.getWritten(), fbs.getWritten());
|
|
}
|