summaryrefslogtreecommitdiff
path: root/www/external/screwdriver.js
blob: c6733776242f834e5fb6ef2c0f8fc7e6a34ba8ca (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
;(function() {

	if(typeof Blob === 'undefined')
		return console.warn('Screw-FileReader is only meant to work in those' +
	'engine who already has some basic support for blob')

	var blob = Blob.prototype
	var fullStreamSupport = false
	var basicStreamSupport = false
	var fetchTransform = false
	var URL = window.URL || window.webkitURL

	function promisify(obj) {
		return new Promise(function(resolve, reject) {
			obj.onload =
			obj.onerror = function(evt) {
				obj.onload =
				obj.onerror = null

				evt.type === 'load'
					? resolve(obj.result || obj)
					: reject(obj.error)
			}
		})
	}

	function toImage(url) {
		var img = new Image
		img.src = url
		return promisify(img)
	}

	try {
		new ReadableStream({})
		basicStreamSupport = true
	} catch (e) {}

	try {
		new ReadableStream({type: 'bytes'})
		fullStreamSupport = true
	} catch (e) {}

	try {
		(new Response(new Blob)).getReader()
		fetchTransform = true
	} catch (e) {}

	if(!blob.arrayBuffer) {
		blob.arrayBuffer = function arrayBuffer() {
			var fr = new FileReader
			fr.readAsArrayBuffer(this)
			return promisify(fr)
		}
	}

	if(!blob.text) {
		blob.text = function text() {
			var fr = new FileReader
			fr.readAsText(this)
			return promisify(fr)
		}
	}

	if(!blob.dataURL) {
		blob.dataURL = function dataURL() {
			var fr = new FileReader
			fr.readAsDataURL(this)
			return promisify(fr)
		}
	}

	if(!blob.url) {
		blob.url = function url() {
			return URL ? URL.createObjectURL(this) : null
		}
	}

	if(!blob.json) {
		blob.json = function json() {
			return this.text().then(JSON.parse)
		}
	}

	if(!blob.image) {
		blob.image = function image() {
			return Promise.resolve(this.url() || this.dataURL()).then(toImage)
		}
	}

	if(!blob.stream) {
		blob.stream =

		fullStreamSupport ? function stream() {
			var position = 0
			var blob = this

			return new ReadableStream({
				type: 'bytes',
				autoAllocateChunkSize: 524288,

				pull: function (controller) {
					var v = controller.byobRequest.view
					var chunk = blob.slice(position, position + v.byteLength)
					return chunk.arrayBuffer()
					.then(function (buffer) {
						let uint8array = new Uint8Array(buffer)
						let bytesRead = uint8array.byteLength

						position += bytesRead
						v.set(uint8array)
							controller.byobRequest.respond(bytesRead)

						if(position >= blob.size)
							controller.close()
					})
				}
			})
		}:

		// basic stream support
		basicStreamSupport ? function stream(blob){
			var position = 0
			var blob = this

			return new ReadableStream({
				pull: function (controller) {
					var chunk = blob.slice(position, position + 524288)

					return chunk.arrayBuffer().then(function (buffer) {
						position += buffer.byteLength
						let uint8array = new Uint8Array(buffer)
						controller.enqueue(uint8array)

						if(position == blob.size)
							controller.close()
					})
				}
			})
		}:

		// fetchTransform
		fetchTransform ? function stream() {
			return (new Response(this)).body
		}:

		function stream() {
			throw new Error('Include https://github.com/creatorrr/web-streams-polyfill')
		}
	}

}());