mirror of
https://github.com/morluto/rea.git
synced 2026-11-10 17:30:32 -10:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
452ed97031 | ||
|
|
c837575512 | ||
|
|
cdb51058f6 |
No files matched your search
@@ -20,6 +20,11 @@ it("reads a Python 3.9 reference-flagged PYZ table", () => {
|
|||||||
]);
|
]);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("reads marshal one-byte string tags as Latin-1", () => {
|
||||||
|
for (const hex of ["6101000000e9", "4101000000e9", "7a01e9", "5a01e9"])
|
||||||
|
expect(readMarshalSubset(bytes(hex))).toEqual({ ok: true, value: "é" });
|
||||||
|
});
|
||||||
|
|
||||||
it("decodes CPython marshal Unicode with surrogatepass", () => {
|
it("decodes CPython marshal Unicode with surrogatepass", () => {
|
||||||
expect(
|
expect(
|
||||||
readMarshalSubset(
|
readMarshalSubset(
|
||||||
|
|||||||
@@ -168,14 +168,8 @@ const readAsciiBytes = (
|
|||||||
): Result<string, PyInstallerFailure> => {
|
): Result<string, PyInstallerFailure> => {
|
||||||
const bytes = readBytes(cursor, length);
|
const bytes = readBytes(cursor, length);
|
||||||
if (!bytes.ok) return bytes;
|
if (!bytes.ok) return bytes;
|
||||||
if (bytes.value.some((byte) => byte > 0x7f))
|
// These tags use CPython's one-byte Unicode constructor, not an ASCII check.
|
||||||
return err(
|
return ok(bytes.value.toString("latin1"));
|
||||||
pyInstallerFailure(
|
|
||||||
"format",
|
|
||||||
"PYZ marshal ASCII string contains a non-ASCII byte",
|
|
||||||
),
|
|
||||||
);
|
|
||||||
return ok(bytes.value.toString("ascii"));
|
|
||||||
};
|
};
|
||||||
|
|
||||||
const readUtf8 = (
|
const readUtf8 = (
|
||||||
|
|||||||
@@ -110,47 +110,3 @@ describe("web resource comparison identity and optional size", () => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
it.each([
|
|
||||||
[[128, 256], [128], [false, true], "unknown"],
|
|
||||||
[[128], [256], [true, true], "unknown"],
|
|
||||||
[[128], [128], [true, true], "unknown"],
|
|
||||||
[[128], [128, 256], [false, true], "changed"],
|
|
||||||
[[], [128], [false, true], "changed"],
|
|
||||||
[[128], [], [true, true], "unknown"],
|
|
||||||
[[128], [null], [false, true], "unknown"],
|
|
||||||
] as const)(
|
|
||||||
"uses directional resource coverage for %j vs %j (limited=%j): %s",
|
|
||||||
(leftSizes, rightSizes, [leftLimited, rightLimited], status) => {
|
|
||||||
const before = capture(leftSizes.map((size) => resource(size)));
|
|
||||||
const after = capture(rightSizes.map((size) => resource(size)));
|
|
||||||
if (leftLimited) before.completeness.truncated_sections.push("resources");
|
|
||||||
if (rightLimited) after.completeness.truncated_sections.push("resources");
|
|
||||||
for (const [left, right] of [
|
|
||||||
[before, after],
|
|
||||||
[after, before],
|
|
||||||
] as const)
|
|
||||||
expect(compareResources(left, right)).toMatchObject({
|
|
||||||
status,
|
|
||||||
total_changes: status === "changed" ? 1 : 0,
|
|
||||||
changes:
|
|
||||||
status === "changed"
|
|
||||||
? [
|
|
||||||
{
|
|
||||||
identity: expect.stringMatching(/^resg_/u),
|
|
||||||
change:
|
|
||||||
left.resources.length === 0
|
|
||||||
? "added"
|
|
||||||
: right.resources.length === 0
|
|
||||||
? "removed"
|
|
||||||
: "modified",
|
|
||||||
},
|
|
||||||
]
|
|
||||||
: [],
|
|
||||||
reason:
|
|
||||||
status === "changed"
|
|
||||||
? null
|
|
||||||
: expect.stringContaining("Resource inventory"),
|
|
||||||
});
|
|
||||||
},
|
|
||||||
);
|
|
||||||
@@ -213,8 +213,9 @@ const compareWebCaptureDimensions = (
|
|||||||
resources: compareResources(
|
resources: compareResources(
|
||||||
before.resources,
|
before.resources,
|
||||||
after.resources,
|
after.resources,
|
||||||
sectionsComplete(before, ["resources"]),
|
sectionsComplete(before, ["resources"]) &&
|
||||||
sectionsComplete(after, ["resources"]),
|
sectionsComplete(after, ["resources"]),
|
||||||
|
"Resource inventory or content-size evidence was incomplete in at least one observation.",
|
||||||
),
|
),
|
||||||
network: networkDimension(before, after),
|
network: networkDimension(before, after),
|
||||||
metadata: compareAggregate(
|
metadata: compareAggregate(
|
||||||
@@ -234,12 +235,9 @@ const compareWebCaptureDimensions = (
|
|||||||
const compareResources = (
|
const compareResources = (
|
||||||
before: WebPageInspection["resources"],
|
before: WebPageInspection["resources"],
|
||||||
after: WebPageInspection["resources"],
|
after: WebPageInspection["resources"],
|
||||||
beforeComplete: boolean,
|
complete: boolean,
|
||||||
afterComplete: boolean,
|
reason: string,
|
||||||
): Dimension => {
|
): Dimension => {
|
||||||
const reason =
|
|
||||||
"Resource inventory or content-size evidence was incomplete in at least one observation.";
|
|
||||||
const complete = beforeComplete && afterComplete;
|
|
||||||
const left = resourceGroups(before);
|
const left = resourceGroups(before);
|
||||||
const right = resourceGroups(after);
|
const right = resourceGroups(after);
|
||||||
const changes: Change[] = [];
|
const changes: Change[] = [];
|
||||||
@@ -248,14 +246,12 @@ const compareResources = (
|
|||||||
const leftSizes = left.get(identity);
|
const leftSizes = left.get(identity);
|
||||||
const rightSizes = right.get(identity);
|
const rightSizes = right.get(identity);
|
||||||
if (leftSizes === undefined || rightSizes === undefined) {
|
if (leftSizes === undefined || rightSizes === undefined) {
|
||||||
const absenceProven =
|
if (!complete) unresolved = true;
|
||||||
leftSizes === undefined ? beforeComplete : afterComplete;
|
else
|
||||||
if (absenceProven)
|
|
||||||
changes.push({
|
changes.push({
|
||||||
identity,
|
identity,
|
||||||
change: leftSizes === undefined ? "added" : "removed",
|
change: leftSizes === undefined ? "added" : "removed",
|
||||||
});
|
});
|
||||||
else unresolved = true;
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
// Stable inventories deduplicate identical observations. A null size also
|
// Stable inventories deduplicate identical observations. A null size also
|
||||||
@@ -265,12 +261,7 @@ const compareResources = (
|
|||||||
unresolved = true;
|
unresolved = true;
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
// A partial set can omit any size variant. Only a complete peer can
|
if (!sameResourceSizes(leftSizes, rightSizes))
|
||||||
// contradict a retained variant, including when the other side is partial.
|
|
||||||
if (
|
|
||||||
(beforeComplete && !resourceSizesContained(rightSizes, leftSizes)) ||
|
|
||||||
(afterComplete && !resourceSizesContained(leftSizes, rightSizes))
|
|
||||||
)
|
|
||||||
changes.push({ identity, change: "modified" });
|
changes.push({ identity, change: "modified" });
|
||||||
}
|
}
|
||||||
if (changes.length > 0)
|
if (changes.length > 0)
|
||||||
@@ -301,10 +292,11 @@ const resourceGroups = (
|
|||||||
return groups;
|
return groups;
|
||||||
};
|
};
|
||||||
|
|
||||||
const resourceSizesContained = (
|
const sameResourceSizes = (
|
||||||
observed: ReadonlySet<number | null>,
|
left: ReadonlySet<number | null>,
|
||||||
complete: ReadonlySet<number | null>,
|
right: ReadonlySet<number | null>,
|
||||||
): boolean => [...observed].every((size) => complete.has(size));
|
): boolean =>
|
||||||
|
left.size === right.size && [...left].every((size) => right.has(size));
|
||||||
|
|
||||||
type BodyShapeSources = {
|
type BodyShapeSources = {
|
||||||
readonly request: boolean;
|
readonly request: boolean;
|
||||||
|
|||||||
@@ -407,6 +407,30 @@ it("charges long digits to the string budget and keeps large previews bounded",
|
|||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("reads marshal one-byte string tags as Latin-1 with Unicode identity", () => {
|
||||||
|
for (const tag of [0x61, 0x41, 0x7a, 0x5a]) {
|
||||||
|
const encoded = Buffer.concat([
|
||||||
|
Buffer.from([tag]),
|
||||||
|
tag === 0x61 || tag === 0x41 ? u32(1) : Buffer.from([1]),
|
||||||
|
Buffer.from([0xe9]),
|
||||||
|
]);
|
||||||
|
const sameUnicode = marshalUnicode(Buffer.from("é", "utf8"));
|
||||||
|
const set = Buffer.concat([
|
||||||
|
Buffer.from([0x3c]),
|
||||||
|
u32(2),
|
||||||
|
encoded,
|
||||||
|
sameUnicode,
|
||||||
|
]);
|
||||||
|
const report = root(parse(withConsts([encoded, set])));
|
||||||
|
expect(report.consts[0]).toMatchObject({
|
||||||
|
kind: "str",
|
||||||
|
value: "é",
|
||||||
|
bytes: 1,
|
||||||
|
});
|
||||||
|
expect(report.consts[1]).toEqual({ kind: "set", length: 1 });
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
it("decodes marshal strings with CPython surrogatepass rules", () => {
|
it("decodes marshal strings with CPython surrogatepass rules", () => {
|
||||||
const report = parse(
|
const report = parse(
|
||||||
withConsts([marshalUnicode(Buffer.from("efbbbf73eda080efbbbf", "hex"))]),
|
withConsts([marshalUnicode(Buffer.from("efbbbf73eda080efbbbf", "hex"))]),
|
||||||
@@ -1534,6 +1558,36 @@ it("hashes a long TYPE_REF tuple chain without recursing", () => {
|
|||||||
expect(pythonPycSchema.safeParse(report).success).toBe(true);
|
expect(pythonPycSchema.safeParse(report).success).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("hashes shallow TYPE_REF code chains without using the JavaScript stack", () => {
|
||||||
|
const links = 3000;
|
||||||
|
const codes = Array.from({ length: links }, (_, index) =>
|
||||||
|
marshalCode("py311", {
|
||||||
|
flagged: true,
|
||||||
|
name: "f",
|
||||||
|
consts: index === 0 ? [Buffer.from([0x4e])] : [marshalRef(index - 1)],
|
||||||
|
}),
|
||||||
|
);
|
||||||
|
const bytes = Buffer.concat([
|
||||||
|
pythonPycHeader(3531),
|
||||||
|
marshalCode("py311", {
|
||||||
|
constsObject: Buffer.concat([
|
||||||
|
Buffer.from([0x28]),
|
||||||
|
u32(links + 1),
|
||||||
|
...codes,
|
||||||
|
Buffer.from([0x3c]),
|
||||||
|
u32(1),
|
||||||
|
marshalRef(links - 1),
|
||||||
|
]),
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
const report = parseWith(bytes, { max_objects: 65_536 });
|
||||||
|
expect(root(report).consts.at(-1)).toEqual({ kind: "set", length: 1 });
|
||||||
|
expect(report.coverage).toMatchObject({
|
||||||
|
status: "complete",
|
||||||
|
code_objects: links + 1,
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
it("rejects code CPython treats as corrupt instead of complete coverage", () => {
|
it("rejects code CPython treats as corrupt instead of complete coverage", () => {
|
||||||
const file = (
|
const file = (
|
||||||
layout: "py37" | "py38" | "py311",
|
layout: "py37" | "py38" | "py311",
|
||||||
|
|||||||
@@ -332,7 +332,7 @@ class MarshalReader {
|
|||||||
readonly #codeKeys = new WeakMap<CodeNode, string>();
|
readonly #codeKeys = new WeakMap<CodeNode, string>();
|
||||||
readonly #codeIdentities = new WeakMap<CodeNode, number>();
|
readonly #codeIdentities = new WeakMap<CodeNode, number>();
|
||||||
readonly #codeEquality = new WeakMap<CodeNode, CodeEquality>();
|
readonly #codeEquality = new WeakMap<CodeNode, CodeEquality>();
|
||||||
/** Python hashability per code object. False while that check is in progress. */
|
/** Completed Python hashability checks per code object. */
|
||||||
readonly #codeHashable = new WeakMap<CodeNode, boolean>();
|
readonly #codeHashable = new WeakMap<CodeNode, boolean>();
|
||||||
/** Tuples whose items are still being read; CPython cannot hash them yet. */
|
/** Tuples whose items are still being read; CPython cannot hash them yet. */
|
||||||
readonly #readingTuples = new WeakSet<MarshalValue>();
|
readonly #readingTuples = new WeakSet<MarshalValue>();
|
||||||
@@ -436,13 +436,19 @@ class MarshalReader {
|
|||||||
};
|
};
|
||||||
case TYPE_INTERNED:
|
case TYPE_INTERNED:
|
||||||
case TYPE_UNICODE:
|
case TYPE_UNICODE:
|
||||||
return this.utf8(this.nonNegativeInt32("Marshal string length"), false);
|
return this.string(
|
||||||
|
this.nonNegativeInt32("Marshal string length"),
|
||||||
|
"utf8",
|
||||||
|
);
|
||||||
case TYPE_ASCII:
|
case TYPE_ASCII:
|
||||||
case TYPE_ASCII_INTERNED:
|
case TYPE_ASCII_INTERNED:
|
||||||
return this.utf8(this.nonNegativeInt32("Marshal string length"), true);
|
return this.string(
|
||||||
|
this.nonNegativeInt32("Marshal string length"),
|
||||||
|
"latin1",
|
||||||
|
);
|
||||||
case TYPE_SHORT_ASCII:
|
case TYPE_SHORT_ASCII:
|
||||||
case TYPE_SHORT_ASCII_INTERNED:
|
case TYPE_SHORT_ASCII_INTERNED:
|
||||||
return this.utf8(this.u8(), true);
|
return this.string(this.u8(), "latin1");
|
||||||
case TYPE_TUPLE:
|
case TYPE_TUPLE:
|
||||||
return this.sequenceValue(
|
return this.sequenceValue(
|
||||||
"tuple",
|
"tuple",
|
||||||
@@ -1309,13 +1315,70 @@ class MarshalReader {
|
|||||||
#isCodeHashable(node: CodeNode): boolean {
|
#isCodeHashable(node: CodeNode): boolean {
|
||||||
const known = this.#codeHashable.get(node);
|
const known = this.#codeHashable.get(node);
|
||||||
if (known !== undefined) return known;
|
if (known !== undefined) return known;
|
||||||
this.#codeHashable.set(node, false);
|
const frames: { value: MarshalValue; finish: boolean }[] = [
|
||||||
const material =
|
{ value: { kind: "code", value: node }, finish: false },
|
||||||
this.#codeEquality.get(node) ??
|
];
|
||||||
malformed("Code object is missing equality material.");
|
const gray = new Set<MarshalValue | CodeNode>();
|
||||||
const hashable = this.#equalityKey(material.constsTuple, "hash") !== null;
|
const complete = new Set<MarshalValue>();
|
||||||
this.#codeHashable.set(node, hashable);
|
const reject = (): false => {
|
||||||
return hashable;
|
this.#codeHashable.set(node, false);
|
||||||
|
return false;
|
||||||
|
};
|
||||||
|
while (frames.length > 0) {
|
||||||
|
this.#takeKeyStep();
|
||||||
|
const frame = frames.pop()!;
|
||||||
|
const value = frame.value;
|
||||||
|
const identity = value.kind === "code" ? value.value : value;
|
||||||
|
if (frame.finish) {
|
||||||
|
gray.delete(identity);
|
||||||
|
if (value.kind === "code") {
|
||||||
|
const material =
|
||||||
|
this.#codeEquality.get(value.value) ??
|
||||||
|
malformed("Code object is missing equality material.");
|
||||||
|
// Child code checks are now complete, so the existing tuple key
|
||||||
|
// walker preserves its equality and expansion budgets without recursion.
|
||||||
|
const hashable =
|
||||||
|
this.#equalityKey(material.constsTuple, "hash") !== null;
|
||||||
|
this.#codeHashable.set(value.value, hashable);
|
||||||
|
if (!hashable) return reject();
|
||||||
|
} else complete.add(value);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if (value.kind === "code") {
|
||||||
|
const cached = this.#codeHashable.get(value.value);
|
||||||
|
if (cached === false) return reject();
|
||||||
|
if (cached === true) continue;
|
||||||
|
} else {
|
||||||
|
const cached = this.#keyCache.get(value);
|
||||||
|
if (cached === null) return reject();
|
||||||
|
if (cached !== undefined || complete.has(value)) continue;
|
||||||
|
}
|
||||||
|
if (
|
||||||
|
gray.has(identity) ||
|
||||||
|
this.#readingTuples.has(value) ||
|
||||||
|
value.kind === "list" ||
|
||||||
|
value.kind === "set" ||
|
||||||
|
value.kind === "dict" ||
|
||||||
|
value.kind === "null"
|
||||||
|
)
|
||||||
|
return reject();
|
||||||
|
const children =
|
||||||
|
value.kind === "code"
|
||||||
|
? [
|
||||||
|
(
|
||||||
|
this.#codeEquality.get(value.value) ??
|
||||||
|
malformed("Code object is missing equality material.")
|
||||||
|
).constsTuple,
|
||||||
|
]
|
||||||
|
: value.kind === "tuple" || value.kind === "frozenset"
|
||||||
|
? value.items
|
||||||
|
: [];
|
||||||
|
gray.add(identity);
|
||||||
|
frames.push({ value, finish: true });
|
||||||
|
for (let index = children.length - 1; index >= 0; index -= 1)
|
||||||
|
frames.push({ value: children[index]!, finish: false });
|
||||||
|
}
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
#codeIdentity(node: CodeNode): number {
|
#codeIdentity(node: CodeNode): number {
|
||||||
@@ -1492,17 +1555,20 @@ class MarshalReader {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
utf8(length: number, ascii: boolean): MarshalValue {
|
string(length: number, encoding: "latin1" | "utf8"): MarshalValue {
|
||||||
const bytes = this.blob(length);
|
const bytes = this.blob(length);
|
||||||
if (ascii) {
|
if (encoding === "latin1") {
|
||||||
if (bytes.some((byte) => byte > 0x7f))
|
// CPython reads the ASCII-tagged forms as one-byte Unicode, even when
|
||||||
malformed("Marshal ASCII string contains a non-ASCII byte.");
|
// high bytes appear. Identity must agree with the UTF-8 string form.
|
||||||
|
const value = bytes.toString("latin1");
|
||||||
return {
|
return {
|
||||||
kind: "str",
|
kind: "str",
|
||||||
value: bytes.toString("latin1"),
|
value,
|
||||||
previewEnd: Math.min(length, PYTHON_PYC_CONST_PREVIEW_LIMIT),
|
previewEnd: Math.min(length, PYTHON_PYC_CONST_PREVIEW_LIMIT),
|
||||||
bytes: length,
|
bytes: length,
|
||||||
raw: bytes,
|
raw: bytes.some((byte) => byte > 0x7f)
|
||||||
|
? Buffer.from(value, "utf8")
|
||||||
|
: bytes,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
const decoded = decodeMarshalUtf8(bytes, PYTHON_PYC_CONST_PREVIEW_LIMIT);
|
const decoded = decodeMarshalUtf8(bytes, PYTHON_PYC_CONST_PREVIEW_LIMIT);
|
||||||
|
|||||||
Reference in new issue
Block a user