mirror of
https://github.com/alexgo-io/libbrc20-indexer.git
synced 2026-04-29 04:05:13 +08:00
41 lines
1.3 KiB
Go
41 lines
1.3 KiB
Go
package indexer
|
|
|
|
import (
|
|
"errors"
|
|
"log"
|
|
|
|
"github.com/unisat-wallet/libbrc20-indexer/conf"
|
|
"github.com/unisat-wallet/libbrc20-indexer/model"
|
|
"github.com/unisat-wallet/libbrc20-indexer/utils"
|
|
)
|
|
|
|
func (g *BRC20ModuleIndexer) ProcessCommitFunctionSend(moduleInfo *model.BRC20ModuleSwapInfo, f *model.SwapFunctionData) error {
|
|
addressTo := f.Params[0]
|
|
pkScriptTo, _ := utils.GetPkScriptByAddress(addressTo, conf.GlobalNetParams)
|
|
|
|
token := f.Params[1]
|
|
tokenAmtStr := f.Params[2]
|
|
|
|
tokenAmt, _ := g.CheckTickVerify(token, tokenAmtStr)
|
|
tokenBalanceFrom := moduleInfo.GetUserTokenBalance(token, f.PkScript)
|
|
|
|
// fixme: Must use the confirmed amount
|
|
if tokenBalanceFrom.SwapAccountBalance.Cmp(tokenAmt) < 0 {
|
|
log.Printf("token[%s] user[%s], balance %s", token, f.Address, tokenBalanceFrom)
|
|
return errors.New("send: token balance insufficient")
|
|
}
|
|
|
|
tokenBalanceTo := moduleInfo.GetUserTokenBalance(token, string(pkScriptTo))
|
|
|
|
// User Real-time Balance Update
|
|
tokenBalanceFrom.SwapAccountBalance = tokenBalanceFrom.SwapAccountBalance.Sub(tokenAmt)
|
|
tokenBalanceTo.SwapAccountBalance = tokenBalanceTo.SwapAccountBalance.Add(tokenAmt)
|
|
|
|
tokenBalanceFrom.UpdateHeight = g.BestHeight
|
|
tokenBalanceTo.UpdateHeight = g.BestHeight
|
|
|
|
log.Printf("pool send [%s] swappable: %s -> %s", token, tokenBalanceFrom.SwapAccountBalance, tokenBalanceTo.SwapAccountBalance)
|
|
|
|
return nil
|
|
}
|