mirror of
https://git.robbyzambito.me/zaprus
synced 2025-12-21 00:34:50 +00:00
Compare commits
1 Commits
push-lwzrp
...
invy
| Author | SHA1 | Date | |
|---|---|---|---|
| 8779b29149 |
@@ -48,11 +48,9 @@ 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 = .{ 255, 255, 255, 255 } },
|
.header = .{ .dest = .{ 70, 70, 70, 70 } },
|
||||||
.payload = payload,
|
.payload = payload,
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
@@ -85,11 +85,9 @@ 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 },
|
||||||
@@ -98,10 +96,8 @@ 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