#1. This code only runs after a post request from AT
    @ussd.route('/ussd/callback', methods=['POST'])
    def ussd_callback():
        """
        Handles post call back from AT

        :return:
        """

    # 2. Import all neccesary modules
    from flask import g, make_response
    
    from app.models import AnonymousUser
    from . import ussd
    from .airtime import Airtime
    from .deposit import Deposit
    from .home import LowerLevelMenu
    from .register import RegistrationMenu
    from .withdraw import WithDrawal

    # 3. get data from ATs post payload
    session_id = request.values.get("sessionId", None)
    phone_number = request.values.get("phoneNumber", None)
    text = request.values.get("text", "default")

    text_array = text.split("*")
    user_response = text_array[len(text_array) - 1]

	# 4. Query session metadata from redis or initialize a new session for this user if the session does not exist
        # get session
        session = redis.get(session_id)
        if session is None:
            session = {"level": 0, "session_id": session_id}
            redis.set(session_id, json.dumps(session))
        else:
            session = json.loads(session.decode())
        # add user, response and session to the request variable g
        g.user_response = text_array[len(text_array) - 1]
        g.session = session
        g.current_user = user
        g.phone_number = phone_number
        g.session_id = session_id
        return func(*args, **kwargs)

	# 5. Check if the user is in the db
    session_id = g.session_id
    user = g.current_user
    session = g.session
    user_response = g.user_response
    if isinstance(user, AnonymousUser):
        # register user
        menu = RegistrationMenu(session_id=session_id, session=session, phone_number=g.phone_number,
                                user_response=user_response, user=user)
        return menu.execute()

    # 7. Serve the Services Menu 
    if level < 2:
        menu = LowerLevelMenu(session_id=session_id, session=session, phone_number=g.phone_number,
                              user_response=user_response, user=user)
        return menu.execute()

    if level >= 50:
        menu = Deposit(session_id=session_id, session=session, phone_number=g.phone_number,
                       user_response=user_response, user=user, level=level)
        return menu.execute()

    if level >= 40:
        menu = WithDrawal(session_id=session_id, session=session, phone_number=g.phone_number,
                          user_response=user_response, user=user, level=level)
        return menu.execute()

    if level >= 10:
        menu = Airtime(session_id=session_id, session=session, phone_number=g.phone_number, user_response=user_response,
                       user=user, level=level)
        return menu.execute()
	

    if isinstance(user, AnonymousUser):
        # register user
        menu = RegistrationMenu(session_id=session_id, session=session, phone_number=g.phone_number,
                                user_response=user_response, user=user)
        return menu.execute()
        

   def please_call(self):
        # call the user and bridge to a sales person
        menu_text = "END Please wait while we place your call.\n"

        # make a call
        caller = current_app.config["AT_NUMBER"]
        to = self.user.phone_number

        # create a new instance of our awesome gateway
        gateway = AfricasTalkingGateway(
            current_app.config["AT_USERNAME"], current_app.config["AT_APIKEY"])
        try:
            gateway.call(caller, to)
        except AfricasTalkingGateway as e:
            print "Encountered an error when calling: {}".format(str(e))

        # print the response on to the page so that our gateway can read it
        return respond(menu_text)	case "2":

    @ussd.route('/voice/callback', methods=['POST'])
    def voice_callback():
        """
        voice_callback from AT's gateway is handled here

        """
        sessionId = request.get('sessionId')
        isActive = request.get('isActive')

        if isActive == "1":
            callerNumber = request.get('callerNumber')
            # GET values from the AT's POST request
            session_id = request.values.get("sessionId", None)
            isActive = request.values.get('isActive')
            serviceCode = request.values.get("serviceCode", None)
            text = request.values.get("text", "default")
            text_array = text.split("*")
            user_response = text_array[len(text_array) - 1]

            # Compose the response
            menu_text = '<?xml version="1.0" encoding="UTF-8"?>'
            menu_text += '<Response>'
            menu_text += '<GetDigits timeout="30" finishOnKey="#" callbackUrl="https://49af2317.ngrok.io/api/v1.1/voice/callback">'
            menu_text += '<Say>"Thank you for calling. Press 0 to talk to sales, 1 to talk to support or 2 to hear this message again."</Say>'
            menu_text += '</GetDigits>'
            menu_text += '<Say>"Thank you for calling. Good bye!"</Say>'
            menu_text += '</Response>'

            # Print the response onto the page so that our gateway can read it
            return respond(menu_text)

        else:
            # Read in call details (duration, cost). This flag is set once the call is completed.
            # Note that the gateway does not expect a response in thie case

            duration = request.get('durationInSeconds')
            currencyCode = request.get('currencyCode')
            amount = request.get('amount')

            # You can then store this information in the database for your records					

   @ussd.route('/voice/menu')
    def voice_menu():
        """
        When the user enters the digit - in this case 0, 1 or 2, this route 
        switches between the various dtmf digits to 
        make an outgoing call to the right recipient, who will be 
        bridged to speak to the person currently listening to music on hold. 
        We specify this music with the ringtone flag as follows: 
        ringbackTone="url_to/static/media/SautiFinaleMoney.mp3"
        """
    
        # 1. Receive POST from AT
        isActive = request.get('isActive')
        callerNumber = request.get('callerNumber')
        dtmfDigits = request.get('dtmfDigits')
        sessionId = request.get('sessionId')
        # Check if isActive=1 to act on the call or isActive=='0' to store the
        # result
    
        if (isActive == '1'):
                # 2a. Switch through the DTMFDigits
            if (dtmfDigits == "0"):
                # Compose response - talk to sales-
                response = '<?xml version="1.0" encoding="UTF-8"?>'
                response += '<Response>'
                response += '<Say>Please hold while we connect you to Sales.</Say>'
                response += '<Dial phoneNumbers="[email protected]" ringbackTone="{}"/>'.format(url_for('media', path='SautiFinaleMoney.mp3'))
                response += '</Response>'
    
                # Print the response onto the page so that our gateway can read it
                return respond(response)
    
            elif (dtmfDigits == "1"):
                # 2c. Compose response - talk to support-
                response = '<?xml version="1.0" encoding="UTF-8"?>'
                response += '<Response>'
                response += '<Say>Please hold while we connect you to Support.</Say>'
                response += '<Dial phoneNumbers="[email protected]" ringbackTone="{}"/>'.format(url_for('media', path='SautiFinaleMoney.mp3'))
                response += '</Response>'
    
                # Print the response onto the page so that our gateway can read it
                return respond(response)
            elif (dtmfDigits == "2"):
                # 2d. Redirect to the main IVR-
                response = '<?xml version="1.0" encoding="UTF-8"?>'
                response += '<Response>'
                response += '<Redirect>{}</Redirect>'.format(url_for('voice_callback'))
                response += '</Response>'
    
                # Print the response onto the page so that our gateway can read it
                return respond(response)
            else:
                # 2e. By default talk to support
                response = '<?xml version="1.0" encoding="UTF-8"?>'
                response += '<Response>'
                response += '<Say>Please hold while we connect you to Support.</Say>'
                response += '<Dial phoneNumbers="[email protected]" ringbackTone="{}"/>'.format(url_for('media', path='SautiFinaleMoney.mp3'))
                response += '</Response>'
    
                # Print the response onto the page so that our gateway can read it
                return respond(response)
        else:
            # 3. Store the data from the POST
            durationInSeconds = request.get('durationInSeconds')
            direction = request.get('direction')
            amount = request.get('amount')
            callerNumber = request.get('callerNumber')
            destinationNumber = request.get('destinationNumber')
            sessionId = request.get('sessionId')
            callStartTime = request.get('callStartTime')
            isActive = request.get('isActive')
            currencyCode = request.get('currencyCode')
            status = request.get('status')

        # 3a. Store the data, write your SQL statements here-