diff --git a/src/tui/inputview.zig b/src/tui/inputview.zig index 810126d..80578c4 100644 --- a/src/tui/inputview.zig +++ b/src/tui/inputview.zig @@ -13,7 +13,6 @@ const input = @import("input"); const tui = @import("tui.zig"); const Widget = @import("Widget.zig"); -const MessageFilter = @import("MessageFilter.zig"); pub const name = "inputview"; @@ -44,14 +43,10 @@ pub fn create(allocator: Allocator, parent: Plane) !Widget { .buffer = .empty, }; try tui.input_listeners().add(EventHandler.bind(self, listen)); - try tui.message_filters().add(MessageFilter.bind(self, keybind_match)); - tui.enable_match_events(); return Widget.to(self); } pub fn deinit(self: *Self, allocator: Allocator) void { - tui.disable_match_events(); - tui.message_filters().remove_ptr(self); tui.input_listeners().remove_ptr(self); for (self.buffer.items) |item| self.allocator.free(item.json); @@ -135,21 +130,6 @@ fn listen(self: *Self, _: tp.pid_ref, m: tp.message) tp.result { self.append(result.written()) catch |e| return tp.exit_error(e, @errorReturnTrace()); } -fn keybind_match(self: *Self, _: tp.pid_ref, m: tp.message) MessageFilter.Error!bool { - var namespace: []const u8 = undefined; - var section: []const u8 = undefined; - var cmds: []const u8 = undefined; - if (!(m.match(.{ "K", tp.extract(&namespace), tp.extract(§ion), tp.extract_cbor(&cmds) }) catch false)) return false; - - var result: Writer.Allocating = .init(self.allocator); - defer result.deinit(); - const writer = &result.writer; - cbor.toJsonWriter(m.buf, writer, .{}) catch return true; - - self.append(result.written()) catch return true; - return true; -} - pub fn receive(_: *Self, _: tp.pid_ref, _: tp.message) error{Exit}!bool { return false; } diff --git a/src/tui/keybindview.zig b/src/tui/keybindview.zig new file mode 100644 index 0000000..3e5c3f3 --- /dev/null +++ b/src/tui/keybindview.zig @@ -0,0 +1,114 @@ +const eql = @import("std").mem.eql; +const time = @import("std").time; +const Allocator = @import("std").mem.Allocator; +const ArrayList = @import("std").ArrayList; +const Writer = @import("std").Io.Writer; + +const tp = @import("thespian"); +const cbor = @import("cbor"); + +const Plane = @import("renderer").Plane; +const input = @import("input"); + +const tui = @import("tui.zig"); +const Widget = @import("Widget.zig"); +const MessageFilter = @import("MessageFilter.zig"); + +pub const name = "keybindview"; + +allocator: Allocator, +parent: Plane, +plane: Plane, +buffer: Buffer, + +const Self = @This(); + +const Entry = struct { + time: i64, + tdiff: i64, + msg: []u8, +}; +const Buffer = ArrayList(Entry); + +pub fn create(allocator: Allocator, parent: Plane) !Widget { + var n = try Plane.init(&(Widget.Box{}).opts_vscroll(@typeName(Self)), parent); + errdefer n.deinit(); + const self = try allocator.create(Self); + errdefer allocator.destroy(self); + self.* = .{ + .allocator = allocator, + .parent = parent, + .plane = n, + .buffer = .empty, + }; + try tui.message_filters().add(MessageFilter.bind(self, keybind_match)); + tui.enable_match_events(); + return Widget.to(self); +} + +pub fn deinit(self: *Self, allocator: Allocator) void { + tui.disable_match_events(); + tui.message_filters().remove_ptr(self); + for (self.buffer.items) |item| + self.allocator.free(item.msg); + self.buffer.deinit(self.allocator); + self.plane.deinit(); + allocator.destroy(self); +} + +pub fn render(self: *Self, theme: *const Widget.Theme) bool { + self.plane.set_base_style(theme.panel); + self.plane.erase(); + self.plane.home(); + const height = self.plane.dim_y(); + var first = true; + const count = self.buffer.items.len; + const begin_at = if (height > count) 0 else count - height; + for (self.buffer.items[begin_at..]) |item| { + if (first) first = false else _ = self.plane.putstr("\n") catch return false; + self.output_tdiff(item.tdiff) catch return false; + _ = self.plane.putstr(item.msg) catch return false; + } + return false; +} + +fn output_tdiff(self: *Self, tdiff: i64) !void { + const msi = @divFloor(tdiff, time.us_per_ms); + if (msi == 0) { + const d: f64 = @floatFromInt(tdiff); + const ms = d / time.us_per_ms; + _ = try self.plane.print("{d:6.2}▎", .{ms}); + } else { + const ms: u64 = @intCast(msi); + _ = try self.plane.print("{d:6}▎", .{ms}); + } +} + +fn append(self: *Self, msg: []const u8) !void { + const ts = time.microTimestamp(); + const tdiff = if (self.buffer.items.len > 0) ts -| self.buffer.items[self.buffer.items.len - 1].time else 0; + (try self.buffer.addOne(self.allocator)).* = .{ + .time = ts, + .tdiff = tdiff, + .msg = try self.allocator.dupeZ(u8, msg), + }; +} + +fn keybind_match(self: *Self, _: tp.pid_ref, m: tp.message) MessageFilter.Error!bool { + var namespace: []const u8 = undefined; + var section: []const u8 = undefined; + var cmds: []const u8 = undefined; + if (!(m.match(.{ "K", tp.extract(&namespace), tp.extract(§ion), tp.extract_cbor(&cmds) }) catch false)) return false; + + var result: Writer.Allocating = .init(self.allocator); + defer result.deinit(); + const writer = &result.writer; + cbor.toJsonWriter(m.buf, writer, .{}) catch return true; + + self.append(result.written()) catch return true; + return true; +} + +pub fn receive(_: *Self, _: tp.pid_ref, _: tp.message) error{Exit}!bool { + return false; +}