68 lines
1.8 KiB
TypeScript
68 lines
1.8 KiB
TypeScript
|
import { unlink } from 'fs/promises';
|
||
|
|
import prisma from '../lib/db';
|
||
|
|
|
||
|
|
export const deleteExpiredSecrets = async () => {
|
||
|
|
try {
|
||
|
|
const now = new Date();
|
||
|
|
await prisma.secrets.deleteMany({
|
||
|
|
where: {
|
||
|
|
OR: [
|
||
|
|
{
|
||
|
|
expiresAt: {
|
||
|
|
lte: now,
|
||
|
|
},
|
||
|
|
},
|
||
|
|
{
|
||
|
|
views: 0,
|
||
|
|
},
|
||
|
|
],
|
||
|
|
},
|
||
|
|
});
|
||
|
|
} catch (error) {
|
||
|
|
console.error('Error deleting expired secrets:', error);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
export const deleteOrphanedFiles = async () => {
|
||
|
|
try {
|
||
|
|
// Find files that are not associated with any secret
|
||
|
|
const orphanedFiles = await prisma.file.findMany({
|
||
|
|
where: {
|
||
|
|
secrets: {
|
||
|
|
none: {},
|
||
|
|
},
|
||
|
|
},
|
||
|
|
});
|
||
|
|
|
||
|
|
if (orphanedFiles.length === 0) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Delete files from disk in parallel for better performance
|
||
|
|
const deleteResults = await Promise.allSettled(
|
||
|
|
orphanedFiles.map((file) => unlink(file.path))
|
||
|
|
);
|
||
|
|
|
||
|
|
// Log any failures (file may already be deleted or inaccessible)
|
||
|
|
deleteResults.forEach((result, index) => {
|
||
|
|
if (result.status === 'rejected') {
|
||
|
|
console.error(
|
||
|
|
`Failed to delete file from disk: ${orphanedFiles[index].path}`,
|
||
|
|
result.reason
|
||
|
|
);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
// Delete orphaned file records from database
|
||
|
|
await prisma.file.deleteMany({
|
||
|
|
where: {
|
||
|
|
id: {
|
||
|
|
in: orphanedFiles.map((f) => f.id),
|
||
|
|
},
|
||
|
|
},
|
||
|
|
});
|
||
|
|
} catch (error) {
|
||
|
|
console.error('Error deleting orphaned files:', error);
|
||
|
|
}
|
||
|
|
};
|