8e243517e2
All checks were successful
Deploy / deploy (push) Successful in 12s
- Fix CollapsibleSection overflow clipping select dropdowns - Add SlidePanel footer prop for always-visible save/cancel bar - Add approval action buttons: Send to Review, Approve, Reject, Schedule - Add sync-brands.js script for local→remote NocoDB brand sync - Add posts.reject i18n key (en + ar) Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
113 lines
3.7 KiB
JavaScript
113 lines
3.7 KiB
JavaScript
#!/usr/bin/env node
|
|
/**
|
|
* Sync brands from local NocoDB to a remote NocoDB instance.
|
|
*
|
|
* Usage:
|
|
* REMOTE_NOCODB_URL=https://... REMOTE_NOCODB_TOKEN=... REMOTE_NOCODB_BASE_ID=... node sync-brands.js
|
|
*
|
|
* Reads local config from .env (NOCODB_URL, NOCODB_TOKEN, NOCODB_BASE_ID).
|
|
* Syncs all brands from local → remote (upserts by name).
|
|
*/
|
|
|
|
import 'dotenv/config'
|
|
|
|
const LOCAL_URL = process.env.NOCODB_URL || 'http://localhost:8090'
|
|
const LOCAL_TOKEN = process.env.NOCODB_TOKEN
|
|
const LOCAL_BASE_ID = process.env.NOCODB_BASE_ID
|
|
|
|
const REMOTE_URL = process.env.REMOTE_NOCODB_URL
|
|
const REMOTE_TOKEN = process.env.REMOTE_NOCODB_TOKEN
|
|
const REMOTE_BASE_ID = process.env.REMOTE_NOCODB_BASE_ID
|
|
|
|
if (!REMOTE_URL || !REMOTE_TOKEN || !REMOTE_BASE_ID) {
|
|
console.error('Missing env vars: REMOTE_NOCODB_URL, REMOTE_NOCODB_TOKEN, REMOTE_NOCODB_BASE_ID')
|
|
process.exit(1)
|
|
}
|
|
|
|
async function resolveTableId(baseUrl, token, baseId, tableName) {
|
|
const res = await fetch(`${baseUrl}/api/v2/meta/bases/${baseId}/tables`, {
|
|
headers: { 'xc-token': token },
|
|
})
|
|
const data = await res.json()
|
|
const table = (data.list || []).find(t => t.title === tableName)
|
|
if (!table) throw new Error(`Table "${tableName}" not found`)
|
|
return table.id
|
|
}
|
|
|
|
async function listRecords(baseUrl, token, tableId) {
|
|
const res = await fetch(`${baseUrl}/api/v2/tables/${tableId}/records?limit=200`, {
|
|
headers: { 'xc-token': token },
|
|
})
|
|
const data = await res.json()
|
|
return data.list || []
|
|
}
|
|
|
|
async function createRecord(baseUrl, token, tableId, record) {
|
|
const res = await fetch(`${baseUrl}/api/v2/tables/${tableId}/records`, {
|
|
method: 'POST',
|
|
headers: { 'xc-token': token, 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(record),
|
|
})
|
|
return res.json()
|
|
}
|
|
|
|
async function updateRecord(baseUrl, token, tableId, record) {
|
|
const res = await fetch(`${baseUrl}/api/v2/tables/${tableId}/records`, {
|
|
method: 'PATCH',
|
|
headers: { 'xc-token': token, 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(record),
|
|
})
|
|
return res.json()
|
|
}
|
|
|
|
async function main() {
|
|
console.log('Resolving table IDs...')
|
|
const localTableId = await resolveTableId(LOCAL_URL, LOCAL_TOKEN, LOCAL_BASE_ID, 'Brands')
|
|
const remoteTableId = await resolveTableId(REMOTE_URL, REMOTE_TOKEN, REMOTE_BASE_ID, 'Brands')
|
|
|
|
console.log('Fetching local brands...')
|
|
const localBrands = await listRecords(LOCAL_URL, LOCAL_TOKEN, localTableId)
|
|
console.log(` Found ${localBrands.length} local brands`)
|
|
|
|
console.log('Fetching remote brands...')
|
|
const remoteBrands = await listRecords(REMOTE_URL, REMOTE_TOKEN, remoteTableId)
|
|
console.log(` Found ${remoteBrands.length} remote brands`)
|
|
|
|
const remoteByName = new Map(remoteBrands.map(b => [b.name, b]))
|
|
|
|
const FIELDS = ['name', 'name_ar', 'priority', 'color', 'icon', 'category', 'logo']
|
|
|
|
let created = 0, updated = 0, skipped = 0
|
|
|
|
for (const brand of localBrands) {
|
|
const data = {}
|
|
for (const f of FIELDS) {
|
|
if (brand[f] !== undefined && brand[f] !== null) data[f] = brand[f]
|
|
}
|
|
|
|
const existing = remoteByName.get(brand.name)
|
|
if (existing) {
|
|
// Check if anything changed
|
|
const needsUpdate = FIELDS.some(f => brand[f] !== existing[f])
|
|
if (needsUpdate) {
|
|
await updateRecord(REMOTE_URL, REMOTE_TOKEN, remoteTableId, { Id: existing.Id, ...data })
|
|
console.log(` Updated: ${brand.name}`)
|
|
updated++
|
|
} else {
|
|
skipped++
|
|
}
|
|
} else {
|
|
await createRecord(REMOTE_URL, REMOTE_TOKEN, remoteTableId, data)
|
|
console.log(` Created: ${brand.name}`)
|
|
created++
|
|
}
|
|
}
|
|
|
|
console.log(`\nDone! Created: ${created}, Updated: ${updated}, Skipped (no changes): ${skipped}`)
|
|
}
|
|
|
|
main().catch(err => {
|
|
console.error('Sync failed:', err)
|
|
process.exit(1)
|
|
})
|