Skip to content

Commit 47939ec

Browse files
committed
logging added
1 parent d73d7e4 commit 47939ec

File tree

1 file changed

+16
-5
lines changed

1 file changed

+16
-5
lines changed

duneanalytics/duneanalytics.py

Lines changed: 16 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,19 @@
22
"""This provides the DuneAnalytics class implementation"""
33

44
from requests import Session
5+
import logging
56

67
# --------- Constants --------- #
78

89
BASE_URL = "https://dune.com"
910
GRAPH_URL = 'https://core-hsr.duneanalytics.com/v1/graphql'
1011

1112
# --------- Constants --------- #
13+
logging.basicConfig(
14+
level=logging.INFO,
15+
format='%(asctime)s : %(levelname)s : %(funcName)-9s : %(message)s'
16+
)
17+
logger = logging.getLogger("dune")
1218

1319

1420
class DuneAnalytics:
@@ -70,6 +76,8 @@ def login(self):
7076

7177
self.session.post(auth_url, data=form_data)
7278
self.auth_refresh = self.session.cookies.get('auth-refresh')
79+
if self.auth_refresh is None:
80+
logger.warning("Login Failed!")
7381

7482
def fetch_auth_token(self):
7583
"""
@@ -81,8 +89,10 @@ def fetch_auth_token(self):
8189
response = self.session.post(session_url)
8290
if response.status_code == 200:
8391
self.token = response.json().get('token')
92+
if self.token is None:
93+
logger.warning("Fetching Token Failed!")
8494
else:
85-
print(response.text)
95+
logger.error(response.text)
8696

8797
def query_result_id(self, query_id):
8898
"""
@@ -102,13 +112,14 @@ def query_result_id(self, query_id):
102112
response = self.session.post(GRAPH_URL, json=query_data)
103113
if response.status_code == 200:
104114
data = response.json()
105-
print(data)
115+
logger.debug(data)
106116
if 'errors' in data:
117+
logger.error(data.get('errors'))
107118
return None
108119
result_id = data.get('data').get('get_result_v2').get('result_id')
109120
return result_id
110121
else:
111-
print(response.text)
122+
logger.error(response.text)
112123
return None
113124

114125
def query_result(self, result_id):
@@ -132,8 +143,8 @@ def query_result(self, result_id):
132143
response = self.session.post(GRAPH_URL, json=query_data)
133144
if response.status_code == 200:
134145
data = response.json()
135-
print(data)
146+
logger.debug(data)
136147
return data
137148
else:
138-
print(response.text)
149+
logger.error(response.text)
139150
return {}

0 commit comments

Comments
 (0)