Chore: Migrate lib/rocketchat.js to TS - structure PoC

app/definitions/IServer.ts

@@ -6,7 +6,7 @@ export interface IServer {
 	useRealName: boolean;
 	FileUpload_MediaTypeWhiteList: string;
 	FileUpload_MaxFileSize: number;
-	roomsUpdatedAt: Date;
+	roomsUpdatedAt: Date | null;
 	version: string;
 	lastLocalAuthenticatedSession: Date;
 	autoLock: boolean;

app/definitions/ITeam.ts

@@ -1,5 +1,5 @@
 // https://github.com/RocketChat/Rocket.Chat/blob/develop/definition/ITeam.ts
-exports.TEAM_TYPE = {
-	PUBLIC: 0,
-	PRIVATE: 1
-};
+export enum TEAM_TYPE {
+	PUBLIC = 0,
+	PRIVATE = 1
+}

app/lib/rocketchat/index.ts

@@ -0,0 +1,4 @@
+import RocketChat, { THEME_PREFERENCES_KEY, CRASH_REPORT_KEY, ANALYTICS_EVENTS_KEY } from './rocketchat';
+
+export { THEME_PREFERENCES_KEY, CRASH_REPORT_KEY, ANALYTICS_EVENTS_KEY };
+export default RocketChat;

app/lib/rocketchat/methods/clearCache.ts

@@ -0,0 +1,23 @@
+import database from '../../database';
+
+export default async function clearCache({ server }: { server: string }): Promise<void> {
+	try {
+		const serversDB = database.servers;
+		await serversDB.write(async () => {
+			const serverCollection = serversDB.get('servers');
+			const serverRecord = await serverCollection.find(server);
+			await serverRecord.update(s => {
+				s.roomsUpdatedAt = null;
+			});
+		});
+	} catch (e) {
+		// Do nothing
+	}
+
+	try {
+		const db = database.active;
+		await db.write(() => db.unsafeResetDatabase());
+	} catch (e) {
+		// Do nothing
+	}
+}

app/lib/rocketchat/methods/getPermalinkMessage.ts

@@ -0,0 +1,24 @@
+import log from '../../../utils/log';
+import { TMessageModel, TSubscriptionModel } from '../../../definitions';
+import reduxStore from '../../createStore';
+import getRoom from './getRoom';
+import isGroupChat from './isGroupChat';
+
+type TRoomType = 'p' | 'c' | 'd';
+
+export default async function getPermalinkMessage(message: TMessageModel): Promise<string | null> {
+	let room: TSubscriptionModel;
+	try {
+		room = await getRoom(message.subscription.id);
+	} catch (e) {
+		log(e);
+		return null;
+	}
+	const { server } = reduxStore.getState().server;
+	const roomType = {
+		p: 'group',
+		c: 'channel',
+		d: 'direct'
+	}[room.t as TRoomType];
+	return `${server}/${roomType}/${isGroupChat(room) ? room.rid : room.name}?msg=${message.id}`;
+}

app/lib/rocketchat/methods/getRoom.ts

@@ -0,0 +1,12 @@
+import { TSubscriptionModel } from '../../../definitions';
+import database from '../../database';
+
+export default async function getRoom(rid: string): Promise<TSubscriptionModel> {
+	try {
+		const db = database.active;
+		const room = await db.get('subscriptions').find(rid);
+		return Promise.resolve(room);
+	} catch (error) {
+		return Promise.reject(new Error('Room not found'));
+	}
+}

app/lib/rocketchat/methods/isGroupChat.ts

@@ -0,0 +1,5 @@
+import { ISubscription, TSubscriptionModel } from '../../../definitions';
+
+export default function isGroupChat(room: ISubscription | TSubscriptionModel): boolean {
+	return ((room.uids && room.uids.length > 2) || (room.usernames && room.usernames.length > 2)) ?? false;
+}