mirror of
https://github.com/0glabs/0g-chain.git
synced 2024-12-26 00:05:18 +00:00
d849d690e5
* wip: tpyes and keeper methods * wip: iterators * wip: types and keeper methods * wip: add msgs * wip: client methods * wip: rebase develop * wip: types tests * wip: keeper tests, small fixes * wip: add cdp tests * wip: deposit tests * wip: keeper tests * wip: tests and module methods * feat: error when fetching expired price * feat: conversion factor for external assets * feat: debt floor for new cdps * feat: save deposits on export genesis * feat: ensure messages implement msg * feat: index deposits by status * fix: stray comment * wip: address review comments * address review comments
79 lines
2.2 KiB
Go
79 lines
2.2 KiB
Go
package keeper
|
|
|
|
import (
|
|
"github.com/cosmos/cosmos-sdk/codec"
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
abci "github.com/tendermint/tendermint/abci/types"
|
|
|
|
"github.com/kava-labs/kava/x/pricefeed/types"
|
|
)
|
|
|
|
// NewQuerier is the module level router for state queries
|
|
func NewQuerier(keeper Keeper) sdk.Querier {
|
|
return func(ctx sdk.Context, path []string, req abci.RequestQuery) (res []byte, err sdk.Error) {
|
|
switch path[0] {
|
|
case types.QueryCurrentPrice:
|
|
return queryCurrentPrice(ctx, path[1:], req, keeper)
|
|
case types.QueryRawPrices:
|
|
return queryRawPrices(ctx, path[1:], req, keeper)
|
|
case types.QueryAssets:
|
|
return queryAssets(ctx, req, keeper)
|
|
default:
|
|
return nil, sdk.ErrUnknownRequest("unknown pricefeed query endpoint")
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
func queryCurrentPrice(ctx sdk.Context, path []string, req abci.RequestQuery, keeper Keeper) (res []byte, err sdk.Error) {
|
|
marketID := path[0]
|
|
_, found := keeper.GetMarket(ctx, marketID)
|
|
if !found {
|
|
return []byte{}, sdk.ErrUnknownRequest("asset not found")
|
|
}
|
|
currentPrice, err := keeper.GetCurrentPrice(ctx, marketID)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
bz, err2 := codec.MarshalJSONIndent(keeper.cdc, currentPrice)
|
|
if err2 != nil {
|
|
panic("could not marshal result to JSON")
|
|
}
|
|
|
|
return bz, nil
|
|
}
|
|
|
|
func queryRawPrices(ctx sdk.Context, path []string, req abci.RequestQuery, keeper Keeper) (res []byte, err sdk.Error) {
|
|
var priceList types.QueryRawPricesResp
|
|
marketID := path[0]
|
|
_, found := keeper.GetMarket(ctx, marketID)
|
|
if !found {
|
|
return []byte{}, sdk.ErrUnknownRequest("asset not found")
|
|
}
|
|
rawPrices := keeper.GetRawPrices(ctx, marketID)
|
|
for _, price := range rawPrices {
|
|
priceList = append(priceList, price.String())
|
|
}
|
|
bz, err2 := codec.MarshalJSONIndent(keeper.cdc, priceList)
|
|
if err2 != nil {
|
|
panic("could not marshal result to JSON")
|
|
}
|
|
|
|
return bz, nil
|
|
}
|
|
|
|
func queryAssets(ctx sdk.Context, req abci.RequestQuery, keeper Keeper) (res []byte, err sdk.Error) {
|
|
var assetList types.QueryAssetsResp
|
|
assets := keeper.GetMarketParams(ctx)
|
|
for _, asset := range assets {
|
|
assetList = append(assetList, asset.String())
|
|
}
|
|
bz, err2 := codec.MarshalJSONIndent(keeper.cdc, assetList)
|
|
if err2 != nil {
|
|
panic("could not marshal result to JSON")
|
|
}
|
|
|
|
return bz, nil
|
|
}
|