grassrootseconomics/sarafu-api
8
0
Fork 0
Code Issues 4 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

add logs,use same pool instance

Browse Source
This commit is contained in:
Carlosokumu 2025-03-12 23:18:36 +03:00
parent 3244c717cb
commit 5432365874
Signed by: carlos
GPG Key ID: 7BD6BC8160A5C953
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
dev/api.go
View File

@ -213,17 +213,15 @@ func (das *DevAccountService) loadAlias(ctx context.Context, alias string, key [
return nil return nil
} }
func (das *DevAccountService) loadPoolInfo(ctx context.Context, name string, key []byte) error { func (das *DevAccountService) loadPoolInfo(ctx context.Context, name string, v []byte) error {
var pool Pool var pool Pool
poolB, err := das.db.Get(ctx, key)
if err != nil { err := json.Unmarshal(v, &pool)
return err
}
err = json.Unmarshal(poolB, &pool)
if err != nil { if err != nil {
return fmt.Errorf("failed to unmarshall pool info: %v", err) return fmt.Errorf("failed to unmarshall pool info: %v", err)
} }
das.pool = pool das.pool = pool
logg.InfoCtxf(ctx, "loaded pool info", "name", das.pool.name, "vouchers", das.pool.vouchers)
return nil return nil
} }
@ -260,13 +258,13 @@ func (das *DevAccountService) loadAll(ctx context.Context) error {
} }
for true { for true {
k, v := dumper.Next(ctx) k, v := dumper.Next(ctx)
logg.InfoCtxf(ctx, "loading all", "key", string(k), "value", string(v))
if k == nil { if k == nil {
break break
} }
if !bytes.HasPrefix(k, das.pfx) { if !bytes.HasPrefix(k, das.pfx) {
continue continue
} }
err = das.loadItem(ctx, k, v) err = das.loadItem(ctx, k, v)
if err != nil { if err != nil {
return err return err
@ -485,11 +483,13 @@ func (das *DevAccountService) PoolDeposit(ctx context.Context, amount, from, poo
return nil, fmt.Errorf("voucher address %v found but does not resolve", tokenAddress) return nil, fmt.Errorf("voucher address %v found but does not resolve", tokenAddress)
} }
das.pool = Pool{ das.pool.vouchers = append(das.pool.vouchers, voucher)
vouchers: append(das.pool.vouchers, voucher), das.pool.poolLimit = map[string]string{tokenAddress: amount}
poolLimit: map[string]string{tokenAddress: amount},
err = das.savePoolInfo(ctx, das.pool)
if err != nil {
return nil, err
} }
das.savePoolInfo(ctx, das.pool)
return &models.PoolDepositResult{ return &models.PoolDepositResult{
TrackingId: uid.String(), TrackingId: uid.String(),
}, nil }, nil
@ -511,7 +511,7 @@ func (das *DevAccountService) GetPoolSwapQuote(ctx context.Context, amount, from
if !p.hasVoucher(toTokenAddress) { if !p.hasVoucher(toTokenAddress) {
return nil, fmt.Errorf("Voucher with address: %v not found in the pool", toTokenAddress) return nil, fmt.Errorf("Voucher with address: %v not found in the pool", toTokenAddress)
} }
//Return a a quote that is equal to the amount enter //Return a a quote that is equal to the amount entered
return &models.PoolSwapQuoteResult{IncludesFeesDeduction: false, OutValue: amount}, nil return &models.PoolSwapQuoteResult{IncludesFeesDeduction: false, OutValue: amount}, nil
} }