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

feat: support command arguments in run_async

Browse source
This commit is contained in:
CJ van den Berg 2024-11-20 20:13:05 +01:00
parent 22edc62874
commit e861bcecbe
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 38 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
src/tui/tui.zig
View file

@ -1,5 +1,6 @@
const std = @import("std");
const tp = @import("thespian");
const cbor = @import("cbor");
const log = @import("log");
const config = @import("config");
const project_manager = @import("project_manager");
@ -817,11 +818,44 @@ const cmds = struct {
}
pub const open_keybind_config_meta = .{ .description = "Edit key bindings" };
pub fn run_async(_: *Self, ctx: Ctx) Result {
var cmd: []const u8 = undefined;
if (!try ctx.args.match(.{tp.extract(&cmd)}))
pub fn run_async(self: *Self, ctx: Ctx) Result {
var iter = ctx.args.buf;
var len = try cbor.decodeArrayHeader(&iter);
if (len < 1)
return tp.exit_error(error.InvalidArgument, null);
try tp.self_pid().send(.{ "cmd", cmd, .{} });
var cmd: []const u8 = undefined;
if (!try cbor.matchValue(&iter, cbor.extract(&cmd)))
return tp.exit_error(error.InvalidArgument, null);
len -= 1;
var args = std.ArrayList([]const u8).init(self.allocator);
defer args.deinit();
while (len > 0) : (len -= 1) {
var arg: []const u8 = undefined;
if (try cbor.matchValue(&iter, cbor.extract_cbor(&arg))) {
try args.append(arg);
} else return tp.exit_error(error.InvalidArgument, null);
}
var args_cb = std.ArrayList(u8).init(self.allocator);
defer args_cb.deinit();
{
const writer = args_cb.writer();
try cbor.writeArrayHeader(writer, args.items.len);
for (args.items) |arg| try writer.writeAll(arg);
}
var msg_cb = std.ArrayList(u8).init(self.allocator);
defer msg_cb.deinit();
{
const writer = msg_cb.writer();
try cbor.writeArrayHeader(writer, 3);
try cbor.writeValue(writer, "cmd");
try cbor.writeValue(writer, cmd);
try writer.writeAll(args_cb.items);
}
try tp.self_pid().send_raw(.{ .buf = msg_cb.items });
}
pub const run_async_meta = .{ .interactive = false };
};