Jennie Robinson Faber
50a358b294
Add add/remove toggle to batch tag picker. Clean up unused requireAdmin import from wiki sync route.
83 lines
2.4 KiB
JavaScript
83 lines
2.4 KiB
JavaScript
import WikiArticle from '../../../models/wikiArticle.js'
|
|
import { connectDB } from '../../../utils/mongoose.js'
|
|
import { fetchAllDocuments, extractSummary } from '../../../utils/outline.js'
|
|
|
|
export default defineEventHandler(async (event) => {
|
|
await requireAdmin(event)
|
|
|
|
// Fetch ALL documents first — if this fails, no DB changes happen
|
|
let documents
|
|
try {
|
|
documents = await fetchAllDocuments()
|
|
} catch (err) {
|
|
console.error('[wiki-sync] Outline fetch failed:', err)
|
|
throw createError({
|
|
statusCode: err.statusCode || 502,
|
|
statusMessage: err.statusMessage || 'Failed to fetch documents from Outline'
|
|
})
|
|
}
|
|
|
|
await connectDB()
|
|
|
|
const fetchedOutlineIds = new Set(documents.map((doc) => doc.id))
|
|
|
|
// Get all existing articles for comparison
|
|
const existing = await WikiArticle.find({}, 'outlineId publishedAt')
|
|
const existingByOutlineId = new Map(
|
|
existing.map((a) => [a.outlineId, a])
|
|
)
|
|
|
|
let created = 0
|
|
let updated = 0
|
|
let deleted = 0
|
|
let errors = 0
|
|
|
|
// Upsert each fetched document
|
|
for (const doc of documents) {
|
|
try {
|
|
const articleData = {
|
|
title: doc.title,
|
|
collection: doc.collection?.name || null,
|
|
url: doc.url,
|
|
summary: extractSummary(doc.text),
|
|
publishedAt: doc.publishedAt ? new Date(doc.publishedAt) : new Date(doc.createdAt),
|
|
permission: doc.permission || null,
|
|
lastSyncedAt: new Date(),
|
|
outlineUpdatedAt: doc.updatedAt ? new Date(doc.updatedAt) : null
|
|
}
|
|
|
|
const result = await WikiArticle.findOneAndUpdate(
|
|
{ outlineId: doc.id },
|
|
{ $set: articleData },
|
|
{ upsert: true, new: true, rawResult: true }
|
|
)
|
|
|
|
if (result.lastErrorObject?.updatedExisting) {
|
|
updated++
|
|
} else {
|
|
created++
|
|
}
|
|
} catch (err) {
|
|
console.error(`[wiki-sync] Error upserting doc ${doc.id}:`, err)
|
|
errors++
|
|
}
|
|
}
|
|
|
|
// Soft-delete articles no longer in Outline
|
|
for (const [outlineId, article] of existingByOutlineId) {
|
|
if (!fetchedOutlineIds.has(outlineId) && article.publishedAt !== null) {
|
|
try {
|
|
await WikiArticle.findOneAndUpdate(
|
|
{ outlineId },
|
|
{ $set: { publishedAt: null, lastSyncedAt: new Date() } }
|
|
)
|
|
deleted++
|
|
} catch (err) {
|
|
console.error(`[wiki-sync] Error soft-deleting ${outlineId}:`, err)
|
|
errors++
|
|
}
|
|
}
|
|
}
|
|
|
|
return { created, updated, deleted, errors }
|
|
})
|