34 lines
1.0 KiB
TypeScript
34 lines
1.0 KiB
TypeScript
import { join } from 'node:path';
|
|
import { unlinkSync } from 'node:fs';
|
|
import { openEmailDb } from '../src/servers/api/email/email-db';
|
|
import { importMaildir } from '../src/servers/queue/handlers/gmail-sync';
|
|
|
|
const DATA_PATH = process.env.DATA_PATH ?? join(process.cwd(), 'data');
|
|
const email = process.argv[2];
|
|
|
|
if (!email) {
|
|
console.error('Usage: bun scripts/reimport-gmail.ts <email>');
|
|
process.exit(1);
|
|
}
|
|
|
|
const maildirPath = join(DATA_PATH, email, 'Gmail', 'Maildir');
|
|
const dbPath = join(DATA_PATH, email, 'emails.db');
|
|
|
|
// Delete existing DB for a fresh import
|
|
try {
|
|
unlinkSync(dbPath);
|
|
console.log(`Deleted ${dbPath}`);
|
|
} catch {
|
|
console.log('No existing DB to delete');
|
|
}
|
|
|
|
const db = openEmailDb(email);
|
|
|
|
console.log(`Importing from ${maildirPath}...`);
|
|
const result = await importMaildir({ maildirPath, emailAccount: email, db, onProgress: (saved, skipped) => {
|
|
process.stdout.write(`\r saved ${saved}, skipped ${skipped}`);
|
|
}});
|
|
|
|
console.log(`\nDone: saved ${result.saved}, skipped ${result.skipped}, errors ${result.errors}`);
|
|
db.close();
|