dialup/main.py

import asyncio
import pjsua2 as pj
from threading import Thread
from markupsafe import escape
from unificontrol import UnifiClient
from dotenv import load_dotenv
from os import getenv
from ssl import get_server_certificate
from flask import Flask, request, render_template, Response, send_from_directory
from queue import Queue
from time import sleep
import os

app = Flask(__name__)
app.config['TEMPLATES_AUTO_RELOAD'] = True
global unifi

QUEUE = Queue()
VISITOR_COUNT_FILE = "visitor_count"

LIB = None

def call():
    sip_server = str(getenv("SIP_SERVER"))
    sip_username = str(getenv("SIP_USERNAME"))
    sip_password = str(getenv("SIP_PASSWORD"))

    # Initialize lib
    LIB = pj.Endpoint()
    LIB.libCreate()

    ep_cfg = pj.EpConfig()
    LIB.libInit(ep_cfg)

    transport_cfg = pj.TransportConfig()
    transport_cfg.port = 5060
    LIB.transportCreate(pj.PJSIP_TRANSPORT_UDP, transport_cfg)

    LIB.libStart()

    class MyAccount(pj.Account):
        def __init__(self):
            pj.Account.__init__(self)

        def onRegState(self, prm):
            print("Registration state:", prm.code)

    class MyCall(pj.Call):
        def __init__(self, acc, dest_uri):
            pj.Call.__init__(self, acc)
            self.makeCall(dest_uri, pj.CallOpParam(True))

        def onCallState(self, prm):
            ci = self.getInfo()
            print("Call state:", ci.stateText)

    # Account config
    acc_cfg = pj.AccountConfig()
    acc_cfg.idUri = f"sip:{sip_username}@{sip_server}"
    acc_cfg.regConfig.registrarUri = f"sip:{sip_server}"
    cred = pj.AuthCredInfo("digest", "*", sip_username, 0, sip_password)
    acc_cfg.sipConfig.authCreds.append(cred)

    acc = MyAccount()
    acc.create(acc_cfg)


    while True:
        try:
            id = QUEUE.get(block = True)

            # Spawn audio on phone
            call_phone(sip_server, acc)

            # authorize guest after a certain amount of time
            unifi.authorize_guest(id, 1)
        except:
            sleep(5)

def call_phone(hostname, acc):
    # Make call
    call = MyCall(acc, f"sip:3002@{hostname}")

    # Keep the program running for the duration of the ringtone
    sleep(18)
    del call


def main():
    if not os.path.exists(VISITOR_COUNT_FILE):
        os.mknod(VISITOR_COUNT_FILE)
        with open(VISITOR_COUNT_FILE, "w") as f:
            f.write("0")

    load_dotenv()

    HOSTNAME = str(getenv("HOSTNAME"))
    USERNAME = str(getenv("USERNAME"))
    PASSWORD = str(getenv("PASSWORD"))

    cert = get_server_certificate((HOSTNAME, 443))

    global unifi
    unifi = UnifiClient(host=HOSTNAME,
        username=USERNAME, password=PASSWORD, cert=cert)

    Thread(target=call).start()

    app.run(host="0.0.0.0", port=80)

def visitor_count():
    visitor_count = 1337
    # Yes there is a race condition here, I don't care
    try:
        with open(VISITOR_COUNT_FILE, "r+") as f:
            visitors = int(f.read().strip())
            visitors += 1
            f.seek(0)
            f.write(str(visitors))
            f.truncate()
            visitor_count = visitors
    except Exception as e:
        print(f"error {e}")
    return visitor_count

LANG_EN = {
    "Inbellen bij TechInc": "Dialup with TechInc",
    "TechInc inbel portaal": "TechInc dialup portal",
    "GRATIS": "FREE",
    "Gratis": "Free",
    "gratis": "freely",
    "Verbind": "Connect for",
    "met het wereldwijde web": "with the world wide web",
    "Openen van telefoonlijn...": "Opening the phone line...",
    "Bellen naar TechInc...": "Calling into TechInc...",
    "Ontvang verbindingsopties...": "Receiving the connection options...",
    "Uitzetten van echo onderdrukking...": "Disabling the echo suppression...",
    "Breedbandspectrum peilen...": "Probing wide-spectrum...",
    "Equalizer en echo-onderdrukkingstraining...": "Equalizer and echo-suppression training....",
    "Verbinding met TechInc is gelegd!": "Connection with TechInc has been established!",
    "openbaar": "publicly",
    "Welkom, surfer!": "Welcome, surfer!",
    "Onze snelle telefoon lijn is": "Our fast phone line is",
    "en": "and",
    "beschikbaar": "available",
    "Via onderstaande knop kan je inbellen via je modem.": "With the buttom below you can dial up with your modem",
    "Inbellen via TechInc heeft de volgende voordelen": "Dial up via TechInc has the following advantages",
    "Altijd en overal toegang": "Always and everywhere access",
    "tot het internet via uw telefoonlijn": "to the internet via your telephone line",
    "Compatibel met alle gangbare 14.4k, 28.8k en 56k modems": "Compatible with all common 14.4k, 28.8k and 56k modems",
    "Geen installatie nodig": "No installation required!",
    "werkt direct met Windows 95/98 en Netscape Navigator": "works instantly with Windows 95/98 and Netscape Navigator",
    "Ondersteuning voor e-mail, nieuwsgroepen en Internet Relay Chat (IRC)": "Support for e-mail, newsgroups and Internet Relay Chat (IRC)",
    "Beveiligde verbinding via ons eigen TechInc-netwerk": "Secure connecton with our own TechInc network",
    "u betaalt helemaal niets": "you don't pay anything",
    "ook niet voor de gespreksduur!": "not even for the duration of the call!",
    "doe-het-zelf helpdesk voor al uw internetvragen": "do-it-yourself helpdesk for all your internet questions",
    "Verbind nu!": "Connect now!",
    "/afbeeldingen/verbind.gif": "/afbeeldingen/connect.gif",
    "U BENT BEZOEKER NUMMER": "YOU ARE VISITOR NUMBER"
}

