Dimtrovich\DbDumper\Importer::process()

Complexity

Conditions	20
Paths	636

Size

Total Lines	75
Code Lines	43

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	19
CRAP Score	22.1035

Importance

Changes	4
Bugs	0	Features	0

<?php
    public function process(string $filename): void
    {
        $extension = pathinfo($filename, PATHINFO_EXTENSION);

        switch ($extension) {
            case 'gz':
            case 'gzip':
                $this->compressor = CompressorFactory::create(Option::COMPRESSION_GZIP);
                break;

            case 'bz2':
            case 'bzip2':
                $this->compressor = CompressorFactory::create(Option::COMPRESSION_BZIP2);
                break;

            case 'sql':
                $this->compressor = CompressorFactory::create(Option::COMPRESSION_NONE);
                break;

            default:
                throw Exception::unavailableDriverForcompression($extension);

It seems like $extension can also be of type array; however, parameter $extension of Dimtrovich\DbDumper\Exceptions\Exception::unavailableDriverForcompression() does only seem to accept string, maybe add an additional type check?

        }

        if (null === $filename = $this->getFile($filename)) {
            throw Exception::failledToRead(func_get_arg(0));
        }

        if ($this->option->disable_foreign_keys_check && '' !== $disableForeignKeysCheck = $this->adapter->startDisableForeignKeysCheck()) {
            $this->pdo->exec($disableForeignKeysCheck);
        }

        /**
         * Read backup file line by line
         */
        $handle = fopen($filename, 'rb');

        if (! $handle) {

$handle is of type resource, thus it always evaluated to false.

            throw Exception::failledToRead($filename);
        }

        $buffer = '';

        try {
            while (! feof($handle)) {
                $line = fgets($handle);

                if (substr($line, 0, 2) === '--' || ! $line) {
                    continue; // skip comments
                }

                $buffer .= $line;

                // if it has a semicolon at the end, it's the end of the query
                if (';' === substr(rtrim($line), -1, 1)) {
                    if (false !== $affectedRows = $this->pdo->exec($buffer)) {
                        if (preg_match('/^CREATE TABLE `([^`]+)`/i', $buffer, $tableName)) {
                            $this->event->emit('table.create', $tableName[1]);
                        }
                        if (preg_match('/^INSERT INTO `([^`]+)`/i', $buffer, $tableName)) {
                            $this->event->emit('table.insert', $tableName[1], $affectedRows);
                        }
                    }

                    $buffer = '';
                }
            }
        } catch (PDOException $e) {
            throw Exception::pdoException($e->getMessage(), $buffer);
        } finally {
            fclose($handle);
            unlink($filename);
        }

        if ($this->option->disable_foreign_keys_check && '' !== $enableForeignKeysCheck = $this->adapter->endDisableForeignKeysCheck()) {
            $this->pdo->exec($enableForeignKeysCheck);
        }