no-copy-frontend/src/app/actions/violationActions.ts

'use server'

import { getSessionData } from '@/app/actions/session';
import { API_BASE_URL } from '@/app/actions/definitions';

export async function getViolationSearchStatus() {
	const token = await getSessionData('token');

	try {
		const response = await fetch(`${API_BASE_URL}/api/v1/global-search/actual-task`, {
			method: 'GET',
			headers: {
				'Content-Type': 'application/json',
				'Accept': 'application/json',
				'Authorization': `Bearer ${token}`,
			}
		});

		if (response.ok) {
			const text = await response.text();

			if (text) {
				try {
					const parsed = JSON.parse(text);
					console.log('Parsed:', parsed);
					return parsed;
				} catch (e) {
					console.log('Not JSON, raw text:', text);
					return {
						status: text === 'Task not found' ? 'task-not-found' : text
					};
				}
			} else {
				return null;
			}

		} else {
			return null
		}
	} catch (error) {
		return null
	}
}

export async function startGlobalMonitoring(monitoringType: 'monitoring' | 'all_files') {
	const token = await getSessionData('token');
	console.log('startGlobalMonitoring');

	try {
		const response = await fetch(`${API_BASE_URL}/api/v1/global-search/start`, {
			method: 'POST',
			body: JSON.stringify({
				searchType: monitoringType,
				...(monitoringType === 'all_files' && { fileIds: [] })

			}),
			headers: {
				'Content-Type': 'application/json',
				'Authorization': `Bearer ${token}`,
			}
		});

		if (response.ok) {
			const parsed: {
				taskId: string,
				status: string,
				totalFiles: number
			} = await response.json();

			console.log(parsed);
			if (parsed?.status === 'ACCEPTED') {
				return parsed
			} else {
				return null
			}

		} else {
			return null
		}
	} catch (error) {
		return null
	}
}