Packages
kujira
0.1.63
0.1.80
0.1.79
0.1.78
0.1.77
0.1.76
0.1.75
0.1.74
0.1.73
0.1.72
0.1.71
0.1.70
0.1.69
0.1.68
0.1.67
0.1.66
0.1.65
0.1.64
0.1.63
0.1.62
0.1.61
0.1.60
0.1.59
0.1.58
0.1.57
0.1.56
0.1.55
0.1.54
0.1.53
0.1.52
0.1.51
0.1.50
0.1.49
0.1.48
0.1.47
0.1.46
0.1.45
0.1.44
0.1.43
0.1.42
0.1.41
0.1.40
0.1.39
0.1.38
0.1.37
0.1.36
0.1.35
0.1.34
0.1.33
0.1.32
0.1.31
0.1.30
0.1.29
0.1.28
0.1.27
0.1.25
0.1.24
0.1.23
0.1.22
0.1.21
0.1.20
0.1.19
0.1.18
0.1.17
0.1.16
0.1.15
0.1.14
0.1.13
0.1.12
0.1.10
0.1.9
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
Elixir interfaces to Kujira dApps, for building indexers, APIs and bots
Current section
Files
Jump to
Current section
Files
lib/kujira/orca.ex
defmodule Kujira.Orca do
@moduledoc """
Methods for querying the Orca Liquidation Queues, and related data
"""
alias GRPC.Channel
alias Kujira.Contract
alias Kujira.Orca.Bid
alias Kujira.Orca.Queue
use Memoize
@code_ids Application.compile_env(:kujira, __MODULE__, code_ids: [234, 349])
|> Keyword.get(:code_ids)
@doc """
Fetches the Queue contract and its current config from the chain
"""
@spec get_queue(Channel.t(), String.t()) :: {:ok, Queue.t()} | {:error, :not_found}
def get_queue(channel, address), do: Contract.get(channel, {Queue, address})
@doc """
Fetches all Liquidation Queues
"""
@spec list_queues(GRPC.Channel.t(), list(integer())) ::
{:ok, list(Queue.t())} | {:error, GRPC.RPCError.t()}
def list_queues(channel, code_ids \\ @code_ids) when is_list(code_ids),
do: Contract.list(channel, Queue, code_ids)
@doc """
Loads the current contract state into the Queue; the totals of each bid pool
"""
@spec load_queue(Channel.t(), Queue.t()) :: {:ok, Queue.t()} | {:error, GRPC.RPCError.t()}
def load_queue(channel, queue) do
with {:ok, %{"bid_pools" => bid_pools}} <-
Contract.query_state_smart(channel, queue.address, %{bid_pools: %{limit: 30}}) do
{:ok, Queue.load_pools(bid_pools, queue)}
else
err -> err
end
end
@doc """
Loads a bid for a specific Queue
"""
@spec load_bid(Channel.t(), Queue.t(), String.t()) ::
{:ok, Bid.t()} | {:error, :not_found} | {:error, GRPC.RPCError.t()}
def load_bid(channel, queue, idx) do
with {:ok, bid} <-
Contract.query_state_smart(channel, queue.address, %{bid: %{bid_idx: idx}}) do
{:ok, Bid.from_query(queue, bid)}
else
{:error,
%GRPC.RPCError{
message:
"codespace wasm code 9: query wasm contract failed: Generic error: No bids with the specified information exist",
status: 2
}} ->
{:error, :not_found}
err ->
err
end
end
@doc """
Loads a user's bids for a specific Queue
"""
@spec load_bids(Channel.t(), Queue.t(), String.t()) ::
{:ok, list(Bid.t())} | {:error, GRPC.RPCError.t()}
def load_bids(channel, queue, address, start_after \\ nil) do
with {:ok, %{"bids" => bids}} <-
Contract.query_state_smart(channel, queue.address, %{
bids_by_user: %{bidder: address, start_after: start_after, limit: 30}
}) do
# TODO: Page through > 30
bids = Enum.map(bids, &Bid.from_query(queue, &1))
{:ok, bids}
else
err -> err
end
end
@doc """
Creates a lazy stream for fetching all bids for a Queue
"""
@spec stream_positions(GRPC.Channel.t(), Queue.t()) ::
%Stream{}
def stream_positions(channel, queue) do
channel
|> Contract.stream_state_all(queue.address)
|> Stream.map(&Bid.from_query(queue, &1))
|> Stream.filter(&(not is_nil(&1)))
end
end