avoid dup order processing
This commit is contained in:
parent
89f15c8197
commit
d1734a01c0
1 changed files with 14 additions and 0 deletions
|
|
@ -18,6 +18,11 @@ const Utils = require('../utils')
|
|||
|
||||
const getUser = () => require('../../Mediator').getUser()
|
||||
|
||||
/**
|
||||
* @type {Set<string>}
|
||||
*/
|
||||
const ordersProcessed = new Set()
|
||||
|
||||
/**
|
||||
* @typedef {import('../SimpleGUN').GUNNode} GUNNode
|
||||
* @typedef {import('../SimpleGUN').ListenerData} ListenerData
|
||||
|
|
@ -46,6 +51,15 @@ const listenerForAddr = (addr, SEA) => async (order, orderID) => {
|
|||
return
|
||||
}
|
||||
|
||||
if (ordersProcessed.has(orderID)) {
|
||||
logger.warn(
|
||||
`skipping already processed order: ${orderID}, this means orders are being processed twice!`
|
||||
)
|
||||
return
|
||||
}
|
||||
|
||||
ordersProcessed.add(orderID)
|
||||
|
||||
logger.info(
|
||||
`onOrders() -> processing order: ${orderID} -- ${JSON.stringify(
|
||||
order
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue