refactor: dedup V1 upload record creation via createUploadRecord

Author: diegolmello

app/lib/methods/sendFileMessage/sendFileMessage.ts

@@ -1,13 +1,9 @@
-import { sanitizedRaw } from '@nozbe/watermelondb/RawRecord';
 import { settings as RocketChatSettings } from '@rocket.chat/sdk';
-import { Alert } from 'react-native';
 
 import { type IUser, type TSendFileMessageFileInfo, type TUploadModel } from '../../../definitions';
-import i18n from '../../../i18n';
 import database from '../../database';
 import FileUpload from '../helpers/fileUpload';
-import log from '../helpers/log';
-import { copyFileToCacheDirectoryIfNeeded, getUploadPath, isUploadActive, persistUploadError, uploadQueue } from './utils';
+import { copyFileToCacheDirectoryIfNeeded, createUploadRecord, persistUploadError, uploadQueue } from './utils';
 import { type IFormData } from '../helpers/fileUpload/definitions';
 
 export async function sendFileMessage(
@@ -19,46 +15,17 @@ export async function sendFileMessage(
 	isForceTryAgain?: boolean
 ): Promise<void> {
 	let uploadPath: string | null = '';
+	let uploadRecord: TUploadModel | null;
 	try {
 		const { id, token } = user;
 		const uploadUrl = `${server}/api/v1/rooms.upload/${rid}`;
 		fileInfo.rid = rid;
 
 		const db = database.active;
-		const uploadsCollection = db.get('uploads');
-		uploadPath = getUploadPath(fileInfo.path, rid);
-		let uploadRecord: TUploadModel;
-		try {
-			uploadRecord = await uploadsCollection.find(uploadPath);
-			if (uploadRecord.id) {
-				if (isUploadActive(fileInfo.path, rid) && !isForceTryAgain) {
-					return Alert.alert(i18n.t('FileUpload_Error'), i18n.t('Upload_in_progress'));
-				}
-				// Record left behind by a crashed or failed upload: reset and reuse it.
-				await db.write(async () => {
-					await uploadRecord?.update(u => {
-						u.error = false;
-						u.progress = 0;
-					});
-				});
-			}
-		} catch (error) {
-			try {
-				await db.write(async () => {
-					uploadRecord = await uploadsCollection.create(u => {
-						u._raw = sanitizedRaw({ id: uploadPath }, uploadsCollection.schema);
-						Object.assign(u, fileInfo);
-						if (tmid) {
-							u.tmid = tmid;
-						}
-						if (u.subscription) {
-							u.subscription.id = rid;
-						}
-					});
-				});
-			} catch (e) {
-				return log(e);
-			}
+
+		[uploadPath, uploadRecord] = await createUploadRecord({ rid, fileInfo, tmid, isForceTryAgain });
+		if (!uploadPath || !uploadRecord) {
+			return;
 		}
 
 		fileInfo.path = await copyFileToCacheDirectoryIfNeeded(fileInfo.path, fileInfo.name);