mirror of
https://github.com/hedgedoc/hedgedoc.git
synced 2025-05-13 14:44:43 -04:00
Use JavaScript Standard Style (part 2)
Fixed all fail on frontend code.
This commit is contained in:
parent
4889e9732d
commit
5bc642d02e
19 changed files with 6790 additions and 7032 deletions
|
@ -1,30 +1,31 @@
|
|||
/* eslint-env browser, jquery */
|
||||
/**
|
||||
* Helper for implementing retries with backoff. Initial retry
|
||||
* delay is 1 second, increasing by 2x (+jitter) for subsequent retries
|
||||
*
|
||||
* @constructor
|
||||
*/
|
||||
var RetryHandler = function() {
|
||||
this.interval = 1000; // Start at one second
|
||||
this.maxInterval = 60 * 1000; // Don't wait longer than a minute
|
||||
};
|
||||
var RetryHandler = function () {
|
||||
this.interval = 1000 // Start at one second
|
||||
this.maxInterval = 60 * 1000 // Don't wait longer than a minute
|
||||
}
|
||||
|
||||
/**
|
||||
* Invoke the function after waiting
|
||||
*
|
||||
* @param {function} fn Function to invoke
|
||||
*/
|
||||
RetryHandler.prototype.retry = function(fn) {
|
||||
setTimeout(fn, this.interval);
|
||||
this.interval = this.nextInterval_();
|
||||
};
|
||||
RetryHandler.prototype.retry = function (fn) {
|
||||
setTimeout(fn, this.interval)
|
||||
this.interval = this.nextInterval_()
|
||||
}
|
||||
|
||||
/**
|
||||
* Reset the counter (e.g. after successful request.)
|
||||
*/
|
||||
RetryHandler.prototype.reset = function() {
|
||||
this.interval = 1000;
|
||||
};
|
||||
RetryHandler.prototype.reset = function () {
|
||||
this.interval = 1000
|
||||
}
|
||||
|
||||
/**
|
||||
* Calculate the next wait time.
|
||||
|
@ -32,10 +33,10 @@ RetryHandler.prototype.reset = function() {
|
|||
*
|
||||
* @private
|
||||
*/
|
||||
RetryHandler.prototype.nextInterval_ = function() {
|
||||
var interval = this.interval * 2 + this.getRandomInt_(0, 1000);
|
||||
return Math.min(interval, this.maxInterval);
|
||||
};
|
||||
RetryHandler.prototype.nextInterval_ = function () {
|
||||
var interval = this.interval * 2 + this.getRandomInt_(0, 1000)
|
||||
return Math.min(interval, this.maxInterval)
|
||||
}
|
||||
|
||||
/**
|
||||
* Get a random int in the range of min to max. Used to add jitter to wait times.
|
||||
|
@ -44,10 +45,9 @@ RetryHandler.prototype.nextInterval_ = function() {
|
|||
* @param {number} max Upper bounds
|
||||
* @private
|
||||
*/
|
||||
RetryHandler.prototype.getRandomInt_ = function(min, max) {
|
||||
return Math.floor(Math.random() * (max - min + 1) + min);
|
||||
};
|
||||
|
||||
RetryHandler.prototype.getRandomInt_ = function (min, max) {
|
||||
return Math.floor(Math.random() * (max - min + 1) + min)
|
||||
}
|
||||
|
||||
/**
|
||||
* Helper class for resumable uploads using XHR/CORS. Can upload any Blob-like item, whether
|
||||
|
@ -75,116 +75,115 @@ RetryHandler.prototype.getRandomInt_ = function(min, max) {
|
|||
* @param {function} [options.onProgress] Callback for status for the in-progress upload
|
||||
* @param {function} [options.onError] Callback if upload fails
|
||||
*/
|
||||
var MediaUploader = function(options) {
|
||||
var noop = function() {};
|
||||
this.file = options.file;
|
||||
this.contentType = options.contentType || this.file.type || 'application/octet-stream';
|
||||
var MediaUploader = function (options) {
|
||||
var noop = function () {}
|
||||
this.file = options.file
|
||||
this.contentType = options.contentType || this.file.type || 'application/octet-stream'
|
||||
this.metadata = options.metadata || {
|
||||
'title': this.file.name,
|
||||
'mimeType': this.contentType
|
||||
};
|
||||
this.token = options.token;
|
||||
this.onComplete = options.onComplete || noop;
|
||||
this.onProgress = options.onProgress || noop;
|
||||
this.onError = options.onError || noop;
|
||||
this.offset = options.offset || 0;
|
||||
this.chunkSize = options.chunkSize || 0;
|
||||
this.retryHandler = new RetryHandler();
|
||||
|
||||
this.url = options.url;
|
||||
if (!this.url) {
|
||||
var params = options.params || {};
|
||||
params.uploadType = 'resumable';
|
||||
this.url = this.buildUrl_(options.fileId, params, options.baseUrl);
|
||||
}
|
||||
this.httpMethod = options.fileId ? 'PUT' : 'POST';
|
||||
};
|
||||
this.token = options.token
|
||||
this.onComplete = options.onComplete || noop
|
||||
this.onProgress = options.onProgress || noop
|
||||
this.onError = options.onError || noop
|
||||
this.offset = options.offset || 0
|
||||
this.chunkSize = options.chunkSize || 0
|
||||
this.retryHandler = new RetryHandler()
|
||||
|
||||
this.url = options.url
|
||||
if (!this.url) {
|
||||
var params = options.params || {}
|
||||
params.uploadType = 'resumable'
|
||||
this.url = this.buildUrl_(options.fileId, params, options.baseUrl)
|
||||
}
|
||||
this.httpMethod = options.fileId ? 'PUT' : 'POST'
|
||||
}
|
||||
|
||||
/**
|
||||
* Initiate the upload.
|
||||
*/
|
||||
MediaUploader.prototype.upload = function() {
|
||||
var self = this;
|
||||
var xhr = new XMLHttpRequest();
|
||||
MediaUploader.prototype.upload = function () {
|
||||
var xhr = new XMLHttpRequest()
|
||||
|
||||
xhr.open(this.httpMethod, this.url, true);
|
||||
xhr.setRequestHeader('Authorization', 'Bearer ' + this.token);
|
||||
xhr.setRequestHeader('Content-Type', 'application/json');
|
||||
xhr.setRequestHeader('X-Upload-Content-Length', this.file.size);
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.contentType);
|
||||
xhr.open(this.httpMethod, this.url, true)
|
||||
xhr.setRequestHeader('Authorization', 'Bearer ' + this.token)
|
||||
xhr.setRequestHeader('Content-Type', 'application/json')
|
||||
xhr.setRequestHeader('X-Upload-Content-Length', this.file.size)
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.contentType)
|
||||
|
||||
xhr.onload = function(e) {
|
||||
xhr.onload = function (e) {
|
||||
if (e.target.status < 400) {
|
||||
var location = e.target.getResponseHeader('Location');
|
||||
this.url = location;
|
||||
this.sendFile_();
|
||||
var location = e.target.getResponseHeader('Location')
|
||||
this.url = location
|
||||
this.sendFile_()
|
||||
} else {
|
||||
this.onUploadError_(e);
|
||||
this.onUploadError_(e)
|
||||
}
|
||||
}.bind(this);
|
||||
xhr.onerror = this.onUploadError_.bind(this);
|
||||
xhr.send(JSON.stringify(this.metadata));
|
||||
};
|
||||
}.bind(this)
|
||||
xhr.onerror = this.onUploadError_.bind(this)
|
||||
xhr.send(JSON.stringify(this.metadata))
|
||||
}
|
||||
|
||||
/**
|
||||
* Send the actual file content.
|
||||
*
|
||||
* @private
|
||||
*/
|
||||
MediaUploader.prototype.sendFile_ = function() {
|
||||
var content = this.file;
|
||||
var end = this.file.size;
|
||||
MediaUploader.prototype.sendFile_ = function () {
|
||||
var content = this.file
|
||||
var end = this.file.size
|
||||
|
||||
if (this.offset || this.chunkSize) {
|
||||
// Only bother to slice the file if we're either resuming or uploading in chunks
|
||||
if (this.chunkSize) {
|
||||
end = Math.min(this.offset + this.chunkSize, this.file.size);
|
||||
end = Math.min(this.offset + this.chunkSize, this.file.size)
|
||||
}
|
||||
content = content.slice(this.offset, end);
|
||||
content = content.slice(this.offset, end)
|
||||
}
|
||||
|
||||
var xhr = new XMLHttpRequest();
|
||||
xhr.open('PUT', this.url, true);
|
||||
xhr.setRequestHeader('Content-Type', this.contentType);
|
||||
xhr.setRequestHeader('Content-Range', "bytes " + this.offset + "-" + (end - 1) + "/" + this.file.size);
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.file.type);
|
||||
var xhr = new XMLHttpRequest()
|
||||
xhr.open('PUT', this.url, true)
|
||||
xhr.setRequestHeader('Content-Type', this.contentType)
|
||||
xhr.setRequestHeader('Content-Range', 'bytes ' + this.offset + '-' + (end - 1) + '/' + this.file.size)
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.file.type)
|
||||
if (xhr.upload) {
|
||||
xhr.upload.addEventListener('progress', this.onProgress);
|
||||
xhr.upload.addEventListener('progress', this.onProgress)
|
||||
}
|
||||
xhr.onload = this.onContentUploadSuccess_.bind(this);
|
||||
xhr.onerror = this.onContentUploadError_.bind(this);
|
||||
xhr.send(content);
|
||||
};
|
||||
xhr.onload = this.onContentUploadSuccess_.bind(this)
|
||||
xhr.onerror = this.onContentUploadError_.bind(this)
|
||||
xhr.send(content)
|
||||
}
|
||||
|
||||
/**
|
||||
* Query for the state of the file for resumption.
|
||||
*
|
||||
* @private
|
||||
*/
|
||||
MediaUploader.prototype.resume_ = function() {
|
||||
var xhr = new XMLHttpRequest();
|
||||
xhr.open('PUT', this.url, true);
|
||||
xhr.setRequestHeader('Content-Range', "bytes */" + this.file.size);
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.file.type);
|
||||
MediaUploader.prototype.resume_ = function () {
|
||||
var xhr = new XMLHttpRequest()
|
||||
xhr.open('PUT', this.url, true)
|
||||
xhr.setRequestHeader('Content-Range', 'bytes */' + this.file.size)
|
||||
xhr.setRequestHeader('X-Upload-Content-Type', this.file.type)
|
||||
if (xhr.upload) {
|
||||
xhr.upload.addEventListener('progress', this.onProgress);
|
||||
xhr.upload.addEventListener('progress', this.onProgress)
|
||||
}
|
||||
xhr.onload = this.onContentUploadSuccess_.bind(this);
|
||||
xhr.onerror = this.onContentUploadError_.bind(this);
|
||||
xhr.send();
|
||||
};
|
||||
xhr.onload = this.onContentUploadSuccess_.bind(this)
|
||||
xhr.onerror = this.onContentUploadError_.bind(this)
|
||||
xhr.send()
|
||||
}
|
||||
|
||||
/**
|
||||
* Extract the last saved range if available in the request.
|
||||
*
|
||||
* @param {XMLHttpRequest} xhr Request object
|
||||
*/
|
||||
MediaUploader.prototype.extractRange_ = function(xhr) {
|
||||
var range = xhr.getResponseHeader('Range');
|
||||
MediaUploader.prototype.extractRange_ = function (xhr) {
|
||||
var range = xhr.getResponseHeader('Range')
|
||||
if (range) {
|
||||
this.offset = parseInt(range.match(/\d+/g).pop(), 10) + 1;
|
||||
this.offset = parseInt(range.match(/\d+/g).pop(), 10) + 1
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Handle successful responses for uploads. Depending on the context,
|
||||
|
@ -194,17 +193,17 @@ MediaUploader.prototype.extractRange_ = function(xhr) {
|
|||
* @private
|
||||
* @param {object} e XHR event
|
||||
*/
|
||||
MediaUploader.prototype.onContentUploadSuccess_ = function(e) {
|
||||
if (e.target.status == 200 || e.target.status == 201) {
|
||||
this.onComplete(e.target.response);
|
||||
} else if (e.target.status == 308) {
|
||||
this.extractRange_(e.target);
|
||||
this.retryHandler.reset();
|
||||
this.sendFile_();
|
||||
MediaUploader.prototype.onContentUploadSuccess_ = function (e) {
|
||||
if (e.target.status === 200 || e.target.status === 201) {
|
||||
this.onComplete(e.target.response)
|
||||
} else if (e.target.status === 308) {
|
||||
this.extractRange_(e.target)
|
||||
this.retryHandler.reset()
|
||||
this.sendFile_()
|
||||
} else {
|
||||
this.onContentUploadError_(e);
|
||||
this.onContentUploadError_(e)
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Handles errors for uploads. Either retries or aborts depending
|
||||
|
@ -213,13 +212,13 @@ MediaUploader.prototype.onContentUploadSuccess_ = function(e) {
|
|||
* @private
|
||||
* @param {object} e XHR event
|
||||
*/
|
||||
MediaUploader.prototype.onContentUploadError_ = function(e) {
|
||||
MediaUploader.prototype.onContentUploadError_ = function (e) {
|
||||
if (e.target.status && e.target.status < 500) {
|
||||
this.onError(e.target.response);
|
||||
this.onError(e.target.response)
|
||||
} else {
|
||||
this.retryHandler.retry(this.resume_.bind(this));
|
||||
this.retryHandler.retry(this.resume_.bind(this))
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Handles errors for the initial request.
|
||||
|
@ -227,9 +226,9 @@ MediaUploader.prototype.onContentUploadError_ = function(e) {
|
|||
* @private
|
||||
* @param {object} e XHR event
|
||||
*/
|
||||
MediaUploader.prototype.onUploadError_ = function(e) {
|
||||
this.onError(e.target.response); // TODO - Retries for initial upload
|
||||
};
|
||||
MediaUploader.prototype.onUploadError_ = function (e) {
|
||||
this.onError(e.target.response) // TODO - Retries for initial upload
|
||||
}
|
||||
|
||||
/**
|
||||
* Construct a query string from a hash/object
|
||||
|
@ -238,12 +237,12 @@ MediaUploader.prototype.onUploadError_ = function(e) {
|
|||
* @param {object} [params] Key/value pairs for query string
|
||||
* @return {string} query string
|
||||
*/
|
||||
MediaUploader.prototype.buildQuery_ = function(params) {
|
||||
params = params || {};
|
||||
return Object.keys(params).map(function(key) {
|
||||
return encodeURIComponent(key) + '=' + encodeURIComponent(params[key]);
|
||||
}).join('&');
|
||||
};
|
||||
MediaUploader.prototype.buildQuery_ = function (params) {
|
||||
params = params || {}
|
||||
return Object.keys(params).map(function (key) {
|
||||
return encodeURIComponent(key) + '=' + encodeURIComponent(params[key])
|
||||
}).join('&')
|
||||
}
|
||||
|
||||
/**
|
||||
* Build the drive upload URL
|
||||
|
@ -253,16 +252,16 @@ MediaUploader.prototype.buildQuery_ = function(params) {
|
|||
* @param {object} [params] Query parameters
|
||||
* @return {string} URL
|
||||
*/
|
||||
MediaUploader.prototype.buildUrl_ = function(id, params, baseUrl) {
|
||||
var url = baseUrl || 'https://www.googleapis.com/upload/drive/v2/files/';
|
||||
MediaUploader.prototype.buildUrl_ = function (id, params, baseUrl) {
|
||||
var url = baseUrl || 'https://www.googleapis.com/upload/drive/v2/files/'
|
||||
if (id) {
|
||||
url += id;
|
||||
url += id
|
||||
}
|
||||
var query = this.buildQuery_(params);
|
||||
var query = this.buildQuery_(params)
|
||||
if (query) {
|
||||
url += '?' + query;
|
||||
url += '?' + query
|
||||
}
|
||||
return url;
|
||||
};
|
||||
return url
|
||||
}
|
||||
|
||||
window.MediaUploader = MediaUploader;
|
||||
window.MediaUploader = MediaUploader
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue