zambyte/zaprus
1
0
Fork 0
mirror of https://git.robbyzambito.me/zaprus synced 2025-12-20 16:24:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

it works!

Browse Source
This commit is contained in:
Robby Zambito
2025-04-02 18:38:31 -04:00
parent 3e265aeadb
commit 0eda295e0c
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/main.zig
View File

@@ -16,7 +16,7 @@ const SaprusHeaderFrame = struct {
const Self = @This(); const Self = @This();
fn toBytes(s: Self, allocator: Allocator) ![]u8 { fn toBytes(s: Self, allocator: Allocator) ![]u8 {
const buf = try allocator.alloc(u8, 32 + s.payload.len); const buf = try allocator.alloc(u8, 4 + s.payload.len);
std.mem.writeInt(u16, buf[0..2], @intFromEnum(s.msg_type), .big); std.mem.writeInt(u16, buf[0..2], @intFromEnum(s.msg_type), .big);
std.mem.writeInt(u16, buf[2..4], @intCast(s.payload.len), .big); std.mem.writeInt(u16, buf[2..4], @intCast(s.payload.len), .big);
std.mem.copyForwards(u8, buf[4..], s.payload); std.mem.copyForwards(u8, buf[4..], s.payload);
@@ -34,6 +34,7 @@ const SaprusRelayMessage = struct {
const buf = try allocator.alloc(u8, 4 + s.payload.len); const buf = try allocator.alloc(u8, 4 + s.payload.len);
std.mem.copyForwards(u8, buf[0..4], &s.dest); std.mem.copyForwards(u8, buf[0..4], &s.dest);
std.mem.copyForwards(u8, buf[4..], s.payload); std.mem.copyForwards(u8, buf[4..], s.payload);
std.debug.print("in tobytes {x}\n", .{buf});
return buf; return buf;
} }
}; };
@@ -47,9 +48,15 @@ pub fn main() !void {
var allocator = if (dba) |*d| d.allocator() else std.heap.smp_allocator; var allocator = if (dba) |*d| d.allocator() else std.heap.smp_allocator;
const str_msg = "Hello darkness my old friend";
var payload_bytes: [str_msg.len + 1]u8 = @splat(0);
// const payload_bytes = try allocator.alloc(u8, str_msg.len);
// defer allocator.free(payload_bytes);
// std.mem.copyForwards(u8, payload_bytes[0..], str_msg);
std.mem.copyBackwards(u8, payload_bytes[0..], str_msg);
const relay: SaprusRelayMessage = .{ const relay: SaprusRelayMessage = .{
.dest = [_]u8{ 255, 255, 255, 255 }, .dest = [_]u8{ 255, 255, 255, 255 },
.payload = @ptrCast(@constCast("Hello darkness my old friend")), .payload = payload_bytes[0..str_msg.len],
}; };
const relay_bytes = try relay.toBytes(allocator); const relay_bytes = try relay.toBytes(allocator);
defer allocator.free(relay_bytes); defer allocator.free(relay_bytes);
@@ -81,6 +88,9 @@ pub fn main() !void {
try sock.bind(bind_addr); try sock.bind(bind_addr);
// std.debug.print("relay: {x}\n", .{relay_bytes});
std.debug.print("message bytes: {x}\n", .{msg_bytes});
// @breakpoint(); // @breakpoint();
_ = try sock.sendTo(dest_addr, msg_bytes); _ = try sock.sendTo(dest_addr, msg_bytes);