app/composables/data/useAp2iRequestService.ts

import {useProfileAccessStore} from "~/store/profile/access";
import {FetchContext, FetchOptions} from "ohmyfetch";
import {TYPE_ALERT} from "~/types/enums";
import {useRuntimeConfig} from "#app";
import ApiRequestService from "~/services/data/apiRequestService";
import {AssociativeArray} from "~/types/data";
import {Ref} from "@vue/reactivity";
import {usePageStore} from "~/store/page";

/**
 * Retourne une instance de ApiRequestService configurée pour interroger l'api Ap2i
 *
 * @see https://github.com/unjs/ohmyfetch/blob/main/README.md#%EF%B8%8F-create-fetch-with-default-options
 */
export const useAp2iRequestService = () => {
    const runtimeConfig = useRuntimeConfig()

    const baseURL = runtimeConfig.baseUrl ?? runtimeConfig.public.baseUrl

    const pending: Ref<boolean> = ref(false)

    /**
     * Peuple les headers avant l'envoi de la requête
     *
     * @param request
     * @param options
     */
    const onRequest = async function ({ request, options }: FetchContext) {
        // @ts-ignore
        if(options && options.noXaccessId) {
            return
        }

        const profileAccessStore = useProfileAccessStore()

        const headers: AssociativeArray = {
            'x-accessid': String(profileAccessStore.id),
            'Authorization': 'BEARER ' + profileAccessStore.bearer,
        }

        if (profileAccessStore.switchId) {
            headers['x-switch-user'] = String(profileAccessStore.switchId)
        }

        options.headers = { ...options.headers, ...headers }

        pending.value = true
        console.log('Request : ' + request + ' (SSR: ' + process.server + ')')
    }

    const onRequestError = async function({ request, options, response }: FetchContext) {
        pending.value = false
    }

    /**
     * Server responded
     *
     * @param request
     * @param options
     * @param response
     */
    const onResponse = async function({ request, options, response }: FetchContext) {
        pending.value = false
    }

    /**
     * Gère les erreurs retournées par l'api
     *
     * @param request
     * @param response
     * @param error
     */
    const onResponseError = async function ({ request, response, error }: FetchContext) {
        pending.value = false

        if (response && response.status === 401) {
            // navigateTo('/login')
            console.error('Unauthorized')
        }
        else if (response && response.status === 403) {
            usePageStore().addAlerts(TYPE_ALERT.ALERT, ['forbidden'])
            console.error('Forbidden')
        }
        else if (response && response.status >= 404) {
            // @see https://developer.mozilla.org/fr/docs/Web/HTTP/Status
            usePageStore().addAlerts(TYPE_ALERT.ALERT, [error ? error.message : response.statusText])
            console.error(error ? error.message : response.statusText)
        }
    }

    const config : FetchOptions = {
        baseURL,
        onRequest,
        onRequestError,
        onResponse,
        onResponseError
    }

    // Utilise la fonction `create` de ohmyfetch pour générer un fetcher dédié à l'interrogation de Ap2i
    const fetcher = $fetch.create(config)

    return { apiRequestService: new ApiRequestService(fetcher), pending: pending }
}