rename file-upload

src/app/actions/fileUpload.ts

@@ -0,0 +1,203 @@
+'use server'
+
+import { localDevelopmentUrl } from '@/app/actions/definitions';
+import { getSessionData, createSession } from '@/app/actions/session';
+
+const API_BASE_URL = process.env.NODE_ENV === 'development'
+	? localDevelopmentUrl
+	: 'http://app:8080';
+
+interface initMessageBody {
+	file_name: string,
+	file_type: string,
+	extension: string,
+	file_size: number | string,
+	action?: string,
+	token?: string
+}
+
+export async function fileUpload(messageBody: initMessageBody) {
+	const token = await getSessionData('token');
+	if (!token) {
+		return;
+	}
+	const message = messageBody;
+	message.action = "init";
+	message.token = token;
+
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 20004,
+				message_body: message
+			}),
+			headers: {
+				"Content-Type": "application/json",
+				"Accept": "application/json"
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json() as {
+				message_desc: string,
+				message_body: {
+					upload_id: string,
+					total_chunks: number,
+					chunk_size: number,
+					status: string
+				},
+				message_code: string
+			};
+
+			if (parsed.message_desc === 'Operation successful') {
+				return parsed.message_body;
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+	} catch (error) {
+		return error;
+	}
+}
+
+export async function cancelUpload(udloadId: string) {
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 20004,
+				message_body: {
+					action: "cancel",
+					upload_id: udloadId,
+				}
+			}),
+			headers: {
+				"Content-Type": "application/json",
+				"Accept": "application/json"
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json() as {
+				message_code: string,
+				message_desc: string,
+				message_body: {
+					upload_id: string,
+					message: string
+				}
+			};
+
+			if (parsed.message_desc === 'Upload cancelled successfully') {
+				console.log('cancelUpload done');
+				return parsed.message_body;
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+	} catch (error) {
+		console.log('cancelUpload error');
+		return error;
+	}
+}
+
+export async function chunkUpload(formData: FormData) {
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/files/chunk`, {
+			method: 'POST',
+			body: formData
+		});
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed.message_desc === 'Upload cancelled successfully') {
+				return parsed.message_body;
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+
+	} catch (error) {
+		return error
+	}
+}
+
+export async function checkChunkStatus(upload_id: string) {
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 20004,
+				message_body: {
+					action: 'chunks',
+					upload_id
+				}
+			}),
+			headers: {
+				"Content-Type": "application/json",
+				"Accept": "application/json"
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed.message_desc === 'Upload cancelled successfully') {
+				return parsed.message_body;
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+
+	} catch (error) {
+		return error
+	}
+}
+
+export async function getAllowedFilesExtensions(type: string) {
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 20004,
+				message_body: {
+					action: 'file_extension',
+					file_type: type
+				}
+			}),
+			headers: {
+				"Content-Type": "application/json",
+				"Accept": "application/json"
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed.message_desc === 'Operation successful') {
+				return parsed.message_body;
+			} else {
+				console.log('error cancel getAllowedFilesExtensions');
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+
+	} catch (error) {
+		return error
+	}
+}