forked from Cryz/battle_royale_sim
128 lines
4.8 KiB
Python
128 lines
4.8 KiB
Python
#import datetime
|
|
#import pytz
|
|
from telegram.ext import Application
|
|
from telegram.ext import CommandHandler
|
|
from telegram.ext import MessageHandler
|
|
from telegram.ext import filters
|
|
from telegram import ReplyKeyboardMarkup
|
|
from telegram import ReplyKeyboardRemove
|
|
import main as _brsim
|
|
import debug as _dbg
|
|
from bot_libs import player_handling as _bot_player
|
|
from bot_libs import syms as _botsyms
|
|
|
|
async def simulate_day(context, chat_id):
|
|
if 'arena' in context.application.bot_data:
|
|
Arena= context.application.bot_data['arena']
|
|
if len(Arena.get_alive_players()) <= 1: return # TODO break the loop
|
|
print(f'{chat_id}: Guarino ha trovato l\'arena')
|
|
await context.bot.send_message(chat_id, f'Giorno #{Arena.day}')
|
|
msg= _dbg.play_one_day_debug(Arena)
|
|
await context.bot.send_message(chat_id, msg)
|
|
else:
|
|
print('Arena non trovata')
|
|
await context.bot.send_message(chat_id, 'Che e\' successo? un Guarino ha rubato l\'arena, avvia una nuova partita con /start')
|
|
|
|
async def loop_game(context):
|
|
chat_id = context.job.chat_id
|
|
return await simulate_day(context, chat_id)
|
|
|
|
async def bot_start(update, context):
|
|
await update.message.reply_text(_botsyms.START_MSG)
|
|
|
|
keyboard = [
|
|
['Init/Restart'],
|
|
['Add Player'],
|
|
['Get Players', 'Get Alive Players', 'Get Death Players'],
|
|
['Simulate Day', 'Run Periodically']
|
|
]
|
|
reply_markup= ReplyKeyboardMarkup(keyboard, one_time_keyboard=False, resize_keyboard=True)
|
|
|
|
chat_id = update.effective_chat.id
|
|
print(f'{chat_id}: Sto costruendo il mondo di gioco...')
|
|
Arena= _brsim.init_arena()
|
|
|
|
await update.message.reply_text('Ho creato il mondo di gioco', reply_markup=reply_markup)
|
|
context.application.bot_data['arena'] = Arena
|
|
|
|
async def start_loop_game(update, context):
|
|
chat_id = update.effective_chat.id
|
|
if 'arena' not in context.application.bot_data:
|
|
print(f'{chat_id}: Arena non trovata')
|
|
await update.message.reply_text(f'Arena non trovata, avviare con /start')
|
|
return
|
|
|
|
Arena= context.application.bot_data['arena']
|
|
if len(Arena.get_players()) < 2:
|
|
print(f'{chat_id}: Guarino pretende che ci siano almeno 2 giocatori')
|
|
await update.message.reply_text(f'Servono almeno 2 giocatori. Ecco i giocatori presenti nel mondo do gioco: \n{Arena.get_players()}')
|
|
return
|
|
|
|
context.job_queue.run_repeating(loop_game, interval=86400, first=1, chat_id= chat_id)
|
|
#timezone = pytz.timezone('Europe/Rome')
|
|
#context.job_queue.run_daily(
|
|
#loop_game,
|
|
#time=datetime.time(hour=23, minute=40, second=0, tzinfo= timezone),
|
|
#chat_id=chat_id,
|
|
#name=str(chat_id)
|
|
#)
|
|
print(f'Job giornaliero creato per la chat {chat_id}')
|
|
|
|
async def bot_commands(update, context):
|
|
text= update.message.text
|
|
chat_id = update.effective_chat.id
|
|
|
|
if text == 'Init/Restart':
|
|
print(f'bot_command: {chat_id} Init/Restart')
|
|
return await bot_start(update, context)
|
|
|
|
if text == 'Add Player':
|
|
print(f'bot_command: {chat_id} Add Player')
|
|
context.application.bot_data['ask_name'] = 1
|
|
return
|
|
if text == 'Get Players':
|
|
print(f'bot_command: {chat_id} Get Players')
|
|
return await _bot_player.get_players(update, context)
|
|
if text == 'Get Alive Players':
|
|
print(f'bot_command: {chat_id} Get Alive Players')
|
|
return await _bot_player.get_alive_players(update, context)
|
|
if text == 'Get Death Players':
|
|
print(f'bot_command: {chat_id} Get Death Players')
|
|
return await _bot_player.get_death_players(update, context)
|
|
if text == 'Simulate Day':
|
|
print(f'bot_command: {chat_id} Simulate Day')
|
|
return await simulate_day(context, chat_id)
|
|
if text == 'Run Periodically':
|
|
print(f'bot_command: {chat_id} Run Periodically')
|
|
return await update.message.reply_text(_botsyms.WIP_MSG)
|
|
#return await simulate_day(context, chat_id)
|
|
|
|
waiting_for_name= context.application.bot_data.get('ask_name')
|
|
if waiting_for_name:
|
|
print(f'bot_command: {chat_id} Collected Player Name {text}')
|
|
del(context.application.bot_data['ask_name'])
|
|
return await _bot_player.add_player(update, context, text)
|
|
|
|
print(f'{chat_id} ha inviato questo testo: {text}')
|
|
await update.message.reply_text(_botsyms.WIP_MSG)
|
|
|
|
def main():
|
|
application = Application.builder().token(_botsyms.TOKEN).build()
|
|
|
|
application.add_handler(CommandHandler('start', bot_start))
|
|
#application.add_handler(CommandHandler('start_game', start_loop_game))
|
|
|
|
# player handler
|
|
#application.add_handler(CommandHandler('add_player', _bot_player.add_player))
|
|
#application.add_handler(CommandHandler('get_players', _bot_player.get_players))
|
|
#application.add_handler(CommandHandler('get_alive_players', _bot_player.get_alive_players))
|
|
#application.add_handler(CommandHandler('get_death_players', _bot_player.get_death_players))
|
|
|
|
application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, bot_commands))
|
|
|
|
print('Bot in esecuzione...')
|
|
application.run_polling()
|
|
|
|
if __name__ == '__main__':
|
|
main()
|