import { defineStore } from 'pinia';
import { getCurrentOrganizationId } from '@/utils/useUser';
import { api } from '../../../openapi.json.client';
import { reactive, ref } from 'vue';
import type { CreateTaskBody, Task, UpdateTaskBody } from '@/utils/api';
import { useNotificationsStore } from '@/utils/notification';

export const useTasksStore = defineStore('tasks', () => {
    const tasks = ref<Task[]>(reactive([]));
    const { handleApiRequestNotifications } = useNotificationsStore();

    async function fetchTasks() {
        const organizationId = getCurrentOrganizationId();
        if (organizationId) {
            const tasksResponse = await handleApiRequestNotifications(() =>
                api.getTasks({
                    params: {
                        organization: organizationId,
                    },
                    queries: {
                        done: 'all',
                    },
                })
            );
            if (tasksResponse?.data) {
                tasks.value = tasksResponse.data;
            }
        }
    }

    async function updateTask(taskId: string, taskBody: UpdateTaskBody) {
        const organizationId = getCurrentOrganizationId();
        if (organizationId) {
            await handleApiRequestNotifications(
                () =>
                    api.updateTask(taskBody, {
                        params: {
                            task: taskId,
                            organization: organizationId,
                        },
                    }),
                'Task updated successfully',
                'Failed to update task'
            );
            await fetchTasks();
        }
    }

    async function createTask(task: CreateTaskBody) {
        const organizationId = getCurrentOrganizationId();
        if (organizationId) {
            await handleApiRequestNotifications(
                () =>
                    api.createTask(task, {
                        params: {
                            organization: organizationId,
                        },
                    }),
                'Task created successfully',
                'Failed to create task'
            );
            await fetchTasks();
        }
    }

    async function deleteTask(taskId: string) {
        const organizationId = getCurrentOrganizationId();
        if (organizationId) {
            await handleApiRequestNotifications(
                () =>
                    api.deleteTask(
                        {},
                        {
                            params: {
                                organization: organizationId,
                                task: taskId,
                            },
                        }
                    ),
                'Task deleted successfully',
                'Failed to delete task'
            );
            await fetchTasks();
        }
    }

    return {
        tasks,
        fetchTasks,
        updateTask,
        createTask,
        deleteTask,
    };
});