|
@@ -7,41 +7,38 @@ from dotenv import load_dotenv
|
|
|
import roman
|
|
import roman
|
|
|
import requests
|
|
import requests
|
|
|
|
|
|
|
|
|
|
+base_url = 'https://discordapp.com/api/webhooks/'
|
|
|
|
|
+
|
|
|
|
|
|
|
|
def send_message(status):
|
|
def send_message(status):
|
|
|
- base_url = 'https://discordapp.com/api/webhooks/'
|
|
|
|
|
load_dotenv()
|
|
load_dotenv()
|
|
|
webhooks_json = os.environ["DISCORD_TOKENS"]
|
|
webhooks_json = os.environ["DISCORD_TOKENS"]
|
|
|
webhooks = json.loads(webhooks_json)
|
|
webhooks = json.loads(webhooks_json)
|
|
|
name = status['name']
|
|
name = status['name']
|
|
|
its_id = status['id']
|
|
its_id = status['id']
|
|
|
- status_text = f"[{name} \[{its_id}\]](https://www.torn.com/profiles.php?XID={its_id}) → Loot level changed to "+roman.toRoman(status['integer'])
|
|
|
|
|
|
|
+ status_text = f"[{name} \[{its_id}\]](https://www.torn.com/profiles.php?XID={its_id}) → " + \
|
|
|
|
|
+ "Loot level changed to "+roman.toRoman(status['integer'])
|
|
|
status_text += "\n" + status['time_string']
|
|
status_text += "\n" + status['time_string']
|
|
|
this_json = {'content': status_text}
|
|
this_json = {'content': status_text}
|
|
|
pprint(this_json)
|
|
pprint(this_json)
|
|
|
- for webhook in webhooks:
|
|
|
|
|
- url = base_url+webhook
|
|
|
|
|
- response = requests.post(url, json=this_json)
|
|
|
|
|
- if response.status_code in [200, 204]:
|
|
|
|
|
- print("Webhook executed")
|
|
|
|
|
- else:
|
|
|
|
|
- print("status code {}: {}".format(response.status_code, response.content.decode("utf-8")))
|
|
|
|
|
- if response.status_code == int(429):
|
|
|
|
|
- sys.exit(1)
|
|
|
|
|
|
|
+ _send(webhooks, this_json)
|
|
|
|
|
|
|
|
|
|
|
|
|
def send_alert(this_alert):
|
|
def send_alert(this_alert):
|
|
|
- base_url = 'https://discordapp.com/api/webhooks/'
|
|
|
|
|
load_dotenv()
|
|
load_dotenv()
|
|
|
webhooks_json = os.environ["DISCORD_TOKENS"]
|
|
webhooks_json = os.environ["DISCORD_TOKENS"]
|
|
|
webhooks = json.loads(webhooks_json)
|
|
webhooks = json.loads(webhooks_json)
|
|
|
this_json = {'content': this_alert}
|
|
this_json = {'content': this_alert}
|
|
|
- for webhook in webhooks:
|
|
|
|
|
|
|
+ _send(webhooks, this_json)
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+def _send(send_webhooks, send_json):
|
|
|
|
|
+ for webhook in send_webhooks:
|
|
|
url = base_url+webhook
|
|
url = base_url+webhook
|
|
|
- response = requests.post(url, json=this_json)
|
|
|
|
|
|
|
+ response = requests.post(url, json=send_json)
|
|
|
if response.status_code in [200, 204]:
|
|
if response.status_code in [200, 204]:
|
|
|
print("Webhook executed")
|
|
print("Webhook executed")
|
|
|
else:
|
|
else:
|
|
|
print("status code {}: {}".format(response.status_code, response.content.decode("utf-8")))
|
|
print("status code {}: {}".format(response.status_code, response.content.decode("utf-8")))
|
|
|
if response.status_code == int(429):
|
|
if response.status_code == int(429):
|
|
|
- sys.exit(1)
|
|
|
|
|
|
|
+ sys.exit(1)
|