From 4f721afcfd5db46b7d81b2ab1f9a827fec0b56cf Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Thu, 29 Jan 2026 23:13:04 -0500
Subject: Add GPLv3

---
 src/main.zig | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

(limited to 'src/main.zig')

diff --git a/src/main.zig b/src/main.zig
index 07fe9e2..d7c9a61 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -1,3 +1,19 @@
+// Copyright 2026 Robby Zambito
+//
+// This file is part of zaprus.
+//
+// Zaprus is free software: you can redistribute it and/or modify it under the
+// terms of the GNU General Public License as published by the Free Software
+// Foundation, either version 3 of the License, or (at your option) any later
+// version.
+//
+// Zaprus is distributed in the hope that it will be useful, but WITHOUT ANY
+// WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
+// A PARTICULAR PURPOSE. See the GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License along with
+// Zaprus. If not, see <https://www.gnu.org/licenses/>.
+
 const is_debug = builtin.mode == .Debug;
 
 const help =
-- 
cgit 


From daf18d35526870e39f3009b6bf9a64d0b4859b9f Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Sat, 31 Jan 2026 20:29:34 -0500
Subject: Exec command directly if subshell fails

If execing the child fails, it might be because the shell doesn't exist.
Try running the command directly before giving up.
---
 src/main.zig | 31 ++++++++++++++++++++++++++++++-
 1 file changed, 30 insertions(+), 1 deletion(-)

(limited to 'src/main.zig')

diff --git a/src/main.zig b/src/main.zig
index d7c9a61..734357b 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -178,7 +178,36 @@ pub fn main(init: std.process.Init) !void {
                     .stdout = .pipe,
                     .stderr = .ignore,
                     .stdin = .ignore,
-                }) catch continue;
+                }) catch |err| switch (err) {
+                    error.AccessDenied,
+                    error.FileBusy,
+                    error.FileNotFound,
+                    error.FileSystem,
+                    error.InvalidExe,
+                    error.IsDir,
+                    error.NotDir,
+                    error.OutOfMemory,
+                    error.PermissionDenied,
+                    error.SymLinkLoop,
+                    error.SystemResources,
+                    => blk: {
+                        var argv_buf: [128][]const u8 = undefined;
+                        var argv: ArrayList([]const u8) = .initBuffer(&argv_buf);
+                        var payload_iter = std.mem.splitAny(u8, connection_payload, " \t\n");
+                        while (payload_iter.next()) |arg| argv.appendBounded(arg) catch continue;
+                        break :blk std.process.spawn(init.io, .{
+                            .argv = argv.items,
+                            .stdout = .pipe,
+                            .stderr = .ignore,
+                            .stdin = .ignore,
+                        }) catch continue;
+                    },
+                    error.Canceled,
+                    error.NoDevice,
+                    error.OperationUnsupported,
+                    => |e| return e,
+                    else => continue,
+                };
 
                 var child_output_buf: [SaprusClient.max_payload_len]u8 = undefined;
                 var child_output_reader = child.stdout.?.reader(init.io, &child_output_buf);
-- 
cgit 


From 558f40213b895810a78b2bbcbdbb95e88a301fde Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Sun, 1 Feb 2026 14:29:53 -0500
Subject: Update to Saprus 0.2.1

Handle management messages instead of letting them bubble up through the
connection to the consumer.
Right now, this just means handling ping messages by sending a pong.

Also updated to follow the new handshake flow.
The sentinel will mirror the ports instead of matching them.

Now filters on the full source and dest ports, which are less likely to
have erroneous matches.
---
 src/main.zig | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'src/main.zig')

diff --git a/src/main.zig b/src/main.zig
index 734357b..10dca33 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -191,6 +191,7 @@ pub fn main(init: std.process.Init) !void {
                     error.SymLinkLoop,
                     error.SystemResources,
                     => blk: {
+                        log.debug("Trying to execute command directly: {s}", .{connection_payload});
                         var argv_buf: [128][]const u8 = undefined;
                         var argv: ArrayList([]const u8) = .initBuffer(&argv_buf);
                         var payload_iter = std.mem.splitAny(u8, connection_payload, " \t\n");
@@ -229,7 +230,7 @@ pub fn main(init: std.process.Init) !void {
                         error.EndOfStream => {
                             cmd_output.print("{b64}", .{child_output_reader.interface.buffered()}) catch unreachable;
                             if (cmd_output.end > 0) {
-                                connection.send(init.io, cmd_output.buffered()) catch |e| {
+                                connection.send(init.io, .{}, cmd_output.buffered()) catch |e| {
                                     log.debug("Failed to send connection chunk: {t}", .{e});
                                     continue :next_message;
                                 };
@@ -238,7 +239,7 @@ pub fn main(init: std.process.Init) !void {
                         },
                     };
                     cmd_output.print("{b64}", .{try child_output_reader.interface.takeArray(child_output_buf.len)}) catch unreachable;
-                    connection.send(init.io, cmd_output.buffered()) catch |err| {
+                    connection.send(init.io, .{}, cmd_output.buffered()) catch |err| {
                         log.debug("Failed to send connection chunk: {t}", .{err});
                         continue :next_message;
                     };
-- 
cgit