import { Api } from 'nocodb-sdk'
import { defineNuxtPlugin } from 'nuxt3/app'

export default defineNuxtPlugin((nuxtApp) => {
  const api = getApi(null, null)

  addAxiosInterceptors(api)

  nuxtApp.provide('api', api)
})

const DbNotFoundMsg = 'Database config not found'

function addAxiosInterceptors(api: Api<any>) {
  const router = useRouter()
  const route = useRoute()
  const { user, setToken } = useUser()

  api.instance.interceptors.request.use((config) => {
    config.headers['xc-gui'] = 'true'

    if (user?.token) config.headers['xc-auth'] = user?.token

    if (!config.url?.endsWith('/user/me') && !config.url?.endsWith('/admin/roles')) {
      // config.headers['xc-preview'] = store.state.users.previewAs
    }

    if (!config.url?.endsWith('/user/me') && !config.url?.endsWith('/admin/roles')) {
      if (route && route.params && route.params.shared_base_id) config.headers['xc-shared-base-id'] = route.params.shared_base_id
    }

    return config
  })

  // Return a successful response back to the calling service
  api.instance.interceptors.response.use(
    (response) => response,
    // Handle Error
    (error) => {
      if (error.response && error.response.data && error.response.data.msg === DbNotFoundMsg) return router.replace('/project/0')

      // Return any error which is not due to authentication back to the calling service
      if (!error.response || error.response.status !== 401) {
        return new Promise((resolve, reject) => {
          reject(error)
        })
      }

      // Logout user if token refresh didn't work or user is disabled
      if (error.config.url === '/auth/refresh-token') {
        // todo: clear token
        setToken()

        return new Promise((resolve, reject) => {
          reject(error)
        })
      }

      // Try request again with new token
      return api.instance
        .post('/auth/refresh-token', null, {
          withCredentials: true,
        })
        .then((token) => {
          // New request with new token
          const config = error.config
          config.headers['xc-auth'] = token.data.token
          if (user) user.token = token.data.token

          return new Promise((resolve, reject) => {
            api.instance
              .request(config)
              .then((response) => {
                resolve(response)
              })
              .catch((error) => {
                reject(error)
              })
          })
        })
        .catch(async (error) => {
          // todo: clear token
          // await store.dispatch('users/ActSignOut')
          setToken()
          // todo: handle new user
          // if (store.state.project.appInfo.firstUser) {
          //   router.replace('/')
          // }
          // else {
          // $toast.clear()
          // $toast.info('Token Expired. Please login again.', {
          //   position: 'bottom-center'
          // }).goAway(5000)
          router.replace('/signin')
          // }
          return Promise.reject(error)
        })
    },
  )
}

export function getApi(store: any, axios: any) {
  const api = new Api({
    baseURL: 'http://localhost:8080',
    headers: {
      'xc-auth': store?.state?.users?.token,
    },
  })

  if (axios) {
    // overwrite with nuxt axios instance
    api.instance = axios
  }

  return api
}