morgue\zip\ArchiveReader::read()

Complexity

Conditions	7
Paths	11

Size

Total Lines	48
Code Lines	25

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	56

Importance

Changes

0

<?php
    public function read($stream, int $offset = 0): Archive
    {
        $meta = \stream_get_meta_data($stream);
        if (!$meta['seekable']) {
            throw new \InvalidArgumentException('Zip archive can only be read from a seekable stream.');
        }

        $endOfCentralDirectory = $this->findEndOfCentralDirectory($stream);

        // Read central directory binary representation
        if (\fseek($stream, $offset + $endOfCentralDirectory->getOffsetOfStartOfCentralDirectoryWithRespectToTheStartingDiskNumber()) === -1) {
            throw new \RuntimeException("Unable to read Central Directory");
        }
        $centralDirectoryData = \fread($stream, $endOfCentralDirectory->getSizeOfTheCentralDirectory());

        $archive = new Archive();
        $archive = $archive->withComment($endOfCentralDirectory->getZipFileComment());

        // Read entries from central directory
        for ($position = 0, $i=0; $i<$endOfCentralDirectory->getTotalNumberOfEntriesInTheCentralDirectory(); $i++) {
            // Parse central directory entry incl. variable length fields
            $centralDirectoryEntry = CentralDirectoryHeader::parse($centralDirectoryData, $position);
            $position += CentralDirectoryHeader::MIN_LENGTH;
            if ($centralDirectoryEntry->getVariableLength() > 0) {
                $position += $centralDirectoryEntry->parseAdditionalData($centralDirectoryData, $position);
            }

            // Seek to local file header, parse it incl. variable length fields
            // File handle position is now at the start of the file content
            \fseek($stream, $offset + $centralDirectoryEntry->getRelativeOffsetOfLocalHeader());
            $localHeader = LocalFileHeader::parse(\fread($stream, LocalFileHeader::MIN_LENGTH));
            if ($localHeader->getVariableLength() > 0) {
                $localHeader->parseAdditionalData(\fread($stream, $localHeader->getVariableLength()));
            }

            // Create archive entry and attach content stream for non-directories
            $archiveEntry = $centralDirectoryEntry->toArchiveEntry();
            if (!$centralDirectoryEntry->isDirectory()) {
                $archiveEntry = $archiveEntry->withSourceStream(
                    \fopen(SUBSTREAM_SCHEME . '://' . \ftell($stream) . ':' . $centralDirectoryEntry->getCompressedSize() . '/' . (int)$stream, 'r')
                );
            }

            $archive = $archive->addEntry($archiveEntry);
        }

        return $archive;
    }