mirror of
https://github.com/denoland/deno.git
synced 2024-12-23 15:49:44 -05:00
da60e2afcb
This commit marks the `Deno.Buffer` / `Deno.readAll` / `Deno.readAllSync` / `Deno.writeAll` / `Deno.writeAllSync` utils as deprecated, and schedules them for removal in Deno 2.0. These utilities are implemented in pure JS, so should not be part of the Deno namespace. These utilities are now available in std/io/buffer and std/io/util: https://github.com/denoland/deno_std/pull/808. This additionallty removes all internal dependance on Deno.Buffer.
74 lines
2 KiB
TypeScript
74 lines
2 KiB
TypeScript
// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
|
|
import { assertEquals, unitTest } from "./test_util.ts";
|
|
import { Buffer } from "../../../test_util/std/io/buffer.ts";
|
|
|
|
const DEFAULT_BUF_SIZE = 32 * 1024;
|
|
|
|
type Spy = { calls: number };
|
|
|
|
function repeat(c: string, bytes: number): Uint8Array {
|
|
assertEquals(c.length, 1);
|
|
const ui8 = new Uint8Array(bytes);
|
|
ui8.fill(c.charCodeAt(0));
|
|
return ui8;
|
|
}
|
|
|
|
function spyRead(obj: Buffer): Spy {
|
|
const spy: Spy = {
|
|
calls: 0,
|
|
};
|
|
|
|
const orig = obj.read.bind(obj);
|
|
|
|
obj.read = (p: Uint8Array): Promise<number | null> => {
|
|
spy.calls++;
|
|
return orig(p);
|
|
};
|
|
|
|
return spy;
|
|
}
|
|
|
|
unitTest(async function copyWithDefaultBufferSize() {
|
|
const xBytes = repeat("b", DEFAULT_BUF_SIZE);
|
|
const reader = new Buffer(xBytes.buffer as ArrayBuffer);
|
|
const write = new Buffer();
|
|
|
|
const readSpy = spyRead(reader);
|
|
|
|
const n = await Deno.copy(reader, write);
|
|
|
|
assertEquals(n, xBytes.length);
|
|
assertEquals(write.length, xBytes.length);
|
|
assertEquals(readSpy.calls, 2); // read with DEFAULT_BUF_SIZE bytes + read with 0 bytes
|
|
});
|
|
|
|
unitTest(async function copyWithCustomBufferSize() {
|
|
const bufSize = 1024;
|
|
const xBytes = repeat("b", DEFAULT_BUF_SIZE);
|
|
const reader = new Buffer(xBytes.buffer as ArrayBuffer);
|
|
const write = new Buffer();
|
|
|
|
const readSpy = spyRead(reader);
|
|
|
|
const n = await Deno.copy(reader, write, { bufSize });
|
|
|
|
assertEquals(n, xBytes.length);
|
|
assertEquals(write.length, xBytes.length);
|
|
assertEquals(readSpy.calls, DEFAULT_BUF_SIZE / bufSize + 1);
|
|
});
|
|
|
|
unitTest({ perms: { write: true } }, async function copyBufferToFile() {
|
|
const filePath = "test-file.txt";
|
|
// bigger than max File possible buffer 16kb
|
|
const bufSize = 32 * 1024;
|
|
const xBytes = repeat("b", bufSize);
|
|
const reader = new Buffer(xBytes.buffer as ArrayBuffer);
|
|
const write = await Deno.open(filePath, { write: true, create: true });
|
|
|
|
const n = await Deno.copy(reader, write, { bufSize });
|
|
|
|
assertEquals(n, xBytes.length);
|
|
|
|
write.close();
|
|
await Deno.remove(filePath);
|
|
});
|