Function messages

web/pgadmin/tools/debugger/__init__.py:1308–1358

messages(trans_id) This method polls the messages returned by the database server. Parameters: trans_id - unique transaction id.

(trans_id)

)
@pga_login_required
def messages(trans_id):
    """
    messages(trans_id)

    This method polls the messages returned by the database server.

    Parameters:
        trans_id
        - unique transaction id.
    """
    de_inst = DebuggerInstance(trans_id)
    if de_inst.debugger_data is None:
        return make_json_response(
            data={
                'status': 'NotConnected',
                'result': SERVER_CONNECTION_CLOSED
            }
        )

    manager = get_driver(PG_DEFAULT_DRIVER).connection_manager(
        de_inst.debugger_data['server_id'])
    conn = manager.connection(
        did=de_inst.debugger_data['database_id'],
        conn_id=de_inst.debugger_data['conn_id'])

    port_number = ''

    if conn.connected():
        status = 'Busy'
        notify = conn.messages()
        if notify:
            # In notice message we need to find "PLDBGBREAK" string to find
            # the port number to attach.
            # Notice message returned by the server is
            # "NOTICE:  PLDBGBREAK:7".
            # From the above message we need to find out port number
            # as "7" so below logic will find 7 as port number
            # and attach listened to that port number
            tmp_list = [x for x in notify if 'PLDBGBREAK' in x]
            if len(tmp_list) > 0:
                port_number = re.search(r'\d+', tmp_list[0])
                if port_number is not None:
                    status = 'Success'
                    port_number = port_number.group(0)

        return make_json_response(
            data={'status': status, 'result': port_number}
        )
    else:
        result = SERVER_CONNECTION_CLOSED
        return internal_server_error(errormsg=str(result))


@blueprint.route(