Spaces:

Leon4gr45
/

nova-header-nav

Paused

nova-header-nav / node_modules /@huggingface /hub /src /utils /sha256-node.ts

Upload folder using huggingface_hub (part 5)

01e6679 verified 3 months ago

747 Bytes

import { Readable } from "node:stream";
import type { ReadableStream } from "node:stream/web";
import { createHash } from "node:crypto";

export async function* sha256Node(
	buffer: ArrayBuffer | Blob,
	opts?: {
		abortSignal?: AbortSignal;
	},
): AsyncGenerator<number, string> {
	const sha256Stream = createHash("sha256");
	const size = buffer instanceof Blob ? buffer.size : buffer.byteLength;
	let done = 0;
	const readable =
		buffer instanceof Blob ? Readable.fromWeb(buffer.stream() as ReadableStream) : Readable.from(Buffer.from(buffer));

	for await (const buffer of readable) {
		sha256Stream.update(buffer);
		done += buffer.length;
		yield done / size;

		opts?.abortSignal?.throwIfAborted();
	}

	return sha256Stream.digest("hex");
}

	import { Readable } from "node:stream";
	import type { ReadableStream } from "node:stream/web";
	import { createHash } from "node:crypto";

	export async function* sha256Node(
	buffer: ArrayBuffer \| Blob,
	opts?: {
	abortSignal?: AbortSignal;
	},
	): AsyncGenerator<number, string> {
	const sha256Stream = createHash("sha256");
	const size = buffer instanceof Blob ? buffer.size : buffer.byteLength;
	let done = 0;
	const readable =
	buffer instanceof Blob ? Readable.fromWeb(buffer.stream() as ReadableStream) : Readable.from(Buffer.from(buffer));

	for await (const buffer of readable) {
	sha256Stream.update(buffer);
	done += buffer.length;
	yield done / size;

	opts?.abortSignal?.throwIfAborted();
	}

	return sha256Stream.digest("hex");
	}