zambyte/zaprus
1
0
Fork 0
mirror of https://git.robbyzambito.me/zaprus synced 2026-02-04 08:24:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Chunk messages to 1000 byte payloads

Browse Source
This commit is contained in:
Robby Zambito
2026-01-24 10:55:29 -05:00
parent 157afa13b1
commit fc9c5bcd5d
3 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/Client.zig
View File

@@ -5,6 +5,8 @@ const Client = @This();
const max_message_size = 2048; const max_message_size = 2048;
pub const max_payload_len = RawSocket.max_payload_len;
socket: RawSocket, socket: RawSocket,
pub fn init() !Client { pub fn init() !Client {

2
src/RawSocket.zig
View File

@@ -4,6 +4,8 @@ fd: i32,
sockaddr_ll: std.posix.sockaddr.ll, sockaddr_ll: std.posix.sockaddr.ll,
mac: [6]u8, mac: [6]u8,
pub const max_payload_len = 1000;
const Ifconf = extern struct { const Ifconf = extern struct {
ifc_len: i32, ifc_len: i32,
ifc_ifcu: extern union { ifc_ifcu: extern union {

19
src/main.zig
View File

@@ -127,14 +127,21 @@ pub fn main(init: std.process.Init) !void {
var child_stderr: std.ArrayList(u8) = .empty; var child_stderr: std.ArrayList(u8) = .empty;
defer child_stderr.deinit(init.gpa); defer child_stderr.deinit(init.gpa);
try child.collectOutput(init.gpa, &child_stdout, &child_stderr, 2048); try child.collectOutput(init.gpa, &child_stdout, &child_stderr, std.math.maxInt(usize));
const b64e = std.base64.standard.Encoder; // const b64e = std.base64.standard.Encoder;
var cmd_output_buf: [2048]u8 = undefined; var cmd_output: Writer = blk: {
const encoded_cmd_output = b64e.encode(&cmd_output_buf, child_stdout.items); var cmd_output_buf: [2048]u8 = undefined;
break :blk .fixed(&cmd_output_buf);
};
connection.send(init.io, encoded_cmd_output) catch continue; var cmd_output_window_iter = std.mem.window(u8, child_stdout.items, SaprusClient.max_payload_len, SaprusClient.max_payload_len);
try init.io.sleep(.fromMilliseconds(40), .real); while (cmd_output_window_iter.next()) |chunk| {
cmd_output.end = 0;
try cmd_output.print("{b64}", .{chunk});
try connection.send(init.io, cmd_output.buffered());
try init.io.sleep(.fromMilliseconds(40), .real);
}
} }
} }
} }