drawio/war/js/diagramly/DropboxClient.js
Gaudenz Alder 5798efc85f 6.2.3 release
Former-commit-id: 3dc20ef7b4
2017-02-28 16:40:36 +01:00

854 lines
20 KiB
JavaScript

/**
* Copyright (c) 2006-2017, JGraph Ltd
* Copyright (c) 2006-2017, Gaudenz Alder
*/
DropboxClient = function(editorUi)
{
DrawioClient.call(this, editorUi, 'dbauth');
this.client = new Dropbox({clientId: App.DROPBOX_APPKEY});
this.client.setAccessToken(this.token);
};
// Extends DrawioClient
mxUtils.extend(DropboxClient, DrawioClient);
/**
* FIXME: How to find name of app folder for current user. The Apps part of the
* name is internationalized so this hardcoded check does not work everywhere.
*/
DropboxClient.prototype.appPath = '/drawio/';
/**
* Executes the first step for connecting to Google Drive.
*/
DropboxClient.prototype.extension = '.html';
/**
* Executes the first step for connecting to Google Drive.
*/
DropboxClient.prototype.writingFile = false;
/**
* Executes the first step for connecting to Google Drive.
*/
DropboxClient.prototype.maxRetries = 4;
/**
* Authorizes the client, gets the userId and calls <open>.
*/
DropboxClient.prototype.logout = function()
{
this.clearPersistentToken();
this.setUser(null);
this.token = null;
this.client.authTokenRevoke().then(mxUtils.bind(this, function()
{
this.client.setAccessToken(null);
}));
};
/**
* Checks if the client is authorized and calls the next step.
*/
DropboxClient.prototype.updateUser = function(success, error, failOnAuth)
{
var acceptResponse = true;
var timeoutThread = window.setTimeout(mxUtils.bind(this, function()
{
acceptResponse = false;
error({code: App.ERROR_TIMEOUT});
}), this.ui.timeout);
var promise = this.client.usersGetCurrentAccount();
promise.then(mxUtils.bind(this, function(response)
{
window.clearTimeout(timeoutThread);
if (acceptResponse)
{
this.setUser(new DrawioUser(response.account_id,
response.email, response.name.display_name));
success();
}
}));
// Workaround for IE8/9 support with catch function
promise['catch'](mxUtils.bind(this, function(err)
{
window.clearTimeout(timeoutThread);
if (acceptResponse)
{
if (err != null && err.status === 401 && !failOnAuth)
{
this.setUser(null);
this.client.setAccessToken(null);
this.authenticate(mxUtils.bind(this, function()
{
this.updateUser(success, error, true);
}), error);
}
else
{
error({message: mxResources.get('accessDenied')});
}
}
}));
};
/**
* Authorizes the client, gets the userId and calls <open>.
*/
DropboxClient.prototype.authenticate = function(success, error)
{
if (window.onDropboxCallback == null)
{
var auth = mxUtils.bind(this, function()
{
var acceptAuthResponse = true;
this.ui.showAuthDialog(this, true, mxUtils.bind(this, function(remember, authSuccess)
{
var win = window.open(this.client.getAuthenticationUrl('https://' +
window.location.host + '/dropbox.html'), 'dbauth');
if (win != null)
{
window.onDropboxCallback = mxUtils.bind(this, function(token, authWindow)
{
if (acceptAuthResponse)
{
window.onDropboxCallback = null;
acceptAuthResponse = false;
try
{
if (token == null)
{
error({message: mxResources.get('accessDenied'), retry: auth});
}
else
{
if (authSuccess != null)
{
authSuccess();
}
this.client.setAccessToken(token);
this.setUser(null);
if (remember)
{
this.setPersistentToken(token);
}
success();
}
}
catch (e)
{
error(e);
}
finally
{
if (authWindow != null)
{
authWindow.close();
}
}
}
else if (authWindow != null)
{
authWindow.close();
}
});
}
else
{
error({message: mxResources.get('serviceUnavailableOrBlocked'), retry: auth});
}
}), mxUtils.bind(this, function()
{
if (acceptAuthResponse)
{
window.onDropboxCallback = null;
acceptAuthResponse = false;
error({message: mxResources.get('accessDenied'), retry: auth});
}
}));
});
auth();
}
else
{
error({code: App.ERROR_BUSY});
}
};
/**
* Authorizes the client, gets the userId and calls <open>.
*/
DropboxClient.prototype.executePromise = function(promise, success, error)
{
var doExecute = mxUtils.bind(this, function(failOnAuth)
{
var acceptResponse = true;
var timeoutThread = window.setTimeout(mxUtils.bind(this, function()
{
acceptResponse = false;
error({code: App.ERROR_TIMEOUT, retry: fn});
}), this.ui.timeout);
promise.then(mxUtils.bind(this, function(response)
{
window.clearTimeout(timeoutThread);
if (acceptResponse && success != null)
{
success(response);
}
}));
// Workaround for IE8/9 support with catch function
promise['catch'](mxUtils.bind(this, function(err)
{
window.clearTimeout(timeoutThread);
if (acceptResponse)
{
if (err != null && (err.status == 500 || err.status == 400 ||
err.status == 401))
{
this.setUser(null);
this.client.setAccessToken(null);
if (!failOnAuth)
{
this.authenticate(function()
{
doExecute(true);
}, error);
}
else
{
error({message: mxResources.get('accessDenied'), retry: mxUtils.bind(this, function()
{
this.authenticate(function()
{
fn(true);
}, error);
})});
}
}
else
{
error({message: mxResources.get('error') + ' ' + err.status});
}
}
}));
});
var fn = mxUtils.bind(this, function(failOnAuth)
{
if (this.user == null)
{
this.updateUser(function()
{
fn(true);
}, error, failOnAuth);
}
else
{
doExecute(failOnAuth);
}
});
if (this.client.getAccessToken() === null)
{
this.authenticate(function()
{
fn(true);
}, error);
}
else
{
fn(false);
}
};
/**
* Checks if the client is authorized and calls the next step.
*/
DropboxClient.prototype.getLibrary = function(path, success, error)
{
this.getFile(path, success, error, true);
};
/**
* DenyConvert is ignored in this client, just added for API compatibility.
*/
DropboxClient.prototype.getFile = function(path, success, error, asLibrary)
{
asLibrary = (asLibrary != null) ? asLibrary : false;
if (/^https:\/\//i.test(path) || /\.vsdx$/i.test(path) || /\.gliffy$/i.test(path) || /\.png$/i.test(path))
{
// Should never be null
if (this.token != null)
{
var tokens = path.split('/');
var name = (tokens.length > 0) ? tokens[tokens.length - 1] : path;
this.ui.convertFile(path, name, null, this.extension, success, error);
}
else
{
error({message: mxResources.get('accessDenied')});
}
}
else
{
var arg = {path: '/' + path};
if (urlParams['rev'] != null)
{
arg.rev = urlParams['rev'];
}
this.readFile(arg, mxUtils.bind(this, function(data, response)
{
success((asLibrary) ? new DropboxLibrary(this.ui, data, response) :
new DropboxFile(this.ui, data, response));
}), error);
}
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.readFile = function(arg, success, error)
{
var doExecute = mxUtils.bind(this, function(failOnAuth)
{
var acceptResponse = true;
var timeoutThread = window.setTimeout(mxUtils.bind(this, function()
{
acceptResponse = false;
error({code: App.ERROR_TIMEOUT});
}), this.ui.timeout);
// Workaround for Uncaught DOMException in filesDownload is to
// get the metadata to handle the file not found case
var checkPromise = this.client.filesGetMetadata({path: '/' + arg.path.substring(1), include_deleted: false});
checkPromise.then(mxUtils.bind(this, function(response)
{
// ignore
}));
// Workaround for IE8/9 support with catch function
checkPromise['catch'](function(err)
{
window.clearTimeout(timeoutThread);
if (acceptResponse && err != null && err.status == 409)
{
acceptResponse = false;
error({message: mxResources.get('fileNotFound')});
}
});
// Download file in parallel
// LATER: Report Uncaught DOMException with path/not_found in filesDownload
var promise = this.client.filesDownload(arg);
promise.then(mxUtils.bind(this, function(response)
{
window.clearTimeout(timeoutThread);
if (acceptResponse)
{
acceptResponse = false;
try
{
var reader = new FileReader();
reader.onload = mxUtils.bind(this, function(event)
{
success(reader.result, response);
});
reader.readAsText(response.fileBlob);
}
catch (e)
{
error(e);
}
}
}));
// Workaround for IE8/9 support with catch function
promise['catch'](mxUtils.bind(this, function(err)
{
window.clearTimeout(timeoutThread);
if (acceptResponse)
{
acceptResponse = false;
if (err != null && (err.status == 500 || err.status == 400 ||
err.status == 401))
{
this.client.setAccessToken(null);
this.setUser(null);
if (!failOnAuth)
{
this.authenticate(function()
{
doExecute(true);
}, error);
}
else
{
error({message: mxResources.get('accessDenied'), retry: mxUtils.bind(this, function()
{
this.authenticate(function()
{
fn(true);
}, error);
})});
}
}
else
{
error({message: mxResources.get('error') + ' ' + err.status});
}
}
}));
});
var fn = mxUtils.bind(this, function(failOnAuth)
{
if (this.user == null)
{
this.updateUser(function()
{
fn(true);
}, error, failOnAuth);
}
else
{
doExecute(failOnAuth);
}
});
if (this.client.getAccessToken() === null)
{
this.authenticate(function()
{
fn(true);
}, error);
}
else
{
fn(false);
}
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.checkExists = function(filename, fn, noConfirm)
{
var promise = this.client.filesGetMetadata({path: '/' + filename.toLowerCase(), include_deleted: false});
this.executePromise(promise, mxUtils.bind(this, function(response)
{
if (noConfirm)
{
fn(false, true, response);
}
else
{
this.ui.confirm(mxResources.get('replaceIt', [filename]), function()
{
fn(true, true, response);
}, function()
{
fn(false, true, response);
});
}
}), function(err)
{
fn(true, false);
});
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.renameFile = function(file, filename, success, error)
{
if (/[\\\/:\?\*"\|]/.test(filename))
{
error({message: mxResources.get('dropboxCharsNotAllowed')});
}
else
{
// Appends working directory of source file
if (file != null && filename != null)
{
var path = file.stat.path_display.substring(1);
var idx = path.lastIndexOf('/');
if (idx > 0)
{
filename = path.substring(0, idx + 1) + filename;
}
}
if (file != null && filename != null && file.stat.path_lower.substring(1) !== filename.toLowerCase())
{
// Checks if file exists
this.checkExists(filename, mxUtils.bind(this, function(checked, exists, response)
{
if (checked)
{
var thenHandler = mxUtils.bind(this, function(deleteResponse)
{
var move = this.client.filesMove({from_path: file.stat.path_display, to_path: '/' +
filename, autorename: false});
this.executePromise(move, success, error);
});
// API fails on same name with different upper-/lowercase
if (!exists || response.path_lower.substring(1) === filename.toLowerCase())
{
thenHandler();
}
else
{
// Deletes file first to avoid conflict in filesMove (non-atomic)
var promise = this.client.filesDelete({path: '/' + filename.toLowerCase()});
this.executePromise(promise, thenHandler, error);
}
}
else
{
error();
}
}));
}
else
{
// Same name with different upper-/lowercase not supported by Dropbox API
error({message: mxResources.get('invalidName')});
}
}
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.insertLibrary = function(filename, data, success, error)
{
this.insertFile(filename, data, success, error, true);
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.insertFile = function(filename, data, success, error, asLibrary)
{
asLibrary = (asLibrary != null) ? asLibrary : false;
this.checkExists(filename, mxUtils.bind(this, function(checked)
{
if (checked)
{
this.saveFile(filename, data, mxUtils.bind(this, function(stat)
{
if (asLibrary)
{
success(new DropboxLibrary(this.ui, data, stat));
}
else
{
success(new DropboxFile(this.ui, data, stat));
}
}), error);
}
else
{
error();
}
}));
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.saveFile = function(filename, data, success, error)
{
if (/[\\\/:\?\*"\|]/.test(filename))
{
error({message: mxResources.get('dropboxCharsNotAllowed')});
}
else if (data.length >= 150000000 /*150MB*/)
{
error({message: mxResources.get('drawingTooLarge') + ' (' +
this.ui.formatFileSize(data.length) + ' / 150 MB)'});
}
else
{
var promise = this.client.filesUpload({path: '/' + filename, mode: {'.tag': 'overwrite'},
contents: new Blob([data], {type: 'text/plain'})});
this.executePromise(promise, success, error);
}
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.pickLibrary = function(fn)
{
// Authentication will be carried out on open to make sure the
// autosave does not show an auth dialog. Showing it here will
// block the second dialog (the file picker) so it's too early.
Dropbox.choose(
{
linkType : 'direct',
cancel: mxUtils.bind(this, function()
{
// do nothing
}),
success : mxUtils.bind(this, function(files)
{
if (this.ui.spinner.spin(document.body, mxResources.get('loading')))
{
var error = mxUtils.bind(this, function(e)
{
this.ui.spinner.stop();
this.ui.handleError(e);
});
var tmp = files[0].link.indexOf(this.appPath);
if (tmp > 0)
{
// Checks if file is in app folder by loading file from there and comparing relative path and size
// KNOWN: This check fails if a file is inside a drawio directory with same relative path and size
var rel = decodeURIComponent(files[0].link.substring(tmp + this.appPath.length - 1));
this.readFile({path: rel}, mxUtils.bind(this, function(data, stat)
{
if (stat != null && parseInt(files[0].bytes) === parseInt(stat.size) && rel === stat.path_display)
{
// No need to load file a second time
try
{
this.ui.spinner.stop();
fn(rel.substring(1), new DropboxLibrary(this.ui, data, stat));
}
catch (e)
{
this.ui.handleError(e);
}
}
else
{
this.createLibrary(files[0], fn, error);
}
}), error);
}
else
{
this.createLibrary(files[0], fn, error);
}
}
})
});
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.createLibrary = function(file, success, error)
{
this.ui.confirm(mxResources.get('note') + ': ' + mxResources.get('fileWillBeSavedInAppFolder', [file.name]), mxUtils.bind(this, function()
{
this.ui.loadUrl(file.link, mxUtils.bind(this, function(data)
{
this.insertFile(file.name, data, mxUtils.bind(this, function(newFile)
{
try
{
this.ui.spinner.stop();
success(newFile.getHash().substring(1), newFile);
}
catch (e)
{
error(e);
}
}), error, true);
}), error);
}), mxUtils.bind(this, function()
{
this.ui.spinner.stop();
}));
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.pickFile = function(fn, readOnly)
{
if (Dropbox.choose != null)
{
fn = (fn != null) ? fn : mxUtils.bind(this, function(path, file)
{
this.ui.loadFile((path != null) ? 'D' + encodeURIComponent(path) : file.getHash(), null, file);
});
// Authentication will be carried out on open to make sure the
// autosave does not show an auth dialog. Showing it here will
// block the second dialog (the file picker) so it's too early.
Dropbox.choose(
{
linkType : 'direct',
cancel: mxUtils.bind(this, function()
{
// do nothing
}),
success : mxUtils.bind(this, function(files)
{
if (this.ui.spinner.spin(document.body, mxResources.get('loading')))
{
// File used for read-only
if (readOnly)
{
this.ui.spinner.stop();
fn(files[0].link);
}
else
{
var error = mxUtils.bind(this, function(e)
{
this.ui.spinner.stop();
this.ui.handleError(e);
});
var success = mxUtils.bind(this, function(path, file)
{
this.ui.spinner.stop();
fn(path, file);
});
if ((/\.vsdx$/i.test(files[0].name) || /\.gliffy$/i.test(files[0].name) ||
/\.png$/i.test(files[0].name)))
{
success(files[0].link);
}
else
{
var tmp = files[0].link.indexOf(this.appPath);
if (tmp > 0)
{
// Checks if file is in app folder by loading file from there and comparing relative path and size
// KNOWN: This check fails if a file is inside a drawio directory with same relative path and size
var rel = decodeURIComponent(files[0].link.substring(tmp + this.appPath.length - 1));
this.readFile({path: rel}, mxUtils.bind(this, function(data, stat)
{
if (stat != null && parseInt(files[0].bytes) === parseInt(stat.size) && rel === stat.path_display)
{
this.ui.spinner.stop();
// No need to load file a second time
fn(rel.substring(1), new DropboxFile(this.ui, data, stat));
}
else
{
this.createFile(files[0], success, error);
}
}), error);
}
else
{
this.createFile(files[0], success, error);
}
}
}
}
})
});
}
else
{
this.ui.handleError({message: mxResources.get('serviceUnavailableOrBlocked')});
}
};
/**
* Translates this point by the given vector.
*
* @param {number} dx X-coordinate of the translation.
* @param {number} dy Y-coordinate of the translation.
*/
DropboxClient.prototype.createFile = function(file, success, error)
{
this.ui.loadUrl(file.link, mxUtils.bind(this, function(data)
{
if (data != null && data.length > 0)
{
this.ui.confirm(mxResources.get('note') + ': ' + mxResources.get('fileWillBeSavedInAppFolder', [file.name]), mxUtils.bind(this, function()
{
this.insertFile(file.name, data, mxUtils.bind(this, function(newFile)
{
success(file.name, newFile);
}), error);
}), mxUtils.bind(this, function()
{
this.ui.spinner.stop();
}));
}
else
{
this.ui.spinner.stop();
error({message: mxResources.get('errorLoadingFile')});
}
}), error, /(\.png)$/i.test(file.name));
};