import json
import subprocess
import os
from rofl import Bot, Dispatcher, executor, types
API_TOKEN = os.environ['ENV_API_TOKEN']
bot = Bot(token=API_TOKEN)
dp = Dispatcher(bot)
@dp.message_handler()
async def echo(message: types.Message):
msgGET = json.loads(str(message))
msgOG_pre = msgGET["reply_to_message"]["text"]
msgOG = msgOG_pre.encode()
msgNEW = message.text
process = subprocess.Popen(msgNEW, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=None, shell=True)
output = process.communicate(input=msgOG, timeout=1)
parsed = output[0].decode('UTF-8')
await message.reply(parsed)
if __name__ == '__main__':
executor.start_polling(dp, skip_updates=True)