|
|
|
import { Api } from 'nocodb-sdk'
|
|
|
|
import { defineNuxtPlugin } from 'nuxt3/app'
|
|
|
|
|
|
|
|
export default defineNuxtPlugin((nuxtApp) => {
|
|
|
|
const api = new Api({
|
|
|
|
baseURL: 'http://localhost:8080',
|
|
|
|
})
|
|
|
|
|
|
|
|
addAxiosInterceptors(api, nuxtApp)
|
|
|
|
|
|
|
|
nuxtApp.provide('api', api)
|
|
|
|
})
|
|
|
|
|
|
|
|
const DbNotFoundMsg = 'Database config not found'
|
|
|
|
|
|
|
|
function addAxiosInterceptors(api: Api<any>, app: any) {
|
|
|
|
const router = useRouter()
|
|
|
|
const route = useRoute()
|
|
|
|
|
|
|
|
api.instance.interceptors.request.use((config) => {
|
|
|
|
config.headers['xc-gui'] = 'true'
|
|
|
|
|
|
|
|
if (app.$state.value.token) config.headers['xc-auth'] = app.$state.value.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') {
|
|
|
|
app.$state.value.token = undefined
|
|
|
|
|
|
|
|
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 (app.$state.value.token) app.$state.value.token = token.data.token
|
|
|
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
api.instance
|
|
|
|
.request(config)
|
|
|
|
.then((response) => {
|
|
|
|
resolve(response)
|
|
|
|
})
|
|
|
|
.catch((error) => {
|
|
|
|
reject(error)
|
|
|
|
})
|
|
|
|
})
|
|
|
|
})
|
|
|
|
.catch(async (error) => {
|
|
|
|
app.$state.value.token = undefined
|
|
|
|
// todo: handle new user
|
|
|
|
|
|
|
|
router.replace('/signin')
|
|
|
|
|
|
|
|
return Promise.reject(error)
|
|
|
|
})
|
|
|
|
},
|
|
|
|
)
|
|
|
|
}
|