grassrootseconomics/sarafu-vise
8
0
Fork 0
Code Issues 15 Pull Requests 3 Actions Packages Projects Releases Wiki Activity

use the userstore instead of the prefixdb

Browse Source
This commit is contained in:
Alfred Kamanda 2025-05-19 02:30:12 +03:00
parent c8159113f0
commit 7d8631fa87
Signed by: Alfred-mk
GPG Key ID: 7EA3D01708908703
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
store/pools.go
View File

@ -23,8 +23,8 @@ func ProcessPools(pools []dataserviceapi.PoolDetails) PoolsMetadata {
for i, p := range pools { for i, p := range pools {
poolNames = append(poolNames, fmt.Sprintf("%d:%s", i+1, p.PoolName)) poolNames = append(poolNames, fmt.Sprintf("%d:%s", i+1, p.PoolName))
poolSymbols = append(poolSymbols, fmt.Sprintf("%d:%s", i+1, p.PoolSymbol)) poolSymbols = append(poolSymbols, fmt.Sprintf("%d:%s", i+1, p.PoolSymbol))
poolContractAdrresses = append(poolContractAdrresses, fmt.Sprintf("%d:%s", i+1, p.PoolContractAdrress)) poolContractAdrresses = append(poolContractAdrresses, fmt.Sprintf("%d:%s", i+1, p.PoolContractAdrress))
} }
data.PoolNames = strings.Join(poolNames, "\n") data.PoolNames = strings.Join(poolNames, "\n")
@ -36,7 +36,7 @@ func ProcessPools(pools []dataserviceapi.PoolDetails) PoolsMetadata {
// GetPoolData retrieves and matches pool data // GetPoolData retrieves and matches pool data
// if no match is found, it fetches the API with the symbol // if no match is found, it fetches the API with the symbol
func GetPoolData(ctx context.Context, db storedb.PrefixDb, input string) (*dataserviceapi.PoolDetails, error) { func GetPoolData(ctx context.Context, store DataStore, sessionId string, input string) (*dataserviceapi.PoolDetails, error) {
keys := []storedb.DataTyp{ keys := []storedb.DataTyp{
storedb.DATA_POOL_NAMES, storedb.DATA_POOL_NAMES,
storedb.DATA_POOL_SYMBOLS, storedb.DATA_POOL_SYMBOLS,
@ -45,9 +45,9 @@ func GetPoolData(ctx context.Context, db storedb.PrefixDb, input string) (*datas
data := make(map[storedb.DataTyp]string) data := make(map[storedb.DataTyp]string)
for _, key := range keys { for _, key := range keys {
value, err := db.Get(ctx, storedb.ToBytes(key)) value, err := store.ReadEntry(ctx, sessionId, key)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to get prefix key %x: %v", storedb.ToBytes(key), err) return nil, fmt.Errorf("failed to get data key %x: %v", key, err)
} }
data[key] = string(value) data[key] = string(value)
} }
@ -63,9 +63,9 @@ func GetPoolData(ctx context.Context, db storedb.PrefixDb, input string) (*datas
} }
return &dataserviceapi.PoolDetails{ return &dataserviceapi.PoolDetails{
PoolName: string(name), PoolName: string(name),
PoolSymbol: string(symbol), PoolSymbol: string(symbol),
PoolContractAdrress: string(address), PoolContractAdrress: string(address),
}, nil }, nil
} }