[#11] Rename neofs contract to frostfs

Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>

pkg/innerring/processors/frostfs/process_assets.go

@@ -0,0 +1,129 @@
+package frostfs
+
+import (
+	"github.com/TrueCloudLab/frostfs-node/pkg/morph/client/balance"
+	frostfsEvent "github.com/TrueCloudLab/frostfs-node/pkg/morph/event/frostfs"
+	"github.com/nspcc-dev/neo-go/pkg/util"
+	"go.uber.org/zap"
+)
+
+const (
+	// lockAccountLifeTime defines the amount of epochs when lock account is valid.
+	lockAccountLifetime uint64 = 20
+)
+
+// Process deposit event by invoking a balance contract and sending native
+// gas in the sidechain.
+func (np *Processor) processDeposit(deposit *frostfsEvent.Deposit) {
+	if !np.alphabetState.IsAlphabet() {
+		np.log.Info("non alphabet mode, ignore deposit")
+		return
+	}
+
+	prm := balance.MintPrm{}
+
+	prm.SetTo(deposit.To())
+	prm.SetAmount(np.converter.ToBalancePrecision(deposit.Amount()))
+	prm.SetID(deposit.ID())
+
+	// send transferX to a balance contract
+	err := np.balanceClient.Mint(prm)
+	if err != nil {
+		np.log.Error("can't transfer assets to balance contract", zap.Error(err))
+	}
+
+	curEpoch := np.epochState.EpochCounter()
+	receiver := deposit.To()
+
+	// check if the receiver has already received some mint GAS emissions
+	// we should lock there even though LRU cache is already thread save
+	// we lock there because GAS transfer AND cache update must be atomic
+	np.mintEmitLock.Lock()
+	defer np.mintEmitLock.Unlock()
+
+	val, ok := np.mintEmitCache.Get(receiver.String())
+	if ok && val+np.mintEmitThreshold >= curEpoch {
+		np.log.Warn("double mint emission declined",
+			zap.String("receiver", receiver.String()),
+			zap.Uint64("last_emission", val),
+			zap.Uint64("current_epoch", curEpoch))
+
+		return
+	}
+
+	// get gas balance of the node
+	// before gas transfer check if the balance is greater than the threshold
+	balance, err := np.morphClient.GasBalance()
+	if err != nil {
+		np.log.Error("can't get gas balance of the node", zap.Error(err))
+		return
+	}
+
+	if balance < np.gasBalanceThreshold {
+		np.log.Warn("gas balance threshold has been reached",
+			zap.Int64("balance", balance),
+			zap.Int64("threshold", np.gasBalanceThreshold))
+
+		return
+	}
+
+	err = np.morphClient.TransferGas(receiver, np.mintEmitValue)
+	if err != nil {
+		np.log.Error("can't transfer native gas to receiver",
+			zap.String("error", err.Error()))
+
+		return
+	}
+
+	np.mintEmitCache.Add(receiver.String(), curEpoch)
+}
+
+// Process withdraw event by locking assets in the balance account.
+func (np *Processor) processWithdraw(withdraw *frostfsEvent.Withdraw) {
+	if !np.alphabetState.IsAlphabet() {
+		np.log.Info("non alphabet mode, ignore withdraw")
+		return
+	}
+
+	// create lock account
+	lock, err := util.Uint160DecodeBytesBE(withdraw.ID()[:util.Uint160Size])
+	if err != nil {
+		np.log.Error("can't create lock account", zap.Error(err))
+		return
+	}
+
+	curEpoch := np.epochState.EpochCounter()
+
+	prm := balance.LockPrm{}
+
+	prm.SetID(withdraw.ID())
+	prm.SetUser(withdraw.User())
+	prm.SetLock(lock)
+	prm.SetAmount(np.converter.ToBalancePrecision(withdraw.Amount()))
+	prm.SetDueEpoch(int64(curEpoch + lockAccountLifetime))
+
+	err = np.balanceClient.Lock(prm)
+	if err != nil {
+		np.log.Error("can't lock assets for withdraw", zap.Error(err))
+	}
+}
+
+// Process cheque event by transferring assets from the lock account back to
+// the reserve account.
+func (np *Processor) processCheque(cheque *frostfsEvent.Cheque) {
+	if !np.alphabetState.IsAlphabet() {
+		np.log.Info("non alphabet mode, ignore cheque")
+		return
+	}
+
+	prm := balance.BurnPrm{}
+
+	prm.SetTo(cheque.LockAccount())
+	prm.SetAmount(np.converter.ToBalancePrecision(cheque.Amount()))
+	prm.SetID(cheque.ID())
+
+	err := np.balanceClient.Burn(prm)
+	if err != nil {
+		np.log.Error("can't transfer assets to fed contract", zap.Error(err))
+	}
+}