import axios, { AxiosInstance } from 'axios'

import type { RequestInterceptor } from '@/core/types'

import { type DeduplicatedClient, withDeduplication } from './deduplicatedClient'

/**

* Creates a configured axios client for API calls

* @param apiBaseUrl - Base URL of the Flowise server

* @param token - Authentication token (optional)

* @param requestInterceptor - Optional callback to customize outgoing requests

*/

export function bindApiClient(apiBaseUrl: string, token?: string, requestInterceptor?: RequestInterceptor): DeduplicatedClient {

const headers: Record<string, string> = {

'Content-Type': 'application/json'

}

if (token) {

headers['Authorization'] = `Bearer ${token}`

}

const client = axios.create({

baseURL: `${apiBaseUrl}/api/v1`,

headers

})

// Add request interceptor for consumer customization

client.interceptors.request.use(

(config) => {

if (!requestInterceptor) return config

try {

return requestInterceptor(config)

} catch (error) {

console.error('[Agentflow] requestInterceptor threw:', error)

return config

}

},

(error) => Promise.reject(error)

)

// Add response interceptor for error handling

client.interceptors.response.use(

(response) => response,

(error) => {

if (error.response?.status === 401) {

console.error('[Agentflow] 401 Authentication error:', {

url: error.config?.url,

message: error.response?.data?.message || error.message,

hasToken: !!token,

tokenLength: token?.length

})

}

return Promise.reject(error)

}

)

return withDeduplication(client)

}

export type { AxiosInstance }