Tools: Refactor Discourse code

packages/tools/utils/discourse.ts

@@ -0,0 +1,83 @@
+import fetch from 'node-fetch';
+
+interface ApiConfig {
+	baseUrl: string;
+	key: string;
+	username: string;
+	newsCategoryId: number;
+}
+
+export enum HttpMethod {
+	GET = 'GET',
+	POST = 'POST',
+	DELETE = 'DELETE',
+	PUT = 'PUT',
+	PATCH = 'PATCH',
+}
+
+interface ForumTopPost {
+	id: number;
+	raw: string;
+	title: string;
+}
+
+export const config: ApiConfig = {
+	baseUrl: 'https://discourse.joplinapp.org',
+	key: '',
+	username: '',
+	newsCategoryId: 9,
+};
+
+export const execApi = async (method: HttpMethod, path: string, body: Record<string, string | number> = null) => {
+	interface Request {
+		method: HttpMethod;
+		headers: Record<string, string>;
+		body?: string;
+	}
+
+	const headers: Record<string, string> = {
+		'Api-Key': config.key,
+		'Api-Username': config.username,
+	};
+
+	if (method !== HttpMethod.GET) headers['Content-Type'] = 'application/json;';
+
+	const request: Request = {
+		method,
+		headers,
+	};
+
+	if (body) request.body = JSON.stringify(body);
+
+	const response = await fetch(`${config.baseUrl}/${path}`, request);
+
+	if (!response.ok) {
+		const errorText = await response.text();
+		const error = new Error(`On ${method} ${path}: ${errorText}`);
+		let apiObject = null;
+		try {
+			apiObject = JSON.parse(errorText);
+		} catch (error) {
+			// Ignore - it just means that the error object is a plain string
+		}
+		(error as any).apiObject = apiObject;
+		throw error;
+	}
+
+	return response.json() as any;
+};
+
+export const getForumTopPostByExternalId = async (externalId: string): Promise<ForumTopPost> => {
+	try {
+		const existingForumTopic = await execApi(HttpMethod.GET, `t/external_id/${externalId}.json`);
+		const existingForumPost = await execApi(HttpMethod.GET, `posts/${existingForumTopic.post_stream.posts[0].id}.json`);
+		return {
+			id: existingForumPost.id,
+			title: existingForumTopic.title,
+			raw: existingForumPost.raw,
+		};
+	} catch (error) {
+		if (error.apiObject && error.apiObject.error_type === 'not_found') return null;
+		throw error;
+	}
+};