Asterisk Manager and Channel objects.
__author__ = 'David Wilson'
__id__ = '$Id$'
import socket, time, logging, errno, os, re, datetime
from new import instancemethod
import Asterisk, Asterisk.Util, Asterisk.Logging
# Your ParentBaseException class should provide a __str__ method that combined
# _prefix and _error as  ('%s: %s' % (_prefix, _error) or similar.
class BaseException(Asterisk.BaseException):
    'Base class for all Asterisk Manager API exceptions.'
    _prefix = 'Asterisk'
class AuthenticationFailure(BaseException):
    'This exception is raised when authentication to the PBX instance fails.'
    _error = 'Authentication failed.'
class CommunicationError(BaseException):
    'This exception is raised when the PBX responds in an unexpected manner.'
    def __init__(self, packet, msg = None):
        e = 'Unexpected response from PBX: %r\n' % (msg,)
        self._error = e + ': %r' % (packet,)
class GoneAwayError(BaseException):
    'This exception is raised when the Manager connection becomes closed.'
class InternalError(BaseException):
    'This exception is raised when an error occurs within a Manager object.'
    _prefix = 'py-Asterisk internal error'
class ActionFailed(BaseException):
    'This exception is raised when a PBX action fails.'
    _prefix = 'py-Asterisk action failed'
class PermissionDenied(BaseException):
    This exception is raised when our connection is not permitted to perform a
    requested action.
    _error = 'Permission denied'
class BaseChannel(Asterisk.Logging.InstanceLogger):
    Represents a living Asterisk channel, with shortcut methods for operating
    on it. The object acts as a mapping, ie. you may get and set items of it.
    This translates to Getvar and Setvar actions on the channel.
    def __init__(self, manager, id):
        Initialise a new Channel object belonging to <id> reachable via
        BaseManager <manager>.
        self.manager = manager
        self.id = id
        self.log = self.getLogger()
    def __eq__(self, other):
        'Return truth if <other> is equal to this object.'
        return (self.id == other.id) and (self.manager is other.manager)
    def __hash__(self):
        'Return the hash value of this channel.'
        return hash(self.id) ^ id(self.manager)
    def __str__(self):
        return self.id
    def __repr__(self):
        return '<%s.%s referencing channel %r of %r>' %\
            (self.__class__.__module__, self.__class__.__name__,
             self.id, self.manager)
    def AbsoluteTimeout(self, timeout):
        'Set the absolute timeout of this channel to <timeout>.'
        return self.manager.AbsoluteTimeout(self, timeout)
    def ChangeMonitor(self, pathname):
        'Change the monitor filename of this channel to <pathname>.'
        return self.manager.ChangeMonitor(self, pathname)
    def Getvar(self, variable, default = Asterisk.Util.Unspecified):
        Return the value of this channel's <variable>, or <default> if variable
        is not set.
        if default is Asterisk.Util.Unspecified:
            return self.manager.Getvar(self, variable)
        return self.manager.Getvar(self, variable, default)
    def Hangup(self):
        'Hangup this channel.'
        return self.manager.Hangup(self)
    def Monitor(self, pathname, format, mix):
        'Begin monitoring of this channel into <pathname> using <format>.'
        return self.manager.Monitor(self, pathname, format, mix)
    def Redirect(self, context, extension = 's', priority = 1, channel2 = None):
        Redirect this channel to <priority> of <extension> in <context>,
        optionally bridging with <channel2>.
        return self.manager.Redirect(self, context, extension, priority, channel2)
    def SetCDRUserField(self, data, append = False):
        "Append or replace this channel's CDR user field with <data>."
        return self.manager.SetCDRUserField(self, data, append)
    def Setvar(self, variable, value):
        'Set the <variable> in this channel to <value>.'
        return self.manager.Setvar(self, variable, value)
    def Status(self):
        'Return the Status() dict for this channel (wasteful!).'
        return self.manager.Status()[self]
    def StopMonitor(self):
        'Stop monitoring of this channel.'
        return self.manager.StopMonitor(self)
    def __getitem__(self, key):
        'Fetch <key> as a variable from this channel.'
        return self.Getvar(key)
    def __setitem__(self, key, value):
        'Set <key> as a variable on this channel.'
        return self.Setvar(key, value)
