(query: Filter<Task>)
| 15 | const argv = cac().parse(); |
| 16 | |
| 17 | async function getFirst(query: Filter<Task>) { |
| 18 | if (process.env.CI) return null; |
| 19 | try { |
| 20 | const q = { ...query }; |
| 21 | const res = await coll.findOneAndDelete(q, { sort: { priority: -1 } }); |
| 22 | if (res) { |
| 23 | logger.debug('%o', res); |
| 24 | return res; |
| 25 | } |
| 26 | return null; |
| 27 | } catch (e) { |
| 28 | // Usually caused by the database being down |
| 29 | // Should recover once it is back |
| 30 | logger.error(e); |
| 31 | return null; |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | export class Consumer { |
| 36 | consuming: boolean; |