╭─────────────╮ │scroll to top│ ╰─────────────╯ ╭ web.zig ──────────────────────────────────────────────────────╮ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ ╰───────────────────────────────────────────────────────────────╯
╭────╮ ╭ clone ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╮ │http│ ssh │ │ ╰────╯ ╰ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╯
2881 defer file.close(self.io); 2882 try file.writeStreamingAll(self.io, user_id); 2883 return token_hex; 2884 } 2885 2886 fn createFlash(self: SessionStore, allocator: std.mem.Allocator, value: ui.Session.FormFeedback) ![token_hex_len]u8 { 2887 var token: [evt.event_id_size]u8 = undefined; 2888 self.io.random(&token); 2889 const token_hex = std.fmt.bytesToHex(token, .lower); 2890 const file = try self.flash_dir.createFile(self.io, &token_hex, .{}); 2891 errdefer self.flash_dir.deleteFile(self.io, &token_hex) catch {}; 2892 defer file.close(self.io); 2893 2894 var json: std.Io.Writer.Allocating = .init(allocator); 2895 defer json.deinit(); 2896 try std.json.Stringify.value(value, .{}, &json.writer); 2897 try file.writeStreamingAll(self.io, json.written()); 2898 return token_hex; 2899 } 2900 2901 fn takeFlash(self: SessionStore, allocator: std.mem.Allocator, token_hex: []const u8) ?ui.Session.FormFeedback { 2902 if (!isToken(token_hex)) return null; 2903 const file = self.flash_dir.openFile(self.io, token_hex, .{ .mode = .read_only }) catch return null; 2904 defer self.flash_dir.deleteFile(self.io, token_hex) catch {}; 2905 defer file.close(self.io); 2906 2907 var storage: [4096]u8 = undefined; 2908 var reader = file.reader(self.io, &storage); 2909 const bytes = reader.interface.allocRemaining(allocator, .limited(512 * 1024)) catch return null; 2910 return std.json.parseFromSliceLeaky(ui.Session.FormFeedback, allocator, bytes, .{}) catch null; 2911 } 2912 2913 // resolve a cookie's token to its user_id. returns false (logged out) for a 2914 // missing, malformed, or unknown token. 2915 pub fn lookup(self: SessionStore, token_hex: []const u8, out: *[evt.event_id_size]u8) bool { 2916 if (!isToken(token_hex)) return false; 2917 const file = self.dir.openFile(self.io, token_hex, .{ .mode = .read_only }) catch return false; 2918 defer file.close(self.io); 2919 var storage: [evt.event_id_size]u8 = undefined; 2920 var file_reader = file.reader(self.io, &storage); 2921 file_reader.interface.readSliceAll(out) catch return false; 2922 return true; 2923 } 2924 2925 // revoke a session. a no-op for a missing or malformed token. 2926 pub fn remove(self: SessionStore, token_hex: []const u8) void { 2927 if (!isToken(token_hex)) return; 2928 self.dir.deleteFile(self.io, token_hex) catch {}; 2929 } 2930 2931 // leave `token_hex`'s session for visitors arriving without one. only the 2932 // `try` fixture writes one. the name can't collide with a session token. 2933 pub fn offerAutoLogin(self: SessionStore, token_hex: *const [token_hex_len]u8) !void { 2934 const file = try self.dir.createFile(self.io, auto_login_name, .{}); 2935 defer file.close(self.io); 2936 try file.writeStreamingAll(self.io, token_hex); 2937 } 2938 2939 pub fn autoLogin(self: SessionStore, out: *[token_hex_len]u8) bool { 2940 out.* = self.auto_login orelse return false; 2941 return true; 2942 } 2943 2944 const auto_login_name = "auto-login"; 2945 2946 // a token is exactly token_hex_len hex chars. validating before using the 2947 // value as a path keeps attacker-supplied cookies from escaping the 2948 // sessions dir (e.g. via "/" or ".." bytes). 2949 fn isToken(token_hex: []const u8) bool { 2950 if (token_hex.len != token_hex_len) return false; 2951 for (token_hex) |c| if (!std.ascii.isHex(c)) return false; 2952 return true; 2953 } 2954 }; 2955