LANG_NL = {
    "Inbellen bij TechInc": "Inbellen bij TechInc",
    "TechInc inbel portaal": "TechInc inbel portaal",
    "GRATIS": "GRATIS",
    "Gratis": "Gratis",
    "gratis": "gratis",
    "Verbind": "Verbind",
    "met het wereldwijde web": "met het wereldwijde web",
    "Openen van telefoonlijn...": "Openen van telefoonlijn...",
    "Bellen naar TechInc...": "Bellen naar TechInc...",
    "Ontvang verbindingsopties...": "Ontvang verbindingsopties...",
    "Uitzetten van echo onderdrukking...": "Uitzetten van echo onderdrukking...",
    "Breedbandspectrum peilen...": "Breedbandspectrum peilen...",
    "Equalizer en echo-onderdrukkingstraining...": "Equalizer en echo-onderdrukkingstraining...",
    "Verbinding met TechInc is gelegd!": "Verbinding met TechInc is gelegd!",
    "openbaar": "openbaar",
    "Welkom, surfer!": "Welkom, surfer!",
    "Onze snelle telefoon lijn is": "Onze snelle telefoon lijn is",
    "en": "en",
    "beschikbaar": "beschikbaar",
    "Via onderstaande knop kan je inbellen via je modem.": "Via onderstaande knop kan je inbellen via je modem.",
    "Inbellen via TechInc heeft de volgende voordelen": "Inbellen via TechInc heeft de volgende voordelen",
    "Altijd en overal toegang": "Altijd en overal toegang",
    "tot het internet via uw telefoonlijn": "tot het internet via uw telefoonlijn",
    "Compatibel met alle gangbare 14.4k, 28.8k en 56k modems": "Compatibel met alle gangbare 14.4k, 28.8k en 56k modems",
    "Geen installatie nodig": "Geen installatie nodig",
    "werkt direct met Windows 95/98 en Netscape Navigator": "werkt direct met Windows 95/98 en Netscape Navigator",
    "Ondersteuning voor e-mail, nieuwsgroepen en Internet Relay Chat (IRC)": "Ondersteuning voor e-mail, nieuwsgroepen en Internet Relay Chat (IRC)",
    "Beveiligde verbinding via ons eigen TechInc-netwerk": "Beveiligde verbinding via ons eigen TechInc-netwerk",
    "u betaalt helemaal niets": "u betaalt helemaal niets",
    "ook niet voor de gespreksduur!": "ook niet voor de gespreksduur!",
    "doe-het-zelf helpdesk voor al uw internetvragen": "doe-het-zelf helpdesk voor al uw internetvragen",
    "Verbind nu!": "Verbind nu!",
    "/afbeeldingen/verbind.gif": "/afbeeldingen/verbind.gif",
    "U BENT BEZOEKER NUMMER": "U BENT BEZOEKER NUMMER"
}

LANG = {
    'nl': LANG_NL,
    'en': LANG_EN
}

@app.route('/guest/s/default/', methods=["GET"])
def root():
    supported_languages = ["en", "nl"]
    lang = request.accept_languages.best_match(supported_languages)

    id = escape(request.args.get('id'))
    page = render_template("index.html", dialing_up=False, id=id, lang=LANG[lang], visitor_count=visitor_count())
    response = Response(page, mimetype="text/html")
    return response

@app.route("/dialup", methods=["POST"])
def dialup():
    supported_languages = ["en", "nl"]
    lang = request.accept_languages.best_match(supported_languages)

    id = escape(request.args.get('id'))

    page = render_template("index.html", dialing_up=True, id=id, lang=LANG[lang], visitor_count=visitor_count())
    response = Response(page, mimetype="text/html")
    QUEUE.put(id)
    return response

@app.route('/afbeeldingen/<path:path>')
def static_folder(path):
    return send_from_directory('static', path)

if __name__ == "__main__":
    main()