UrlFetcher.mjs

import {fileReaders} from '../plugins.mjs'
import {fetchUrlAsArrayBuffer} from '../reader.mjs'
import {ChunkedReader} from './ChunkedReader.mjs'
import {fetch} from '../polyfill/fetch.mjs'


export class UrlFetcher extends ChunkedReader {

	async readWhole() {
		this.chunked = false
		let chunk = await fetchUrlAsArrayBuffer(this.input)
		if (chunk instanceof ArrayBuffer)
			this._swapArrayBuffer(chunk)
		else if (chunk instanceof Uint8Array)
			this._swapBuffer(chunk)
	}

	async _readChunk(offset, length) {
		let end = length ? offset + length - 1 : undefined
		// note: end in http range is inclusive, unlike APIs in node,
		let headers = this.options.httpHeaders || {};
		if (offset || end) headers.range = `bytes=${[offset, end].join('-')}`
		let res = await fetch(this.input, {headers})
		let abChunk = await res.arrayBuffer()
		let bytesRead = abChunk.byteLength
		if (res.status === 416) return undefined
		if (bytesRead !== length) this.size = offset + bytesRead
		return this.set(abChunk, offset, true)
	}

}

fileReaders.set('url', UrlFetcher)