29 lines
640 B
JavaScript
29 lines
640 B
JavaScript
import serialize from '../api/resolvers/serial.js'
|
|
|
|
export function auction ({ models }) {
|
|
return async function ({ name }) {
|
|
console.log('running', name)
|
|
// get all items we need to check
|
|
const items = await models.item.findMany(
|
|
{
|
|
where: {
|
|
maxBid: {
|
|
not: null
|
|
},
|
|
status: {
|
|
not: 'STOPPED'
|
|
}
|
|
}
|
|
}
|
|
)
|
|
|
|
// for each item, run serialized auction function
|
|
items.forEach(async item => {
|
|
await serialize(models,
|
|
models.$executeRaw`SELECT run_auction(${item.id}::INTEGER)`)
|
|
})
|
|
|
|
console.log('done', name)
|
|
}
|
|
}
|