Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

1.2.0 #17

Merged
merged 7 commits into from
Aug 28, 2024
Merged

1.2.0 #17

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
6d8db86
Add new endpoints, comment functions, fix types, add black code style
sndmndss Aug 28, 2024
629b8a6
1.2.0
sndmndss Aug 28, 2024
34c68cf
delete simulations for updating
sndmndss Aug 28, 2024
b6fa411
fix proxy init
sndmndss Aug 28, 2024
4942edc
typing for older python versions
sndmndss Aug 28, 2024
0e64ab3
fix proxy typing
sndmndss Aug 28, 2024
edca0b7
fix all typings
sndmndss Aug 28, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
236 changes: 166 additions & 70 deletions bpx/account.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,110 +1,206 @@
from bpx.base.base_account import BaseAccount
from bpx.http_client.sync_http_client import SyncHttpClient
from typing import Optional

http_client = SyncHttpClient()


class Account(BaseAccount):
def __init__(self,
public_key: str,
secret_key: str,
window: int = 5000,
proxy: dict = {},
debug: bool = False,
default_http_client: SyncHttpClient = http_client
):

super().__init__(public_key,
secret_key,
window,
debug)
def __init__(
self,
public_key: str,
secret_key: str,
window: int = 5000,
proxy: Optional[dict] = None,
debug: bool = False,
default_http_client: SyncHttpClient = http_client,
):
super().__init__(public_key, secret_key, window, debug)
self.http_client = default_http_client
self.http_client.proxies = proxy

def get_balances(self, window: int = None):
def get_balances(self, window: Optional[int] = None):
"""
Returns the account balances

https://docs.backpack.exchange/#tag/Capital/operation/get_balances
"""
url, headers = super().get_balances(window)
return self.http_client.get(url, headers=headers)

def get_deposits(self, limit: int = 100, offset: int = 0,
from_: int = None, to: int = None, window: int = None):

def get_deposits(
self,
limit: int = 100,
offset: int = 0,
from_: Optional[int] = None,
to: Optional[int] = None,
window: Optional[int] = None,
):
"""
Returns the account deposits

https://docs.backpack.exchange/#tag/Capital/operation/get_deposits
"""
url, headers, params = super().get_deposits(limit, offset, window, from_, to)
return self.http_client.get(url, headers=headers, params=params)

def get_deposit_address(self, blockchain: str, window: int = None):
def get_deposit_address(self, blockchain: str, window: Optional[int] = None):
"""
Returns the deposit address for a specified blockchain

https://docs.backpack.exchange/#tag/Capital/operation/get_deposit_address
"""
url, headers, params = super().get_deposit_address(blockchain, window)
return self.http_client.get(url, headers=headers, params=params)

def get_withdrawals(self, limit: int = 100, offset: int = 0,
from_: int = None, to: int = None, window: int = None):

def get_withdrawals(
self,
limit: int = 100,
offset: int = 0,
from_: Optional[int] = None,
to: Optional[int] = None,
window: Optional[int] = None,
):
"""
Returns the account withdrawals

https://docs.backpack.exchange/#tag/Capital/operation/get_withdrawals
"""
url, headers, params = super().get_withdrawals(limit, offset, from_, to, window)
return self.http_client.get(url, headers=headers, params=params)

def withdrawal(self, address: str,
symbol: str,
blockchain: str,
quantity: str,
window: int = None):
url, headers, params = super().withdrawal(address, symbol, blockchain, quantity, window)
def withdrawal(
self,
address: str,
symbol: str,
blockchain: str,
quantity: str,
window: Optional[int] = None,
):
"""
Posts withdrawal and returns withdrawal status

https://docs.backpack.exchange/#tag/Capital/operation/request_withdrawal
"""
url, headers, params = super().withdrawal(
address, symbol, blockchain, quantity, window
)
return self.http_client.post(url, headers=headers, data=params)

def get_order_history_query(self, symbol: str, limit: int = 100, offset: int = 0, window: int = None):
url, headers, params = super().get_order_history_query(symbol, limit, offset, window)
def get_order_history_query(
self, symbol: str, limit: int = 100, offset: int = 0, window: Optional[int] = None
):
"""
Returns orders history of a specified symbol

https://docs.backpack.exchange/#tag/History/operation/get_order_history
"""
url, headers, params = super().get_order_history_query(
symbol, limit, offset, window
)
return self.http_client.get(url, headers=headers, params=params)

