Compare commits

...

1 Commits

Author SHA1 Message Date
Pavel Karpy 8243ac6307 [#128] IR: Do not try to emit GAS to nobody
Fix sending GAS to an empty extra wallets receivers list. Also, send GAS to
extra wallets even if netmap is empty.

Signed-off-by: Pavel Karpy <p.karpy@yadro.com>
2023-03-21 10:54:00 +03:00
1 changed files with 19 additions and 14 deletions

View File

@ -49,15 +49,18 @@ func (ap *Processor) processEmit() {
} }
nmNodes := networkMap.Nodes() nmNodes := networkMap.Nodes()
nmLen := len(nmNodes)
extraLen := len(ap.parsedWallets)
ln := len(nmNodes) ap.log.Debug("gas emission",
if ln == 0 { zap.Int("network_map", nmLen),
ap.log.Debug("empty network map, do not emit gas") zap.Int("extra_wallets", extraLen))
if nmLen+extraLen == 0 {
return return
} }
gasPerNode := fixedn.Fixed8(ap.storageEmission / uint64(ln+len(ap.parsedWallets))) gasPerNode := fixedn.Fixed8(ap.storageEmission / uint64(nmLen+extraLen))
for i := range nmNodes { for i := range nmNodes {
keyBytes := nmNodes[i].PublicKey() keyBytes := nmNodes[i].PublicKey()
@ -80,9 +83,10 @@ func (ap *Processor) processEmit() {
} }
} }
if extraLen != 0 {
err = ap.morphClient.BatchTransferGas(ap.parsedWallets, gasPerNode) err = ap.morphClient.BatchTransferGas(ap.parsedWallets, gasPerNode)
if err != nil { if err != nil {
receiversLog := make([]string, len(ap.parsedWallets)) receiversLog := make([]string, extraLen)
for i, addr := range ap.parsedWallets { for i, addr := range ap.parsedWallets {
receiversLog[i] = addr.StringLE() receiversLog[i] = addr.StringLE()
} }
@ -93,3 +97,4 @@ func (ap *Processor) processEmit() {
) )
} }
} }
}