frontend/src/lib/apis/automations/index.ts

import { REXPRO_API_BASE_URL } from '$lib/constants';

export type AutomationTerminalConfig = {
	server_id: string;
	cwd?: string;
};

export type AutomationData = {
	prompt: string;
	model_id: string;
	rrule: string;
	terminal?: AutomationTerminalConfig;
};

export type AutomationForm = {
	name: string;
	data: AutomationData;
	meta?: {
		system_prompt?: string;
		temperature?: number;
		max_tokens?: number;
		webhook?: string;
	};
	is_active?: boolean;
};

export type AutomationRunModel = {
	id: string;
	automation_id: string;
	chat_id: string | null;
	status: string;
	error: string | null;
	created_at: number;
};

export type AutomationResponse = {
	id: string;
	user_id: string;
	name: string;
	data: AutomationData;
	meta: Record<string, any> | null;
	is_active: boolean;
	last_run_at: number | null;
	next_run_at: number | null;

	created_at: number;
	updated_at: number;
	last_run: AutomationRunModel | null;
	next_runs: number[] | null;
};

export const getAutomationItems = async (
	token: string,
	query: string | null,
	status: string | null,
	page: number
): Promise<{ items: AutomationResponse[]; total: number }> => {
	let error = null;

	const searchParams = new URLSearchParams();
	if (query) {
		searchParams.append('query', query);
	}
	if (status && status !== 'all') {
		searchParams.append('status', status);
	}
	if (page) {
		searchParams.append('page', page.toString());
	}

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/list?${searchParams.toString()}`, {
		method: 'GET',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		}
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const createAutomation = async (token: string, form: AutomationForm) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/create`, {
		method: 'POST',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		},
		body: JSON.stringify(form)
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const getAutomationById = async (token: string, id: string) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/${id}`, {
		method: 'GET',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		}
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const updateAutomationById = async (token: string, id: string, form: AutomationForm) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/${id}/update`, {
		method: 'POST',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		},
		body: JSON.stringify(form)
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const toggleAutomationById = async (token: string, id: string) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/${id}/toggle`, {
		method: 'POST',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		}
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const runAutomationById = async (token: string, id: string) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/${id}/run`, {
		method: 'POST',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		}
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const deleteAutomationById = async (token: string, id: string) => {
	let error = null;

	const res = await fetch(`${REXPRO_API_BASE_URL}/automations/${id}/delete`, {
		method: 'DELETE',
		headers: {
			Accept: 'application/json',
			'Content-Type': 'application/json',
			authorization: `Bearer ${token}`
		}
	})
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};

export const getAutomationRuns = async (
	token: string,
	id: string,
	skip: number = 0,
	limit: number = 50
) => {
	let error = null;

	const res = await fetch(
		`${REXPRO_API_BASE_URL}/automations/${id}/runs?skip=${skip}&limit=${limit}`,
		{
			method: 'GET',
			headers: {
				Accept: 'application/json',
				'Content-Type': 'application/json',
				authorization: `Bearer ${token}`
			}
		}
	)
		.then(async (res) => {
			if (!res.ok) throw await res.json();
			return res.json();
		})
		.catch((err) => {
			error = err.detail;
			console.error(err);
			return null;
		});

	if (error) {
		throw error;
	}

	return res;
};