2016-03-13 17:08:25 +01:00
|
|
|
'use strict';
|
|
|
|
|
2016-03-27 14:57:22 +02:00
|
|
|
var StorageBase = require('./storage-base');
|
2016-03-13 17:08:25 +01:00
|
|
|
|
2016-03-27 14:57:22 +02:00
|
|
|
var GDriveClientId = '847548101761-koqkji474gp3i2gn3k5omipbfju7pbt1.apps.googleusercontent.com';
|
2016-03-27 11:08:54 +02:00
|
|
|
|
2016-03-27 09:06:23 +02:00
|
|
|
var StorageGDrive = StorageBase.extend({
|
2016-03-13 17:08:25 +01:00
|
|
|
name: 'gdrive',
|
2016-03-26 23:04:34 +01:00
|
|
|
enabled: true,
|
2016-03-13 17:08:25 +01:00
|
|
|
uipos: 30,
|
|
|
|
iconSvg: '<svg xmlns:svg="http://www.w3.org/2000/svg" xmlns="http://www.w3.org/2000/svg" width="128" height="128" viewBox="0 0 128 128" version="1.1">' +
|
|
|
|
'<path d="M120.76421 71.989219 84.87226 9.6679848l-41.828196 0 35.899791 62.3212342zM58.014073 56.294956 37.107816 19.986746 1.2237094 82.284404 ' +
|
|
|
|
'22.137808 118.59261Zm-21.415974 63.012814 69.180421 0 20.9141-39.459631-67.635587 0z"/></svg>',
|
|
|
|
|
2016-03-27 14:57:22 +02:00
|
|
|
_baseUrl: 'https://www.googleapis.com/drive/v3',
|
2016-03-27 11:08:54 +02:00
|
|
|
|
2016-03-13 17:08:25 +01:00
|
|
|
load: function(path, opts, callback) {
|
2016-03-26 21:12:56 +01:00
|
|
|
var that = this;
|
|
|
|
that.stat(path, opts, function(err, stat) {
|
|
|
|
if (err) { return callback && callback(err); }
|
2016-03-27 09:06:23 +02:00
|
|
|
that.logger.debug('Load', path);
|
|
|
|
var ts = that.logger.ts();
|
2016-03-27 14:57:22 +02:00
|
|
|
var url = that._baseUrl + '/files/{id}/revisions/{rev}?alt=media'
|
2016-03-26 21:12:56 +01:00
|
|
|
.replace('{id}', path)
|
|
|
|
.replace('{rev}', stat.rev);
|
2016-03-27 09:42:48 +02:00
|
|
|
that._xhr({
|
|
|
|
url: url,
|
|
|
|
responseType: 'arraybuffer',
|
|
|
|
success: function(response) {
|
|
|
|
that.logger.debug('Loaded', path, stat.rev, that.logger.ts(ts));
|
|
|
|
return callback && callback(null, response, { rev: stat.rev });
|
|
|
|
},
|
|
|
|
error: function(err) {
|
|
|
|
that.logger.debug('Load error', path, err, that.logger.ts(ts));
|
|
|
|
return callback && callback(err);
|
2016-03-26 21:12:56 +01:00
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
2016-03-13 17:08:25 +01:00
|
|
|
},
|
|
|
|
|
|
|
|
stat: function(path, opts, callback) {
|
2016-03-26 21:12:56 +01:00
|
|
|
var that = this;
|
2016-03-27 15:18:05 +02:00
|
|
|
this._oauthAuthorize(function(err) {
|
2016-03-26 21:12:56 +01:00
|
|
|
if (err) {
|
|
|
|
return callback && callback(err);
|
|
|
|
}
|
2016-03-27 09:06:23 +02:00
|
|
|
that.logger.debug('Stat', path);
|
|
|
|
var ts = that.logger.ts();
|
2016-03-27 14:57:22 +02:00
|
|
|
var url = that._baseUrl + '/files/{id}?fields=headRevisionId'
|
2016-03-27 09:42:48 +02:00
|
|
|
.replace('{id}', path);
|
|
|
|
that._xhr({
|
|
|
|
url: url,
|
|
|
|
responseType: 'json',
|
|
|
|
success: function(response) {
|
|
|
|
var rev = response.headRevisionId;
|
|
|
|
that.logger.debug('Stated', path, rev, that.logger.ts(ts));
|
|
|
|
return callback && callback(null, { rev: rev });
|
|
|
|
},
|
|
|
|
error: function(err) {
|
2016-03-27 09:46:43 +02:00
|
|
|
that.logger.error('Stat error', that.logger.ts(ts), err);
|
2016-03-27 09:42:48 +02:00
|
|
|
return callback && callback(err);
|
|
|
|
}
|
2016-03-26 21:12:56 +01:00
|
|
|
});
|
|
|
|
});
|
|
|
|
},
|
|
|
|
|
|
|
|
save: function(path, opts, data, callback, rev) {
|
|
|
|
var that = this;
|
|
|
|
that.stat(path, opts, function(err, stat) {
|
|
|
|
if (rev) {
|
|
|
|
if (err) { return callback && callback(err); }
|
|
|
|
if (stat.rev !== rev) {
|
|
|
|
return callback && callback({revConflict: true}, stat);
|
|
|
|
}
|
|
|
|
}
|
2016-03-27 09:06:23 +02:00
|
|
|
that.logger.debug('Save', path);
|
|
|
|
var ts = that.logger.ts();
|
2016-03-26 21:12:56 +01:00
|
|
|
var url = 'https://www.googleapis.com/upload/drive/v3/files/{id}?uploadType=media&fields=headRevisionId'
|
|
|
|
.replace('{id}', path)
|
|
|
|
.replace('{rev}', stat.rev);
|
2016-03-27 09:42:48 +02:00
|
|
|
that._xhr({
|
|
|
|
url: url,
|
|
|
|
method: 'PATCH',
|
|
|
|
responseType: 'json',
|
|
|
|
data: new Blob([data], {type: 'application/octet-stream'}),
|
|
|
|
success: function(response) {
|
|
|
|
that.logger.debug('Saved', path, that.logger.ts(ts));
|
|
|
|
var newRev = response.headRevisionId;
|
|
|
|
if (!newRev) {
|
|
|
|
return callback && callback('save error: no rev');
|
|
|
|
}
|
|
|
|
return callback && callback(null, { rev: newRev });
|
|
|
|
},
|
|
|
|
error: function(err) {
|
|
|
|
that.logger.debug('Save error', path, err, that.logger.ts(ts));
|
|
|
|
return callback && callback(err);
|
2016-03-26 21:12:56 +01:00
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
},
|
|
|
|
|
|
|
|
list: function(callback) {
|
|
|
|
var that = this;
|
2016-03-27 15:18:05 +02:00
|
|
|
this._oauthAuthorize(function(err) {
|
2016-03-26 21:12:56 +01:00
|
|
|
if (err) { return callback && callback(err); }
|
2016-03-27 09:06:23 +02:00
|
|
|
that.logger.debug('List');
|
2016-03-27 14:57:22 +02:00
|
|
|
var url = that._baseUrl + '/files?fields={fields}&q={q}'
|
2016-03-27 09:42:48 +02:00
|
|
|
.replace('{fields}', encodeURIComponent('files'))
|
|
|
|
.replace('{q}', encodeURIComponent('fileExtension="kdbx" and mimeType="application/octet-stream" and trashed=false'));
|
2016-03-27 09:06:23 +02:00
|
|
|
var ts = that.logger.ts();
|
2016-03-27 09:42:48 +02:00
|
|
|
that._xhr({
|
|
|
|
url: url,
|
|
|
|
responseType: 'json',
|
|
|
|
success: function(response) {
|
|
|
|
if (!response) {
|
2016-03-27 13:54:35 +02:00
|
|
|
that.logger.error('List error', that.logger.ts(ts));
|
2016-03-27 09:42:48 +02:00
|
|
|
return callback && callback('list error');
|
|
|
|
}
|
2016-03-27 13:54:35 +02:00
|
|
|
that.logger.debug('Listed', that.logger.ts(ts));
|
2016-03-27 09:42:48 +02:00
|
|
|
var fileList = response.files.map(function(f) {
|
|
|
|
return {
|
|
|
|
name: f.name,
|
|
|
|
path: f.id,
|
|
|
|
rev: f.headRevisionId
|
|
|
|
};
|
|
|
|
});
|
|
|
|
return callback && callback(null, fileList);
|
|
|
|
},
|
|
|
|
error: function(err) {
|
|
|
|
that.logger.error('List error', that.logger.ts(ts), err);
|
|
|
|
return callback && callback(err);
|
2016-03-26 21:12:56 +01:00
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
},
|
|
|
|
|
2016-03-27 15:18:05 +02:00
|
|
|
_getOAuthConfig: function() {
|
2016-03-27 14:57:22 +02:00
|
|
|
var clientId = this.appSettings.get('gdriveClientId') || GDriveClientId;
|
|
|
|
var url = 'https://accounts.google.com/o/oauth2/v2/auth' +
|
|
|
|
'?client_id={cid}&scope={scope}&response_type=token&redirect_uri={url}'
|
|
|
|
.replace('{cid}', clientId)
|
|
|
|
.replace('{scope}', encodeURIComponent('https://www.googleapis.com/auth/drive'))
|
|
|
|
.replace('{url}', encodeURIComponent(window.location));
|
2016-03-27 15:18:05 +02:00
|
|
|
return {
|
2016-03-27 14:57:22 +02:00
|
|
|
url: url,
|
|
|
|
width: 600,
|
|
|
|
height: 400
|
2016-03-27 15:18:05 +02:00
|
|
|
};
|
2016-03-13 17:08:25 +01:00
|
|
|
}
|
2016-03-27 09:06:23 +02:00
|
|
|
});
|
2016-03-13 17:08:25 +01:00
|
|
|
|
2016-03-27 09:46:43 +02:00
|
|
|
module.exports = new StorageGDrive();
|