mirror/rea
1
0
Fork 0
mirror of https://github.com/morluto/rea synced 2026-10-26 06:16:17 -04:00
Code Issues Packages Projects Releases Wiki Activity

refactor(apple): reuse artifact stream byte validation

Browse Source
This commit is contained in:
morluto
2026-10-24 05:00:32 +08:00
parent 250e209f32
commit e05beb39c2
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/artifacts/apple/AppleAssetCatalogAnalysis.ts
+2 -1
View File
@@ -1,5 +1,6 @@
import { createHash } from "node:crypto";
import { lstat } from "node:fs/promises";
import { streamChunkToBuffer } from "../StreamBytes.js";
import { DirectoryArtifactReader } from "../DirectoryArtifactReader.js";
import { ArtifactTraversalObservation } from "../ArtifactTraversalObservation.js";
import {
@@ -353,7 +354,7 @@ const digestBounded = async (
"Asset catalog inspection cancelled",
{ cause: signal.reason },
);
const bytes = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
const bytes = streamChunkToBuffer(chunk);
length += bytes.length;
if (length > MAX_CATALOG_BYTES)
throw new ArtifactReaderFailure(
src/artifacts/apple/InterfaceBuilderAnalysis.ts
+2 -3
View File
@@ -8,6 +8,7 @@ import {
isSourceLessAppKitAnnotationConnector,
isUIKitRuntimeConnectionClass,
} from "../../domain/apple/interfaceBuilderKeyedArchive.js";
import { streamChunkToBuffer } from "../StreamBytes.js";
import { DirectoryArtifactReader } from "../DirectoryArtifactReader.js";
import { ArtifactTraversalObservation } from "../ArtifactTraversalObservation.js";
import {
@@ -861,9 +862,7 @@ const readEntry = async (
const chunks: Buffer[] = [];
let length = 0;
for await (const chunk of stream) {
const bytes = Buffer.isBuffer(chunk)
? chunk
: Buffer.from(chunk as Uint8Array);
const bytes = streamChunkToBuffer(chunk);
length += bytes.length;
if (length > maxInputBytes) {
stream.destroy();