42 lines
1.1 KiB
JavaScript
42 lines
1.1 KiB
JavaScript
|
import { readFile } from 'node:fs/promises';
|
||
|
|
import path from 'node:path';
|
||
|
|
import pg from 'pg';
|
||
|
|
|
||
|
|
const { Pool } = pg;
|
||
|
|
const contentPath = process.argv[2]
|
||
|
|
? path.resolve(process.argv[2])
|
||
|
|
: path.resolve('deploy-data', 'homepage-content.json');
|
||
|
|
const connectionString = process.env.DATABASE_URL;
|
||
|
|
|
||
|
|
if (!connectionString) {
|
||
|
|
throw new Error('DATABASE_URL is required for homepage content sync.');
|
||
|
|
}
|
||
|
|
|
||
|
|
const rawContent = await readFile(contentPath, 'utf8');
|
||
|
|
const homepageContent = JSON.parse(rawContent);
|
||
|
|
const pool = new Pool({ connectionString });
|
||
|
|
|
||
|
|
try {
|
||
|
|
await pool.query(`
|
||
|
|
create table if not exists site_content (
|
||
|
|
key text primary key,
|
||
|
|
value jsonb not null,
|
||
|
|
updated_at timestamptz not null default now()
|
||
|
|
)
|
||
|
|
`);
|
||
|
|
|
||
|
|
await pool.query(
|
||
|
|
`
|
||
|
|
insert into site_content (key, value)
|
||
|
|
values ($1, $2::jsonb)
|
||
|
|
on conflict (key)
|
||
|
|
do update set value = excluded.value, updated_at = now()
|
||
|
|
`,
|
||
|
|
['homepage', JSON.stringify(homepageContent)]
|
||
|
|
);
|
||
|
|
|
||
|
|
console.log(`[content-sync] Synced homepage content from ${contentPath}`);
|
||
|
|
} finally {
|
||
|
|
await pool.end();
|
||
|
|
}
|