class ZapChannel(BaseChannel):
    def ZapDNDoff(self):
        'Disable DND status on this Zapata driver channel.'
        return self.manager.ZapDNDoff(self)
    def ZapDNDon(self):
        'Enable DND status on this Zapata driver channel.'
        return self.manager.ZapDNDon(self)
    def ZapDialOffhook(self, number):
        'Off-hook dial <number> on this Zapata driver channel.'
        return self.manager.ZapDialOffhook(self, number)
    def ZapHangup(self):
        'Hangup this Zapata driver channel.'
        return self.manager.ZapHangup(self)
    def ZapTransfer(self):
        'Transfer this Zapata driver channel.'
        return self.manager.ZapTransfer(self)
class BaseManager(Asterisk.Logging.InstanceLogger):
    'Base protocol implementation for the Asterisk Manager API.'
    _AST_BANNERS = [
        'Asterisk Call Manager/1.0\r\n',
        'Asterisk Call Manager/1.1\r\n',
        'Asterisk Call Manager/1.2\r\n',
        'Asterisk Call Manager/1.3\r\n',
    def __init__(self, address, username, secret, listen_events=True,
        Provide communication methods for the PBX instance running at
        <address>. Authenticate using <username> and <secret>. Receive event
        information from the Manager API if <listen_events> is True.
        self.address = address
        self.username = username
        self.secret = secret
        self.listen_events = listen_events
        self.events = Asterisk.Util.EventCollection()
        self.timeout = timeout
        # Configure logging:
        self.log = self.getLogger()
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.file = sock.makefile('r+', 0) # line buffered.
        self.fileno = self.file.fileno
        self.response_buffer = []
    def get_channel(self, channel_id):
        'Return a channel object for the given <channel_id>.'
        if channel_id[:3].lower() == 'zap':
            return ZapChannel(self, channel_id)
        return BaseChannel(self, channel_id)
    def _authenticate(self):
        'Read the server banner and attempt to authenticate.'
        banner = self.file.readline()
        if banner not in self._AST_BANNERS:
            raise Exception('banner incorrect; got %r, expected one of %r' %\
                            (banner, self._AST_BANNERS))
        action = {
            'Username': self.username,
            'Secret': self.secret
        if not self.listen_events:
            action['Events'] = 'off'
        self.log.debug('Authenticating as %r/%r.', self.username, self.secret)
        self._write_action('Login', action)
        if self._read_packet().Response == 'Error':
            raise AuthenticationFailure('authentication failed.')
        self.log.debug('Authenticated as %r.', self.username)
    def __repr__(self):
        'Return a string representation of this object.'
        return '<%s.%s connected as %s to %s:%d>' %\
            ((self.__module__, self.__class__.__name__,
             self.username) + self.address)
    def _write_action(self, action, data = None):
        Write an <action> request to the Manager API, sending header keys and
        values from the mapping <data>. Return the (string) action identifier
        on success. Values from <data> are omitted if they are None.
        id = str(time.time()) # Assumes microsecond precision for reliability.
        lines = [ 'Action: ' + action, 'ActionID: ' + id ]
        if data is not None:
            for item in data.iteritems():
                if item[1] is not None:
                    if not isinstance(item[1], list):
                        lines.append('%s: %s' % item)
                    elif isinstance(item[1], list):
                        for param in item[1]:
                            lines.append('%s: %s' % (item[0], param))
        self.log.packet('write_action: %r', lines)
        for line in lines:
            self.file.write(line + '\r\n')
            self.log.io('_write_action: send %r', line + '\r\n')
        self.log.io('_write_action: send: %r', '\r\n')
        return id
    def _read_response_follows(self):
        Continue reading the remainder of this packet, in the format sent by
        the "command" action.
        self.log.debug('In _read_response_follows().')
        lines = []
        packet = Asterisk.Util.AttributeDict({
            'Response': 'Follows', 'Lines': lines
        line_nr = 0
        empty_line_ts = None
        while True:
            line = self.file.readline().rstrip()
            self.log.io('_read_response_follows: recv %r', line)
            line_nr += 1
            # In some case, ActionID is the line 2 the first starting with
            # 'Privilege:'
            if line_nr in [1, 2] and line.startswith('ActionID: '):
                # Asterisk is a pile of shite!!!!!!!!!
                packet.ActionID = line[10:]
            elif line == '--END COMMAND--':
                self.log.debug('Completed _read_response_follows().')
                return packet
            elif not line:
                if self.timeout:
                    now = datetime.datetime.now()
                    if empty_line_ts is None:
                        empty_line_ts = now
                        if (now - empty_line_ts).seconds > self.timeout:
                            self.log.debug("Bogus asterisk 'Command' answer.'")
                            raise CommunicationError(packet, 'expected --END COMMAND--')
                self.log.debug('Empty line encountered.')
    def _read_packet(self, discard_events = False):
        Read a set of packet from the Manager API, stopping when a "\r\n\r\n"
        sequence is read. Return the packet as a mapping.
        If <discard_events> is True, discard all Event packets and wait for a
        Response packet, this is used while closing down the channel.
        packet = Asterisk.Util.AttributeDict()
        self.log.debug('In _read_packet().')
        while True:
            line = self.file.readline().rstrip()
            self.log.io('_read_packet: recv %r', line)
            if not line:
                if not packet:
                    raise GoneAwayError('Asterisk Manager connection has gone away.')
                self.log.packet('_read_packet: %r', packet)
                if discard_events and 'Event' in packet:
                    self.log.debug('_read_packet() discarding: %r.', packet)
                self.log.debug('_read_packet() completed.')
                return packet
            val = None
            if line.count(':') == 1 and line[-1] == ':': # Empty field:
                key, val = line[:-1], ''
            elif line.count(',') == 1 and line[0] == ' ': # ChannelVariable
                key, val = line[1:].split(',', 1)
                # Some asterisk features like 'XMPP' presence
                # send bogus packets with empty lines in the datas
                # We should properly fail on those packets.
                    key, val = line.split(': ', 1)
                    raise InternalError('Malformed packet detected: %r' % (packet,))
            if key == 'Response' and val == 'Follows':
                return self._read_response_follows()
            packet[key] = val
    def _dispatch_packet(self, packet):
        'Feed a single packet to an event handler.'
        if 'Response' in packet:
            self.log.debug('_dispatch_packet() placed response in buffer.')
        elif 'Event' in packet:
            self.log.debug('_dispatch_packet() passing event to on_Event.')
            raise InternalError('Unknown packet type detected: %r' % (packet,))
    def _translate_response(self, packet, success = None):
        Raise an error if the reponse packet reports failure. Convert any
        channel identifiers to their equivalent objects using get_channel().
        for key in ('Channel', 'Channel1', 'Channel2'):
            if key in packet:
                packet[key] = self.get_channel(packet[key])
        if packet.Response in ('Success', 'Follows', 'Pong'):
            return packet
        if packet.Message == 'Permission denied':
            raise PermissionDenied
        raise ActionFailed(packet.Message)
    def _translate_event(self, event):
        Translate any objects discovered in <event> to Python types.
        for key in ('Channel', 'Channel1', 'Channel2'):
            if key in event:
                event[key] = self.get_channel(event[key])
    def close(self):
        'Log off and close the connection to the PBX.'
        self.log.debug('Closing down.')
        packet = self._read_packet(discard_events = True)
        if packet.Response != 'Goodbye':
            raise CommunicationError(packet, 'expected goodbye')
    def read(self):
        'Called by the parent code when activity is detected on our fd.'
        self.log.io('read(): Activity detected on our fd.')
        packet = self._read_packet()
    def read_response(self, id):
        'Return the response packet found for the given action <id>.'
        buffer = self.response_buffer
        while True:
            if buffer:
                for idx, packet in enumerate(buffer):
                    # It is an error if no ActionID is sent. This is intentional.
                    if packet.ActionID == id:
                        return packet
            packet = self._read_packet()
            if 'Event' in packet:
            elif not packet.has_key('ActionID'):
                raise CommunicationError(packet, 'no ActionID')
            elif packet.ActionID == id:
                return packet
    def on_Event(self, event):
        'Triggered when an event is received from the Manager.'
        self.events.fire(event.Event, self, event)
    def responses_waiting(self):
        'Return truth if there are unprocessed buffered responses.'
        return bool(self.response_buffer)
    def serve_forever(self):
        'Handle one event at a time until doomsday.'
        while True:
            packet = self._read_packet()
    def strip_evinfo(self, event):
        Given an event, remove it's ActionID and Event members.
        new = event.copy()
        del new['ActionID'], new['Event']
        return new
class CoreActions(object):
    Provide methods for Manager API actions exposed by the core Asterisk
    def AbsoluteTimeout(self, channel, timeout):
        'Set the absolute timeout of <channel> to <timeout>.'
        id = self._write_action('AbsoluteTimeout', {
            'Channel': channel,
            'Timeout': int(timeout)
    def ChangeMonitor(self, channel, pathname):
        'Change the monitor filename of <channel> to <pathname>.'
        id = self._write_action('ChangeMonitor', {
            'Channel': channel,
            'File': pathname
    def Command(self, command):
        'Execute console command <command> and return its output lines.'
        id = self._write_action('Command', {'Command': command})
        return self._translate_response(self.read_response(id))['Lines']
    def DBGet(self, family, key):
        'Retrieve a key from the Asterisk database'
        id = self._write_action('DBGet', {'Family': family, 'Key': key})
            response = self._translate_response(self.read_response(id))
        except Asterisk.Manager.ActionFailed as e:
            return str(e)
        if response.get('Response') == 'Success':
            packet = self._read_packet()
        return packet.get('Value')
    def Events(self, categories):
        'Filter received events to only those in the list <categories>.'
        id = self._write_action('Events', { 'EventMask': ','.join(categories) })
        return self._translate_response(self.read_response(id))
    def ExtensionStates(self):
        'Return nested dictionary of contexts, extensions and their state'
        hint_re = re.compile(r'\s+(\d+)@(\S+).+State:(\S+)')
        state_dict = dict()
        for line in self.Command('core show hints'):
            match = hint_re.search(line)
            if match:
                extension, context, state = match.groups()
                if context in state_dict:
                    state_dict[context][extension] = state
                    state_dict[context] = {extension: state}
        return state_dict
    def Getvar(self, channel, variable, default = Asterisk.Util.Unspecified):
        Return the value of <channel>'s <variable>, or <default> if <variable>
        is not set.
        self.log.debug('Getvar(%r, %r, default=%r)', channel, variable, default)
        id = self._write_action('Getvar', {
            'Channel': channel,
            'Variable': variable
        response = self._translate_response(self.read_response(id))
        if response.has_key(variable):
            value = response[variable]
            value = response['Value']
        if value == '(null)':
            if default is Asterisk.Util.Unspecified:
                raise KeyError(variable)
                self.log.debug('Getvar() returning %r', default)
                return default
        self.log.debug('Getvar() returning %r', value)
        return value
    def Hangup(self, channel):
        'Hangup <channel>.'
        id = self._write_action('Hangup', { 'Channel': channel })
        return self._translate_response(self.read_response(id))
    def ListCommands(self):
        'Return a dict of all available <action> => <desc> items.'
        id = self._write_action('ListCommands')
        commands = self._translate_response(self.read_response(id))
        del commands['Response']
        return commands
    def Logoff(self):
        'Close the connection to the PBX.'
        return self.close()
    def MailboxCount(self, mailbox):
        'Return a (<new_msgs>, <old_msgs>) tuple for the given <mailbox>.'
        # TODO: this can sum multiple mailboxes too.
        id = self._write_action('MailboxCount', { 'Mailbox': mailbox })
        result = self._translate_response(self.read_response(id))
        return int(result.NewMessages), int(result.OldMessages)
    def MailboxStatus(self, mailbox):
        'Return the number of messages in <mailbox>.'
        id = self._write_action('MailboxStatus', { 'Mailbox': mailbox })
        return int(self._translate_response(self.read_response(id))['Waiting'])
    def MeetMe(self):
        Return list of dictionaries containing confnum, parties, marked, activity and creation.
        Returns empty list if no conferences active.
        resp = self.Command('meetme')
        meetme_list = list()
        if resp[1] == 'No active MeetMe conferences.':
            return meetme_list
            meetme_re = re.compile(r'^(?P<confnum>\d+)\s+(?P<parties>\d+)\s+(?P<marked>\S+)\s+(?P<activity>\S+)\s+(?P<creation>\S+)')
            for line in resp:
                match = meetme_re.search(line)
                if match:
        return meetme_list
    def MeetMeList(self, confnum):
        'Lists users in conferences'
        resp = self.Command('meetme list %s' % confnum)
        caller_list = list()
        if (resp[1] == 'No active conferences.') or ('No such conference' in resp[1]):
            return caller_list
            meetme_re = re.compile(r'^User #: (?P<usernum>\d+)\s+(?P<callerid>.+)\s+Channel: (?P<channel>\S+)\s+\((?P<monitor>.+)\)\s+(?P<duration>\S+)')
            for line in resp:
                match = meetme_re.search(line)
                if match:
        return caller_list
    def Monitor(self, channel, pathname, format, mix):
        'Begin monitoring of <channel> into <pathname> using <format>.'
        id = self._write_action('Monitor', {
            'Channel': channel,
            'File': pathname,
            'Format': format,
            'Mix': mix and 'yes' or 'no'
        return self._translate_response(self.read_response(id))
    def Originate(self, channel, context = None, extension = None, priority = None,
    application = None, data = None, timeout = None, caller_id = None,
    variable = None, account = None, async = None):
        Originate(channel, context = .., extension = .., priority = ..[, ...])
        Originate(channel, application = ..[, data = ..[, ...]])
        Originate a call on <channel>, bridging it to the specified dialplan
        extension (format 1) or application (format 2).
            <context>       Dialplan context to bridge with.
            <extension>     Context extension to bridge with.
            <priority>      Context priority to bridge with.
            <application>   Application to bridge with.
            <data>          Application parameters.
            <timeout>       Answer timeout for <channel> in milliseconds.
            <caller_id>     Outgoing channel Caller ID.
            <variable>      channel variable to set (K=V[|K2=V2[|..]]).
            <account>       CDR account code.
            <async>         Return successfully immediately.
        # Since channel is a required parameter, no need including it here.
        # As a matter of fact, including it here, generates an AttributeError
        # because 'None' does not have an 'id' attribute which is required in
        # checking equality with an object like channel
        has_dialplan = None not in (context, extension)
        has_application = application is not None
        if has_dialplan and has_application:
            raise ActionFailed('Originate: dialplan and application calling style are mutually exclusive.')
        if not (has_dialplan or has_application):
            raise ActionFailed('Originate: neither dialplan or application calling style used. Refer to documentation.')
        if not channel:
            raise ActionFailed('Originate: you must specify a channel.')
        data = {
            'Channel': channel,             'Context': context,
            'Exten': extension,             'Priority': priority,
            'Application': application,     'Data': data,
            'Timeout': timeout,             'CallerID': caller_id,
            'Variable': variable,           'Account': account,
            'Async': int(bool(async))
        id = self._write_action('Originate', data)
        return self._translate_response(self.read_response(id))
    def Originate2(self, channel, parameters):
        Originate a call, using parameters in the mapping <parameters>.
        Provided for compatibility with RPC bridges that do not support keyword
        return self.Originate(channel, **parameters)
    def ParkedCalls(self):
        'Return a nested dict describing currently parked calls.'
        id = self._write_action('ParkedCalls')
        parked = {}
        def ParkedCall(self, event):
            event = self.strip_evinfo(event)
            parked[event.pop('Exten')] = event
        def ParkedCallsComplete(self, event):
            stop_flag[0] = True
        events = Asterisk.Util.EventCollection([ ParkedCall, ParkedCallsComplete ])
        self.events += events
            stop_flag = [ False ]
            while stop_flag[0] == False:
                packet = self._read_packet()
            self.events -= events
        return parked
    def Ping(self):
        'No-op to ensure the PBX is still there and keep the connection alive.'
        id = self._write_action('Ping')
        return self._translate_response(self.read_response(id))
    def QueueAdd(self, queue, interface, penalty = 0):
        'Add <interface> to <queue> with optional <penalty>.'
        id = self._write_action('QueueAdd', {
            'Queue': queue,
            'Interface': interface,
            'Penalty': str(int(penalty))
        return self._translate_response(self.read_response(id))
    def QueuePause(self, queue, interface, paused):
        'Pause <interface> in <queue>.'
        id = self._write_action('QueuePause', {
            'Queue': queue,
            'Interface': interface,
            'Paused': paused and 'true' or 'false'
        return self._translate_response(self.read_response(id))
    def QueueRemove(self, queue, interface):
        'Remove <interface> from <queue>.'
        id = self._write_action('QueueRemove', {
            'Queue': queue,
            'Interface': interface
        return self._translate_response(self.read_response(id))
    def QueueStatus(self):
        'Return a complex nested dict describing queue statii.'
        id = self._write_action('QueueStatus')
        queues = {}
        def QueueParams(self, event):
            queue = self.strip_evinfo(event)
            queue['members'] = {}
            queue['entries'] = {}
            queues[queue.pop('Queue')] = queue
        def QueueMember(self, event):
            member = self.strip_evinfo(event)
            queues[member.pop('Queue')]['members'][member.pop('Location')] = member
        def QueueEntry(self, event):
            entry = self.strip_evinfo(event)
            queues[entry.pop('Queue')]['entries'][event.pop('Channel')] = entry
        def QueueStatusComplete(self, event):
            stop_flag[0] = True
        events = Asterisk.Util.EventCollection([
            QueueParams, QueueMember, QueueEntry, QueueStatusComplete])
        self.events += events
            stop_flag = [False]
            while stop_flag[0] == False:
                packet = self._read_packet()
            self.events -= events
        return queues
    Queues = QueueStatus
    def Redirect(self, channel, context, extension = 's', priority = 1, channel2 = None):
        Redirect <channel> to <priority> of <extension> in <context>,
        optionally bridging with <channel2>
        id = self._write_action('Redirect', {
            'Channel': channel,
            'Context': context,
            'Exten': extension,
            'Priority': priority,
            'ExtraChannel': channel2
        return self._translate_response(self.read_response(id))
    def SetCDRUserField(self, channel, data, append = False):
        "Append or replace <channel>'s CDR user field with <data>'."
        id = self._write_action('SetCDRUserField', {
            'Channel': channel,
            'UserField': data,
            'Append': append and 'yes' or 'no'
        return self._translate_response(self.read_response(id))
    def Setvar(self, channel, variable, value):
        'Set <variable> of <channel> to <value>.'
        id = self._write_action('Setvar', {
            'Channel': channel,
            'Variable': variable,
            'Value': value
        return self._translate_response(self.read_response(id))
    def SipShowPeer(self, peer):
        'Fetch the status of SIP peer <peer>.'
        id = self._write_action('SIPshowpeer', {'Peer': peer})
        showpeer = self._translate_response(self.read_response(id))
        del showpeer['Response']
        return showpeer
    def SipShowRegistry(self):
        'Return a nested dict of SIP registry.'
        id = self._write_action('SIPshowregistry')
        registry = {}
        def RegistryEntry(self, event):
            event = self.strip_evinfo(event)
            name = event.pop('Host')
            registry[name] = event
        def RegistrationsComplete(self, event):
            stop_flag[0] = True
        events = Asterisk.Util.EventCollection([ RegistryEntry, RegistrationsComplete ])
        self.events += events
            stop_flag = [ False ]
            while stop_flag[0] == False:
                packet = self._read_packet()
            self.events -= events
        return registry
    def Status(self):
        'Return a nested dict of channel statii.'
        id = self._write_action('Status')
        channels = {}
        def Status(self, event):
            event = self.strip_evinfo(event)
            name = event.pop('Channel')
            channels[name] = event
        def StatusComplete(self, event):
            stop_flag[0] = True
        events = Asterisk.Util.EventCollection([ Status, StatusComplete ])
        self.events += events
            stop_flag = [ False ]
            while stop_flag[0] == False:
                packet = self._read_packet()
            self.events -= events
        return channels
    def StopMonitor(self, channel):
        'Stop monitoring of <channel>.'
        id = self._write_action('StopMonitor', { 'Channel': channel })
        return self._translate_response(self.read_response(id))
class ZapataActions(object):
    'Provide methods for Manager API actions exposed by the Zapata driver.'
    def ZapDialOffhook(self, channel, number):
        'Off-hook dial <number> on Zapata driver <channel>.'
        id = self._write_action('ZapDialOffhook', {
            'ZapChannel': channel,
            'Number': number
        return self._translate_response(self.read_response(id))
    def ZapDNDoff(self, channel):
        'Disable DND status on Zapata driver <channel>.'
        id = self._write_action('ZapDNDoff', { 'ZapChannel': str(int(channel)) })
        return self._translate_response(self.read_response(id))
    def ZapDNDon(self, channel):
        'Enable DND status on Zapata driver <channel>.'
        id = self._write_action('ZapDNDon', { 'ZapChannel': str(int(channel)) })
        return self._translate_response(self.read_response(id))
    def ZapHangup(self, channel):
        'Hangup Zapata driver <channel>.'
        id = self._write_action('ZapHangup', { 'ZapChannel': str(int(channel)) })
        return self._translate_response(self.read_response(id))
    def ZapShowChannels(self):
        'Return a nested dict of Zapata driver channel statii.'
        id = self._write_action('ZapShowChannels')
        channels = {}
        def ZapShowChannels(self, event):
            event = self.strip_evinfo(event)
            number = int(event.pop('Channel'))
            channels[number] = event
        def ZapShowChannelsComplete(self, event):
            stop_flag[0] = True
        events = Asterisk.Util.EventCollection([
            ZapShowChannels, ZapShowChannelsComplete ])
        self.events += events
            stop_flag = [ False ]
            while stop_flag[0] == False:
                packet = self._read_packet()
            self.events -= events
        return channels
    def ZapTransfer(self, channel):
        'Transfer Zapata driver <channel>.'
        # TODO: Does nothing on X100P. What is this for?
        id = self._write_action('ZapTransfer', { 'ZapChannel': channel })
        return self._translate_response(self.read_response(id))
class CoreManager(BaseManager, CoreActions, ZapataActions):
    Asterisk Manager API protocol implementation and core actions, but without
    event handlers.
class Manager(BaseManager, CoreActions, ZapataActions):
    Asterisk Manager API protocol implementation, core event handler
    placeholders, and core actions.