Metadata-Version: 2.1
Name: greenswitch
Version: 0.0.13
Summary: Battle proven FreeSWITCH Event Socket Protocol client implementation with Gevent.
Home-page: https://github.com/evoluxbr/greenswitch
Author: Ítalo Rossi
Author-email: italorossib@gmail.com
License: MIT
Platform: UNKNOWN
Classifier: Development Status :: 5 - Production/Stable
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 2.7
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.5
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Requires-Dist: gevent
Requires-Dist: six

GreenSWITCH: FreeSWITCH Event Socket Protocol
=============================================

.. image:: https://github.com/EvoluxBR/greenswitch/actions/workflows/tests.yml/badge.svg
    :target: https://github.com/EvoluxBR/greenswitch/actions

.. image:: https://img.shields.io/pypi/v/greenswitch.svg
    :target: https://pypi.python.org/pypi/greenswitch

.. image:: https://img.shields.io/pypi/dm/greenswitch.svg
    :target: https://pypi.python.org/pypi/greenswitch

Battle proven FreeSWITCH Event Socket Protocol client implementation with Gevent.

This is an implementation of FreeSWITCH Event Socket Protocol using Gevent
Greenlets. It is already in production and processing hundreds of calls per day.

Full Python3 support!

Inbound Socket Mode
===================

.. code-block:: python

    >>> import greenswitch
    >>> fs = greenswitch.InboundESL(host='127.0.0.1', port=8021, password='ClueCon')
    >>> fs.connect()
    >>> r = fs.send('api list_users')
    >>> print r.data


Outbound Socket Mode
====================

Outbound is implemented with sync and async support. The main idea is to create
an Application that will be called passing an OutboundSession as argument.
This OutboundSession represents a call that is handled by the ESL connection.
Basic functions are implemented already:

 - playback
 - play_and_get_digits
 - hangup
 - park
 - uuid_kill
 - answer
 - sleep

With current api, it's easy to mix sync and async actions, for example:
play_and_get_digits method will return the pressed DTMF digits in a block mode,
that means as soon as you call that method in your Python code the execution
flow will block and wait for the application to end only returning to the next
line after ending the application. But after getting digits, if you need to consume
an external system, like posting this to an external API you can leave the caller
hearing MOH while the API call is being done, you can call the playback method
with block=False, playback('my_moh.wav', block=False), after your API end we need
to tell FreeSWITCH to stop playing the file and give us back the call control,
for that we can use uuid_kill method.

Example of Outbound Socket Mode:

.. code-block:: python

    '''
    Add a extension on your dialplan to bound the outbound socket on FS channel
    as example below

    <extension name="out socket">
        <condition>
            <action application="socket" data="<outbound socket server host>:<outbound socket server port> async full"/>
        </condition>
    </extension>

    Or see the complete doc on https://freeswitch.org/confluence/display/FREESWITCH/mod_event_socket
    '''
    import gevent
    import greenswitch

    import logging
    logging.basicConfig(level=logging.DEBUG)


    class MyApplication(object):
        def __init__(self, session):
            self.session = session

        def run(self):
            """
            Main function that is called when a call comes in.
            """
            try:
                self.handle_call()
            except:
                logging.exception('Exception raised when handling call')
                self.session.stop()

        def handle_call(self):
            # We want to receive events related to this call
            # They are also needed to know when an application is done running
            # for example playback
            self.session.myevents()
            print("myevents")
            # Send me all the events related to this call even if the call is already
            # hangup
            self.session.linger()
            print("linger")
            self.session.answer()
            print("answer")
            gevent.sleep(1)
            print("sleep")
            # Now block until the end of the file. pass block=False to
            # return immediately.
            self.session.playback('ivr/ivr-welcome')
            print("welcome")
            # blocks until the caller presses a digit, see response_timeout and take
            # the audio length in consideration when choosing this number
            digit = self.session.play_and_get_digits('1', '1', '3', '5000', '#',
                                                     'conference/conf-pin.wav',
                                                     'invalid.wav',
                                                     'test', '\d', '1000', "''",
                                                     block=True, response_timeout=5)
            print("User typed: %s" % digit)
            # Start music on hold in background without blocking code execution
            # block=False makes the playback function return immediately.
            self.session.playback('local_stream://default', block=False)
            print("moh")
            # Now we can do a long task, for example, processing a payment,
            # consuming an APIs or even some database query to find our customer :)
            gevent.sleep(5)
            print("sleep 5")
            # We finished processing, stop the music on hold and do whatever you want
            # Note uuid_break is a general API and requires full permission
            self.session.uuid_break()
            print("break")
            # Bye caller
            self.session.hangup()
            print("hangup")
            # Close the socket so freeswitch can leave us alone
            self.session.stop()

        server = greenswitch.OutboundESLServer(bind_address='0.0.0.0',
                                       bind_port=5000,
                                       application=MyApplication,
                                       max_connections=5)
        server.listen()


Enjoy!

Feedbacks always welcome.


