@kentcdodds/lineage

src/reset-ingest.ts

19 lines · 593 B · TypeScript

import { bucket, ensureSchema, ingestSummary } from './storage.ts'

/**
 * Clear stored commit buckets so a backfill can recount with updated filters.
 * Use after changing generated-file rules.
 *
 * @returns Remaining ingest summary after the wipe
 *
 * @example
 * import resetIngest from 'kody:@kentcdodds/lineage/reset-ingest'
 *
 * const cleared = await resetIngest()
 */
export default async function resetIngest() {
	await ensureSchema()
	await bucket().sql('DELETE FROM commit_buckets')
	await bucket().sql('DELETE FROM commits')
	return { ok: true, ingest: await ingestSummary() }
}