1
0
mirror of https://github.com/laurent22/joplin.git synced 2024-12-03 08:35:29 +02:00
joplin/packages/lib/onedrive-api.ts

435 lines
15 KiB
TypeScript
Raw Normal View History

import shim from './shim';
import time from './time';
import Logger from './Logger';
import { _ } from './locale';
const { stringify } = require('query-string');
2020-11-05 18:58:23 +02:00
const urlUtils = require('./urlUtils.js');
const Buffer = require('buffer').Buffer;
2017-06-22 21:44:38 +02:00
const logger = Logger.create('OneDriveApi');
export default class OneDriveApi {
private clientId_: string;
private clientSecret_: string;
private auth_: any = null;
private accountProperties_: any = null;
private isPublic_: boolean;
private listeners_: Record<string, any>;
// `isPublic` is to tell OneDrive whether the application is a "public" one (Mobile and desktop
// apps are considered "public"), in which case the secret should not be sent to the API.
// In practice the React Native app is public, and the Node one is not because we
// use a local server for the OAuth dance.
constructor(clientId: string, clientSecret: string, isPublic: boolean) {
2017-06-22 21:44:38 +02:00
this.clientId_ = clientId;
this.clientSecret_ = clientSecret;
2017-06-22 23:52:27 +02:00
this.auth_ = null;
this.accountProperties_ = null;
this.isPublic_ = isPublic;
this.listeners_ = {
2019-07-29 15:43:53 +02:00
authRefreshed: [],
};
}
isPublic() {
return this.isPublic_;
}
dispatch(eventName: string, param: any) {
const ls = this.listeners_[eventName];
for (let i = 0; i < ls.length; i++) {
ls[i](param);
}
}
on(eventName: string, callback: Function) {
this.listeners_[eventName].push(callback);
2017-06-22 21:44:38 +02:00
}
2017-06-22 23:52:27 +02:00
tokenBaseUrl() {
return 'https://login.microsoftonline.com/common/oauth2/v2.0/token';
}
nativeClientRedirectUrl() {
return 'https://login.microsoftonline.com/common/oauth2/nativeclient';
}
auth(): any {
return this.auth_;
}
setAuth(auth: any) {
2017-06-22 23:52:27 +02:00
this.auth_ = auth;
this.dispatch('authRefreshed', this.auth());
2017-06-22 23:52:27 +02:00
}
token() {
return this.auth_ ? this.auth_.access_token : null;
2017-06-22 21:44:38 +02:00
}
clientId() {
return this.clientId_;
}
clientSecret() {
return this.clientSecret_;
}
2017-06-22 23:52:27 +02:00
async appDirectory() {
const driveId = this.accountProperties_.driveId;
const r = await this.execJson('GET', `/me/drives/${driveId}/special/approot`);
2019-09-19 23:51:18 +02:00
return `${r.parentReference.path}/${r.name}`;
2017-06-22 23:52:27 +02:00
}
authCodeUrl(redirectUri: string) {
const query = {
2017-06-22 21:44:38 +02:00
client_id: this.clientId_,
scope: 'files.readwrite offline_access sites.readwrite.all',
2017-06-22 21:44:38 +02:00
response_type: 'code',
redirect_uri: redirectUri,
};
2019-09-19 23:51:18 +02:00
return `https://login.microsoftonline.com/common/oauth2/v2.0/authorize?${stringify(query)}`;
2017-06-22 21:44:38 +02:00
}
async execTokenRequest(code: string, redirectUri: string) {
const body: any = {};
2020-10-28 17:50:34 +02:00
body['client_id'] = this.clientId();
if (!this.isPublic()) body['client_secret'] = this.clientSecret();
body['code'] = code;
body['redirect_uri'] = redirectUri;
body['grant_type'] = 'authorization_code';
2017-07-06 21:29:09 +02:00
const r = await shim.fetch(this.tokenBaseUrl(), {
method: 'POST',
2020-10-28 17:50:34 +02:00
body: urlUtils.objectToQueryString(body),
Mobile: Upgraded React Native to v0.63 commit 2fb6cee90174bfcc02f77ba1606bfd8c4e2c8fc8 Merge: 4e303be85f db509955f6 Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 16:24:07 2020 +0100 Merge branch 'dev' into rn_63 commit 4e303be85f7b3162b7e5b96e18557da13acfc988 Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 16:14:39 2020 +0100 Clean up commit e3a37ec2d6f3e6cc07c018b11b3f80ca8256063e Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 15:57:55 2020 +0100 Use different script for pre-commit and manual start commit bd236648fcd92a812cd16369dfa2238d38c6638f Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 15:56:45 2020 +0100 Removed RN eslint config commit e7feda41c9b473cd18768f2ce7686611fa2b3d08 Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 15:27:08 2020 +0100 Revert "Disable git hook for now" This reverts commit 89263ac7425bae5b03b60742ab186441217b37dc. commit cfd63fe46fbc714c065f13dd9add5a0b8e18bf1f Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 13:02:32 2020 +0100 Ask permission to use geo-location commit 66059939a38460ba05c09eed7f3b19fc4ead924c Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 12:26:20 2020 +0100 Fixed WebView race condition commit 1e0d2b7b86d88629f19ae6574f73c945d422d0b5 Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 11:56:21 2020 +0100 Fixed webview issues commit f537d22d7fc4bcf6ddb54a4faadf72f585ae271c Author: Laurent Cozic <laurent@cozic.net> Date: Fri Oct 16 11:08:29 2020 +0100 Improve resource file watching commit eec32cf70aaf69b04a703ce49c3ede48a6ac1067 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 18:40:13 2020 +0100 Removed cache package dependency and implemented one more suitable for React Native commit efa346fea48414c98c1e577bf0d74a6e90a78044 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 14:57:21 2020 +0100 iOS: Added fonts to Info.plist although it was working without it commit 572b647bc0ff5b12ddd555ad7ca2bb18ccaeb512 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 14:56:49 2020 +0100 Specify content-type header for OneDrive to prevent network error commit bcedf6c7f0c35a428fd1c0800d4f17de662a49ff Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 12:45:01 2020 +0100 iOS: Disable long press menu since it is already built-in commit 7359dd61d1a609dbfce87b0deb169b8c5e2ace14 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 12:37:40 2020 +0100 Removed unused react-native-device-info commit 2d63ab36d32775f07236dae62f6cc7792dac435a Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 12:35:54 2020 +0100 iOS: Fixed taking a picture commit 8e2875a91c87b48ba3e230e9296d032cd05a267c Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 12:11:13 2020 +0100 iOS: Restored camera roll functionality commit 75f5edf2addfe3590d1a37bdac99680cb1a5c84c Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 11:40:13 2020 +0100 iOS: Fixed build settings commit b220c984198e78a2401387f4385bfdd331852d78 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 11:40:03 2020 +0100 iOS: Got images to work with WebKit commit c34b43e841b768104f19e86900133a1986b53af9 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 10:24:52 2020 +0100 iOS: Restore more settings commit 32997611e625f1775df05af966782ae763c1aa17 Author: Laurent Cozic <laurent@cozic.net> Date: Thu Oct 15 10:15:14 2020 +0100 iOS: Added back icons and other properties commit b5811d7f7cff227a30bb10ecad76f52cb212170a Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 23:53:14 2020 +0100 Got iOS build to work commit dc6d7c00e0048088cca653d5214d1cc4679ca005 Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 18:40:06 2020 +0100 Imported old settings in gradle build commit dff59f560317d260b8540a9324bcdd5e749a0c0b Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 18:20:00 2020 +0100 Restored sharing commit 0bdb449e72ef1766bd5aac878f44106c36e662c2 Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 17:25:40 2020 +0100 Updated NoteBodyViewer commit 0c0d228815251cfaf66ba25a276852d32192f106 Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 16:54:42 2020 +0100 Fixed networking commit 6ff45ce485d59e3e0fe66a9658a678499c887058 Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 13:11:00 2020 +0100 Fixed document picker commit cc889182b66052b8dfad03b46121e6a14763a51a Author: Laurent Cozic <laurent@cozic.net> Date: Wed Oct 14 12:56:27 2020 +0100 Added back support for alarms commit 040261abfad89e5a58617d4c2d4f811d324ea488 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 22:04:49 2020 +0100 Fixed Clipboard and remove image-picker package commit 1077ad8f16481afcc63d92020e91cd37f077f207 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 21:54:52 2020 +0100 Fixed Select Alarm dialog and PoorManIntervals class commit 8296676fd52878b2f1cc2028a099f31909e6f286 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 21:32:52 2020 +0100 Fixed icons and warnings commit 3b0e3f6f43c83bb103132e8296d3887fccd386b5 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 17:02:59 2020 +0100 Got app to build again commit 89263ac7425bae5b03b60742ab186441217b37dc Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 15:41:17 2020 +0100 Disable git hook for now commit d6da162f674f94ba2c462268e39c161fa6126220 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 15:39:12 2020 +0100 Restored back all RN packages commit 7f8ce3732cf4c8ff6dcbcc0a8918c680adadd3f4 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 15:13:12 2020 +0100 Restored base packages commit ea59726eb3e0414afcdbe8af30a7765875239225 Author: Laurent Cozic <laurent@cozic.net> Date: Tue Oct 13 15:05:17 2020 +0100 Started over from scratch
2020-10-16 17:26:19 +02:00
headers: {
['Content-Type']: 'application/x-www-form-urlencoded',
},
2019-07-29 15:43:53 +02:00
});
2017-07-06 21:29:09 +02:00
if (!r.ok) {
const text = await r.text();
2019-09-19 23:51:18 +02:00
throw new Error(`Could not retrieve auth code: ${r.status}: ${r.statusText}: ${text}`);
2017-07-06 21:29:09 +02:00
}
try {
const json = await r.json();
this.setAuth(json);
} catch (error) {
this.setAuth(null);
2017-07-06 21:29:09 +02:00
const text = await r.text();
2019-09-19 23:51:18 +02:00
error.message += `: ${text}`;
2017-07-06 21:29:09 +02:00
throw error;
}
}
oneDriveErrorResponseToError(errorResponse: any) {
2017-06-29 20:03:16 +02:00
if (!errorResponse) return new Error('Undefined error');
if (errorResponse.error) {
const e = errorResponse.error;
const output: any = new Error(e.message);
2017-06-29 20:03:16 +02:00
if (e.code) output.code = e.code;
if (e.innerError) output.innerError = e.innerError;
return output;
2019-07-29 15:43:53 +02:00
} else {
2017-06-29 20:03:16 +02:00
return new Error(JSON.stringify(errorResponse));
}
}
async uploadChunk(url: string, handle: any, buffer: any, options: any) {
options = Object.assign({}, options);
if (!options.method) { options.method = 'POST'; }
if (!options.contentLength) throw new Error('uploadChunk: contentLength is missing');
if (!options.headers) throw new Error('uploadChunk: header is missing');
if (buffer) {
options.body = buffer.slice(options.startByte, options.startByte + options.contentLength);
} else {
const chunk = await shim.fsDriver().readFileChunk(handle, options.contentLength);
const buffer = Buffer.from(chunk, 'base64');
options.body = buffer;
}
delete options.contentLength;
delete options.startByte;
const response = await shim.fetch(url,options);
return response;
}
async uploadBigFile(url: string, options: any) {
const response = await shim.fetch(url, {
method: 'POST',
headers: {
'Authorization': options.headers.Authorization,
'Content-Type': 'application/json',
},
});
if (!response.ok) {
return response;
} else {
const uploadUrl = (await response.json()).uploadUrl;
const chunkSize = 7.5 * 1024 * 1024;
let byteSize = null;
let handle = null;
let buffer = null;
if (options.body) {
byteSize = Buffer.byteLength(options.body);
buffer = Buffer.from(options.body);
} else {
byteSize = (await shim.fsDriver().stat(options.path)).size;
handle = await shim.fsDriver().open(options.path, 'r');
}
const numberOfChunks = Math.ceil(byteSize / chunkSize);
try {
for (let i = 0; i < numberOfChunks; i++) {
const startByte = i * chunkSize;
let endByte = null;
let contentLength = null;
if (i === numberOfChunks - 1) {
// Last fragment. It is not ensured that the last fragment is a multiple of 327,680 bytes as recommanded in the api doc. The reasons is that the docs are out of day for this purpose: https://github.com/OneDrive/onedrive-api-docs/issues/1200#issuecomment-597281253
endByte = byteSize - 1;
contentLength = byteSize - ((numberOfChunks - 1) * chunkSize);
} else {
endByte = (i + 1) * chunkSize - 1;
contentLength = chunkSize;
}
logger.debug(`Uploading File Fragment ${(startByte / 1048576).toFixed(2)} - ${(endByte / 1048576).toFixed(2)} from ${(byteSize / 1048576).toFixed(2)} Mbit ...`);
const headers = {
'Content-Length': contentLength,
'Content-Range': `bytes ${startByte}-${endByte}/${byteSize}`,
'Content-Type': 'application/octet-stream; charset=utf-8',
};
const response = await this.uploadChunk(uploadUrl, handle, buffer, { startByte: startByte, contentLength: contentLength, method: 'PUT', headers: headers });
if (!response.ok) {
return response;
}
}
return { ok: true };
} catch (error) {
const type = (handle) ? 'Resource' : 'Note Content';
logger.error(`Couldn't upload ${type} > 4 Mb. Got unhandled error:`, error ? error.code : '', error ? error.message : '', error);
throw error;
} finally {
if (handle) await shim.fsDriver().close(handle);
}
}
}
async exec(method: string, path: string, query: any = null, data: any = null, options: any = null) {
if (!path) throw new Error('Path is required');
2017-06-22 21:44:38 +02:00
method = method.toUpperCase();
if (!options) options = {};
if (!options.headers) options.headers = {};
2017-07-06 23:30:45 +02:00
if (!options.target) options.target = 'string';
2017-06-22 21:44:38 +02:00
if (method != 'GET') {
options.method = method;
}
2017-06-23 23:32:24 +02:00
if (method == 'PATCH' || method == 'POST') {
2017-06-22 21:44:38 +02:00
options.headers['Content-Type'] = 'application/json';
if (data) data = JSON.stringify(data);
}
2017-06-29 20:03:16 +02:00
let url = path;
2017-06-22 21:44:38 +02:00
2017-06-29 20:03:16 +02:00
// In general, `path` contains a path relative to the base URL, but in some
// cases the full URL is provided (for example, when it's a URL that was
// retrieved from the API).
if (url.indexOf('https://') !== 0) {
const slash = path.indexOf('/') === 0 ? '' : '/';
url = `https://graph.microsoft.com/v1.0${slash}${path}`;
}
2017-06-29 20:03:16 +02:00
if (query) {
url += url.indexOf('?') < 0 ? '?' : '&';
url += stringify(query);
}
2017-06-22 21:44:38 +02:00
if (data) options.body = data;
2017-10-15 13:13:09 +02:00
options.timeout = 1000 * 60 * 5; // in ms
for (let i = 0; i < 5; i++) {
2019-09-19 23:51:18 +02:00
options.headers['Authorization'] = `bearer ${this.token()}`;
options.headers['User-Agent'] = `ISV|Joplin|Joplin/${shim.appVersion()}`;
2017-06-22 23:52:27 +02:00
const handleRequestRepeat = async (error: any, sleepSeconds: number = null) => {
sleepSeconds ??= (i + 1) * 5;
logger.info(`Got error below - retrying (${i})...`);
logger.info(error);
await time.sleep(sleepSeconds);
};
2017-07-06 23:30:45 +02:00
let response = null;
2017-07-13 00:32:08 +02:00
try {
if (path.includes('/createUploadSession')) {
response = await this.uploadBigFile(url, options);
} else if (options.source == 'file' && (method == 'POST' || method == 'PUT')) {
response = await shim.uploadBlob(url, options);
2017-08-01 23:40:14 +02:00
} else if (options.target == 'string') {
2017-07-13 00:32:08 +02:00
response = await shim.fetch(url, options);
2019-07-29 15:43:53 +02:00
} else {
// file
2017-07-13 00:32:08 +02:00
response = await shim.fetchBlob(url, options);
}
} catch (error) {
if (shim.fetchRequestCanBeRetried(error)) {
await handleRequestRepeat(error);
continue;
} else {
logger.error('Got unhandled error:', error ? error.code : '', error ? error.message : '', error);
throw error;
}
2017-07-06 23:30:45 +02:00
}
2017-06-22 23:52:27 +02:00
if (!response.ok) {
const errorResponseText = await response.text();
2017-11-30 20:29:10 +02:00
let errorResponse = null;
2017-11-30 20:29:10 +02:00
try {
2019-10-09 21:35:13 +02:00
errorResponse = JSON.parse(errorResponseText); // await response.json();
2017-11-30 20:29:10 +02:00
} catch (error) {
2019-09-19 23:51:18 +02:00
error.message = `OneDriveApi::exec: Cannot parse JSON error: ${errorResponseText} ${error.message}`;
await handleRequestRepeat(error);
continue;
2017-11-30 20:29:10 +02:00
}
const error = this.oneDriveErrorResponseToError(errorResponse);
2017-06-22 23:52:27 +02:00
2017-07-08 00:25:03 +02:00
if (error.code == 'InvalidAuthenticationToken' || error.code == 'unauthenticated') {
logger.info('Token expired: refreshing...');
2017-06-22 23:52:27 +02:00
await this.refreshAccessToken();
continue;
} else if (error && ((error.error && error.error.code == 'generalException') || error.code == 'generalException' || error.code == 'EAGAIN')) {
2017-07-06 21:48:17 +02:00
// Rare error (one Google hit) - I guess the request can be repeated
// { error:
// { code: 'generalException',
// message: 'An error occurred in the data store.',
// innerError:
// { 'request-id': 'b4310552-c18a-45b1-bde1-68e2c2345eef',
// date: '2017-06-29T00:15:50' } } }
2017-07-06 21:48:17 +02:00
// { FetchError: request to https://graph.microsoft.com/v1.0/drive/root:/Apps/Joplin/.sync/7ee5dc04afcb414aa7c684bfc1edba8b.md_1499352102856 failed, reason: connect EAGAIN 65.52.64.250:443 - Local (0.0.0.0:54374)
// name: 'FetchError',
// message: 'request to https://graph.microsoft.com/v1.0/drive/root:/Apps/Joplin/.sync/7ee5dc04afcb414aa7c684bfc1edba8b.md_1499352102856 failed, reason: connect EAGAIN 65.52.64.250:443 - Local (0.0.0.0:54374)',
// type: 'system',
// errno: 'EAGAIN',
// code: 'EAGAIN' }
await handleRequestRepeat(error);
2017-12-05 01:01:22 +02:00
continue;
2017-12-31 16:23:05 +02:00
} else if (error && (error.code === 'resourceModified' || (error.error && error.error.code === 'resourceModified'))) {
2017-12-05 01:01:22 +02:00
// NOTE: not tested, very hard to reproduce and non-informative error message, but can be repeated
// Error: ETag does not match current item's value
// Code: resourceModified
// Header: {"_headers":{"cache-control":["private"],"transfer-encoding":["chunked"],"content-type":["application/json"],"request-id":["d...ea47"],"client-request-id":["d99...ea47"],"x-ms-ags-diagnostic":["{\"ServerInfo\":{\"DataCenter\":\"North Europe\",\"Slice\":\"SliceA\",\"Ring\":\"2\",\"ScaleUnit\":\"000\",\"Host\":\"AGSFE_IN_13\",\"ADSiteName\":\"DUB\"}}"],"duration":["96.9464"],"date":[],"connection":["close"]}}
// Request: PATCH https://graph.microsoft.com/v1.0/drive/root:/Apps/JoplinDev/f56c5601fee94b8085524513bf3e352f.md null "{\"fileSystemInfo\":{\"lastModifiedDateTime\":\"....\"}}" {"headers":{"Content-Type":"application/json","Authorization":"bearer ...
await handleRequestRepeat(error);
2017-07-06 21:48:17 +02:00
continue;
} else if (error?.code === 'activityLimitReached' && response?.headers?._headers['retry-after'][0] && !isNaN(Number(response?.headers?._headers['retry-after'][0]))) {
// Wait for OneDrive throttling
// Relavent Microsoft Docs: https://docs.microsoft.com/en-us/sharepoint/dev/general-development/how-to-avoid-getting-throttled-or-blocked-in-sharepoint-online#best-practices-to-handle-throttling
// Decrement retry count as multiple sync threads will cause repeated throttling errors - this will wait until throttling is resolved to continue, preventing a hard stop on the sync
i--;
const sleepSeconds = response.headers._headers['retry-after'][0];
logger.info(`OneDrive Throttle, sync thread sleeping for ${sleepSeconds} seconds...`);
await handleRequestRepeat(error, Number(sleepSeconds));
continue;
2017-07-11 01:17:03 +02:00
} else if (error.code == 'itemNotFound' && method == 'DELETE') {
// Deleting a non-existing item is ok - noop
return;
2017-06-22 23:52:27 +02:00
} else {
2019-09-19 23:51:18 +02:00
error.request = `${method} ${url} ${JSON.stringify(query)} ${JSON.stringify(data)} ${JSON.stringify(options)}`;
2017-10-26 23:57:49 +02:00
error.headers = await response.headers;
2017-06-22 23:52:27 +02:00
throw error;
}
}
2017-06-22 21:44:38 +02:00
2017-06-22 23:52:27 +02:00
return response;
}
2019-09-19 23:51:18 +02:00
throw new Error(`Could not execute request after multiple attempts: ${method} ${url}`);
2017-06-22 21:44:38 +02:00
}
setAccountProperties(accountProperties: any) {
this.accountProperties_ = accountProperties;
}
async execAccountPropertiesRequest() {
try {
const response = await this.exec('GET','https://graph.microsoft.com/v1.0/me/drive');
const data = await response.json();
const accountProperties = { accountType: data.driveType, driveId: data.id };
return accountProperties;
} catch (error) {
throw new Error(`Could not retrieve account details (drive ID, Account type. Error code: ${error.code}, Error message: ${error.message}`);
}
}
async execJson(method: string, path: string, query: any = null, data: any = null) {
const response = await this.exec(method, path, query, data);
const errorResponseText = await response.text();
2017-11-30 20:29:10 +02:00
try {
const output = JSON.parse(errorResponseText); // await response.json();
2017-11-30 20:29:10 +02:00
return output;
} catch (error) {
2019-09-19 23:51:18 +02:00
error.message = `OneDriveApi::execJson: Cannot parse JSON: ${errorResponseText} ${error.message}`;
2017-11-30 20:29:10 +02:00
throw error;
2019-10-09 21:35:13 +02:00
// throw new Error('Cannot parse JSON: ' + text);
2017-11-30 20:29:10 +02:00
}
2017-06-22 21:44:38 +02:00
}
async execText(method: string, path: string, query: any = null, data: any = null) {
const response = await this.exec(method, path, query, data);
const output = await response.text();
2017-06-22 21:44:38 +02:00
return output;
}
2017-06-22 23:52:27 +02:00
async refreshAccessToken() {
2017-07-26 23:07:27 +02:00
if (!this.auth_ || !this.auth_.refresh_token) {
this.setAuth(null);
2017-07-28 20:13:07 +02:00
throw new Error(_('Cannot refresh token: authentication data is missing. Starting the synchronisation again may fix the problem.'));
2017-07-26 23:07:27 +02:00
}
2017-06-22 23:52:27 +02:00
const body: any = {};
2020-10-28 17:50:34 +02:00
body['client_id'] = this.clientId();
if (!this.isPublic()) body['client_secret'] = this.clientSecret();
body['refresh_token'] = this.auth_.refresh_token;
body['redirect_uri'] = 'http://localhost:1917';
body['grant_type'] = 'refresh_token';
2017-06-22 23:52:27 +02:00
2020-10-28 17:50:34 +02:00
const response = await shim.fetch(this.tokenBaseUrl(), {
2017-06-22 23:52:27 +02:00
method: 'POST',
2020-10-28 17:50:34 +02:00
body: urlUtils.objectToQueryString(body),
headers: {
['Content-Type']: 'application/x-www-form-urlencoded',
},
});
2017-06-22 23:52:27 +02:00
if (!response.ok) {
this.setAuth(null);
const msg = await response.text();
2019-09-19 23:51:18 +02:00
throw new Error(`${msg}: TOKEN: ${this.auth_}`);
2017-06-22 23:52:27 +02:00
}
const auth = await response.json();
this.setAuth(auth);
2017-06-22 23:52:27 +02:00
}
2017-06-22 21:44:38 +02:00
}