import { ALLOC, REALLOC, REGISTER, LINK, ArrayBufferView, FREE } from "./runtime"; import { ArrayBuffer } from "./arraybuffer"; import { COMPARATOR, SORT } from "./util/sort"; import { itoa, dtoa, itoa_stream, dtoa_stream, MAX_DOUBLE_LENGTH } from "./util/number"; import { isArray as builtin_isArray } from "./builtins"; export class Array<T> extends ArrayBufferView { private length_: i32; @inline static isArray<U>(value: U): bool { return builtin_isArray(value) && value !== null; } constructor(length: i32 = 0) { super(length, alignof<T>()); this.length_ = length; } @unsafe get buffer(): ArrayBuffer { return this.data; } get length(): i32 { return this.length_; } set length(length: i32) { this.resize(length); this.length_ = length; } private resize(length: i32): void { var oldData = this.data; var oldCapacity = oldData.byteLength >>> alignof<T>(); if (<u32>length > <u32>oldCapacity) { const MAX_LENGTH = ArrayBuffer.MAX_BYTELENGTH >>> alignof<T>(); if (<u32>length > <u32>MAX_LENGTH) throw new RangeError("Invalid array length"); let newCapacity = <usize>length << alignof<T>(); let newData = REALLOC(changetype<usize>(oldData), newCapacity); // registers on move if (newData !== changetype<usize>(oldData)) { this.data = changetype<ArrayBuffer>(newData); // links this.dataStart = newData; this.dataEnd = newData + newCapacity; } } } every(callbackfn: (element: T, index: i32, array: Array<T>) => bool): bool { for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { if (!callbackfn(load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this)) return false; } return true; } findIndex(predicate: (element: T, index: i32, array: Array<T>) => bool): i32 { for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { if (predicate(load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this)) return index; } return -1; } // @operator("[]") // private __get(index: i32): T { // var buffer = this.buffer_; // return <u32>index < <u32>(buffer.byteLength >>> alignof<T>()) // ? LOAD<T>(buffer, index) // : <T>unreachable(); // } // @operator("{}") // private __unchecked_get(index: i32): T { // return LOAD<T>(this.buffer_, index); // } // @operator("[]=") // private __set(index: i32, value: T): void { // var buffer = this.buffer_; // var capacity = buffer.byteLength >>> alignof<T>(); // if (<u32>index >= <u32>capacity) { // const MAX_LENGTH = MAX_BLENGTH >>> alignof<T>(); // if (<u32>index >= <u32>MAX_LENGTH) throw new Error("Invalid array length"); // buffer = reallocateUnsafe(buffer, (index + 1) << alignof<T>()); // this.buffer_ = buffer; // this.length_ = index + 1; // } // STORE<T>(buffer, index, value); // if (isManaged<T>()) __gc_link(changetype<usize>(this), changetype<usize>(value)); // tslint:disable-line // } // @operator("{}=") // private __unchecked_set(index: i32, value: T): void { // STORE<T>(this.buffer_, index, value); // if (isManaged<T>()) __gc_link(changetype<usize>(this), changetype<usize>(value)); // tslint:disable-line // } fill(value: T, start: i32 = 0, end: i32 = i32.MAX_VALUE): this { var dataStart = this.dataStart; var length = this.length_; start = start < 0 ? max(length + start, 0) : min(start, length); end = end < 0 ? max(length + end, 0) : min(end, length); if (sizeof<T>() == 1) { if (start < end) { memory.fill( dataStart + <usize>start, <u8>value, <usize>(end - start) ); } } else { for (; start < end; ++start) { store<T>(dataStart + (<usize>start << alignof<T>()), value); } } return this; } includes(searchElement: T, fromIndex: i32 = 0): bool { return this.indexOf(searchElement, fromIndex) >= 0; } indexOf(searchElement: T, fromIndex: i32 = 0): i32 { var length = this.length_; if (length == 0 || fromIndex >= length) return -1; if (fromIndex < 0) fromIndex = max(length + fromIndex, 0); var dataStart = this.dataStart; while (fromIndex < length) { if (load<T>(dataStart + (<usize>fromIndex << alignof<T>())) == searchElement) return fromIndex; ++fromIndex; } return -1; } lastIndexOf(searchElement: T, fromIndex: i32 = this.length_): i32 { var length = this.length_; if (length == 0) return -1; if (fromIndex < 0) fromIndex = length + fromIndex; else if (fromIndex >= length) fromIndex = length - 1; var dataStart = this.dataStart; while (fromIndex >= 0) { if (load<T>(dataStart + (<usize>fromIndex << alignof<T>())) == searchElement) return fromIndex; --fromIndex; } return -1; } push(element: T): i32 { var newLength = this.length_ + 1; this.resize(newLength); this.length_ = newLength; store<T>(this.dataStart + (<usize>(newLength - 1) << alignof<T>()), element); if (isManaged<T>()) LINK(changetype<usize>(element), changetype<usize>(this)); return newLength; } concat(other: Array<T>): Array<T> { var thisLen = this.length_; var otherLen = select(0, other.length_, other === null); var out = new Array<T>(thisLen + otherLen); var outStart = out.dataStart; var thisSize = <usize>thisLen << alignof<T>(); if (isManaged<T>()) { let thisStart = this.dataStart; for (let offset: usize = 0; offset < thisSize; offset += sizeof<T>()) { let element = load<T>(thisStart + offset); store<T>(outStart + offset, element); LINK(changetype<usize>(element), changetype<usize>(out)); } let otherStart = other.dataStart; let otherSize = <usize>otherLen << alignof<T>(); for (let offset: usize = 0; offset < otherSize; offset += sizeof<T>()) { let element = load<T>(otherStart + offset); store<T>(outStart + thisSize + offset, element); LINK(changetype<usize>(element), changetype<usize>(out)); } } else { memory.copy(outStart, this.dataStart, thisSize); memory.copy(outStart + thisSize, other.dataStart, <usize>otherLen << alignof<T>()); } return out; } copyWithin(target: i32, start: i32, end: i32 = i32.MAX_VALUE): this { var dataStart = this.dataStart; var len = this.length_; end = min<i32>(end, len); var to = target < 0 ? max(len + target, 0) : min(target, len); var from = start < 0 ? max(len + start, 0) : min(start, len); var last = end < 0 ? max(len + end, 0) : min(end, len); var count = min(last - from, len - to); if (from < to && to < (from + count)) { from += count - 1; to += count - 1; while (count) { store<T>(dataStart + (<usize>to << alignof<T>()), load<T>(dataStart + (<usize>from << alignof<T>()))); --from, --to, --count; } } else { memory.copy( dataStart + (<usize>to << alignof<T>()), dataStart + (<usize>from << alignof<T>()), <usize>count << alignof<T>() ); } return this; } pop(): T { var length = this.length_; if (length < 1) throw new RangeError("Array is empty"); var element = load<T>(this.dataStart + (<usize>--length << alignof<T>())); this.length_ = length; return element; } forEach(callbackfn: (value: T, index: i32, array: Array<T>) => void): void { for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { callbackfn(load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this); } } map<U>(callbackfn: (value: T, index: i32, array: Array<T>) => U): Array<U> { var length = this.length_; var out = new Array<U>(length); var outStart = out.dataStart; for (let index = 0; index < min(length, this.length_); ++index) { let value = load<T>(this.dataStart + (<usize>index << alignof<T>())); let result = callbackfn(value, index, this); store<U>(outStart + (<usize>index << alignof<U>()), result); if (isManaged<U>()) LINK(changetype<usize>(result), changetype<usize>(out)); } return out; } filter(callbackfn: (value: T, index: i32, array: Array<T>) => bool): Array<T> { var result = new Array<T>(); for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { let value = load<T>(this.dataStart + (<usize>index << alignof<T>())); if (callbackfn(value, index, this)) result.push(value); } return result; } reduce<U>( callbackfn: (previousValue: U, currentValue: T, currentIndex: i32, array: Array<T>) => U, initialValue: U ): U { var accum = initialValue; for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { accum = callbackfn(accum, load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this); } return accum; } reduceRight<U>( callbackfn: (previousValue: U, currentValue: T, currentIndex: i32, array: Array<T>) => U, initialValue: U ): U { var accum = initialValue; for (let index = this.length_ - 1; index >= 0; --index) { accum = callbackfn(accum, load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this); } return accum; } shift(): T { var length = this.length_; if (length < 1) throw new RangeError("Array is empty"); var base = this.dataStart; var element = load<T>(base); var lastIndex = length - 1; memory.copy( base, base + sizeof<T>(), <usize>lastIndex << alignof<T>() ); store<T>(base + (<usize>lastIndex << alignof<T>()), <T>null); this.length_ = lastIndex; return element; } some(callbackfn: (element: T, index: i32, array: Array<T>) => bool): bool { for (let index = 0, length = this.length_; index < min(length, this.length_); ++index) { if (callbackfn(load<T>(this.dataStart + (<usize>index << alignof<T>())), index, this)) return true; } return false; } unshift(element: T): i32 { var newLength = this.length_; this.resize(newLength); var base = this.dataStart; memory.copy( base + sizeof<T>(), base, <usize>(newLength - 1) << alignof<T>() ); store<T>(base, element); if (isManaged<T>()) LINK(changetype<usize>(element), changetype<usize>(this)); this.length_ = newLength; return newLength; } slice(begin: i32 = 0, end: i32 = i32.MAX_VALUE): Array<T> { var length = this.length_; begin = begin < 0 ? max(begin + length, 0) : min(begin, length); end = end < 0 ? max(end + length, 0) : min(end , length); length = max(end - begin, 0); var slice = new Array<T>(length); var sliceBase = slice.dataStart; var thisBase = this.dataStart + (<usize>begin << alignof<T>()); for (let i = 0; i < length; ++i) { let offset = <usize>i << alignof<T>(); let element = load<T>(thisBase + offset); store<T>(sliceBase + offset, element); if (isManaged<T>()) LINK(changetype<usize>(element), changetype<usize>(slice)); } return slice; } splice(start: i32, deleteCount: i32 = i32.MAX_VALUE): Array<T> { var length = this.length_; start = start < 0 ? max<i32>(length + start, 0) : min<i32>(start, length); deleteCount = max<i32>(min<i32>(deleteCount, length - start), 0); var splice = new Array<T>(deleteCount); var spliceStart = splice.dataStart; var thisStart = this.dataStart; var thisBase = thisStart + (<usize>start << alignof<T>()); for (let i = 0; i < deleteCount; ++i) { let element = load<T>(thisBase + (<usize>i << alignof<T>())); store<T>(spliceStart + (<usize>i << alignof<T>()), element); if (isManaged<T>()) LINK(changetype<usize>(element), changetype<usize>(splice)); } memory.copy( splice.dataStart, thisBase, <usize>deleteCount << alignof<T>() ); var offset = start + deleteCount; if (length != offset) { memory.copy( thisBase, thisStart + (<usize>offset << alignof<T>()), <usize>(length - offset) << alignof<T>() ); } this.length_ = length - deleteCount; return splice; } reverse(): Array<T> { var base = this.dataStart; for (let front = 0, back = this.length_ - 1; front < back; ++front, --back) { let temp = load<T>(base, front); let dest = base + (<usize>back << alignof<T>()); store<T>(base + (<usize>front << alignof<T>()), load<T>(dest)); store<T>(dest, temp); } return this; } sort(comparator: (a: T, b: T) => i32 = COMPARATOR<T>()): this { // TODO remove this when flow will allow tracking null assert(comparator); // The comparison function must be a function var length = this.length_; if (length <= 1) return this; var base = this.dataStart; if (length == 2) { let a: T = load<T>(base, sizeof<T>()); // a = arr[1] let b: T = load<T>(base); // b = arr[0] if (comparator(a, b) < 0) { store<T>(base, b, sizeof<T>()); // arr[1] = b; store<T>(base, a); // arr[0] = a; } return this; } SORT<T>(base, length, comparator); return this; } // FIXME: refactor into multiple functions? join(separator: string = ","): string { var lastIndex = this.length_ - 1; if (lastIndex < 0) return ""; var result = ""; var value: T; var base = this.dataStart; // var buffer = this.buffer_; var sepLen = separator.length; var hasSeparator = sepLen != 0; if (value instanceof bool) { if (!lastIndex) return select("true", "false", load<T>(base)); let valueLen = 5; // max possible length of element len("false") let estLen = (valueLen + sepLen) * lastIndex + valueLen; let result = ALLOC(estLen << 1); let offset = 0; for (let i = 0; i < lastIndex; ++i) { value = load<T>(base + i); valueLen = 4 + <i32>(!value); memory.copy( result + (<usize>offset << 1), changetype<usize>(select("true", "false", value)), <usize>valueLen << 1 ); offset += valueLen; if (hasSeparator) { memory.copy( result + (<usize>offset << 1), changetype<usize>(separator), <usize>sepLen << 1 ); offset += sepLen; } } value = load<T>(base + <usize>lastIndex); valueLen = 4 + <i32>(!value); memory.copy( result + (<usize>offset << 1), changetype<usize>(select("true", "false", value)), valueLen << 1 ); offset += valueLen; if (estLen > offset) { let trimmed = changetype<string>(result).substring(0, offset); FREE(result); return trimmed; // registered in .substring } return REGISTER<string>(result); } else if (isInteger<T>()) { if (!lastIndex) return changetype<string>(itoa<T>(load<T>(base))); const valueLen = (sizeof<T>() <= 4 ? 10 : 20) + <i32>isSigned<T>(); let estLen = (valueLen + sepLen) * lastIndex + valueLen; let result = ALLOC(estLen << 1); let offset = 0; for (let i = 0; i < lastIndex; ++i) { value = load<T>(base + (<usize>i << alignof<T>())); offset += itoa_stream<T>(result, offset, value); if (hasSeparator) { memory.copy( result + (<usize>offset << 1), changetype<usize>(separator), <usize>sepLen << 1 ); offset += sepLen; } } value = load<T>(base + (<usize>lastIndex << alignof<T>())); offset += itoa_stream<T>(result, offset, value); if (estLen > offset) { let trimmed = changetype<string>(result).substring(0, offset); FREE(result); return trimmed; // registered in .substring } return REGISTER<string>(result); } else if (isFloat<T>()) { if (!lastIndex) return changetype<string>(dtoa(load<T>(base))); const valueLen = MAX_DOUBLE_LENGTH; let estLen = (valueLen + sepLen) * lastIndex + valueLen; let result = ALLOC(estLen << 1); let offset = 0; for (let i = 0; i < lastIndex; ++i) { value = load<T>(base + (<usize>i << alignof<T>())); offset += dtoa_stream(result, offset, value); if (hasSeparator) { memory.copy( result + (<usize>offset << 1), changetype<usize>(separator), <usize>sepLen << 1 ); offset += sepLen; } } value = load<T>(base + (<usize>lastIndex << alignof<T>())); offset += dtoa_stream(result, offset, value); if (estLen > offset) { let trimmed = changetype<string>(result).substring(0, offset); FREE(result); return trimmed; // registered in .substring } return REGISTER<string>(result); } else if (isString<T>()) { if (!lastIndex) return load<string>(base); let estLen = 0; for (let i = 0, len = lastIndex + 1; i < len; ++i) { estLen += load<string>(base + (<usize>i << alignof<T>())).length; } let offset = 0; let result = ALLOC((estLen + sepLen * lastIndex) << 1); for (let i = 0; i < lastIndex; ++i) { value = load<string>(base + (<usize>i << alignof<T>())); if (value) { let valueLen = changetype<string>(value).length; memory.copy( result + (<usize>offset << 1), changetype<usize>(value), <usize>valueLen << 1 ); offset += valueLen; } if (hasSeparator) { memory.copy( result + (<usize>offset << 1), changetype<usize>(separator), <usize>sepLen << 1 ); offset += sepLen; } } value = load<string>(base + (<usize>lastIndex << alignof<T>())); if (value) { let valueLen = changetype<string>(value).length; memory.copy( result + (<usize>offset << 1), changetype<usize>(value), <usize>valueLen << 1 ); } return REGISTER<string>(result); } else if (isArray<T>()) { if (!lastIndex) { value = load<T>(base); return value ? value.join(separator) : ""; } for (let i = 0; i < lastIndex; ++i) { value = load<T>(base + (<usize>i << alignof<T>())); if (value) result += value.join(separator); if (hasSeparator) result += separator; } value = load<T>(base + (<usize>lastIndex << alignof<T>())); if (value) result += value.join(separator); return result; // registered by concatenation (FIXME: lots of garbage) } else if (isReference<T>()) { // References if (!lastIndex) return "[object Object]"; const valueLen = 15; // max possible length of element len("[object Object]") let estLen = (valueLen + sepLen) * lastIndex + valueLen; let result = ALLOC(estLen << 1); let offset = 0; for (let i = 0; i < lastIndex; ++i) { value = load<T>(base + (<usize>i << alignof<T>())); if (value) { memory.copy( result + (<usize>offset << 1), changetype<usize>("[object Object]"), <usize>valueLen << 1 ); offset += valueLen; } if (hasSeparator) { memory.copy( result + (<usize>offset << 1), changetype<usize>(separator), <usize>sepLen << 1 ); offset += sepLen; } } if (load<T>(base + (<usize>lastIndex << alignof<T>()))) { memory.copy( result + (<usize>offset << 1), changetype<usize>("[object Object]"), <usize>valueLen << 1 ); offset += valueLen; } if (estLen > offset) { let out = changetype<string>(result).substring(0, offset); FREE(result); return out; // registered in .substring } return REGISTER<string>(result); } else { ERROR("unspported type"); assert(false); } } @inline toString(): string { return this.join(); } // private __gc(): void { // var buffer = this.buffer_; // __gc_mark(changetype<usize>(buffer)); // tslint:disable-line // if (isManaged<T>()) { // let offset: usize = 0; // let end = <usize>this.length_ << alignof<usize>(); // while (offset < end) { // __gc_mark(load<usize>(changetype<usize>(buffer) + offset, HEADER_SIZE)); // tslint:disable-line // offset += sizeof<usize>(); // } // } // } }