def get_fill_history_query(self, symbol: str,
limit: int = 100,
offset: int = 0,
from_: int = None,
to: int = None,
window: int = None):
url, headers, params = super().get_fill_history_query(symbol,
limit,
offset,
from_,
to,
window)
def get_fill_history_query(
self,
symbol: str,
limit: int = 100,
offset: int = 0,
from_: Optional[int] = None,
to: Optional[int] = None,
window: Optional[int] = None,
):
"""
Returns fills history of a specified symbol

https://docs.backpack.exchange/#tag/History/operation/get_fills
"""
url, headers, params = super().get_fill_history_query(
symbol, limit, offset, from_, to, window
)
return self.http_client.get(url, headers=headers, params=params)

def get_open_order(self, symbol: str,
order_id: str = None,
client_id: int = None,
window: int = None):
url, headers, params = super().get_open_order(symbol, order_id, client_id, window)
def get_open_order(
self,
symbol: str,
order_id: Optional[str] = None,
client_id: Optional[int] = None,
window: Optional[int] = None,
):
"""
Returns open orders of a specified symbol

https://docs.backpack.exchange/#tag/Order/operation/get_order
"""
url, headers, params = super().get_open_order(
symbol, order_id, client_id, window
)
return self.http_client.get(url, headers=headers, params=params)

def execute_order(self, symbol: str,
side: str,
order_type: str,
quantity: float,
time_in_force: str = None,
price: float = 0,
trigger_price: float = 0,
self_trade_prevention: str = "RejectBoth",
quote_quantity: float = None,
client_id: int = None,
post_only: bool = None,
window: int = None):

url, headers, params = super().execute_order(symbol, side, order_type,
time_in_force, quantity,
price, trigger_price,
self_trade_prevention, quote_quantity,
client_id, post_only, window)
def execute_order(
self,
symbol: str,
side: str,
order_type: str,
quantity: Optional[float] = None,
time_in_force: Optional[str] = None,
price: float = 0,
trigger_price: float = 0,
self_trade_prevention: str = "RejectBoth",
quote_quantity: Optional[float] = None,
client_id: Optional[int] = None,
post_only: Optional[bool] = None,
window: Optional[int] = None,
):
"""
Posts order and returns the status of the executed order

https://docs.backpack.exchange/#tag/Order/operation/execute_order
"""
url, headers, params = super().execute_order(
symbol,
side,
order_type,
time_in_force,
quantity,
price,
trigger_price,
self_trade_prevention,
quote_quantity,
client_id,
post_only,
window,
)
return self.http_client.post(url, headers=headers, data=params)

def cancel_order(self, symbol: str,
order_id: str = None,
client_id: int = None,
window: int = None):
def cancel_order(
self,
symbol: str,
order_id: Optional[str] = None,
client_id: Optional[int] = None,
window: Optional[int] = None,
):
"""
Cancels an existing order

https://docs.backpack.exchange/#tag/Order/operation/cancel_order
"""
url, headers, params = super().cancel_order(symbol, order_id, client_id, window)
return self.http_client.delete(url, headers=headers, data=params)

def get_open_orders(self, symbol: str = None, window: int = None):
def get_open_orders(self, symbol: str, window: Optional[int] = None):
"""
Returns open orders of a specified symbol

https://docs.backpack.exchange/#tag/Order/operation/get_open_orders
"""
url, headers, params = super().get_open_orders(symbol, window)
return self.http_client.get(url, headers=headers, params=params)

def cancel_all_orders(self, symbol: str, window: int = None):
def cancel_all_orders(self, symbol: str, window: Optional[int] = None):
"""
Cancels all existing orders of a specified symbol

https://docs.backpack.exchange/#tag/Order/operation/cancel_open_orders
"""
url, headers, params = super().cancel_all_orders(symbol, window)
return self.http_client.delete(url, headers=headers, data=params)
Loading
Loading