#!/usr/bin/python3
from flask import Flask, request, jsonify
import codecs
import json
import glob
import shutil
api_key = "s0m3_v3ry_str0ng_k3y"
app = Flask(__name__)
@app.route('/api/conf', methods= ['POST'])
def go_conf():
    content = request.get_json()
    ## Блок авторизации
    if not "api_key" in content:
        return jsonify({'error': 'Authentication required', 'message': 'Please specify api key'}), 401
    if not content["api_key"] == api_key:
        return jsonify({'error': 'Authentication failure', 'message': 'Wrong api key'}), 401
    ## Проверка наличия нужных параметров в запросе
    if not "phone_number" in content or not "room_name" in content or not "caller_id" in content:
        return jsonify({'error': 'not all parameters are specified'}), 400
    if not "lang" in content:
        lang = "ru"
    else:
        lang = content["lang"]
    phone_number = content["phone_number"]
    room_name = content["room_name"]
    caller_id = content["caller_id"]
    calls = glob.glob(f"/var/spool/asterisk/outgoing/*-{phone_number}*")
    callfile = "cb_conf-" + phone_number + "-" + room_name + ".call"
    filename = "/var/spool/asterisk/" + callfile
    if calls:
        return jsonify({'message': 'error', "text": "call already in progress"})
    with codecs.open(filename, "w", encoding='utf8') as f:
        f.write("Channel: LOCAL/" + phone_number + "@telegram-out\n")
        f.write("CallerID: <" + caller_id + ">\n")
        f.write("MaxRetries: 0\nRetryTime: 5\nWaitTime: 30\n")
        f.write("Set: LANG=" + lang + "\nContext: conf-in\n")
        f.write("Extension: " + room_name + "\nArchive: Yes\n")
    shutil.chown(filename, user="asterisk", group="asterisk")
    shutil.move(filename, "/var/spool/asterisk/outgoing/" + callfile)
    return jsonify({'message': 'ok'})
if __name__ == '__main__':
    app.run(debug=True,host='0.0.0.0', port=8080)

import requests
# Заменить example.com на Ваш url
url = "http://example.com:8080/api/conf"
api_key = "s0m3_v3ry_str0ng_k3y"
def go_to_conf(phone_number, room_name, caller_id, lang="ru"):
    payload = "{\n\t"phone_number" : ""+phone_number+"",\n\t"room_name" : ""+room_name+"",\n    "caller_id" : ""+caller_id+"",\n\t"lang": ""+lang+"",\n\t"api_key": ""+api_key+""\n}"
    headers = {
        'content-type': "application/json",
        'cache-control': "no-cache",
        }
    try:
        response = requests.request("POST", url, data=payload, headers=headers, timeout=2, verify=False)
        if "call already in progress" in response.text:
            return False, "Ошибка. Звонок еще не завершен."
        elif "error" in response.text:
            print(response.text)
            return False, "Ошибка. Произошел сбой. Попробуйте позже."
        else:
            return True, response.text
    except:
        return False, "Ошибка. Произошел сбой. Попробуйте позже."

#!/usr/bin/python3.6
import telebot
from telephony_api import go_to_conf
bot = telebot.TeleBot("ВашTOKEN")
pnone_number = "799999999999"# Ваш номер телефона, на который зарегистрирован telegram аккаунт
@bot.message_handler(content_types=['text'])
def main_text_handler(message):
    if message.text == "Подключи меня в аудиоконференцию":
        bot.send_message(message.chat.id, "Ok. Сейчас на telegram Вам прийдет звонок, ответив на который Вы будете подключены в аудиоконференцию")
        func_result, func_message = go_to_conf(pnone_number, "ROOM1", "Bob", "ru")
        if not func_result:
            bot.send_message(chat_id=message.chat.id, text=func_message)
if __name__ == "__main__":)
   print("bot started")
   bot.polling(none_stop=True)