blob: 2a3352b2c41d01cbb4f0b5534de4ca2702794581 [file] [log] [blame]
import toPromise from './toPromise';
import { btoa } from './binary/base64';
import Md5 from 'spark-md5';
var setImmediateShim = global.setImmediate || global.setTimeout;
var MD5_CHUNK_SIZE = 32768;
function rawToBase64(raw) {
return btoa(raw);
}
function appendBuffer(buffer, data, start, end) {
if (start > 0 || end < data.byteLength) {
// only create a subarray if we really need to
data = new Uint8Array(data, start,
Math.min(end, data.byteLength) - start);
}
buffer.append(data);
}
function appendString(buffer, data, start, end) {
if (start > 0 || end < data.length) {
// only create a substring if we really need to
data = data.substring(start, end);
}
buffer.appendBinary(data);
}
var md5 = toPromise(function (data, callback) {
var inputIsString = typeof data === 'string';
var len = inputIsString ? data.length : data.byteLength;
var chunkSize = Math.min(MD5_CHUNK_SIZE, len);
var chunks = Math.ceil(len / chunkSize);
var currentChunk = 0;
var buffer = inputIsString ? new Md5() : new Md5.ArrayBuffer();
var append = inputIsString ? appendString : appendBuffer;
function loadNextChunk() {
var start = currentChunk * chunkSize;
var end = start + chunkSize;
currentChunk++;
if (currentChunk < chunks) {
append(buffer, data, start, end);
setImmediateShim(loadNextChunk);
} else {
append(buffer, data, start, end);
var raw = buffer.end(true);
var base64 = rawToBase64(raw);
callback(null, base64);
buffer.destroy();
}
}
loadNextChunk();
});
export default md5;