103 lines
3.3 KiB
JavaScript
Executable File
103 lines
3.3 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
/**
|
|
* Idempotent content seeder.
|
|
*
|
|
* Reads content.json (same file the frontend bundles as offline fallback)
|
|
* and creates any record that is missing in PocketBase, identified by its
|
|
* `uid` field. Existing records are NEVER overwritten — after the first
|
|
* seed, PocketBase owns the data and content is managed via the admin UI
|
|
* (admin.greatbear.in).
|
|
*
|
|
* Required env: PB_SUPERUSER_EMAIL, PB_SUPERUSER_PASSWORD. Optional: PB_URL.
|
|
*/
|
|
import { existsSync, readFileSync } from 'node:fs'
|
|
import { dirname, join } from 'node:path'
|
|
import { fileURLToPath } from 'node:url'
|
|
|
|
const here = dirname(fileURLToPath(import.meta.url))
|
|
const PB_URL = process.env.PB_URL ?? 'http://127.0.0.1:8090'
|
|
const EMAIL = process.env.PB_SUPERUSER_EMAIL
|
|
const PASSWORD = process.env.PB_SUPERUSER_PASSWORD
|
|
|
|
if (!EMAIL || !PASSWORD) {
|
|
console.error('[seed] PB_SUPERUSER_EMAIL/PB_SUPERUSER_PASSWORD not set — skipping seed')
|
|
process.exit(0)
|
|
}
|
|
|
|
// Inside the image content.json sits next to this script; in the repo it lives
|
|
// with the frontend sources.
|
|
const contentPath = [join(here, 'content.json'), join(here, '../app/src/data/content.json')].find(
|
|
(path) => existsSync(path),
|
|
)
|
|
if (!contentPath) {
|
|
console.error('[seed] content.json not found — nothing to seed')
|
|
process.exit(1)
|
|
}
|
|
const content = JSON.parse(readFileSync(contentPath, 'utf8'))
|
|
|
|
async function auth() {
|
|
const res = await fetch(`${PB_URL}/api/collections/_superusers/auth-with-password`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify({ identity: EMAIL, password: PASSWORD }),
|
|
})
|
|
if (!res.ok) throw new Error(`superuser auth failed (HTTP ${res.status})`)
|
|
const json = await res.json()
|
|
return json.token
|
|
}
|
|
|
|
async function ensureRecord(collection, token, item) {
|
|
const filter = encodeURIComponent(`uid="${item.uid}"`)
|
|
const found = await fetch(
|
|
`${PB_URL}/api/collections/${collection}/records?filter=${filter}`,
|
|
{ headers: { Authorization: token } },
|
|
)
|
|
if (!found.ok) throw new Error(`lookup failed for ${collection}/${item.uid} (HTTP ${found.status})`)
|
|
const list = await found.json()
|
|
if (list.items.length > 0) return 'exists'
|
|
|
|
const created = await fetch(`${PB_URL}/api/collections/${collection}/records`, {
|
|
method: 'POST',
|
|
headers: { Authorization: token, 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(item),
|
|
})
|
|
if (!created.ok) {
|
|
const body = await created.text()
|
|
throw new Error(`create failed for ${collection}/${item.uid} (HTTP ${created.status}): ${body}`)
|
|
}
|
|
return 'created'
|
|
}
|
|
|
|
const COLLECTIONS = [
|
|
'settings',
|
|
'stats',
|
|
'brews',
|
|
'experiences',
|
|
'testimonials',
|
|
'menu_categories',
|
|
'menu_items',
|
|
'pairings',
|
|
]
|
|
|
|
try {
|
|
const token = await auth()
|
|
let created = 0
|
|
let existing = 0
|
|
for (const collection of COLLECTIONS) {
|
|
const items = Array.isArray(content[collection])
|
|
? content[collection]
|
|
: content[collection]
|
|
? [content[collection]]
|
|
: []
|
|
for (const item of items) {
|
|
const result = await ensureRecord(collection, token, item)
|
|
if (result === 'created') created++
|
|
else existing++
|
|
}
|
|
}
|
|
console.log(`[seed] done: ${created} created, ${existing} already present`)
|
|
} catch (error) {
|
|
console.error(`[seed] failed: ${error.message}`)
|
|
process.exit(1)
|
|
}
|