GithubBackup/moemail
1
0
Fork 0
mirror of https://github.com/beilunyang/moemail.git synced 2026-07-11 07:31:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

Optimize email cleanup and add database indexes

Browse Source
This commit is contained in:
selenium39
2025-05-22 11:16:49 +08:00
parent eb6c3fe5eb
commit 3cac33bed3
2 changed files with 22 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
workers/cleanup.ts
View File

@@ -6,9 +6,6 @@ const CLEANUP_CONFIG = {
// Whether to delete expired emails
DELETE_EXPIRED_EMAILS: true,
// Whether to delete messages from expired emails if not deleting the emails themselves
DELETE_MESSAGES_FROM_EXPIRED: true,
// Batch processing size
BATCH_SIZE: 100,
} as const
@@ -18,50 +15,25 @@ const main = {
const now = Date.now()
try {
// Find expired emails
const { results: expiredEmails } = await env.DB
.prepare(`
SELECT id
FROM email
WHERE expires_at < ?
LIMIT ?
`)
.bind(now, CLEANUP_CONFIG.BATCH_SIZE)
.all()
if (!expiredEmails?.length) {
console.log('No expired emails found')
if (!CLEANUP_CONFIG.DELETE_EXPIRED_EMAILS) {
console.log('Expired email deletion is disabled')
return
}
const expiredEmailIds = expiredEmails.map(email => email.id)
const placeholders = expiredEmailIds.map(() => '?').join(',')
if (CLEANUP_CONFIG.DELETE_EXPIRED_EMAILS) {
// First delete associated messages
await env.DB.prepare(`
DELETE FROM message
WHERE emailId IN (${placeholders})
`).bind(...expiredEmailIds).run()
// Then delete the emails
await env.DB.prepare(`
// Directly delete expired emails (messages will be cascade-deleted via foreign key constraint)
const result = await env.DB
.prepare(`
DELETE FROM email
WHERE id IN (${placeholders})
`).bind(...expiredEmailIds).run()
console.log(`Deleted ${expiredEmails.length} expired emails and their messages`)
} else if (CLEANUP_CONFIG.DELETE_MESSAGES_FROM_EXPIRED) {
// Only delete messages from expired emails
await env.DB.prepare(`
DELETE FROM message
WHERE emailId IN (${placeholders})
`).bind(...expiredEmailIds).run()
console.log(`Deleted messages from ${expiredEmails.length} expired emails`)
} else {
console.log('No cleanup actions performed (disabled in config)')
}
WHERE expires_at < ?
LIMIT ?
RETURNING id
`)
.bind(now, CLEANUP_CONFIG.BATCH_SIZE)
.run()
const deletedCount = result?.meta?.changes || 0
console.log(`Deleted ${deletedCount} expired emails and their associated messages`)
} catch (error) {
console.error('Failed to cleanup:', error)
throw error