users: Connect to Asterisk and show any ongoing calls

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/Makefile.am b/Makefile.am
index fbf9d3bd011da846ab0d53b7d9180aebe2bbae25..b1749141918b04197b8129b562b36b6a2d4bdb10 100644 (file)
--- a/Makefile.am
+++ b/Makefile.am
@@ -49,6 +49,7 @@ CLEANFILES += \
 backend_PYTHON = \
        src/backend/__init__.py \
        src/backend/accounts.py \
+       src/backend/asterisk.py \
        src/backend/base.py \
        src/backend/blog.py \
        src/backend/bugzilla.py \

diff --git a/src/backend/accounts.py b/src/backend/accounts.py
index e43c76d5f14dda2c239f3f964c2cb3be1d235549..3c248f2b952b86b541487002971b7295bfa52e07 100644 (file)
--- a/src/backend/accounts.py
+++ b/src/backend/accounts.py
@@ -829,7 +829,6 @@ class Account(LDAPObject):
                return "postfixMailUser" in self.classes
 
        def has_sip(self):
-               return False # XXX
                return "sipUser" in self.classes or "sipRoutingObject" in self.classes
 
        def is_lwl(self):
@@ -1148,9 +1147,11 @@ class Account(LDAPObject):
 
                return sip_registrations
 
-       @lazy_property
-       def sip_channels(self):
-               return self.backend.talk.freeswitch.get_sip_channels(self)
+       async def get_sip_channels(self):
+               if not self.has_sip():
+                       return []
+
+               return await self.backend.asterisk.get_sip_channels(self.sip_id)
 
        def get_cdr(self, date=None, limit=None):
                return self.backend.talk.freeswitch.get_cdr_by_account(self, date=date, limit=limit)

diff --git a/src/backend/asterisk.py b/src/backend/asterisk.py
new file mode 100644 (file)
index 0000000..8a478bf
--- /dev/null
+++ b/src/backend/asterisk.py
@@ -0,0 +1,114 @@
+#!/usr/bin/python3
+
+import asyncio
+import datetime
+import logging
+import panoramisk
+
+from . import misc
+from .decorators import *
+
+loop = asyncio.get_event_loop()
+
+class Asterisk(misc.Object):
+       def init(self):
+               self.__manager = None
+
+               # Connect as soon as the event loop starts
+               loop.create_task(self.connect())
+
+       @property
+       def manager(self):
+               if not self.__manager:
+                       raise RuntimeError("Asterisk is not connected")
+
+               return self.__manager
+
+       async def connect(self):
+               """
+                       Connects to Asterisk
+               """
+               manager = panoramisk.Manager(
+                       host     = self.settings.get("asterisk-ami-host"),
+                       username = self.settings.get("asterisk-ami-username"),
+                       secret   = self.settings.get("asterisk-ami-secret"),
+
+                       on_connect=self._on_connect,
+               )
+
+               # Connect
+               await manager.connect()
+
+               return manager
+
+       def _on_connect(self, manager):
+               logging.debug("Connection to Asterisk established")
+
+               # Close any existing connections
+               if self.__manager:
+                       self.__manager.close()
+
+               self.__manager = manager
+
+       async def ping(self):
+               manager = await self.manager()
+
+               result = manager.ping()
+               print(result)
+
+       async def get_sip_channels(self, filter=None):
+               channels = []
+
+               for data in await self.manager.send_action({"Action" : "CoreShowChannels"}):
+                       # Skip header and trailer
+                       if data.eventlist:
+                               continue
+
+                       # Parse channel
+                       channel = Channel(self.backend, data)
+
+                       # Apply filter
+                       if filter and not channel.matches(filter):
+                               continue
+
+                       channels.append(channel)
+
+               return channels
+
+
+class Channel(misc.Object):
+       def init(self, data):
+               self.data = data
+
+       def __str__(self):
+               return self.connected_line
+
+       @property
+       def account_code(self):
+               return self.data.AccountCode
+
+       @property
+       def connected_line(self):
+               return self.data.ConnectedLineName or self.data.ConnectedLineNum
+
+       def matches(self, filter):
+               return filter in (
+                       self.data.CallerIDNum,
+               )
+
+       @property
+       def duration(self):
+               h, m, s = self.data.Duration.split(":")
+
+               try:
+                       h, m, s = int(h), int(m), int(s)
+               except TypeError:
+                       return 0
+
+               return datetime.timedelta(hours=h, minutes=m, seconds=s)
+
+       def is_connected(self):
+               return self.data.ChannelStateDesc == "Up"
+
+       def is_ringing(self):
+               return self.data.ChannelStateDesc == "Ringing"

