Skip to content

Commit 12fe4f1

Browse files
committed
feat: closure repay amount fix
1 parent 30a582b commit 12fe4f1

File tree

1 file changed

+35
-0
lines changed

1 file changed

+35
-0
lines changed
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
package main
2+
3+
import (
4+
"math/big"
5+
6+
"github.com/Gearbox-protocol/sdk-go/core"
7+
"github.com/Gearbox-protocol/sdk-go/log"
8+
"github.com/Gearbox-protocol/third-eye/config"
9+
"github.com/Gearbox-protocol/third-eye/repository"
10+
)
11+
12+
type data struct {
13+
Transfers core.Hstore `gorm:"column:transfers"`
14+
AmountBi *core.BigInt `gorm:"column:amount_bi"`
15+
LogId int64 `gorm:"column:log_id"`
16+
BlockNum int64 `gorm:"column:block_num"`
17+
}
18+
19+
func main() {
20+
cfg := config.NewConfig()
21+
db := repository.NewDBClient(cfg)
22+
query := `select a.log_id , a.block_num, a.tx_hash, a.transfers, b.amount_bi from (select * from account_operations where action like 'Decrease%' and args->>'amount' = '115792089237316195423570985008687907853269984665640564039457584007913129639935' ) a join (select * from pool_ledger where event='Repay' ) b on b.tx_hash = a.tx_hash;`
23+
d := []data{}
24+
err := db.Raw(query).Find(&d).Error
25+
log.CheckFatal(err)
26+
for _, entry := range d {
27+
m := entry.Transfers.GetMap()
28+
for key := range m {
29+
m[key] = new(big.Int).Neg(entry.AmountBi.Convert()).String()
30+
}
31+
log.Info(m)
32+
err = db.Exec(`update account_operations set transfers =? where log_id =? and block_num = ?`, entry.Transfers, entry.LogId, entry.BlockNum).Error
33+
log.CheckFatal(err)
34+
}
35+
}

0 commit comments

Comments
 (0)