adminapi.go

package mongodb

import (
	"errors"
	"fmt"
	"strings"
	"time"

	"github.com/anyswap/CrossChain-Bridge/log"
	"github.com/anyswap/CrossChain-Bridge/tokens"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
)

const (
	minTimeIntervalToReswap = int64(300) // seconds
)

// --------------- blacklist --------------------------------

func getBlacklistKey(address, pairID string) string {
	return strings.ToLower(address + ":" + pairID)
}

// AddToBlacklist add to blacklist
func AddToBlacklist(address, pairID string) error {
	mb := &MgoBlackAccount{
		Key:       getBlacklistKey(address, pairID),
		Address:   strings.ToLower(address),
		PairID:    strings.ToLower(pairID),
		Timestamp: time.Now().Unix(),
	}
	_, err := collBlacklist.InsertOne(clientCtx, mb)
	if err == nil {
		log.Info("mongodb add to black list success", "address", address, "pairID", pairID)
	} else {
		log.Info("mongodb add to black list failed", "address", address, "pairID", pairID, "err", err)
	}
	return mgoError(err)
}

// RemoveFromBlacklist remove from blacklist
func RemoveFromBlacklist(address, pairID string) error {
	_, err := collBlacklist.DeleteOne(clientCtx, bson.M{"_id": getBlacklistKey(address, pairID)})
	if err == nil {
		log.Info("mongodb remove from black list success", "address", address, "pairID", pairID)
	} else {
		log.Info("mongodb remove from black list failed", "address", address, "pairID", pairID, "err", err)
	}
	return mgoError(err)
}

// QueryBlacklist query if is blacked
func QueryBlacklist(address, pairID string) (isBlacked bool, err error) {
	var result MgoBlackAccount
	err = collBlacklist.FindOne(clientCtx, bson.M{"_id": getBlacklistKey(address, pairID)}).Decode(&result)
	if err == nil {
		return true, nil
	}
	if errors.Is(err, mongo.ErrNoDocuments) {
		return false, nil
	}
	return false, err
}

// PassSwapinBigValue pass swapin big value
func PassSwapinBigValue(txid, pairID, bind string) error {
	return passBigValue(txid, pairID, bind, true)
}

// PassSwapoutBigValue pass swapout big value
func PassSwapoutBigValue(txid, pairID, bind string) error {
	return passBigValue(txid, pairID, bind, false)
}

