LogFileMessageEventHandler.handle()

Complexity

Conditions

11

Size

Total Lines

62

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	132

Importance

Changes	1
Bugs	0	Features	0

"""
    @staticmethod
    # ------------------------------------------------------------------------------------------------------------------
    def handle(_event, message, _listener_data):
        """
        Handles a LogFileMessage received event.
        

Trailing whitespace

        :param * _event: Not used.
        :param enarksh.message.logger.LogFileMessage.LogFileMessage message: The message.
        :param * _listener_data: Not used.
        """
        del _event, _listener_data

        print("%s %s %s" % (message.rnd_id, message.name, message.total_size))

        DataLayer.connect()

        if message.total_size > 0:
            # Read the log file or log files and concatenate if necessary.
            with open(message.filename1, 'rb') as f:

The name f does not conform to the variable naming conventions ([a-z_][a-z0-9_]{1,60}$).

                log = f.read()

            if message.filename2:
                with open(message.filename2, 'rb') as f:

The name f does not conform to the variable naming conventions ([a-z_][a-z0-9_]{1,60}$).

                    buf2 = f.read()
            else:
                buf2 = ''

            # Compute the number of skipped bytes.
            skipped = message.total_size - len(log) - len(buf2)

            if skipped != 0:
                # Add a newline to the end of the buffer, if required.
                if log[-1:] != '\n':
                    log += '\n'

                    # Note: This concatenation doesn't work for multi byte character sets.
                    log += '\n'
                    log += "Enarksh: Skipped {0} bytes.\n".format(skipped)
                    log += '\n'

                log += buf2

            blb_id = DataLayer.enk_blob_insert_blob(message.name, 'text/plain', log)

        else:
            blb_id = None

        if message.name == 'out':
            DataLayer.enk_back_run_node_update_log(message.rnd_id, blb_id, message.total_size)
        elif message.name == 'err':
            DataLayer.enk_back_run_node_update_err(message.rnd_id, blb_id, message.total_size)
        else:
            raise ValueError("Unknown output name '%s'" % message.name)

        # Remove the (temporary) log files.
        if message.filename1:
            os.unlink(message.filename1)
        if message.filename2:
            os.unlink(message.filename2)

        DataLayer.commit()
        DataLayer.disconnect()