public/browser
1
0
Fork 0
mirror of https://github.com/lightpanda-io/browser.git synced 2026-03-22 04:34:44 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

use a CapturedResponse struct for captured responses

Browse Source
This commit is contained in:
Pierre Tachoire
2026-03-21 13:11:18 +01:00
parent b5b012bd5d
commit 2107ade3a5
2 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/cdp/cdp.zig
View File

@@ -324,6 +324,11 @@ pub fn BrowserContext(comptime CDP_T: type) type {
const Node = @import("Node.zig"); const Node = @import("Node.zig");
const AXNode = @import("AXNode.zig"); const AXNode = @import("AXNode.zig");
const CapturedResponse = struct {
encode: enum { none, base64 },
data: std.ArrayList(u8),
};
return struct { return struct {
id: []const u8, id: []const u8,
cdp: *CDP_T, cdp: *CDP_T,
@@ -384,7 +389,7 @@ pub fn BrowserContext(comptime CDP_T: type) type {
// ever streamed. So if CDP is the only thing that needs bodies in // ever streamed. So if CDP is the only thing that needs bodies in
// memory for an arbitrary amount of time, then that's where we're going // memory for an arbitrary amount of time, then that's where we're going
// to store the, // to store the,
captured_responses: std.AutoHashMapUnmanaged(usize, std.ArrayList(u8)), captured_responses: std.AutoHashMapUnmanaged(usize, CapturedResponse),
notification: *Notification, notification: *Notification,
@@ -648,9 +653,12 @@ pub fn BrowserContext(comptime CDP_T: type) type {
const id = msg.transfer.id; const id = msg.transfer.id;
const gop = try self.captured_responses.getOrPut(arena, id); const gop = try self.captured_responses.getOrPut(arena, id);
if (!gop.found_existing) { if (!gop.found_existing) {
gop.value_ptr.* = .{}; gop.value_ptr.* = .{
.data = .empty,
.encode = .none,
};
} }
try gop.value_ptr.appendSlice(arena, try arena.dupe(u8, msg.data)); try gop.value_ptr.data.appendSlice(arena, try arena.dupe(u8, msg.data));
} }
pub fn onHttpRequestAuthRequired(ctx: *anyopaque, data: *const Notification.RequestAuthRequired) !void { pub fn onHttpRequestAuthRequired(ctx: *anyopaque, data: *const Notification.RequestAuthRequired) !void {

10
src/cdp/domains/network.zig
View File

@@ -208,15 +208,11 @@ fn getResponseBody(cmd: anytype) !void {
const request_id = try idFromRequestId(params.requestId); const request_id = try idFromRequestId(params.requestId);
const bc = cmd.browser_context orelse return error.BrowserContextNotLoaded; const bc = cmd.browser_context orelse return error.BrowserContextNotLoaded;
const buf = bc.captured_responses.getPtr(request_id) orelse return error.RequestNotFound; const resp = bc.captured_responses.getPtr(request_id) orelse return error.RequestNotFound;
const encoded_len = std.base64.standard.Encoder.calcSize(buf.items.len);
const encoded = try cmd.arena.alloc(u8, encoded_len);
_ = std.base64.standard.Encoder.encode(encoded, buf.items);
try cmd.sendResult(.{ try cmd.sendResult(.{
.body = encoded, .body = resp.data.items,
.base64Encoded = true, .base64Encoded = resp.encode == .base64,
}, .{}); }, .{});
} }