Skip to content

Commit e5a2064

Browse files
jbonzojbonzo
committed
better formatting and returns json response
1 parent 7eb65b7 commit e5a2064

File tree

3 files changed

+41
-41
lines changed

3 files changed

+41
-41
lines changed

‎polygon/rest/__init__.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
from .rest_client import RESTClient
1+
from .rest_client import RESTClient

‎polygon/rest/rest_client.py‎

Lines changed: 39 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -13,156 +13,156 @@ def __init__(self, auth_key):
1313

1414
def tickers(self, **query_params):
1515
endpoint = f"{self.url}/v2/reference/tickers"
16-
return self._session.get(endpoint, params=query_params)
16+
return self._session.get(endpoint, params=query_params).json()
1717

1818
def ticker_types(self, **query_params):
1919
endpoint = f"{self.url}/v2/reference/types"
20-
return self._session.get(endpoint, params=query_params)
20+
return self._session.get(endpoint, params=query_params).json()
2121

2222
def ticker_details(self, symbol, **query_params):
2323
endpoint = f"{self.url}/v1/meta/symbols/{symbol}/company"
24-
return self._session.get(endpoint, params=query_params)
24+
return self._session.get(endpoint, params=query_params).json()
2525

2626
def ticker_news(self, symbol, **query_params):
2727
endpoint = f"{self.url}/v1/meta/symbols/{symbol}/news"
28-
return self._session.get(endpoint, params=query_params)
28+
return self._session.get(endpoint, params=query_params).json()
2929

3030
def markets(self, **query_params):
3131
endpoint = f"{self.url}/v2/reference/markets"
32-
return self._session.get(endpoint, params=query_params)
32+
return self._session.get(endpoint, params=query_params).json()
3333

3434
def locales(self, **query_params):
3535
endpoint = f"{self.url}/v2/reference/locales"
36-
return self._session.get(endpoint, params=query_params)
36+
return self._session.get(endpoint, params=query_params).json()
3737

3838
def stock_splits(self, symbol, **query_params):
3939
endpoint = f"{self.url}/v2/reference/splits/{symbol}"
40-
return self._session.get(endpoint, params=query_params)
40+
return self._session.get(endpoint, params=query_params).json()
4141

4242
def stock_dividends(self, symbol, **query_params):
4343
endpoint = f"{self.url}/v2/reference/dividends/{symbol}"
44-
return self._session.get(endpoint, params=query_params)
44+
return self._session.get(endpoint, params=query_params).json()
4545

4646
def stock_financials(self, symbol, **query_params):
4747
endpoint = f"{self.url}/v2/reference/financials/{symbol}"
48-
return self._session.get(endpoint, params=query_params)
48+
return self._session.get(endpoint, params=query_params).json()
4949

5050
def market_status(self, **query_params):
5151
endpoint = f"{self.url}/v1/marketstatus/now"
52-
return self._session.get(endpoint, params=query_params)
52+
return self._session.get(endpoint, params=query_params).json()
5353

5454
def market_holidays(self, **query_params):
5555
endpoint = f"{self.url}/v1/marketstatus/upcoming"
56-
return self._session.get(endpoint, params=query_params)
56+
return self._session.get(endpoint, params=query_params).json()
5757

5858
def exchanges(self, **query_params):
5959
endpoint = f"{self.url}/v1/meta/exchanges"
60-
return self._session.get(endpoint, params=query_params)
60+
return self._session.get(endpoint, params=query_params).json()
6161

6262
def historic_trades(self, symbol, date, **query_params):
6363
endpoint = f"{self.url}/v1/historic/trades/{symbol}/{date}"
64-
return self._session.get(endpoint, params=query_params)
64+
return self._session.get(endpoint, params=query_params).json()
6565

6666
def v2_historic_trades(self, ticker, date, **query_params):
6767
endpoint = f"{self.url}/v2/ticks/stocks/trades/{ticker}/{date}"
68-
return self._session.get(endpoint, params=query_params)
68+
return self._session.get(endpoint, params=query_params).json()
6969

7070
def historic_quotes(self, symbol, date, **query_params):
7171
endpoint = f"{self.url}/v1/historic/quotes/{symbol}/{date}"
72-
return self._session.get(endpoint, params=query_params)
72+
return self._session.get(endpoint, params=query_params).json()
7373

7474
def v2_historic_nbbo_quotes(self, ticker, date, **query_params):
7575
endpoint = f"{self.url}/v2/ticks/stocks/nbbo/{ticker}/{date}"
76-
return self._session.get(endpoint, params=query_params)
76+
return self._session.get(endpoint, params=query_params).json()
7777

7878
def last_trade_for_a_symbol(self, symbol, **query_params):
7979
endpoint = f"{self.url}/v1/last/stocks/{symbol}"
80-
return self._session.get(endpoint, params=query_params)
80+
return self._session.get(endpoint, params=query_params).json()
8181

8282
def last_quote_for_a_symbol(self, symbol, **query_params):
8383
endpoint = f"{self.url}/v1/last_quote/stocks/{symbol}"
84-
return self._session.get(endpoint, params=query_params)
84+
return self._session.get(endpoint, params=query_params).json()
8585

8686
def daily_open_close(self, symbol, date, **query_params):
8787
endpoint = f"{self.url}/v1/open-close/{symbol}/{date}"
88-
return self._session.get(endpoint, params=query_params)
88+
return self._session.get(endpoint, params=query_params).json()
8989

9090
def condition_mappings(self, ticktype, **query_params):
9191
endpoint = f"{self.url}/v1/meta/conditions/{ticktype}"
92-
return self._session.get(endpoint, params=query_params)
92+
return self._session.get(endpoint, params=query_params).json()
9393

