19 lines
625 B
JavaScript
19 lines
625 B
JavaScript
import { deleteObjects } from '../api/s3'
|
|
|
|
export function deleteUnusedImages ({ models }) {
|
|
return async function ({ name }) {
|
|
console.log('running', name)
|
|
|
|
// delete all images in database and S3 which weren't paid in the last 24 hours
|
|
const unpaidImages = await models.$queryRaw`
|
|
SELECT id
|
|
FROM "Upload"
|
|
WHERE paid = 'f' AND created_at < date_trunc('hour', now() - interval '24 hours')
|
|
`
|
|
const s3Keys = unpaidImages.map(({ id }) => id)
|
|
console.log('deleting images:', s3Keys)
|
|
await deleteObjects(s3Keys)
|
|
await models.upload.deleteMany({ where: { id: { in: s3Keys } } })
|
|
}
|
|
}
|