core: reuse appendTokenTransferInfo from appendTokenTransfer

This commit is contained in:
Anna Shaleva 2022-11-10 14:53:58 +03:00
parent 30cfe4d8c8
commit e7effef052

View file

@ -1852,34 +1852,29 @@ func appendTokenTransfer(cache *dao.Simple, transCache map[util.Uint160]transfer
} }
var ( var (
log *state.TokenTransferLog log *state.TokenTransferLog
newBatch *bool nextBatch uint32
nextBatch *uint32 currTimestamp uint64
currTimestamp *uint64
) )
if !isNEP11 { if !isNEP11 {
log = &transferData.Log17 log = &transferData.Log17
newBatch = &transferData.Info.NewNEP17Batch nextBatch = transferData.Info.NextNEP17Batch
nextBatch = &transferData.Info.NextNEP17Batch currTimestamp = transferData.Info.NextNEP17NewestTimestamp
currTimestamp = &transferData.Info.NextNEP17NewestTimestamp
} else { } else {
log = &transferData.Log11 log = &transferData.Log11
newBatch = &transferData.Info.NewNEP11Batch nextBatch = transferData.Info.NextNEP11Batch
nextBatch = &transferData.Info.NextNEP11Batch currTimestamp = transferData.Info.NextNEP11NewestTimestamp
currTimestamp = &transferData.Info.NextNEP11NewestTimestamp
} }
err := log.Append(transfer) err := log.Append(transfer)
if err != nil { if err != nil {
return err return err
} }
transferData.Info.LastUpdated[token] = bIndex newBatch := log.Size() >= state.TokenTransferBatchSize
*newBatch = log.Size() >= state.TokenTransferBatchSize if newBatch {
if *newBatch { cache.PutTokenTransferLog(addr, currTimestamp, nextBatch, isNEP11, log)
cache.PutTokenTransferLog(addr, *currTimestamp, *nextBatch, isNEP11, log)
*nextBatch++
*currTimestamp = bTimestamp
// Put makes a copy of it anyway. // Put makes a copy of it anyway.
log.Reset() log.Reset()
} }
appendTokenTransferInfo(&transferData.Info, token, bIndex, bTimestamp, isNEP11, newBatch)
transCache[addr] = transferData transCache[addr] = transferData
return nil return nil
} }