func passBigValue(txid, pairID, bind string, isSwapin bool) error {
	swap, err := FindSwap(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	res, err := FindSwapResult(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	if swap.Status != TxWithBigValue && res.Status != TxWithBigValue {
		return fmt.Errorf("swap status is (%v, %v), not big value status %v", swap.Status.String(), res.Status.String(), TxWithBigValue.String())
	}
	if res.SwapTx != "" || res.SwapHeight != 0 || len(res.OldSwapTxs) > 0 {
		return fmt.Errorf("already swapped with swaptx %v", res.SwapTx)
	}
	err = UpdateSwapResultStatus(isSwapin, txid, pairID, bind, MatchTxEmpty, time.Now().Unix(), "")
	if err != nil {
		return err
	}
	return UpdateSwapStatus(isSwapin, txid, pairID, bind, TxNotSwapped, time.Now().Unix(), "")
}

// ReverifySwapin reverify swapin
func ReverifySwapin(txid, pairID, bind string) error {
	return reverifySwap(txid, pairID, bind, true)
}

// ReverifySwapout reverify swapout
func ReverifySwapout(txid, pairID, bind string) error {
	return reverifySwap(txid, pairID, bind, false)
}

func reverifySwap(txid, pairID, bind string, isSwapin bool) error {
	swap, err := FindSwap(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	if !swap.Status.CanReverify() {
		return fmt.Errorf("swap status is %v, no need to reverify", swap.Status.String())
	}
	return UpdateSwapStatus(isSwapin, txid, pairID, bind, TxNotStable, time.Now().Unix(), "")
}

// Reswapin reswapin
func Reswapin(txid, pairID, bind string) error {
	return reswap(txid, pairID, bind, true)
}

// Reswapout reswapout
func Reswapout(txid, pairID, bind string) error {
	return reswap(txid, pairID, bind, false)
}

func reswap(txid, pairID, bind string, isSwapin bool) error {
	swap, err := FindSwap(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	if !swap.Status.CanReswap() {
		return fmt.Errorf("swap status is %v, can not reswap", swap.Status.String())
	}
	swapResult, err := FindSwapResult(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	err = checkCanReswap(swapResult, isSwapin)
	if err != nil {
		return err
	}

	log.Info("[reswap] update status to TxNotSwapped to retry", "txid", txid, "pairID", pairID, "bind", bind, "swaptx", swapResult.SwapTx)
	err = UpdateSwapResultStatus(isSwapin, txid, pairID, bind, Reswapping, time.Now().Unix(), "")
	if err != nil {
		return err
	}

	return UpdateSwapStatus(isSwapin, txid, pairID, bind, TxNotSwapped, time.Now().Unix(), "")
}

func checkCanReswap(res *MgoSwapResult, isSwapin bool) error {
	swapType := tokens.SwapType(res.SwapType)
	if (isSwapin && swapType != tokens.SwapinType) || (!isSwapin && swapType != tokens.SwapoutType) {
		return fmt.Errorf("wrong swap type %v (isSwapin=%v)", swapType.String(), isSwapin)
	}
	if res.Status != MatchTxFailed {
		return fmt.Errorf("swap result status is %v, can not reswap", res.Status.String())
	}

	if res.SwapTx == "" {
		return errors.New("swap without swaptx")
	}

	bridge := tokens.GetCrossChainBridge(!isSwapin)
	txStatus, txHash := getSwapResultsTxStatus(bridge, res)
	if txStatus != nil && txStatus.BlockHeight > 0 &&
		!txStatus.IsSwapTxOnChainAndFailed(bridge.GetTokenConfig(res.PairID)) {
		_ = UpdateSwapResultStatus(isSwapin, res.TxID, res.PairID, res.Bind, MatchTxNotStable, time.Now().Unix(), "")
		return fmt.Errorf("swap succeed with swaptx %v", txHash)
	}

	return checkReswapNonce(bridge, res)
}

func checkReswapNonce(bridge tokens.CrossChainBridge, res *MgoSwapResult) (err error) {
	nonceSetter, ok := bridge.(tokens.NonceSetter)
	if !ok {
		return nil
	}
	tokenCfg := bridge.GetTokenConfig(res.PairID)
	if tokenCfg == nil {
		return fmt.Errorf("no token config for pairID '%v'", res.PairID)
	}
	// eth enhanced, if we fail at nonce a, we should retry after nonce a
	// to ensure tx with nonce a is on blockchain to prevent double swapping
	var nonce uint64
	retryGetNonceCount := 3
	for i := 0; i < retryGetNonceCount; i++ {
		nonce, err = nonceSetter.GetPoolNonce(tokenCfg.DcrmAddress, "latest")
		if err == nil {
			break
		}
		log.Warn("get account nonce failed", "address", tokenCfg.DcrmAddress)
		time.Sleep(time.Second)
	}
	if nonce <= res.SwapNonce {
		return errors.New("can not reswap with lower nonce")
	}
	if res.Timestamp+minTimeIntervalToReswap > time.Now().Unix() {
		return errors.New("can not reswap in too short interval")
	}
	return nil
}

// ManualManageSwap manual manage swap
func ManualManageSwap(txid, pairID, bind, memo string, isSwapin, isPass bool) error {
	swap, err := FindSwap(isSwapin, txid, pairID, bind)
	if err != nil {
		return err
	}
	if isPass {
		if swap.Status == TxWithBigValue {
			return passBigValue(txid, pairID, bind, isSwapin)
		}
		if swap.Status.CanReverify() || swap.Status == ManualMakeFail {
			return UpdateSwapStatus(isSwapin, txid, pairID, bind, TxNotStable, time.Now().Unix(), memo)
		}
	} else if swap.Status.CanManualMakeFail() {
		_ = UpdateSwapResultStatus(isSwapin, txid, pairID, bind, ManualMakeFail, time.Now().Unix(), memo)
		return UpdateSwapStatus(isSwapin, txid, pairID, bind, ManualMakeFail, time.Now().Unix(), memo)
	}
	return fmt.Errorf("swap status is %v, can not operate. txid=%v pairID=%v bind=%v isSwapin=%v isPass=%v", swap.Status.String(), txid, pairID, bind, isSwapin, isPass)
}

func getSwapResultsTxStatus(bridge tokens.CrossChainBridge, res *MgoSwapResult) (status *tokens.TxStatus, txHash string) {
	var err error
	if status, err = bridge.GetTransactionStatus(res.SwapTx); err == nil {
		return status, res.SwapTx
	}
	for _, tx := range res.OldSwapTxs {
		if status, err = bridge.GetTransactionStatus(tx); err == nil {
			return status, tx
		}
	}
	return nil, ""
}