self-hosted/joplin
1
0
Fork 0
mirror of https://github.com/laurent22/joplin.git synced 2025-07-13 00:10:37 +02:00
Code Issues Releases Activity

Chore: Wait when Discourse update fails

Browse Source
This commit is contained in:
Laurent Cozic
2023-12-13 19:39:04 +00:00
parent a730d349e4
commit 995423cadf
1 changed files with 35 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
packages/tools/utils/discourse.ts
View File

@ -1,3 +1,4 @@
import { msleep } from '@joplin/utils/time';
import fetch from 'node-fetch'; import fetch from 'node-fetch';
interface ApiConfig { interface ApiConfig {
@ -54,23 +55,43 @@ export const execApi = async (method: HttpMethod, path: string, body: Record<str
if (body) request.body = JSON.stringify(body); if (body) request.body = JSON.stringify(body);
const response = await fetch(`${config.baseUrl}/${path}`, request); while (true) {
const response = await fetch(`${config.baseUrl}/${path}`, request);
if (!response.ok) { if (!response.ok) {
const errorText = await response.text(); const errorText = await response.text();
const error = new Error(`On ${method} ${path}: ${errorText}`); const error = new Error(`On ${method} ${path}: ${errorText}`);
let apiObject = null; let apiObject = null;
try { try {
apiObject = JSON.parse(errorText); apiObject = JSON.parse(errorText);
} catch (error) { } catch (error) {
// Ignore - it just means that the error object is a plain string // Ignore - it just means that the error object is a plain string
}
// {
// "errors": [
// "You’ve performed this action too many times. Please wait 39 seconds before trying again."
// ],
// "error_type": "rate_limit",
// "extras": {
// "wait_seconds": 39,
// "time_left": "39 seconds"
// }
// }
(error as any).apiObject = apiObject;
(error as any).status = response.status;
if (apiObject?.extras?.wait_seconds) {
await msleep(apiObject.extras.wait_seconds * 1000 + 1000);
continue;
}
throw error;
} }
(error as any).apiObject = apiObject;
(error as any).status = response.status;
throw error;
}
return response.json() as any; return response.json() as any;
}
}; };
export const getForumTopPostByExternalId = async (externalId: string): Promise<ForumTopPost> => { export const getForumTopPostByExternalId = async (externalId: string): Promise<ForumTopPost> => {