9494
def snapshot_all_tickers(self, **query_params):
9595
endpoint = f"{self.url}/v2/snapshot/locale/us/markets/stocks/tickers"
96-
return self._session.get(endpoint, params=query_params)
96+
return self._session.get(endpoint, params=query_params).json()
9797

9898
def snapshot_single_ticker(self, ticker, **query_params):
9999
endpoint = f"{self.url}/v2/snapshot/locale/us/markets/stocks/tickers/{ticker}"
100-
return self._session.get(endpoint, params=query_params)
100+
return self._session.get(endpoint, params=query_params).json()
101101

102102
def snapshot_gainers_losers(self, direction, **query_params):
103103
endpoint = f"{self.url}/v2/snapshot/locale/us/markets/stocks/{direction}"
104-
return self._session.get(endpoint, params=query_params)
104+
return self._session.get(endpoint, params=query_params).json()
105105

106106
def previous_close(self, ticker, **query_params):
107107
endpoint = f"{self.url}/v2/aggs/ticker/{ticker}/prev"
108-
return self._session.get(endpoint, params=query_params)
108+
return self._session.get(endpoint, params=query_params).json()
109109

110110
def aggregates(self, ticker, multiplier, timespan, from_, to, **query_params):
111111
endpoint = f"{self.url}/v2/aggs/ticker/{ticker}/range/{multiplier}/{timespan}/{from_}/{to}"
112-
return self._session.get(endpoint, params=query_params)
112+
return self._session.get(endpoint, params=query_params).json()
113113

114114
def grouped_daily(self, locale, market, date, **query_params):
115115
endpoint = f"{self.url}/v2/aggs/grouped/locale/{locale}/market/{market}/{date}"
116-
return self._session.get(endpoint, params=query_params)
116+
return self._session.get(endpoint, params=query_params).json()
117117

118118
def historic_forex_ticks(self, from_, to, date, **query_params):
119119
endpoint = f"{self.url}/v1/historic/forex/{from_}/{to}/{date}"
120-
return self._session.get(endpoint, params=query_params)
120+
return self._session.get(endpoint, params=query_params).json()
121121

122122
def real_time_currency_conversion(self, from_, to, **query_params):
123123
endpoint = f"{self.url}/v1/conversion/{from_}/{to}"
124-
return self._session.get(endpoint, params=query_params)
124+
return self._session.get(endpoint, params=query_params).json()
125125

126126
def last_quote_for_a_currency_pair(self, from_, to, **query_params):
127127
endpoint = f"{self.url}/v1/last_quote/currencies/{from_}/{to}"
128-
return self._session.get(endpoint, params=query_params)
128+
return self._session.get(endpoint, params=query_params).json()
129129

130130
def snapshot_all_tickers(self, **query_params):
131131
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/forex/tickers"
132-
return self._session.get(endpoint, params=query_params)
132+
return self._session.get(endpoint, params=query_params).json()
133133

134134
def snapshot_gainers_losers(self, direction, **query_params):
135135
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/forex/{direction}"
136-
return self._session.get(endpoint, params=query_params)
136+
return self._session.get(endpoint, params=query_params).json()
137137

138138
def crypto_exchanges(self, **query_params):
139139
endpoint = f"{self.url}/v1/meta/crypto-exchanges"
140-
return self._session.get(endpoint, params=query_params)
140+
return self._session.get(endpoint, params=query_params).json()
141141

142142
def last_trade_for_a_crypto_pair(self, from_, to, **query_params):
143143
endpoint = f"{self.url}/v1/last/crypto/{from_}/{to}"
144-
return self._session.get(endpoint, params=query_params)
144+
return self._session.get(endpoint, params=query_params).json()
145145

146146
def daily_open_close(self, from_, to, date, **query_params):
147147
endpoint = f"{self.url}/v1/open-close/crypto/{from_}/{to}/{date}"
148-
return self._session.get(endpoint, params=query_params)
148+
return self._session.get(endpoint, params=query_params).json()
149149

150150
def historic_crypto_trades(self, from_, to, date, **query_params):
151151
endpoint = f"{self.url}/v1/historic/crypto/{from_}/{to}/{date}"
152-
return self._session.get(endpoint, params=query_params)
152+
return self._session.get(endpoint, params=query_params).json()
153153

154154
def snapshot_all_tickers(self, **query_params):
155155
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/crypto/tickers"
156-
return self._session.get(endpoint, params=query_params)
156+
return self._session.get(endpoint, params=query_params).json()
157157

158158
def snapshot_single_ticker(self, ticker, **query_params):
159159
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/crypto/tickers/{ticker}"
160-
return self._session.get(endpoint, params=query_params)
160+
return self._session.get(endpoint, params=query_params).json()
161161

162162
def snapshot_single_ticker_full_book_l2(self, ticker, **query_params):
163163
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/crypto/tickers/{ticker}/book"
164-
return self._session.get(endpoint, params=query_params)
164+
return self._session.get(endpoint, params=query_params).json()
165165

166166
def snapshot_gainers_losers(self, direction, **query_params):
167167
endpoint = f"{self.url}/v2/snapshot/locale/global/markets/crypto/{direction}"
168-
return self._session.get(endpoint, params=query_params)
168+
return self._session.get(endpoint, params=query_params).json()

‎polygon/websocket/__init__.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
from polygon.websocket.websocket_client import WebSocketClient, STOCKS_CLUSTER, FOREX_CLUSTER, CRYPTO_CLUSTER
1+
from polygon.websocket.websocket_client import WebSocketClient, STOCKS_CLUSTER, FOREX_CLUSTER, CRYPTO_CLUSTER

0 commit comments

Comments
 (0)