HAXY

▄ ▄▀▀▀▀ ▀ ▄▀▀▀▀▀ ▄▀▀▀ ▄▀▀▀▄▀▀ ▄▄▀▀▀▀▄▀ ▄▀▀▄▀▀▀▀ ▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀ ▄ ▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀ ▀▄▄▀▄▀▀▀▀ ▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀ ▄ ▀▀▀▄▀▀▀▀▀▀▀ ▀▀▀▀▀ ▄▀▀▀▀▀▀▀▀▀▄▀▀▄ ▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▄ ▀▀▄ ▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀▄▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀▀ ▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▄▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▄▀▄ ▀▀ ▀▀▀▀▀▀▄▀▀▀▀▀▄▄▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▄▀▄▄▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀▀ ▀▀ ▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▀ ▀ ▀▀▀▀▀▀▀▄▄▀▀▀▀▀▀▀▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▄▄▀▀▀▄▄▀▄▀▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▄▄▀▀▀ ▀▀ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄▀▀▄▀▀▄ ▀▀▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄ ▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀ ▀▀▀▀

╭─────────────╮ │scroll to top│ ╰─────────────╯ ╭ try.zig ──────────────────────────────────────────────────────╮ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ ╰───────────────────────────────────────────────────────────────╯

╭────╮ ╭ clone ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╮ │http│ ssh │ │ ╰────╯ ╰ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╯

.. embed/ event/ test/ ui/ command.zig diff3.zig event.zig lib.zig main.zig main_wasm.zig serve.zig serve_common.zig serve_http.zig serve_ssh.zig serve_ssh_protocol.zig test.zig testnet.zig ╭─────────────────────────────────╮ │try.zig │ ╰─────────────────────────────────╯ ui.zig web.zig

