2017-10-30 13:45:38 +01:00
|
|
|
import multiprocessing
|
2018-04-20 19:46:33 +02:00
|
|
|
import os
|
2017-10-30 13:45:38 +01:00
|
|
|
import telegrambot
|
|
|
|
import discordbot
|
2018-09-05 19:48:34 +02:00
|
|
|
import redditbot
|
2018-01-20 15:28:04 +01:00
|
|
|
import time
|
2018-08-16 19:33:38 +02:00
|
|
|
import logging
|
|
|
|
|
|
|
|
logging.getLogger().setLevel(level=logging.ERROR)
|
|
|
|
logging.getLogger(__name__).setLevel(level=logging.DEBUG)
|
2017-10-30 13:45:38 +01:00
|
|
|
|
2017-11-15 10:48:58 +01:00
|
|
|
discord_telegram_pipe = multiprocessing.Pipe()
|
|
|
|
discord = multiprocessing.Process(target=discordbot.process, args=(discord_telegram_pipe[0],), daemon=True)
|
|
|
|
telegram = multiprocessing.Process(target=telegrambot.process, args=(discord_telegram_pipe[1],), daemon=True)
|
2018-09-05 19:48:34 +02:00
|
|
|
reddit = multiprocessing.Process(target=redditbot.process, daemon=True)
|
2017-10-30 13:45:38 +01:00
|
|
|
|
|
|
|
if __name__ == "__main__":
|
2018-08-16 19:33:38 +02:00
|
|
|
logging.info("Starting Discord process...")
|
2017-10-30 13:45:38 +01:00
|
|
|
discord.start()
|
2018-08-16 19:33:38 +02:00
|
|
|
logging.info("Starting Telegram process...")
|
2017-11-10 08:53:48 +01:00
|
|
|
telegram.start()
|
2018-09-05 19:52:11 +02:00
|
|
|
logging.info("Starting Reddit process...")
|
|
|
|
reddit.start()
|
2018-04-20 19:46:33 +02:00
|
|
|
try:
|
|
|
|
while True:
|
|
|
|
if discord.exitcode is not None:
|
2018-08-16 19:33:38 +02:00
|
|
|
logging.warning(f"Discord Bot exited with {discord.exitcode}")
|
2018-04-20 19:46:33 +02:00
|
|
|
del discord
|
2018-09-05 19:48:34 +02:00
|
|
|
logging.info("Restarting Discord process...")
|
2018-04-20 19:46:33 +02:00
|
|
|
discord = multiprocessing.Process(target=discordbot.process, args=(discord_telegram_pipe[0],), daemon=True)
|
|
|
|
discord.start()
|
|
|
|
if telegram.exitcode is not None:
|
2018-09-05 19:48:34 +02:00
|
|
|
logging.warning(f"Telegram Bot exited with {telegram.exitcode}")
|
2018-04-20 19:46:33 +02:00
|
|
|
del telegram
|
|
|
|
telegram = multiprocessing.Process(target=telegrambot.process, args=(discord_telegram_pipe[1],), daemon=True)
|
2018-09-05 19:48:34 +02:00
|
|
|
logging.info("Restarting Telegram process...")
|
|
|
|
telegram.start()
|
|
|
|
if reddit.exitcode is not None:
|
|
|
|
logging.warning(f"Reddit Bot exited with {reddit.exitcode}")
|
|
|
|
del reddit
|
|
|
|
reddit = multiprocessing.Process(target=redditbot.process, daemon=True)
|
|
|
|
logging.info("Restarting Reddit process...")
|
2018-04-20 19:46:33 +02:00
|
|
|
telegram.start()
|
2018-08-16 19:33:38 +02:00
|
|
|
time.sleep(10)
|
2018-04-20 19:46:33 +02:00
|
|
|
except KeyboardInterrupt:
|
2018-08-16 19:33:38 +02:00
|
|
|
logging.info("Now stopping...")
|
|
|
|
logging.info("Asking Discord process to stop...")
|
2018-07-31 18:31:06 +02:00
|
|
|
discord_telegram_pipe[0].send("stop")
|
2018-08-16 19:33:38 +02:00
|
|
|
logging.info("Waiting for Discord process to stop...")
|
2018-07-31 18:38:54 +02:00
|
|
|
time.sleep(30)
|