mirror of
https://github.com/nocodb/nocodb.git
synced 2026-04-29 17:17:16 +00:00
Merge remote-tracking branch 'origin/develop' into fix/i18n
This commit is contained in:
@@ -125,14 +125,14 @@ async function createOrUpdate() {
|
||||
const { id, ...payload } = syncSource.value
|
||||
|
||||
if (id !== '') {
|
||||
await $fetch(`/api/v1/meta/syncs/${id}`, {
|
||||
await $fetch(`/api/v1/db/meta/syncs/${id}`, {
|
||||
baseURL,
|
||||
method: 'PATCH',
|
||||
headers: { 'xc-auth': $state.token.value as string },
|
||||
body: payload,
|
||||
})
|
||||
} else {
|
||||
syncSource.value = await $fetch(`/api/v1/meta/bases/${baseId}/syncs/${sourceId}`, {
|
||||
syncSource.value = await $fetch(`/api/v1/db/meta/projects/${baseId}/syncs/${sourceId}`, {
|
||||
baseURL,
|
||||
method: 'POST',
|
||||
headers: { 'xc-auth': $state.token.value as string },
|
||||
@@ -144,12 +144,12 @@ async function createOrUpdate() {
|
||||
}
|
||||
}
|
||||
|
||||
async function listenForUpdates() {
|
||||
async function listenForUpdates(id?: string) {
|
||||
if (listeningForUpdates.value) return
|
||||
|
||||
listeningForUpdates.value = true
|
||||
|
||||
const job = await $api.jobs.status({ syncId: syncSource.value.id })
|
||||
const job = id ? { id } : await $api.jobs.status({ syncId: syncSource.value.id })
|
||||
|
||||
if (!job) {
|
||||
listeningForUpdates.value = false
|
||||
@@ -184,7 +184,7 @@ async function listenForUpdates() {
|
||||
}
|
||||
|
||||
async function loadSyncSrc() {
|
||||
const data: any = await $fetch(`/api/v1/meta/bases/${baseId}/syncs/${sourceId}`, {
|
||||
const data: any = await $fetch(`/api/v1/db/meta/projects/${baseId}/syncs/${sourceId}`, {
|
||||
baseURL,
|
||||
method: 'GET',
|
||||
headers: { 'xc-auth': $state.token.value as string },
|
||||
@@ -226,12 +226,12 @@ async function loadSyncSrc() {
|
||||
|
||||
async function sync() {
|
||||
try {
|
||||
await $fetch(`/api/v1/meta/syncs/${syncSource.value.id}/trigger`, {
|
||||
const jobData: any = await $fetch(`/api/v1/db/meta/syncs/${syncSource.value.id}/trigger`, {
|
||||
baseURL,
|
||||
method: 'POST',
|
||||
headers: { 'xc-auth': $state.token.value as string },
|
||||
})
|
||||
listenForUpdates()
|
||||
listenForUpdates(jobData.id)
|
||||
} catch (e: any) {
|
||||
message.error(await extractSdkResponseErrorMsg(e))
|
||||
}
|
||||
@@ -245,12 +245,15 @@ async function abort() {
|
||||
"This is a highly experimental feature and only marks job as not started, please don't abort the job unless you are sure job is stuck.",
|
||||
onOk: async () => {
|
||||
try {
|
||||
await $fetch(`/api/v1/meta/syncs/${syncSource.value.id}/abort`, {
|
||||
await $fetch(`/api/v1/db/meta/syncs/${syncSource.value.id}/abort`, {
|
||||
baseURL,
|
||||
method: 'POST',
|
||||
headers: { 'xc-auth': $state.token.value as string },
|
||||
})
|
||||
step.value = 1
|
||||
progress.value = []
|
||||
goBack.value = false
|
||||
enableAbort.value = false
|
||||
} catch (e: any) {
|
||||
message.error(await extractSdkResponseErrorMsg(e))
|
||||
}
|
||||
@@ -258,6 +261,13 @@ async function abort() {
|
||||
})
|
||||
}
|
||||
|
||||
function cancel() {
|
||||
step.value = 1
|
||||
progress.value = []
|
||||
goBack.value = false
|
||||
enableAbort.value = false
|
||||
}
|
||||
|
||||
function migrateSync(src: any) {
|
||||
if (!src.details?.options) {
|
||||
src.details.options = {
|
||||
@@ -456,7 +466,7 @@ onMounted(async () => {
|
||||
<a-button v-if="showGoToDashboardButton" class="mt-4" size="large" @click="dialogShow = false">
|
||||
{{ $t('labels.goToDashboard') }}
|
||||
</a-button>
|
||||
<a-button v-else-if="goBack" class="mt-4 uppercase" size="large" danger @click="step = 1">{{
|
||||
<a-button v-else-if="goBack" class="mt-4 uppercase" size="large" danger @click="cancel()">{{
|
||||
$t('general.cancel')
|
||||
}}</a-button>
|
||||
<a-button v-else-if="enableAbort" class="mt-4 uppercase" size="large" danger @click="abort()">{{
|
||||
|
||||
Reference in New Issue
Block a user