neurocyte/flow
neurocyte/flow
1
1
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

refactor: add log_execute option to shell module

Browse source
This commit is contained in:
CJ van den Berg 2025-04-21 18:11:51 +02:00
parent a1632da329
commit 8582d223f7
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/shell.zig
View file

@ -36,6 +36,7 @@ pub const Handlers = struct {
out: *const OutputHandler, out: *const OutputHandler,
err: ?*const OutputHandler = null, err: ?*const OutputHandler = null,
exit: *const ExitHandler = log_exit_handler, exit: *const ExitHandler = log_exit_handler,
log_execute: bool = true,
}; };
pub fn execute(allocator: std.mem.Allocator, argv: tp.message, handlers: Handlers) Error!void { pub fn execute(allocator: std.mem.Allocator, argv: tp.message, handlers: Handlers) Error!void {
@ -185,7 +186,8 @@ const Process = struct {
_ = tp.set_trap(true); _ = tp.set_trap(true);
var buf: [1024]u8 = undefined; var buf: [1024]u8 = undefined;
const json = self.argv.to_json(&buf) catch |e| return tp.exit_error(e, @errorReturnTrace()); const json = self.argv.to_json(&buf) catch |e| return tp.exit_error(e, @errorReturnTrace());
self.logger.print("shell: execute {s}", .{json}); if (self.handlers.log_execute)
self.logger.print("shell: execute {s}", .{json});
self.sp = tp.subprocess.init(self.allocator, self.argv, module_name, self.stdin_behavior) catch |e| return tp.exit_error(e, @errorReturnTrace()); self.sp = tp.subprocess.init(self.allocator, self.argv, module_name, self.stdin_behavior) catch |e| return tp.exit_error(e, @errorReturnTrace());
tp.receive(&self.receiver); tp.receive(&self.receiver);
} }