65 lines
4.6 KiB
Python
65 lines
4.6 KiB
Python
import requests
|
|
import os
|
|
from bson.objectid import ObjectId
|
|
url = "https://api.plenusbot.xyz/epic_games?country=IT"
|
|
response = requests.get(url).json()
|
|
|
|
def notification_game1(collection_game, collection_id, bot, OBJECTID_idlist, OBJECTID_game1):
|
|
try:
|
|
print("Try to send first game")
|
|
|
|
#All information for first game
|
|
current_games_title1 = response['currentGames'][0]['title'] # First title current games
|
|
current_games_description1 = response['currentGames'][0]['description'] # First description current games
|
|
current_games_startdate1 = response['currentGames'][0]['promotions']['promotionalOffers'][0]['promotionalOffers'][0]['startDate'] # Public release first game
|
|
current_games_endate1 = response['currentGames'][0]['promotions']['promotionalOffers'][0]['promotionalOffers'][0]['endDate'] # End public release first game
|
|
current_games_price1 = response['currentGames'][0]['price']['totalPrice']['fmtPrice']['originalPrice']
|
|
current_games_images1 = response['currentGames'][0]['keyImages'][0]['url'] # First image current games
|
|
|
|
query = {"_id": ObjectId(OBJECTID_idlist)}
|
|
filter = {"_id": 0}
|
|
collection_find_username = collection_id.find_one(query, filter)
|
|
|
|
#Get just the array
|
|
array_username = collection_find_username["username"]
|
|
for i in array_username:
|
|
#Send first and second message when the free game title change
|
|
title_description_1 = current_games_title1 + "\n\n<b>About:</b>\n" + current_games_description1 + "\n" + "\n<b>Start Date:</b>\n" + current_games_startdate1 + "\n" + "\n<b>End Date:</b>\n" + current_games_endate1 + "\n" + "\n<b>Price:</b>\n" + current_games_price1 + " → " + "Free" # Send title, description, start date and price first current game
|
|
img_1 = bot.send_photo(i, current_games_images1) # Send image first current games
|
|
send_message = bot.send_message(i, title_description_1, parse_mode="HTML") # Send all
|
|
|
|
#Update Collection with new game
|
|
send_game1 = {"Game 1": current_games_title1}
|
|
x = collection_game.update_one({'_id':ObjectId(OBJECTID_game1)}, {"$set": send_game1}, upsert=False)
|
|
except:
|
|
print("An error occurred")
|
|
recheck_game(collection_game=collection_game, collection_id=collection_id, bot=bot, OBJECTID_idlist=OBJECTID_idlist, OBJECTID_game1=OBJECTID_game1)
|
|
|
|
def notification_game2(collection_game, collection_id, bot, OBJECTID_idlist, OBJECTID_game1, OBJECTID_game2):
|
|
try:
|
|
print("Try to send second game")
|
|
#All information for second game
|
|
current_games_title2 = response['currentGames'][1]['title'] # Second title current game
|
|
current_games_images2 = response['currentGames'][1]['keyImages'][0]['url'] # Second image current game
|
|
current_games_description2 = response['currentGames'][1]['description'] # Second description current game
|
|
current_games_startdate2 = response['currentGames'][1]['promotions']['promotionalOffers'][0]['promotionalOffers'][0]['startDate'] #Public release second game
|
|
current_games_endate2 = response['currentGames'][1]['promotions']['promotionalOffers'][0]['promotionalOffers'][0]['endDate'] # End public release second game
|
|
current_games_price2 = response['currentGames'][1]['price']['totalPrice']['fmtPrice']['originalPrice'] # Original price second game
|
|
|
|
query = {"_id": ObjectId(OBJECTID_idlist)} #Take ObjectID for search ID user
|
|
filter = {"_id": 0}
|
|
collection_find = collection_id.find_one(query, filter)
|
|
|
|
array_username = collection_find["username"] #Get the array
|
|
for i in array_username:
|
|
title_description_2 = current_games_title2 + "\n\n<b>About:</b>\n" + current_games_description2 + "\n" + "\n<b>Start Date:</b>\n" + current_games_startdate2 + "\n" + "\n<b>End Date:</b>\n" + current_games_endate2 + "\n" + "\n<b>Price:</b>\n" + current_games_price2 + " → " + "Free" # Send title, description, start date and price second current game
|
|
img_2 = bot.send_photo(i, current_games_images2) # Send image second current games
|
|
send_message = bot.send_message(i, title_description_2, parse_mode="HTML") # Send all
|
|
|
|
#Update Collection with new game
|
|
send_game2 = {"Game 2": current_games_title2}
|
|
z = collection_game.update_one({'_id':ObjectId(OBJECTID_game2)}, {"$set": send_game2})
|
|
|
|
except:
|
|
print("An error occurred")
|
|
recheck_game(collection_game=collection_game, collection_id=collection_id, bot=bot, OBJECTID_idlist=OBJECTID_idlist, OBJECTID_game1 = OBJECTID_game1, OBJECTID_game2=OBJECTID_game2) |