mirror of
https://git.robbyzambito.me/zaprus
synced 2025-12-20 16:24:50 +00:00
Compare commits
1 Commits
invy
...
push-lwzrp
| Author | SHA1 | Date | |
|---|---|---|---|
| 53a84b10bf |
@@ -48,9 +48,11 @@ pub fn main() !void {
|
|||||||
return clap.help(std.io.getStdErr().writer(), clap.Help, ¶ms, .{});
|
return clap.help(std.io.getStdErr().writer(), clap.Help, ¶ms, .{});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
std.debug.print("main\n", .{});
|
||||||
|
|
||||||
if (res.args.relay) |r| {
|
if (res.args.relay) |r| {
|
||||||
try Saprus.sendRelay(if (r.len > 0) r else "Hello darkness my old friend", gpa);
|
try Saprus.sendRelay(if (r.len > 0) r else "Hello darkness my old friend", gpa);
|
||||||
// std.debug.print("Sent: {s}\n", .{r});
|
std.debug.print("Sent: {s}\n", .{r});
|
||||||
return;
|
return;
|
||||||
} else if (res.args.connect) |c| {
|
} else if (res.args.connect) |c| {
|
||||||
const conn_res: ?SaprusMessage = Saprus.connect(if (c.len > 0) c else "Hello darkness my old friend", gpa) catch |err| switch (err) {
|
const conn_res: ?SaprusMessage = Saprus.connect(if (c.len > 0) c else "Hello darkness my old friend", gpa) catch |err| switch (err) {
|
||||||
|
|||||||
@@ -42,7 +42,7 @@ fn broadcastSaprusMessage(msg: SaprusMessage, udp_port: u16, allocator: Allocato
|
|||||||
pub fn sendRelay(payload: []const u8, allocator: Allocator) !void {
|
pub fn sendRelay(payload: []const u8, allocator: Allocator) !void {
|
||||||
const msg = SaprusMessage{
|
const msg = SaprusMessage{
|
||||||
.relay = .{
|
.relay = .{
|
||||||
.header = .{ .dest = .{ 70, 70, 70, 70 } },
|
.header = .{ .dest = .{ 255, 255, 255, 255 } },
|
||||||
.payload = payload,
|
.payload = payload,
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
@@ -85,9 +85,11 @@ pub fn connect(payload: []const u8, allocator: Allocator) !?SaprusMessage {
|
|||||||
var initial_conn_res: ?SaprusMessage = null;
|
var initial_conn_res: ?SaprusMessage = null;
|
||||||
errdefer if (initial_conn_res) |c| c.deinit(allocator);
|
errdefer if (initial_conn_res) |c| c.deinit(allocator);
|
||||||
|
|
||||||
|
std.debug.print("creating socket\n", .{});
|
||||||
var sock = try network.Socket.create(.ipv4, .udp);
|
var sock = try network.Socket.create(.ipv4, .udp);
|
||||||
defer sock.close();
|
defer sock.close();
|
||||||
|
|
||||||
|
std.debug.print("creating endpoint\n", .{});
|
||||||
// Bind to 255.255.255.255:8888
|
// Bind to 255.255.255.255:8888
|
||||||
const bind_addr = network.EndPoint{
|
const bind_addr = network.EndPoint{
|
||||||
.address = network.Address{ .ipv4 = network.Address.IPv4.broadcast },
|
.address = network.Address{ .ipv4 = network.Address.IPv4.broadcast },
|
||||||
@@ -96,8 +98,10 @@ pub fn connect(payload: []const u8, allocator: Allocator) !?SaprusMessage {
|
|||||||
|
|
||||||
// timeout 1s
|
// timeout 1s
|
||||||
try sock.setReadTimeout(1 * std.time.us_per_s);
|
try sock.setReadTimeout(1 * std.time.us_per_s);
|
||||||
|
std.debug.print("binding to socket\n", .{});
|
||||||
try sock.bind(bind_addr);
|
try sock.bind(bind_addr);
|
||||||
|
|
||||||
|
std.debug.print("sending initial connection payload\n", .{});
|
||||||
const msg = try sendInitialConnection(payload, initial_port, allocator);
|
const msg = try sendInitialConnection(payload, initial_port, allocator);
|
||||||
|
|
||||||
var response_buf: [4096]u8 = undefined;
|
var response_buf: [4096]u8 = undefined;
|
||||||
|
|||||||
Reference in New Issue
Block a user