tiny.sql.decodeHistoryFetchRequest

1pub fn decodeFetchRequest(allocator: Allocator, bytes: []const u8) Error!FetchRequest {2    var reader = FetchRequestReader.init(bytes);3    if (try reader.readU32() != fetch_request_magic) return error.InvalidFetchRequest;4    if (try reader.readU32() != fetch_request_format_version) return error.InvalidFetchRequest;5    const want_count = try reader.readCount();6    const have_count = try reader.readCount();7    const wants = try allocator.alloc([]u8, want_count);8    var wants_read: usize = 0;9    errdefer {10        for (wants[0..wants_read]) |want| allocator.free(want);11        if (wants.len != 0) allocator.free(wants);12    }13    for (wants) |*want| {14        want.* = try reader.readOwnedBytes(allocator);15        wants_read += 1;16    }17    const haves = try allocator.alloc(version.Hash, have_count);18    errdefer if (haves.len != 0) allocator.free(haves);19    for (haves) |*have| have.* = try reader.hash();20    try reader.finish();21    return .{22        .allocator = allocator,23        .wants = wants,24        .haves = haves,25    };26}

1pub const decodeHistoryFetchRequest = sync.decodeFetchRequest;