103 lines
2.7 KiB
TypeScript
103 lines
2.7 KiB
TypeScript
import { Order, OrderReuse } from '../../@types/schema'
|
|
import { log } from '@graphprotocol/graph-ts'
|
|
import { toChecksumAddress } from 'ethereumjs-util'
|
|
|
|
export function getOrderId(
|
|
tx: string,
|
|
tokenAddress: string,
|
|
fromAddress: string,
|
|
eventIndex: number
|
|
): string {
|
|
return `${tx}-${tokenAddress}-${fromAddress}-${eventIndex}`
|
|
}
|
|
|
|
export function createOrder(orderId: string): Order {
|
|
const order = new Order(orderId)
|
|
return order
|
|
}
|
|
|
|
export function getOrder(
|
|
transactionHash: string,
|
|
address: string,
|
|
transactionFrom: string,
|
|
eventIndex: number
|
|
): Order {
|
|
const orderId = getOrderId(
|
|
transactionHash,
|
|
address,
|
|
transactionFrom,
|
|
eventIndex
|
|
)
|
|
let newOrder = Order.load(orderId)
|
|
if (newOrder === null) {
|
|
newOrder = createOrder(orderId)
|
|
}
|
|
return newOrder
|
|
}
|
|
|
|
export function searchOrderForEvent(
|
|
transactionHash: string,
|
|
address: string,
|
|
transactionFrom: string,
|
|
eventIndex: number
|
|
): Order {
|
|
let firstEventIndex = eventIndex - 1
|
|
|
|
log.info('firstEventIndex on simple order: {}', [firstEventIndex.toString()])
|
|
while (firstEventIndex >= 0) {
|
|
const orderId = getOrderId(
|
|
transactionHash,
|
|
address,
|
|
transactionFrom,
|
|
firstEventIndex
|
|
)
|
|
log.info('orderId as trial: {}', [orderId])
|
|
const order = Order.load(orderId)
|
|
if (
|
|
order !== null &&
|
|
toChecksumAddress(order.datatoken) === toChecksumAddress(address)
|
|
) {
|
|
log.info('order datatoken: {}', [order.datatoken])
|
|
log.info('event address: {}', [address])
|
|
log.info('typeof order datatoken: {}', [typeof order.datatoken])
|
|
log.info('typeof hex event address: {}', [typeof address])
|
|
// add break
|
|
return getOrder(
|
|
transactionHash,
|
|
address,
|
|
transactionFrom,
|
|
firstEventIndex
|
|
)
|
|
}
|
|
firstEventIndex--
|
|
}
|
|
// return a default Order if it cannot find the right one
|
|
return getOrder(transactionHash, address, transactionFrom, firstEventIndex)
|
|
}
|
|
|
|
export function searchOrderResusedForEvent(
|
|
transactionHash: string,
|
|
eventAddress: string,
|
|
eventIndex: number
|
|
): OrderReuse {
|
|
let firstEventIndex = eventIndex - 1
|
|
log.info('firstEventIndex on simple order: {}', [firstEventIndex.toString()])
|
|
while (firstEventIndex >= 0) {
|
|
const orderReused = OrderReuse.load(`${transactionHash}-${firstEventIndex}`)
|
|
|
|
if (orderReused !== null) {
|
|
const order = Order.load(orderReused.order)
|
|
if (
|
|
order !== null &&
|
|
order.datatoken.toString().toLowerCase() === eventAddress.toLowerCase()
|
|
) {
|
|
return orderReused
|
|
}
|
|
}
|
|
|
|
firstEventIndex--
|
|
}
|
|
// return a default Order if it cannot find the right one
|
|
return new OrderReuse(`${transactionHash}-${firstEventIndex}`)
|
|
}
|