import * as hex from "../encoding/hex.ts";import * as base64 from "../encoding/base64.ts";import { Encodings, normalizeEncoding, notImplemented } from "./_utils.ts";
const notImplementedEncodings = [ "ascii", "binary", "latin1", "ucs2", "utf16le",];
function checkEncoding(encoding = "utf8", strict = true): Encodings { if (typeof encoding !== "string" || (strict && encoding === "")) { if (!strict) return "utf8"; throw new TypeError(`Unkown encoding: ${encoding}`); }
const normalized = normalizeEncoding(encoding);
if (normalized === undefined) { throw new TypeError(`Unkown encoding: ${encoding}`); }
if (notImplementedEncodings.includes(encoding)) { notImplemented(`"${encoding}" encoding`); }
return normalized;}
interface EncodingOp { byteLength(string: string): number;}
const encodingOps: { [key: string]: EncodingOp } = { utf8: { byteLength: (string: string): number => new TextEncoder().encode(string).byteLength, }, ucs2: { byteLength: (string: string): number => string.length * 2, }, utf16le: { byteLength: (string: string): number => string.length * 2, }, latin1: { byteLength: (string: string): number => string.length, }, ascii: { byteLength: (string: string): number => string.length, }, base64: { byteLength: (string: string): number => base64ByteLength(string, string.length), }, hex: { byteLength: (string: string): number => string.length >>> 1, },};
function base64ByteLength(str: string, bytes: number): number { if (str.charCodeAt(bytes - 1) === 0x3d) bytes--; if (bytes > 1 && str.charCodeAt(bytes - 1) === 0x3d) bytes--;
return (bytes * 3) >>> 2;}
export class Buffer extends Uint8Array { static alloc( size: number, fill?: number | string | Uint8Array | Buffer, encoding = "utf8", ): Buffer { if (typeof size !== "number") { throw new TypeError( `The "size" argument must be of type number. Received type ${typeof size}`, ); }
const buf = new Buffer(size); if (size === 0) return buf;
let bufFill; if (typeof fill === "string") { const clearEncoding = checkEncoding(encoding); if ( typeof fill === "string" && fill.length === 1 && clearEncoding === "utf8" ) { buf.fill(fill.charCodeAt(0)); } else bufFill = Buffer.from(fill, clearEncoding); } else if (typeof fill === "number") { buf.fill(fill); } else if (fill instanceof Uint8Array) { if (fill.length === 0) { throw new TypeError( `The argument "value" is invalid. Received ${fill.constructor.name} []`, ); }
bufFill = fill; }
if (bufFill) { if (bufFill.length > buf.length) { bufFill = bufFill.subarray(0, buf.length); }
let offset = 0; while (offset < size) { buf.set(bufFill, offset); offset += bufFill.length; if (offset + bufFill.length >= size) break; } if (offset !== size) { buf.set(bufFill.subarray(0, size - offset), offset); } }
return buf; }
static allocUnsafe(size: number): Buffer { return new Buffer(size); }
static byteLength( string: string | Buffer | ArrayBufferView | ArrayBuffer | SharedArrayBuffer, encoding = "utf8", ): number { if (typeof string != "string") return string.byteLength;
encoding = normalizeEncoding(encoding) || "utf8"; return encodingOps[encoding].byteLength(string); }
static concat(list: Buffer[] | Uint8Array[], totalLength?: number): Buffer { if (totalLength == undefined) { totalLength = 0; for (const buf of list) { totalLength += buf.length; } }
const buffer = Buffer.allocUnsafe(totalLength); let pos = 0; for (const item of list) { let buf: Buffer; if (!(item instanceof Buffer)) { buf = Buffer.from(item); } else { buf = item; } buf.copy(buffer, pos); pos += buf.length; }
return buffer; }
static from(array: number[]): Buffer; static from( arrayBuffer: ArrayBuffer | SharedArrayBuffer, byteOffset?: number, length?: number, ): Buffer; static from(buffer: Buffer | Uint8Array): Buffer; static from(string: string, encoding?: string): Buffer; static from( value: any, offsetOrEncoding?: number | string, length?: number, ): Buffer { const offset = typeof offsetOrEncoding === "string" ? undefined : offsetOrEncoding; let encoding = typeof offsetOrEncoding === "string" ? offsetOrEncoding : undefined;
if (typeof value == "string") { encoding = checkEncoding(encoding, false); if (encoding === "hex") return new Buffer(hex.decodeString(value).buffer); if (encoding === "base64") return new Buffer(base64.decode(value).buffer); return new Buffer(new TextEncoder().encode(value).buffer); }
return new Buffer(value, offset!, length); }
static isBuffer(obj: unknown): obj is Buffer { return obj instanceof Buffer; }
static isEncoding(encoding: any): boolean { return ( typeof encoding === "string" && encoding.length !== 0 && normalizeEncoding(encoding) !== undefined ); }
copy( targetBuffer: Buffer | Uint8Array, targetStart = 0, sourceStart = 0, sourceEnd = this.length, ): number { const sourceBuffer = this .subarray(sourceStart, sourceEnd) .subarray(0, Math.max(0, targetBuffer.length - targetStart));
if (sourceBuffer.length === 0) return 0;
targetBuffer.set(sourceBuffer, targetStart); return sourceBuffer.length; }
equals(otherBuffer: Uint8Array | Buffer): boolean { if (!(otherBuffer instanceof Uint8Array)) { throw new TypeError( `The "otherBuffer" argument must be an instance of Buffer or Uint8Array. Received type ${typeof otherBuffer}`, ); }
if (this === otherBuffer) return true; if (this.byteLength !== otherBuffer.byteLength) return false;
for (let i = 0; i < this.length; i++) { if (this[i] !== otherBuffer[i]) return false; }
return true; }
readBigInt64BE(offset = 0): bigint { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getBigInt64(offset); } readBigInt64LE(offset = 0): bigint { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getBigInt64(offset, true); }
readBigUInt64BE(offset = 0): bigint { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getBigUint64(offset); } readBigUInt64LE(offset = 0): bigint { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getBigUint64(offset, true); }
readDoubleBE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getFloat64(offset); } readDoubleLE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getFloat64(offset, true); }
readFloatBE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getFloat32(offset); } readFloatLE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getFloat32(offset, true); }
readInt8(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getInt8( offset, ); }
readInt16BE(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getInt16( offset, ); } readInt16LE(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getInt16( offset, true, ); }
readInt32BE(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getInt32( offset, ); } readInt32LE(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getInt32( offset, true, ); }
readUInt8(offset = 0): number { return new DataView(this.buffer, this.byteOffset, this.byteLength).getUint8( offset, ); }
readUInt16BE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getUint16(offset); } readUInt16LE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getUint16(offset, true); }
readUInt32BE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getUint32(offset); } readUInt32LE(offset = 0): number { return new DataView( this.buffer, this.byteOffset, this.byteLength, ).getUint32(offset, true); }
slice(begin = 0, end = this.length): Buffer { return this.subarray(begin, end) as Buffer; }
toJSON(): Record<string, unknown> { return { type: "Buffer", data: Array.from(this) }; }
toString(encoding = "utf8", start = 0, end = this.length): string { encoding = checkEncoding(encoding);
const b = this.subarray(start, end); if (encoding === "hex") return hex.encodeToString(b); if (encoding === "base64") return base64.encode(b.buffer);
return new TextDecoder(encoding).decode(b); }
write(string: string, offset = 0, length = this.length): number { return new TextEncoder().encodeInto( string, this.subarray(offset, offset + length), ).written; }
writeBigInt64BE(value: bigint, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setBigInt64( offset, value, ); return offset + 4; } writeBigInt64LE(value: bigint, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setBigInt64( offset, value, true, ); return offset + 4; }
writeBigUInt64BE(value: bigint, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setBigUint64( offset, value, ); return offset + 4; } writeBigUInt64LE(value: bigint, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setBigUint64( offset, value, true, ); return offset + 4; }
writeDoubleBE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setFloat64( offset, value, ); return offset + 8; } writeDoubleLE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setFloat64( offset, value, true, ); return offset + 8; }
writeFloatBE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setFloat32( offset, value, ); return offset + 4; } writeFloatLE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setFloat32( offset, value, true, ); return offset + 4; }
writeInt8(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setInt8( offset, value, ); return offset + 1; }
writeInt16BE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setInt16( offset, value, ); return offset + 2; } writeInt16LE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setInt16( offset, value, true, ); return offset + 2; }
writeInt32BE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint32( offset, value, ); return offset + 4; } writeInt32LE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setInt32( offset, value, true, ); return offset + 4; }
writeUInt8(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint8( offset, value, ); return offset + 1; }
writeUInt16BE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint16( offset, value, ); return offset + 2; } writeUInt16LE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint16( offset, value, true, ); return offset + 2; }
writeUInt32BE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint32( offset, value, ); return offset + 4; } writeUInt32LE(value: number, offset = 0): number { new DataView(this.buffer, this.byteOffset, this.byteLength).setUint32( offset, value, true, ); return offset + 4; }}
export default { Buffer };