Source code for plaso.parsers.text_plugins.teamviewer

"""Text parser plugins for TeamViewer log files."""

import pyparsing

from dfdatetime import time_elements as dfdatetime_time_elements

from plaso.containers import events
from plaso.lib import errors
from plaso.parsers import text_parser
from plaso.parsers.text_plugins import interface


[docs] class TeamViewerApplicationEventData(events.EventData): """TeamViewer application log event data. Attributes: body (str): body of the log entry. process_identifier (int): process identifier that generated the log entry. recorded_time (dfdatetime.DateTimeValues): date and time the log entry was recorded. """ DATA_TYPE = "teamviewer:application_log:entry"
[docs] def __init__(self): """Initializes event data.""" super().__init__(data_type=self.DATA_TYPE) self.body = None self.process_identifier = None self.recorded_time = None
[docs] class TeamViewerConnectionsIncomingEventData(events.EventData): """TeamViewer incoming connection log event data. Attributes: activity_type (str): Type of the activity, such as RemoteSupport or FileTransfer. connection_identifier (str): identifier of the connection, contains an UUID. display_name (string): The display name of the incoming connection source. Usually the computer name or the TeamViewer user name. end_time (dfdatetime.DateTimeValues): connection end time in UTC. local_account (str): The local user account associated with this activity. source_identifier (int): TeamViewer identifier of the incoming connection. start_time (dfdatetime.DateTimeValues): connection start time in UTC. """ DATA_TYPE = "teamviewer:connections_incoming:entry"
[docs] def __init__(self): """Initializes event data.""" super().__init__(data_type=self.DATA_TYPE) self.activity_type = None self.connection_identifier = None self.display_name = None self.end_time = None self.local_account = None self.source_identifier = None self.start_time = None
[docs] class TeamViewerConnectionsOutgoingEventData(events.EventData): """TeamViewer outgoing connection log event data. Attributes: activity_type (str): Type of the activity, such as RemoteSupport or FileTransfer. connection_identifier (str): identifier of the connection, contains a UUID. destination_identifier (int): TeamViewer identifier of the destination. end_time (dfdatetime.DateTimeValues): connection end time in UTC. local_account (str): The local user account associated with this activity. start_time (dfdatetime.DateTimeValues): connection start time in UTC. """ DATA_TYPE = "teamviewer:connections_outgoing:entry"
[docs] def __init__(self): """Initializes event data.""" super().__init__(data_type=self.DATA_TYPE) self.activity_type = None self.connection_identifier = None self.destination_identifier = None self.end_time = None self.local_account = None self.start_time = None
[docs] class TeamViewerApplicationLogTextPlugin(interface.TextPluginWithLineContinuation): """Text parser plugin for TeamViewer application log files.""" NAME = "teamviewer_application_log" DATA_FORMAT = "TeamViewer application log file parser." _TWO_DIGITS = pyparsing.Word(pyparsing.nums, exact=2).set_parse_action( lambda tokens: int(tokens[0], 10) ) _THREE_DIGITS = pyparsing.Word(pyparsing.nums, exact=3).set_parse_action( lambda tokens: int(tokens[0], 10) ) _FOUR_DIGITS = pyparsing.Word(pyparsing.nums, exact=4).set_parse_action( lambda tokens: int(tokens[0], 10) ) _TIMESTAMP = ( _FOUR_DIGITS + pyparsing.Suppress("/") + _TWO_DIGITS + pyparsing.Suppress("/") + _TWO_DIGITS + _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS + pyparsing.Suppress(".") + _THREE_DIGITS ) _LOG_LINE = ( _TIMESTAMP.set_results_name("timestamp") + pyparsing.Word(pyparsing.nums) .set_parse_action(lambda tokens: int(tokens[0], 10)) .set_results_name("process_identifier") + # Field with unknown purpose. pyparsing.Suppress(pyparsing.Word(pyparsing.nums)) + # Field with unknown purpose. pyparsing.Suppress(pyparsing.Word(pyparsing.alphanums + "!")) + pyparsing.restOfLine().set_results_name("body") + pyparsing.Suppress(pyparsing.LineEnd()) ) VERIFICATION_GRAMMAR = _LOG_LINE _LINE_STRUCTURES = [("log_line", _LOG_LINE)]
[docs] def __init__(self): """Initializes a text parser plugin.""" super().__init__() self._body_lines = None self._event_data = None
def _ParseFinalize(self, parser_mediator): """Finalizes parsing. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. """ if self._event_data: self._event_data.body = "".join(self._body_lines) self._body_lines = None parser_mediator.ProduceEventData(self._event_data) self._event_data = None def _ParseLogLine(self, structure): """Parses a log line. Args: structure (pyparsing.ParseResults): structure of tokens derived from a line of a text file. """ time_elements_structure = self._GetValueFromStructure(structure, "timestamp") event_data = TeamViewerApplicationEventData() event_data.process_identifier = self._GetValueFromStructure( structure, "process_identifier" ) event_data.recorded_time = self._ParseTimeElements(time_elements_structure) body = self._GetValueFromStructure(structure, "body").strip() self._body_lines = [body] self._event_data = event_data def _ParseRecord(self, parser_mediator, key, structure): """Parses a pyparsing structure. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. key (str): name of the parsed structure. structure (pyparsing.ParseResults): tokens from a parsed log line. Raises: ParseError: if the structure cannot be parsed. """ if key == "_line_continuation": body = structure.strip() self._body_lines.append(body) else: if self._event_data: self._event_data.body = "".join(self._body_lines) parser_mediator.ProduceEventData(self._event_data) self._ParseLogLine(structure) def _ParseTimeElements(self, time_elements_structure): """Parses date and time elements of a log line. Args: time_elements_structure (pyparsing.ParseResults): date and time elements of a log line. Returns: dfdatetime.TimeElements: date and time value. Raises: ParseError: if a valid date and time value cannot be derived from the time elements. """ try: year, month, day, hours, minutes, seconds, milliseconds = ( time_elements_structure ) time_elements_tuple = ( year, month, day, hours, minutes, seconds, milliseconds, ) date_time = dfdatetime_time_elements.TimeElementsInMilliseconds( time_elements_tuple=time_elements_tuple ) return date_time except (IndexError, TypeError, ValueError) as exception: raise errors.ParseError( f"Unable to parse time elements with error: {exception!s}" ) def _ResetState(self): """Resets stored values.""" self._body_lines = None self._event_data = None
[docs] def CheckRequiredFormat(self, parser_mediator, text_reader): """Check if the log record has the minimal structure required by the parser. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. text_reader (EncodedTextReader): text reader. Returns: bool: True if this is the correct parser, False otherwise. """ try: structure = self._VerifyString(text_reader.lines) except errors.ParseError: return False time_elements_structure = self._GetValueFromStructure(structure, "timestamp") try: self._ParseTimeElements(time_elements_structure) except errors.ParseError: return False self._ResetState() return True
[docs] class TeamViewerConnectionsOutgoingLogTextPlugin(interface.TextPlugin): """Text parser plugin for TeamViewer connections.txt log files.""" NAME = "teamviewer_connections_outgoing" DATA_FORMAT = "TeamViewer connections.txt log file" _TEAMVIEWER_ID = pyparsing.Word(pyparsing.nums, min=8, max=11).set_parse_action( lambda tokens: int(tokens[0], 10) ) _NAME = pyparsing.Word(pyparsing.alphanums + "-" + "." + "_") _GUID = pyparsing.Word(pyparsing.hexnums + "{" + "}" + "-") _TWO_DIGITS = pyparsing.Word(pyparsing.nums, exact=2).set_parse_action( lambda tokens: int(tokens[0], 10) ) _FOUR_DIGITS = pyparsing.Word(pyparsing.nums, exact=4).set_parse_action( lambda tokens: int(tokens[0], 10) ) _DATE = ( _TWO_DIGITS + pyparsing.Suppress("-") + _TWO_DIGITS + pyparsing.Suppress("-") + _FOUR_DIGITS ) _TIME = ( _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS ) _DATE_TIME = _DATE + _TIME _END_OF_LINE = pyparsing.Suppress(pyparsing.LineEnd()) _LOG_LINE = ( _TEAMVIEWER_ID.set_results_name("source_identifier") + _DATE_TIME.set_results_name("session_start_timestamp") + _DATE_TIME.set_results_name("session_end_timestamp") + _NAME.set_results_name("local_account") + pyparsing.Word(pyparsing.alphanums).set_results_name("activity_type") + _GUID.set_results_name("connection_identifier") + pyparsing.Suppress(pyparsing.LineEnd()) ) VERIFICATION_GRAMMAR = _LOG_LINE _LINE_STRUCTURES = [("log_line", _LOG_LINE)] def _ParseRecord(self, parser_mediator, key, structure): """Parses a pyparsing structure. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. key (str): name of the parsed structure. structure (pyparsing.ParseResults): tokens from a parsed log line. Raises: ParseError: if the structure cannot be parsed. """ start_time_elements = self._GetValueFromStructure( structure, "session_start_timestamp" ) end_time_elements = self._GetValueFromStructure( structure, "session_end_timestamp" ) event_data = TeamViewerConnectionsOutgoingEventData() event_data.activity_type = self._GetValueFromStructure( structure, "activity_type" ) event_data.connection_identifier = self._GetValueFromStructure( structure, "connection_identifier" ) event_data.end_time = self._ParseTimeElements(end_time_elements) event_data.local_account = self._GetValueFromStructure( structure, "local_account" ) event_data.destination_identifier = self._GetValueFromStructure( structure, "source_identifier" ) event_data.start_time = self._ParseTimeElements(start_time_elements) parser_mediator.ProduceEventData(event_data) def _ParseTimeElements(self, time_elements_structure): """Parses date and time elements of a log line. Args: time_elements_structure (pyparsing.ParseResults): date and time elements of a log line. Returns: dfdatetime.TimeElements: date and time value. Raises: ParseError: if a valid date and time value cannot be derived from the time elements. """ try: day_of_month, month, year, hours, minutes, seconds = time_elements_structure time_elements_tuple = (year, month, day_of_month, hours, minutes, seconds) date_time = dfdatetime_time_elements.TimeElements( time_elements_tuple=time_elements_tuple, time_zone_offset=0 ) return date_time except (IndexError, TypeError, ValueError) as exception: raise errors.ParseError( f"Unable to parse time elements with error: {exception!s}" )
[docs] def CheckRequiredFormat(self, parser_mediator, text_reader): """Check if the log record has the minimal structure required by the parser. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. text_reader (EncodedTextReader): text reader. Returns: bool: True if this is the correct parser, False otherwise. """ try: structure = self._VerifyString(text_reader.lines) except errors.ParseError: return False start_time_elements = self._GetValueFromStructure( structure, "session_start_timestamp" ) end_time_elements = self._GetValueFromStructure( structure, "session_end_timestamp" ) try: self._ParseTimeElements(start_time_elements) self._ParseTimeElements(end_time_elements) except errors.ParseError: return False return True
[docs] class TeamViewerConnectionsIncomingLogTextPlugin(interface.TextPlugin): """Text parser plugin for TeamViewer connections_incoming.txt .""" NAME = "teamviewer_connections_incoming" DATA_FORMAT = "TeamViewer connections_incoming.txt log file" _TEAMVIEWER_ID = pyparsing.Word(pyparsing.nums, min=8, max=11).set_parse_action( lambda tokens: int(tokens[0], 10) ) _NAME = pyparsing.Word(pyparsing.alphanums + "-" + "." + "_") _GUID = pyparsing.Word(pyparsing.hexnums + "{" + "}" + "-") _TWO_DIGITS = pyparsing.Word(pyparsing.nums, exact=2).set_parse_action( lambda tokens: int(tokens[0], 10) ) _FOUR_DIGITS = pyparsing.Word(pyparsing.nums, exact=4).set_parse_action( lambda tokens: int(tokens[0], 10) ) _DATE = ( _TWO_DIGITS + pyparsing.Suppress("-") + _TWO_DIGITS + pyparsing.Suppress("-") + _FOUR_DIGITS ) _TIME = ( _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS + pyparsing.Suppress(":") + _TWO_DIGITS ) _DATE_TIME = _DATE + _TIME _END_OF_LINE = pyparsing.Suppress(pyparsing.LineEnd()) _LOG_LINE = ( _TEAMVIEWER_ID.set_results_name("source_identifier") + _NAME.set_results_name("display_name") + _DATE_TIME.set_results_name("session_start_timestamp") + _DATE_TIME.set_results_name("session_end_timestamp") + _NAME.set_results_name("local_account") + pyparsing.Word(pyparsing.alphanums).set_results_name("activity_type") + _GUID.set_results_name("connection_identifier") + pyparsing.Suppress(pyparsing.LineEnd()) ) VERIFICATION_GRAMMAR = _LOG_LINE _LINE_STRUCTURES = [("log_line", _LOG_LINE)] def _ParseRecord(self, parser_mediator, key, structure): """Parses a pyparsing structure. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. key (str): name of the parsed structure. structure (pyparsing.ParseResults): tokens from a parsed log line. Raises: ParseError: if the structure cannot be parsed. """ start_time_elements = self._GetValueFromStructure( structure, "session_start_timestamp" ) end_time_elements = self._GetValueFromStructure( structure, "session_end_timestamp" ) event_data = TeamViewerConnectionsIncomingEventData() event_data.activity_type = self._GetValueFromStructure( structure, "activity_type" ) event_data.connection_identifier = self._GetValueFromStructure( structure, "connection_identifier" ) event_data.display_name = self._GetValueFromStructure(structure, "display_name") event_data.end_time = self._ParseTimeElements(end_time_elements) event_data.local_account = self._GetValueFromStructure( structure, "local_account" ) event_data.source_identifier = self._GetValueFromStructure( structure, "source_identifier" ) event_data.start_time = self._ParseTimeElements(start_time_elements) parser_mediator.ProduceEventData(event_data) def _ParseTimeElements(self, time_elements_structure): """Parses date and time elements of a log line. Args: time_elements_structure (pyparsing.ParseResults): date and time elements of a log line. Returns: dfdatetime.TimeElements: date and time value. Raises: ParseError: if a valid date and time value cannot be derived from the time elements. """ try: day_of_month, month, year, hours, minutes, seconds = time_elements_structure time_elements_tuple = (year, month, day_of_month, hours, minutes, seconds) date_time = dfdatetime_time_elements.TimeElements( time_elements_tuple=time_elements_tuple, time_zone_offset=0 ) return date_time except (IndexError, TypeError, ValueError) as exception: raise errors.ParseError( f"Unable to parse time elements with error: {exception!s}" )
[docs] def CheckRequiredFormat(self, parser_mediator, text_reader): """Check if the log record has the minimal structure required by the parser. Args: parser_mediator (ParserMediator): mediates interactions between parsers and other components, such as storage and dfVFS. text_reader (EncodedTextReader): text reader. Returns: bool: True if this is the correct parser, False otherwise. """ try: structure = self._VerifyString(text_reader.lines) except errors.ParseError: return False start_time_elements = self._GetValueFromStructure( structure, "session_start_timestamp" ) end_time_elements = self._GetValueFromStructure( structure, "session_end_timestamp" ) try: self._ParseTimeElements(start_time_elements) self._ParseTimeElements(end_time_elements) except errors.ParseError: return False return True
text_parser.TextLogParser.RegisterPlugins( [ TeamViewerApplicationLogTextPlugin, TeamViewerConnectionsIncomingLogTextPlugin, TeamViewerConnectionsOutgoingLogTextPlugin, ] )