|
@@ -1,6 +1,9 @@
|
|
|
import os
|
|
import os
|
|
|
from datetime import datetime
|
|
from datetime import datetime
|
|
|
import requests
|
|
import requests
|
|
|
|
|
+import json
|
|
|
|
|
+
|
|
|
|
|
+base_url = 'https://discordapp.com/api/webhooks/'
|
|
|
|
|
|
|
|
|
|
|
|
|
def create_message(name, timestamp, price, quantity, current_quantity=0, forecast_previous="",
|
|
def create_message(name, timestamp, price, quantity, current_quantity=0, forecast_previous="",
|
|
@@ -38,10 +41,15 @@ def broadcast(this_message):
|
|
|
"""
|
|
"""
|
|
|
# development only
|
|
# development only
|
|
|
# load_dotenv()
|
|
# load_dotenv()
|
|
|
- url = os.environ["BROADCAST_URL"]
|
|
|
|
|
- json = {'content': this_message}
|
|
|
|
|
- response = requests.post(url, json=json)
|
|
|
|
|
- if response.status_code in [200, 204]:
|
|
|
|
|
- print("Webhook executed")
|
|
|
|
|
- else:
|
|
|
|
|
- print("status code {}: {}".format(response.status_code, response.content.decode("utf-8")))
|
|
|
|
|
|
|
+ # url = os.environ["BROADCAST_URL"]
|
|
|
|
|
+ webhooks_json = os.environ["DISCORD_TOKENS"]
|
|
|
|
|
+ webhooks = json.loads(webhooks_json)
|
|
|
|
|
+ content = {'content': this_message}
|
|
|
|
|
+ for webhook_key in webhooks:
|
|
|
|
|
+ webhook = webhooks[webhook_key]
|
|
|
|
|
+ url = base_url + webhook
|
|
|
|
|
+ response = requests.post(url, json=content)
|
|
|
|
|
+ if response.status_code in [200, 204]:
|
|
|
|
|
+ print("Webhook executed")
|
|
|
|
|
+ else:
|
|
|
|
|
+ print("status code {}: {}".format(response.status_code, response.content.decode("utf-8")))
|