(self, params, **kwargs)
| 898 | return ssh_agent_log_parser |
| 899 | |
| 900 | def execute(self, params, **kwargs): |
| 901 | if not isinstance(params.ssh_agent, SshAgentContext): |
| 902 | logging.warning('SSH Agent is not started') |
| 903 | return |
| 904 | table = [] |
| 905 | headers = ['Time', 'Level', 'Message'] |
| 906 | for record in params.ssh_agent.log_messages: |
| 907 | if record.levelno <= logging.DEBUG: |
| 908 | severity = 'DEBUG' |
| 909 | elif record.levelno <= logging.INFO: |
| 910 | severity = 'INFO' |
| 911 | elif record.levelno <= logging.WARNING: |
| 912 | severity = 'WARN' |
| 913 | else: |
| 914 | severity = 'ERROR' |
| 915 | message = record.msg % record.args |
| 916 | table.append([datetime.datetime.fromtimestamp(int(record.created)), severity, message]) |
| 917 | |
| 918 | return dump_report_data(table, headers=headers, fmt=kwargs.get('format'), filename=kwargs.get('output')) |
no test coverage detected