diff --git a/src/backend/base.py b/src/backend/base.py
index 6ac600d17b606981be3a27dbe11015daa0454d25..ea0c0258890759bbcc340e7042368c788d2c1fd1 100644 (file)
--- a/src/backend/base.py
+++ b/src/backend/base.py
@@ -8,6 +8,7 @@ import tempfile
 import tornado.httpclient
 
 from . import accounts
+from . import asterisk
 from . import blog
 from . import bugzilla
 from . import campaigns
@@ -62,6 +63,7 @@ class Backend(object):
 
                # Initialize backend modules.
                self.accounts = accounts.Accounts(self)
+               self.asterisk = asterisk.Asterisk(self)
                self.bugzilla = bugzilla.Bugzilla(self)
                self.fireinfo = fireinfo.Fireinfo(self)
                self.iuse = iuse.IUse(self)

diff --git a/src/backend/util.py b/src/backend/util.py
index 9a4246d70dca7fbce6c4d7d0722c6af1a82b4d32..00747502ad023b7234eae07f87eac1367bf084c9 100644 (file)
--- a/src/backend/util.py
+++ b/src/backend/util.py
@@ -3,6 +3,7 @@
 import PIL.Image
 import PIL.ImageFilter
 import PIL.ImageOps
+import datetime
 import io
 import ipaddress
 import location
@@ -171,6 +172,9 @@ def format_time(s, shorter=True):
        #_ = handler.locale.translate
        _ = lambda x: x
 
+       if isinstance(s, datetime.timedelta):
+               s = s.total_seconds()
+
        hrs, s = divmod(s, 3600)
        min, s = divmod(s, 60)
 

diff --git a/src/templates/users/show.html b/src/templates/users/show.html
index 842f11ede93d310947dfc0d09528cdbc1c426a7c..40a5ae65fe586004ec2543b43ee0ab189f8b7450 100644 (file)
--- a/src/templates/users/show.html
+++ b/src/templates/users/show.html
@@ -136,6 +136,35 @@
        </section>
 
        {% if current_user == account or current_user.is_staff() %}
+
+               {# SIP Channels #}
+
+               {% if sip_channels %}
+                       <section class="section">
+                               <div class="container">
+                                       {% for channel in sip_channels %}
+                                               <div class="notification
+                                                               {% if channel.is_ringing() %}is-warning
+                                                               {% elif channel.is_connected() %}is-success
+                                                               {% end %}">
+                                                       <span class="icon-text">
+                                                               <span class="icon">
+                                                                       <i class="fa-solid fa-phone-volume"></i>
+                                                               </span>
+                                                               <span>{{ channel }}</span>
+                                                       </span>
+
+                                                       {% if channel.duration %}
+                                                               <span class="is-pulled-right">
+                                                                       {{ format_time(channel.duration) }}
+                                                               </span>
+                                                       {% end %}
+                                               </div>
+                                       {% end %}
+                               </div>
+                       </section>
+               {% end %}
+
                <section class="section">
                        <div class="container">
                                <div class="columns">
@@ -161,7 +190,7 @@
                                                        <ul>
                                                                {% if account.has_sip() %}
                                                                        <li>
-                                                                               {% if account.sip_channels %}
+                                                                               {% if sip_channels %}
                                                                                        <i class="fas fa-phone-volume has-text-warning fa-fw"></i>
                                                                                {% elif account.sip_registrations %}
                                                                                        <i class="fas fa-phone-square has-text-success fa-fw"></i>

diff --git a/src/web/users.py b/src/web/users.py
index 6dee34b9585074a06373bf9799862d1800d5ada4..7435a552c1ae224051689246db2d6ec7397e3950 100644 (file)
--- a/src/web/users.py
+++ b/src/web/users.py
@@ -33,12 +33,15 @@ class IndexHandler(base.BaseHandler):
 
 class ShowHandler(base.BaseHandler):
        @tornado.web.authenticated
-       def get(self, uid):
+       async def get(self, uid):
                account = self.backend.accounts.get_by_uid(uid)
                if not account:
                        raise tornado.web.HTTPError(404, "Could not find account %s" % uid)
 
-               self.render("users/show.html", account=account)
+               # Fetch SIP channels
+               sip_channels = await account.get_sip_channels()
+
+               self.render("users/show.html", account=account, sip_channels=sip_channels)
 
 
 class AvatarHandler(base.BaseHandler):