file upload develop

src/app/actions/file-upload.ts

@@ -2,7 +2,6 @@
 
 import { localDevelopmentUrl } from '@/app/actions/definitions';
 import { getSessionData, createSession } from '@/app/actions/session';
-import { number } from 'zod';
 
 const API_BASE_URL = process.env.NODE_ENV === 'development'
 	? localDevelopmentUrl
@@ -51,7 +50,6 @@ export async function fileUpload(messageBody: initMessageBody) {
 				},
 				message_code: string
 			};
-			console.log(parsed);
 
 			if (parsed.message_desc === 'Operation successful') {
 				return parsed.message_body;
@@ -69,6 +67,7 @@ export async function fileUpload(messageBody: initMessageBody) {
 
 export async function cancelUpload(udloadId: string) {
 	console.log('cancelUpload');
+	console.log(udloadId);
 
 	try {
 		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
@@ -114,20 +113,52 @@ export async function cancelUpload(udloadId: string) {
 }
 
 export async function chunkUpload(formData: FormData) {
-	console.log('chunkUpload');
-	console.log(`${API_BASE_URL}/api/v1/files/chunk`);
-
 	try {
 		const response = await fetch(`${API_BASE_URL}/api/v1/files/chunk`, {
 			method: 'POST',
 			body: formData
 		});
 
-		console.log(response);
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed.message_desc === 'Upload cancelled successfully') {
+				console.log('chunkUpload');
+				console.log(parsed.message_body);
+				return parsed.message_body;
+			} else {
+				console.log('error cancel chunkUpload');
+				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();
-			console.log('response.ok');
 			console.log(parsed);
 
 			if (parsed.message_desc === 'Upload cancelled successfully') {
@@ -140,6 +171,43 @@ export async function chunkUpload(formData: FormData) {
 			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();
+			console.log(parsed);
+
+			if (parsed.message_desc === 'Operation successful') {
+				return parsed.message_body.file_extension;
+			} else {
+				console.log('error cancel getAllowedFilesExtensions');
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+
 	} catch (error) {
 		return error
 	}