Changeset View
Changeset View
Standalone View
Standalone View
pykolab/cli/telemetry/cmd_examine_command_issue.py
| Show First 20 Lines • Show All 66 Lines • ▼ Show 20 Lines | user = db.query( | ||||
| ).first() | ).first() | ||||
| server = db.query( | server = db.query( | ||||
| telemetry.TelemetryServer | telemetry.TelemetryServer | ||||
| ).filter_by( | ).filter_by( | ||||
| id=session.server_id | id=session.server_id | ||||
| ).first() | ).first() | ||||
| print _("Session by %s on server %s") % (user.sasl_username,server.fqdn) | print(_("Session by %s on server %s") % (user.sasl_username,server.fqdn)) | ||||
| command_issues = db.query( | command_issues = db.query( | ||||
| telemetry.TelemetryCommandIssue | telemetry.TelemetryCommandIssue | ||||
| ).filter_by( | ).filter_by( | ||||
| session_id=session.id | session_id=session.id | ||||
| ) | ) | ||||
| for _command_issue in command_issues: | for _command_issue in command_issues: | ||||
| command = db.query( | command = db.query( | ||||
| telemetry.TelemetryCommand | telemetry.TelemetryCommand | ||||
| ).filter_by( | ).filter_by( | ||||
| id=_command_issue.command_id | id=_command_issue.command_id | ||||
| ).first() | ).first() | ||||
| command_arg = db.query( | command_arg = db.query( | ||||
| telemetry.TelemetryCommandArg | telemetry.TelemetryCommandArg | ||||
| ).filter_by( | ).filter_by( | ||||
| id=_command_issue.command_arg_id | id=_command_issue.command_arg_id | ||||
| ).first() | ).first() | ||||
| if command_issue.id == _command_issue.id: | if command_issue.id == _command_issue.id: | ||||
| print "=========" | print("=========") | ||||
| print "Client(%d): %s %s %s" % ( | print("Client(%d): %s %s %s" % ( | ||||
| _command_issue.id, | _command_issue.id, | ||||
| _command_issue.command_tag, | _command_issue.command_tag, | ||||
| command.command, | command.command, | ||||
| command_arg.command_arg | command_arg.command_arg | ||||
| ) | )) | ||||
| server_responses = db.query( | server_responses = db.query( | ||||
| telemetry.TelemetryServerResponse | telemetry.TelemetryServerResponse | ||||
| ).filter_by( | ).filter_by( | ||||
| command_issue_id=_command_issue.id | command_issue_id=_command_issue.id | ||||
| ) | ) | ||||
| for server_response in server_responses: | for server_response in server_responses: | ||||
| server_response_lines = server_response.response.split('\n'); | server_response_lines = server_response.response.split('\n'); | ||||
| for server_response_line in server_response_lines: | for server_response_line in server_response_lines: | ||||
| print "Server(%d): %s" % ( | print("Server(%d): %s" % ( | ||||
| server_response.id, | server_response.id, | ||||
| server_response_line | server_response_line | ||||
| ) | )) | ||||
| if command_issue.id == _command_issue.id: | if command_issue.id == _command_issue.id: | ||||
| print "=========" | print("=========") | ||||