695 } 696 } 697 698 break :blk try ui.Session.init(&session_arena, &repo, .{ .user_id = &admin_user_id }); 699 }; 700 session.is_terminal = true; 701 702 // start the server 703 704 var cli = false; 705 706 var arg_it = try init.minimal.args.iterateAllocator(allocator); 707 defer arg_it.deinit(); 708 _ = arg_it.skip(); 709 while (arg_it.next()) |arg| { 710 if (std.mem.eql(u8, "--cli", arg)) { 711 cli = true; 712 } 713 } 714 715 const server_path = try std.fs.path.join(allocator, &.{ cwd_path, temp_dir_name, "server" }); 716 defer allocator.free(server_path); 717 718 // let the native TUI's page builders open the on-disk repos for the file tree 719 session.io = io; 720 session.repos_dir = try std.fs.path.join(session_arena.allocator(), &.{ server_path, "repos" }); 721 722 // leave a one-shot session for the first browser to hit the web ui, so it 723 // starts logged in as admin 724 { 725 var data_dir = try cwd.createDirPathOpen(io, server_path, .{}); 726 defer data_dir.close(io); 727 const store = try hx.web.SessionStore.init(io, data_dir); 728 defer store.deinit(); 729 const token = try store.create(&admin_user_id); 730 try store.offerAutoLogin(&token); 731 } 732 733 if (cli) { 734 var stdout_writer = std.Io.File.stdout().writer(io, &.{}); 735 var stderr_writer = std.Io.File.stderr().writer(io, &.{}); 736 const run_opts = hx.main.RunOpts{ .out = &stdout_writer.interface, .err = &stderr_writer.interface }; 737 738 const key_path = try std.fs.path.join(allocator, &.{ cwd_path, temp_dir_name, "key" }); 739 defer allocator.free(key_path); 740 741 const Runnable = struct { 742 io: std.Io, 743 key_path: []const u8, 744 745 pub fn run(self: @This(), web_port: u16, ssh_port: u16) !void { 746 _ = web_port; 747 std.debug.print( 748 \\ 749 \\connect to the TUI with: 750 \\ ssh -p {d} -o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null localhost 751 \\ 752 \\create a git repo and push over SSH: 753 \\ mkdir -p temp-try/client/test 754 \\ cd temp-try/client/test 755 \\ git init 756 \\ echo "hello" > hello.txt 757 \\ git add hello.txt 758 \\ git commit -m "let there be light" 759 \\ GIT_SSH_COMMAND='ssh -p {d} -o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null -o IdentitiesOnly=yes -i {s}' git push localhost:admin/test HEAD:master 760 \\ 761 \\to quit, press enter. 762 \\ 763 , .{ ssh_port, ssh_port, self.key_path }); 764 // portable stdin read via std.Io — equivalent to the 765 // std.posix.read(STDIN_FILENO, ...) that doesn't compile 766 // on windows. 767 var buf: [1]u8 = undefined; 768 var stdin_reader = std.Io.File.stdin().reader(self.io, &buf); 769 _ = stdin_reader.interface.takeByte() catch {}; 770 } 771 }; 772 773 try srv.run(.xit, .{}, io, allocator, cwd_path, .{ 774 .data_dir = server_path, 775 }, run_opts.err, Runnable{ .io = io, .key_path = key_path }); 776 } else { 777 var null_writer = std.Io.Writer.Discarding.init(&.{}); 778 const run_opts = hx.main.RunOpts{ .out = &null_writer.writer, .err = &null_writer.writer }; 779 780 const Runnable = struct { 781 io: std.Io, 782 allocator: std.mem.Allocator, 783 session: *ui.Session, 784 repo: *Repo, 785 786 pub fn run(self: @This(), web_port: u16, ssh_port: u16) !void { 787 _ = ssh_port; 788 // launch the TUI; the footer points at whatever port was bound 789 self.session.web_port = web_port; 790 try hx.ui.run(self.io, self.allocator, self.session, self.repo); 791 } 792 }; 793 794 try srv.run(.xit, .{}, io, allocator, cwd_path, .{ 795 .data_dir = server_path, 796 }, run_opts.err, Runnable{ .io = io, .allocator = allocator, .session = &session, .repo = &repo }); 797 } 798 } 799 800 // words cycled through to pad generated lines into prose-like content 801 const scatter_words = [_][]const u8{ 802 "lorem", "ipsum", "dolor", "sit", "amet", "consectetur", 803 "quantum", "vector", "matrix", "buffer", "kernel", "socket", 804 "falcon", "otter", "badger", "walrus", "ferret", "marmot", 805 "scatter", "gather", "encode", "decode", "render", "commit", 806 }; 807 808 // write `path` as 40 lines of mostly-stable filler. revision `c` and file 809 // index `fi` shift which lines change and the words used, so each (c, fi) 810 // yields a distinct multi-hunk diff against the previous revision. untouched 811 // lines stay byte-identical across revisions, so a bump in `c` is a scatter of 812 // small hunks rather than a full rewrite. 813 fn writeScatterFile(io: std.Io, allocator: std.mem.Allocator, repo_dir: std.Io.Dir, path: []const u8, fi: usize, c: usize) !void { 814 const file = try repo_dir.createFile(io, path, .{}); 815 defer file.close(io); 816 var writer = std.Io.Writer.Allocating.init(allocator); 817 defer writer.deinit(); 818 for (0..40) |line| { 819 const start = writer.written().len; 820 if ((line + fi + c) % 8 == 0) { 821 const tag = scatter_words[(line + fi + c * 3) % scatter_words.len]; 822 try writer.writer.print("rev {d} {s}", .{ c, tag }); 823 } 824 const target = 40 + (line * 17 + fi * 23) % 70; 825 var w = line + fi; 826 while (true) : (w += 1) { 827 const word = scatter_words[w % scatter_words.len]; 828 const len = writer.written().len - start; 829 if (len >= target or len + 1 + word.len > 120) break; 830 if (len == 0) 831 try writer.writer.print("{s}", .{word}) 832 else 833 try writer.writer.print(" {s}", .{word}); 834 } 835 try writer.writer.writeByte('\n'); 836 } 837 try file.writeStreamingAll(io, writer.written()); 838 } 839 840 // tag the current HEAD as the next sequential version: v1, v2, and so on 841 fn addNextTag(repo: *rp.Repo(.xit, .{}), io: std.Io, allocator: std.mem.Allocator, n: *usize) !void { 842 var buf: [16]u8 = undefined; 843 const name = try std.fmt.bufPrint(&buf, "v{d}", .{n.*}); 844 _ = try repo.addTag(io, allocator, .{ .name = name }); 845 n.* += 1; 846 } 847 848 // recursively copy the contents of src_dir into dest_dir 849 fn copyDir(io: std.Io, src_dir: std.Io.Dir, dest_dir: std.Io.Dir) !void { 850 var iter = src_dir.iterate(); 851 while (try iter.next(io)) |entry| { 852 switch (entry.kind) { 853 .file => try src_dir.copyFile(entry.name, dest_dir, entry.name, io, .{}), 854 .directory => { 855 try dest_dir.createDirPath(io, entry.name); 856 var dest_entry_dir = try dest_dir.openDir(io, entry.name, .{ .access_sub_paths = true, .iterate = true, .follow_symlinks = false }); 857 defer dest_entry_dir.close(io); 858 var src_entry_dir = try src_dir.openDir(io, entry.name, .{ .access_sub_paths = true, .iterate = true, .follow_symlinks = false }); 859 defer src_entry_dir.close(io); 860 try copyDir(io, src_entry_dir, dest_entry_dir); 861 }, 862 else => {}, 863 } 864 } 865 } 866