mirror of
https://github.com/oven-sh/bun
synced 2026-02-14 21:01:52 +00:00
57a06745a4
* L * ipc * asdfghjkl * dfghjk * it works! * types * patches for next.js * sdfghj * wsdfgn,./ * this * yolo * okay loser * asdfghjk * add some more APIs * MESS * sdfghjkl * remove native events from streams * stuff * remove lazy(primordials) test * debugging * okay * less fake extensions object * fix `Buffer.toString()` args logic * fix deserialize * make tests work * add test for `Buffer.toString` args * Update server.zig * remove test * update test * Update spawn-streaming-stdin.test.ts * fix linux build * Update fs.test.ts * cli message improvements * dfshaj * Fix fs.watch bug maybe? * remove --------- Co-authored-by: Dylan Conway <dylan.conway567@gmail.com>
230 lines
7.7 KiB
TypeScript
230 lines
7.7 KiB
TypeScript
import { Readable } from "stream";
|
|
import { it, expect } from "bun:test";
|
|
|
|
function makeUint8Array(str: string) {
|
|
return new Uint8Array(
|
|
[].map.call(str, function (ch: string) {
|
|
return ch.charCodeAt(0);
|
|
}) as number[],
|
|
);
|
|
}
|
|
|
|
it("should work with .clear()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push({})).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.push({})).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.clear()).toBeUndefined();
|
|
expect(list.length).toBe(0);
|
|
});
|
|
|
|
it("should work with .concat()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(makeUint8Array("foo"))).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.concat(3)).toEqual(new Uint8Array([102, 111, 111]));
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.concat(10)).toEqual(new Uint8Array([102, 111, 111, 98, 97, 114, 0, 0, 0, 0]));
|
|
});
|
|
|
|
it("should fail on .concat() with invalid items", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push("foo")).toBeUndefined();
|
|
list.concat(42);
|
|
});
|
|
|
|
it("should fail on .concat() buffer overflow", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(makeUint8Array("foo"))).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(() => {
|
|
list.concat(2);
|
|
}).toThrow(RangeError);
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(() => {
|
|
list.concat(5);
|
|
}).toThrow(RangeError);
|
|
});
|
|
|
|
it("should work with .consume() on strings", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(() => list.consume()).toThrow();
|
|
expect(list.push("foo")).toBeUndefined();
|
|
expect(list.push("bar")).toBeUndefined();
|
|
expect(list.push("baz")).toBeUndefined();
|
|
expect(list.push("moo")).toBeUndefined();
|
|
expect(list.push("moz")).toBeUndefined();
|
|
expect(list.length).toBe(5);
|
|
expect(list.consume(3, true)).toBe("foo");
|
|
expect(list.length).toBe(4);
|
|
expect(list.consume(4, true)).toBe("barb");
|
|
expect(list.length).toBe(3);
|
|
expect(list.consume(256, true)).toBe("azmoomoz");
|
|
expect(list.length).toBe(0);
|
|
});
|
|
|
|
it("should work with .consume() on buffers", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(() => list.consume()).toThrow();
|
|
expect(list.push(makeUint8Array("foo"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("baz"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("moo"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("moz"))).toBeUndefined();
|
|
expect(list.length).toBe(5);
|
|
expect(list.consume(3, false)).toEqual(makeUint8Array("foo"));
|
|
expect(list.length).toBe(4);
|
|
expect(list.consume(2, false)).toEqual(makeUint8Array("ba"));
|
|
expect(list.length).toBe(4);
|
|
expect(list.consume(4, false)).toEqual(makeUint8Array("rbaz"));
|
|
expect(list.length).toBe(2);
|
|
expect(list.consume(10, false)).toEqual(new Uint8Array([109, 111, 111, 109, 111, 122, 0, 0, 0, 0]));
|
|
expect(list.length).toBe(0);
|
|
});
|
|
|
|
it("should fail on .consume() with invalid items", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push("foo")).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.consume(0, false)).toEqual("");
|
|
expect(list.consume(1, false)).toEqual("f");
|
|
expect(list.consume(2, true)).toBe("oo");
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.consume(0, true).byteLength).toEqual(0);
|
|
expect(list.consume(1, true)[0]).toEqual(98);
|
|
});
|
|
|
|
it("should work with .first()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(() => list.first()).toThrow();
|
|
const item = {};
|
|
expect(list.push(item)).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.first()).toBe(item);
|
|
});
|
|
|
|
it("should work with .join()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(42)).toBeUndefined();
|
|
expect(list.push(null)).toBeUndefined();
|
|
expect(list.push("foo")).toBeUndefined();
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.length).toBe(4);
|
|
expect(list.join("")).toBe("42nullfoo98,97,114");
|
|
expect(list.join(",")).toBe("42,null,foo,98,97,114");
|
|
expect(list.join(" baz ")).toBe("42 baz null baz foo baz 98,97,114");
|
|
});
|
|
|
|
it("should work with .push()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
const item1 = {};
|
|
expect(list.push(item1)).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.first()).toBe(item1);
|
|
const item2 = {};
|
|
expect(list.push(item2)).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.shift()).toBe(item1);
|
|
expect(list.shift()).toBe(item2);
|
|
expect(list.shift()).toBeUndefined();
|
|
});
|
|
|
|
it("should work with .shift()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.shift()).toBeUndefined();
|
|
const item = {};
|
|
expect(list.push(item)).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.shift()).toBe(item);
|
|
expect(list.shift()).toBeUndefined();
|
|
});
|
|
|
|
it("should work with .unshift()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
const item1 = {};
|
|
expect(list.unshift(item1)).toBeUndefined();
|
|
expect(list.length).toBe(1);
|
|
expect(list.first()).toBe(item1);
|
|
const item2 = {};
|
|
expect(list.push(item2)).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.first()).toBe(item1);
|
|
const item3 = {};
|
|
expect(list.unshift(item3)).toBeUndefined();
|
|
expect(list.length).toBe(3);
|
|
expect(list.shift()).toBe(item3);
|
|
expect(list.shift()).toBe(item1);
|
|
expect(list.shift()).toBe(item2);
|
|
expect(list.shift()).toBeUndefined();
|
|
});
|
|
|
|
it("should work with partial .consume() followed by .first()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push("foo")).toBeUndefined();
|
|
expect(list.push("bar")).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.consume(4, true)).toEqual("foob");
|
|
expect(list.length).toBe(1);
|
|
expect(list.first()).toEqual("ar");
|
|
expect(list.length).toBe(1);
|
|
});
|
|
|
|
it("should work with partial .consume() followed by .shift()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(makeUint8Array("foo"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("bar"))).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.consume(4, false)).toEqual(makeUint8Array("foob"));
|
|
expect(list.length).toBe(1);
|
|
expect(list.shift()).toEqual(makeUint8Array("ar"));
|
|
expect(list.length).toBe(0);
|
|
});
|
|
|
|
it("should work with partial .consume() followed by .unshift()", () => {
|
|
// @ts-ignore
|
|
const list = new Readable().readableBuffer;
|
|
expect(list.length).toBe(0);
|
|
expect(list.push(makeUint8Array("😋😋😋"))).toBeUndefined();
|
|
expect(list.push(makeUint8Array("📋📋📋"))).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.consume(7, false)).toEqual(new Uint8Array([61, 11, 61, 11, 61, 11, 61]));
|
|
expect(list.length).toBe(1);
|
|
expect(list.unshift(makeUint8Array("👌👌👌"))).toBeUndefined();
|
|
expect(list.length).toBe(2);
|
|
expect(list.consume(12, false)).toEqual(new Uint8Array([61, 76, 61, 76, 61, 76, 203, 61, 203, 61, 203, 0]));
|
|
expect(list.length).toBe(0);
|
|
});
|