31 lines
656 B
JavaScript
31 lines
656 B
JavaScript
|
const serialize = require('../api/resolvers/serial')
|
||
|
|
||
|
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})`)
|
||
|
})
|
||
|
|
||
|
console.log('done', name)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
module.exports = { auction }
|