TechDivision\Import\Subjects\AbstractSubject::importRow()

Complexity

Conditions	10
Paths	16

Size

Total Lines

108

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	46
CRAP Score	10.0512

Importance

Changes

0

<?php
    public function importRow(array $row)
    {

        // initialize the row
        $this->row = $row;

        // raise the line number and reset the skip row flag
        $this->lineNumber++;
        $this->skipRow = false;

        // invoke the events that has to be fired before the artfact's row will be processed
        $this->getEmitter()->emit(EventNames::SUBJECT_ARTEFACT_ROW_PROCESS_START, $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

        $this->getEmitter()->emit($this->getEventName(EventNames::SUBJECT_ARTEFACT_ROW_PROCESS_START), $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

        // initialize the headers with the columns from the first line
        if (sizeof($this->headers) === 0) {
            // invoke the events that has to be fired before the artfact's header row will be processed
            $this->getEmitter()->emit(EventNames::SUBJECT_ARTEFACT_HEADER_ROW_PROCESS_START, $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

            $this->getEmitter()->emit($this->getEventName(EventNames::SUBJECT_ARTEFACT_HEADER_ROW_PROCESS_START), $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

            // iterate over the column name => key an map the header names, if necessary
            foreach ($this->row as $value => $key) {
                $this->headers[$this->mapAttributeCodeByHeaderMapping($key)] = $value;
            }

            // iterate over the default column values to figure out whether or not the column exists
            foreach ($this->defaultColumnValues as $name => $value) {
                // do nothing, if the column already exists
                if (array_key_exists($key = $this->mapAttributeCodeByHeaderMapping($name), $this->headers)) {
                    continue;
                }
                // add the header and the default value for the column
                $this->headers[$key] = $columnKey = sizeof($this->headers);
                $this->columnValues[$columnKey] = $value;
            }

            // invoke the events that has to be fired when the artfact's header row has been successfully processed
            $this->getEmitter()->emit(EventNames::SUBJECT_ARTEFACT_HEADER_ROW_PROCESS_SUCCESS, $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

            $this->getEmitter()->emit($this->getEventName(EventNames::SUBJECT_ARTEFACT_HEADER_ROW_PROCESS_SUCCESS), $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

        } else {
            // merge the default column value into the actual row
            $this->row = array_replace($this->row, $this->columnValues);

            // load the available observers
            $availableObservers = $this->getObservers();

            // process the observers
            foreach ($availableObservers as $observers) {
                // invoke the pre-import/import and post-import observers
                /** @var \TechDivision\Import\Observers\ObserverInterface $observer */
                foreach ($observers as $observer) {
                    // query whether or not we have to skip the row
                    if ($this->skipRow) {
                        // log a debug message with the actual line nr/file information
                        $this->getSystemLogger()->debug(
                            $this->appendExceptionSuffix(
                                sprintf(
                                    'Skip processing operation "%s" after observer "%s"',
                                    $this->getFullOperationName(),
                                    get_class($observer)
                                )
                            )
                        );

                        // skip the row
                        break 2;
                    }

                    // if not, set the subject and process the observer
                    if ($observer instanceof ObserverInterface) {
                        $this->row = $observer->handle($this);
                    }
                }
            }
        }

        // query whether or not a minute has been passed
        if ($this->lastLog < time() - 59) {
            // log the number processed rows per minute
            $this->getSystemLogger()->info(
                sprintf(
                    'Operation "%s" successfully processed "%d (%d)" rows per minute of file "%s"',
                    $this->getFullOperationName(),
                    $this->lineNumber - $this->lastLineNumber,
                    $this->lineNumber,
                    basename($this->getFilename())
                )
            );

            // reset the last log time and the line number
            $this->lastLog = time();
            $this->lastLineNumber = $this->lineNumber;
        }

        // log a debug message with the actual line nr/file information
        $this->getSystemLogger()->debug(
            $this->appendExceptionSuffix(
                sprintf(
                    'Successfully processed operation "%s"',
                    implode(' > ', $this->getConfiguration()->getConfiguration()->getOperationNames())
                )
            )
        );

        // invoke the events that has to be fired when the artfact's row has been successfully processed
        $this->getEmitter()->emit(EventNames::SUBJECT_ARTEFACT_ROW_PROCESS_SUCCESS, $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

        $this->getEmitter()->emit($this->getEventName(EventNames::SUBJECT_ARTEFACT_ROW_PROCESS_SUCCESS), $this);

The call to EmitterInterface::emit() has too many arguments starting with $this.

    }