<?php

// phpcs:disable WordPress.WP.AlternativeFunctions -- custom read/write file, third party credit.

namespace MainWP\Child;

class Tar_Archiver {
	const IDLE   = 0;
	const APPEND = 1;
	const CREATE = 2;

	protected $excludeZip;

	protected $archive;
	protected $archivePath;
	protected $archiveSize;
	protected $lastRun = 0;

	protected $debug;

	protected $chunk     = '';
	protected $chunkSize = 4194304;

	/** @var $backup MainWP_Backup */
	protected $backup;

	protected $type;
	protected $pidFile;
	protected $pidContent;
	protected $pidUpdated;

	protected $mode = self::IDLE;

	protected $logHandle = false;

	public function __construct( $backup, $type = 'tar', $pidFile = false ) {
		$this->debug = false;

		$this->pidFile = $pidFile;
		$this->backup  = $backup;

		$this->type = $type;
		if ( 'tar.bz2' == $this->type ) {
			if ( ! function_exists( 'bzopen' ) ) {
				$this->type = 'tar.gz';
			}
		}

		if ( 'tar.gz' == $this->type ) {
			if ( ! function_exists( 'gzopen' ) ) {
				$this->type = 'tar';
			}
		}
	}

	public function get_extension() {
		if ( 'tar.bz2' == $this->type ) {
			return '.tar.bz2';
		}
		if ( 'tar.gz' == $this->type ) {
			return '.tar.gz';
		}

		return '.tar';
	}

	public function zip_file( $files, $archive ) {
		$this->create( $archive );
		if ( $this->archive ) {
			foreach ( $files as $filepath ) {
				$this->add_file( $filepath, basename( $filepath ) );
			}

			$this->add_data( pack( 'a1024', '' ) );
			$this->close();

			return true;
		}

		return false;
	}

	private function create_pid_file( $file ) {
		if ( false === $this->pidFile ) {
			return false;
		}
		$this->pidContent = $file;

		/** @var $wp_filesystem WP_Filesystem_Base */
		global $wp_filesystem;

		$wp_filesystem->put_contents( $this->pidFile, $this->pidContent );

		$this->pidUpdated = time();

		return true;
	}

	public function update_pid_file() {
		if ( false === $this->pidFile ) {
			return false;
		}
		if ( time() - $this->pidUpdated < 40 ) {
			return false;
		}

		/** @var $wp_filesystem WP_Filesystem_Base */
		global $wp_filesystem;

		$wp_filesystem->put_contents( $this->pidFile, $this->pidContent );
		$this->pidUpdated = time();

		return true;
	}

	private function complete_pid_file() {
		if ( false === $this->pidFile ) {
			return false;
		}

		/** @var $wp_filesystem WP_Filesystem_Base */
		global $wp_filesystem;

		$filename = basename( $this->pidFile );
		$wp_filesystem->move( $this->pidFile, trailingslashit( dirname( $this->pidFile ) ) . substr( $filename, 0, strlen( $filename ) - 4 ) . '.done' );
		$this->pidFile = false;

		return true;
	}

	public function create_full_backup( $filepath, $excludes, $addConfig, $includeCoreFiles, $excludezip, $excludenonwp, $append = false ) {
		$this->create_pid_file( $filepath );

		$this->excludeZip = $excludezip;

		$this->archivePath = $filepath;

		if ( $append && file_exists( $filepath ) ) {
			$this->mode = self::APPEND;
			$this->prepare_append( $filepath );
		} else {
			$this->mode = self::CREATE;
			$this->create( $filepath );
		}

		if ( $this->archive ) {
			$nodes = glob( ABSPATH . '*' );
			if ( ! $includeCoreFiles ) {
				$coreFiles = array(
					'favicon.ico',
					'index.php',
					'license.txt',
					'readme.html',
					'wp-activate.php',
					'wp-app.php',
					'wp-blog-header.php',
					'wp-comments-post.php',
					'wp-config.php',
					'wp-config-sample.php',
					'wp-cron.php',
					'wp-links-opml.php',
					'wp-load.php',
					'wp-login.php',
					'wp-mail.php',
					'wp-pass.php',
					'wp-register.php',
					'wp-settings.php',
					'wp-signup.php',
					'wp-trackback.php',
					'xmlrpc.php',
				);
				foreach ( $nodes as $key => $node ) {
					if ( MainWP_Helper::starts_with( $node, ABSPATH . WPINC ) ) {
						unset( $nodes[ $key ] );
					} elseif ( MainWP_Helper::starts_with( $node, ABSPATH . basename( admin_url( '' ) ) ) ) {
						unset( $nodes[ $key ] );
					} else {
						foreach ( $coreFiles as $coreFile ) {
							if ( ABSPATH . $coreFile == $node ) {
								unset( $nodes[ $key ] );
							}
						}
					}
				}
				unset( $coreFiles );
			}

			$db_files = $this->backup->create_backup_db( dirname( $filepath ) . DIRECTORY_SEPARATOR . 'dbBackup', false, $this );

			foreach ( $db_files as $db_file ) {
				$this->add_file( $db_file, basename( WP_CONTENT_DIR ) . '/' . basename( $db_file ) );
			}

			if ( file_exists( ABSPATH . '.htaccess' ) ) {
				$this->add_file( ABSPATH . '.htaccess', 'mainwp-htaccess' );
			}

			foreach ( $nodes as $node ) {
				if ( $excludenonwp && is_dir( $node ) ) {
					if ( ! MainWP_Helper::starts_with( $node, WP_CONTENT_DIR ) && ! MainWP_Helper::starts_with( $node, ABSPATH . 'wp-admin' ) && ! MainWP_Helper::starts_with( $node, ABSPATH . WPINC ) ) {
						continue;
					}
				}

				if ( ! MainWP_Helper::in_excludes( $excludes, str_replace( ABSPATH, '', $node ) ) ) {
					if ( is_dir( $node ) ) {
						$this->add_dir( $node, $excludes );
					} elseif ( is_file( $node ) ) {
						$this->add_file( $node, str_replace( ABSPATH, '', $node ) );
					}
				}
			}

			if ( $addConfig ) {
				global $wpdb;
				$plugins = array();
				$dir     = WP_CONTENT_DIR . '/plugins/';
				$fh      = opendir( $dir );
				while ( $entry = readdir( $fh ) ) {
					if ( ! is_dir( $dir . $entry ) ) {
						continue;
					}
					if ( ( '.' === $entry ) || ( '..' === $entry ) ) {
						continue;
					}
					$plugins[] = $entry;
				}
				closedir( $fh );

				$themes = array();
				$dir    = WP_CONTENT_DIR . '/themes/';
				$fh     = opendir( $dir );
				while ( $entry = readdir( $fh ) ) {
					if ( ! is_dir( $dir . $entry ) ) {
						continue;
					}
					if ( ( '.' == $entry ) || ( '..' == $entry ) ) {
						continue;
					}
					$themes[] = $entry;
				}
				closedir( $fh );

				if ( defined( 'MAINWP_CHILD_DEBUG' ) && MAINWP_CHILD_DEBUG ) {
					$string = wp_json_encode(
						array(
							'siteurl' => get_option( 'siteurl' ),
							'home'    => get_option( 'home' ),
							'abspath' => ABSPATH,
							'prefix'  => $wpdb->prefix,
							'lang'    => get_bloginfo( 'language' ),
							'plugins' => $plugins,
							'themes'  => $themes,
						)
					);
				} else {
					$string = base64_encode( // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions -- base64_encode function is used for begin reasons.
						serialize( // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions
							array(
								'siteurl' => get_option( 'siteurl' ),
								'home'    => get_option( 'home' ),
								'abspath' => ABSPATH,
								'prefix'  => $wpdb->prefix,
								'lang'    => get_bloginfo( 'language' ),
								'plugins' => $plugins,
								'themes'  => $themes,
							)
						)
					);
				}

				$this->add_empty_directory( 'clone', 0, 0, 0, time() );
				$this->add_file_from_string( 'clone/config.txt', $string );
			}

			$this->add_data( pack( 'a1024', '' ) );
			$this->close();
			foreach ( $db_files as $db_file ) {
				unlink( $db_file );
			}

			$this->complete_pid_file();

			return true;
		}

		return false;
	}

	public function add_dir( $path, $excludes ) {
		if ( ( '.' == basename( $path ) ) || ( '..' == basename( $path ) ) ) {
			return;
		}

		$this->add_empty_dir( $path, str_replace( ABSPATH, '', $path ) );

		if ( file_exists( rtrim( $path, '/' ) . '/.htaccess' ) ) {
			$this->add_file( rtrim( $path, '/' ) . '/.htaccess', rtrim( str_replace( ABSPATH, '', $path ), '/' ) . '/mainwp-htaccess' );
		}

		$iterator = new RecursiveIteratorIterator( new RecursiveDirectoryIterator( $path ), RecursiveIteratorIterator::SELF_FIRST, RecursiveIteratorIterator::CATCH_GET_CHILD );

		/** @var $path DirectoryIterator */
		foreach ( $iterator as $path ) {
			$name = $path->__toString();
			if ( ( '.' == basename( $name ) ) || ( '..' == basename( $name ) ) ) {
				continue;
			}

			if ( ! MainWP_Helper::in_excludes( $excludes, str_replace( ABSPATH, '', $name ) ) ) {
				if ( $path->isDir() ) {
					$this->add_empty_dir( $name, str_replace( ABSPATH, '', $name ) );
				} else {
					$this->add_file( $name, str_replace( ABSPATH, '', $name ) );
				}
			}
			$name = null;
			unset( $name );
		}

		$iterator = null;
		unset( $iterator );
	}

	private function add_data( $data ) {
		if ( $this->debug ) {
			$this->chunk .= $data;

			if ( strlen( $this->chunk ) > $this->chunkSize ) {
				$this->write_chunk();
			}

			return;
		}

		if ( 'tar.gz' == $this->type ) {
			if ( false === gzwrite( $this->archive, $data, strlen( $data ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
		} elseif ( 'tar.bz2' == $this->type ) {
			if ( false === bzwrite( $this->archive, $data, strlen( $data ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
		} else {
			if ( false === fwrite( $this->archive, $data, strlen( $data ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
			fflush( $this->archive );
		}
	}

	private function write_chunk() {
		$len = strlen( $this->chunk );
		if ( 0 == $len ) {
			return;
		}

		if ( 'tar.gz' == $this->type ) {
			$this->log( 'writing & flushing ' . $len );
			$this->chunk = gzencode( $this->chunk );
			if ( false === fwrite( $this->archive, $this->chunk, strlen( $this->chunk ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
			fflush( $this->archive );
		} elseif ( 'tar.bz2' == $this->type ) {
			if ( false === bzwrite( $this->archive, $this->chunk, strlen( $len ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
		} else {
			if ( false === fwrite( $this->archive, $len, strlen( $len ) ) ) {
				throw new \Exception( 'Could not write to archive' );
			}
			fflush( $this->archive );
		}

		$this->chunk = '';
	}

	private function add_empty_dir( $path, $entryName ) {
		$stat = stat( $path );

		$this->add_empty_directory( $entryName, $stat['mode'], $stat['uid'], $stat['gid'], $stat['mtime'] );
	}

	private function add_empty_directory( $entryName, $mode, $uid, $gid, $mtime ) {
		if ( self::APPEND == $this->mode ) {
			if ( true === $this->check_before_append( $entryName ) ) {
				return true;
			}
		}

		$prefix = '';
		if ( strlen( $entryName ) > 99 ) {
			$prefix    = substr( $entryName, 0, strpos( $entryName, '/', strlen( $entryName ) - 100 ) + 1 );
			$entryName = substr( $entryName, strlen( $prefix ) );
			if ( strlen( $prefix ) > 154 || strlen( $entryName ) > 99 ) {
				$entryName = $prefix . $entryName;
				$prefix    = '';

				$block = pack(
					'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
					'././@LongLink',
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%011o', strlen( $entryName ) ),
					sprintf( '%011o', 0 ),
					'        ',
					'L',
					'',
					'ustar',
					' ',
					'',
					'',
					'',
					'',
					'',
					''
				);

				$checksum = 0;
				for ( $i = 0; $i < 512; $i ++ ) {
					$checksum += ord( substr( $block, $i, 1 ) );
				}
				$checksum = pack( 'a8', sprintf( '%07o', $checksum ) );
				$block    = substr_replace( $block, $checksum, 148, 8 );

				$this->add_data( $block );
				$this->add_data( pack( 'a512', $entryName ) );
				$entryName = substr( $entryName, 0, 100 );
			}
		}

		$block = pack(
			'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
			$entryName,
			sprintf( '%07o', $mode ),
			sprintf( '%07o', $uid ),
			sprintf( '%07o', $gid ),
			sprintf( '%011o', 0 ),
			sprintf( '%011o', $mtime ),
			'        ',
			5,
			'',
			'ustar',
			' ',
			'Unknown',
			'Unknown',
			'',
			'',
			$prefix,
			''
		);

		$checksum = 0;
		for ( $i = 0; $i < 512; $i ++ ) {
			$checksum += ord( substr( $block, $i, 1 ) );
		}
		$checksum = pack( 'a8', sprintf( '%07o', $checksum ) );
		$block    = substr_replace( $block, $checksum, 148, 8 );

		$this->add_data( $block );

		return true;
	}

	protected $block;
	protected $tempContent;
	protected $gcCnt = 0;
	protected $cnt   = 0;

	private function add_file( $path, $entryName ) {
		if ( ( '.' == basename( $path ) ) || ( '..' == basename( $path ) ) ) {
			return false;
		}

		if ( $this->excludeZip && MainWP_Helper::ends_with( $path, '.zip' ) ) {
			$this->log( 'Skipping ' . $path );

			return false;
		}

		$this->log( 'Adding ' . $path );

		$this->update_pid_file();

		$rslt = false;
		if ( self::APPEND == $this->mode ) {
			$rslt = $this->check_before_append( $entryName );
			if ( true === $rslt ) {
				return true;
			}
		}

		if ( time() - $this->lastRun > 60 ) {
			set_time_limit( 20 * 60 * 60 );
			$this->lastRun = time();
		}

		$this->gcCnt ++;
		if ( $this->gcCnt > 20 ) {
			if ( function_exists( 'gc_enable' ) ) {
				gc_enable();
			}
			if ( function_exists( 'gc_collect_cycles' ) ) {
				gc_collect_cycles();
			}
			$this->gcCnt = 0;
		}

		$stat = stat( $path );
		$fp   = fopen( $path, 'rb' );
		if ( ! $fp ) {
			return;
		}

		$prefix = '';
		if ( strlen( $entryName ) > 99 ) {
			$prefix    = substr( $entryName, 0, strpos( $entryName, '/', strlen( $entryName ) - 100 ) + 1 );
			$entryName = substr( $entryName, strlen( $prefix ) );
			if ( strlen( $prefix ) > 154 || strlen( $entryName ) > 99 ) {
				$entryName = $prefix . $entryName;
				$prefix    = '';

				$block = pack(
					'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
					'././@LongLink',
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%011o', strlen( $entryName ) ),
					sprintf( '%011o', 0 ),
					'        ',
					'L',
					'',
					'ustar',
					' ',
					'',
					'',
					'',
					'',
					'',
					''
				);

				$checksum = 0;
				for ( $i = 0; $i < 512; $i ++ ) {
					$checksum += ord( substr( $block, $i, 1 ) );
				}
				$checksum = pack( 'a8', sprintf( '%07o', $checksum ) );
				$block    = substr_replace( $block, $checksum, 148, 8 );

				if ( ! isset( $rslt['bytesRead'] ) ) {
					$this->add_data( $block );
				}
				if ( ! isset( $rslt['bytesRead'] ) ) {
					$this->add_data( pack( 'a512', $entryName ) );
				}
				$entryName = substr( $entryName, 0, 100 );
			}
		}

		$this->block = pack(
			'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
			$entryName,
			sprintf( '%07o', $stat['mode'] ),
			sprintf( '%07o', $stat['uid'] ),
			sprintf( '%07o', $stat['gid'] ),
			sprintf( '%011o', $stat['size'] ),
			sprintf( '%011o', $stat['mtime'] ),
			'        ',
			0,
			'',
			'ustar',
			' ',
			'Unknown',
			'Unknown',
			'',
			'',
			$prefix,
			''
		);

		$checksum = 0;
		for ( $i = 0; $i < 512; $i ++ ) {
			$checksum += ord( substr( $this->block, $i, 1 ) );
		}
		$checksum    = pack( 'a8', sprintf( '%07o', $checksum ) );
		$this->block = substr_replace( $this->block, $checksum, 148, 8 );

		if ( ! isset( $rslt['bytesRead'] ) ) {
			$this->add_data( $this->block );
		}

		if ( isset( $rslt['bytesRead'] ) ) {
			fseek( $fp, $rslt['bytesRead'] );

			$alreadyRead = ( $rslt['bytesRead'] % 512 );
			$toRead      = 512 - $alreadyRead;
			if ( $toRead > 0 ) {
				$this->tempContent = fread( $fp, $toRead );

				$this->add_data( $this->tempContent );

				$remainder = 512 - ( strlen( $this->tempContent ) + $alreadyRead );
				$this->log( 'DEBUG-Added ' . strlen( $this->tempContent ) . '(before: ' . $alreadyRead . ') will pack: ' . $remainder . ' (packed: ' . strlen( pack( 'a' . $remainder, '' ) ) );
				if ( $remainder > 0 ) {
					$this->add_data( pack( 'a' . $remainder ), '' );
				}
			}
		}

		while ( ! feof( $fp ) ) {
			$this->tempContent = fread( $fp, 1024000 * 5 );

			$read   = strlen( $this->tempContent );
			$divide = $read % 512;

			$this->add_data( substr( $this->tempContent, 0, $read - $divide ) );

			if ( $divide > 0 ) {
				$this->add_data( pack( 'a512', substr( $this->tempContent, - 1 * $divide ) ) );
			}

			$this->update_pid_file();
		}

		fclose( $fp );

		return true;
	}

	private function add_file_from_string( $entryName, $content ) {
		$this->log( 'Add from string ' . $entryName );

		if ( self::APPEND == $this->mode ) {
			if ( true === $this->check_before_append( $entryName ) ) {
				return true;
			}
		}

		$prefix = '';
		if ( strlen( $entryName ) > 99 ) {
			$prefix    = substr( $entryName, 0, strpos( $entryName, '/', strlen( $entryName ) - 100 ) + 1 );
			$entryName = substr( $entryName, strlen( $prefix ) );
			if ( strlen( $prefix ) > 154 || strlen( $entryName ) > 99 ) {
				$entryName = $prefix . $entryName;
				$prefix    = '';

				$block = pack(
					'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
					'././@LongLink',
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%07o', 0 ),
					sprintf( '%011o', strlen( $entryName ) ),
					sprintf( '%011o', 0 ),
					'        ',
					'L',
					'',
					'ustar',
					' ',
					'',
					'',
					'',
					'',
					'',
					''
				);

				$checksum = 0;
				for ( $i = 0; $i < 512; $i ++ ) {
					$checksum += ord( substr( $block, $i, 1 ) );
				}
				$checksum = pack( 'a8', sprintf( '%07o', $checksum ) );
				$block    = substr_replace( $block, $checksum, 148, 8 );

				$this->add_data( $block );
				$this->add_data( pack( 'a512', $entryName ) );
				$entryName = substr( $entryName, 0, 100 );
			}
		}

		$block = pack(
			'a100a8a8a8a12a12a8a1a100a6a2a32a32a8a8a155a12',
			$entryName,
			sprintf( '%07o', 0 ),
			sprintf( '%07o', 0 ),
			sprintf( '%07o', 0 ),
			sprintf( '%011o', strlen( $content ) ),
			sprintf( '%011o', time() ),
			'        ',
			0,
			'',
			'ustar',
			' ',
			'Unknown',
			'Unknown',
			'',
			'',
			$prefix,
			''
		);

		$checksum = 0;
		for ( $i = 0; $i < 512; $i ++ ) {
			$checksum += ord( substr( $block, $i, 1 ) );
		}
		$checksum = pack( 'a8', sprintf( '%07o', $checksum ) );
		$block    = substr_replace( $block, $checksum, 148, 8 );

		$this->add_data( $block );
		$i = 0;
		while ( ( $line = substr( $content, $i * 512, 512 ) ) != '' ) {
			$i++;
			$this->add_data( pack( 'a512', $line ) );
		}

		return true;
	}

	private function check_before_append( $entryName ) {
		$rslt = $this->is_next_file( $entryName );

		if ( true === $rslt ) {
			return true;
		}

		$out = false;

		$this->close( false );
		$this->log( 'Reopen archive to append from here' );
		$this->append( $this->archivePath );
		if ( is_array( $rslt ) ) {
			if ( 'tar' == $this->type ) {
				$startOffset = $rslt['startOffset'];
				fseek( $this->archive, $startOffset );
				ftruncate( $this->archive, $startOffset );
			} elseif ( 'tar.gz' == $this->type ) {
				$readOffset = $rslt['readOffset'];
				$bytesRead  = $rslt['bytesRead'];

				$out = array( 'bytesRead' => $bytesRead );
			}
		} elseif ( false === $rslt ) {
			if ( 'tar' == $this->type ) {
				fseek( $this->archive, 0, SEEK_END );
			}
		} else {
			fseek( $this->archive, $rslt );
			ftruncate( $this->archive, $rslt );
		}
		$this->mode = self::CREATE;

		return $out;
	}

	/**
	 * return true: skip file
	 * return number: nothing to read, will continue with current file..
	 * return false: nothing to read, will continue with current file..
	 * exception: corrupt zip - invalid file order!
	 *
	 * return array: continue the busy directory or file..
	 *
	 * @param $entryName
	 *
	 * @return array|bool
	 * @throws \Exception
	 */
	private function is_next_file( $entryName ) {
		$currentOffset = ftell( $this->archive );
		$rslt          = array( 'startOffset' => $currentOffset );
		try {
			$block = fread( $this->archive, 512 );

			if ( false === $block || 0 == strlen( $block ) ) {
				return $rslt;
			}

			if ( 512 != strlen( $block ) ) {
				throw new \Exception( 'Invalid block found' );
			}

			$temp = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
			if ( 'L' == $temp['type'] ) {
				$fname          = trim( fread( $this->archive, 512 ) );
				$block          = fread( $this->archive, 512 );
				$temp           = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
				$temp['prefix'] = '';
				$temp['name']   = $fname;
			}
			$file = array(
				'name'     => trim( $temp['prefix'] ) . trim( $temp['name'] ),
				'stat'     => array(
					2 => $temp['mode'],
					4 => octdec( $temp['uid'] ),
					5 => octdec( $temp['gid'] ),
					7 => octdec( $temp['size'] ),
					9 => octdec( $temp['mtime'] ),
				),
				'checksum' => octdec( $temp['checksum'] ),
				'type'     => $temp['type'],
				'magic'    => $temp['magic'],
			);

			if ( 5 == $file['type'] ) {
				if ( 0 == strcmp( trim( $file['name'] ), trim( $entryName ) ) ) {
					$this->log( 'Skipping directory [' . $file['name'] . ']' );

					return true;
				} else {
					throw new \Exception( 'Unexpected directory [' . $file['name'] . ']' );
				}
			} elseif ( 0 == $file['type'] ) {
				if ( 0 == strcmp( trim( $file['name'] ), trim( $entryName ) ) ) {
					$previousFtell = ftell( $this->archive );

					$bytes = $file['stat'][7] + ( 512 == ( 512 - $file['stat'][7] % 512 ) ? 0 : ( 512 - $file['stat'][7] % 512 ) );
					fseek( $this->archive, ftell( $this->archive ) + $bytes );

					$ftell = ftell( $this->archive );
					if ( 'tar.gz' == $this->type ) {
						if ( ( false === $ftell ) || ( -1 == $ftell ) ) {
							fseek( $this->archive, $previousFtell );

							$bytesRead   = 0;
							$bytesToRead = $file['stat'][7];

							while ( $bytesToRead > 0 ) {
								$readNow            = $bytesToRead > 1024 ? 1024 : $bytesToRead;
								$bytesCurrentlyRead = strlen( fread( $this->archive, $readNow ) );

								if ( 0 == $bytesCurrentlyRead ) {
									break;
								}

								$bytesRead   += $bytesCurrentlyRead;
								$bytesToRead -= $bytesCurrentlyRead;
							}

							if ( 0 == $bytesToRead ) {
								$toRead = ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 );
								if ( $toRead > 0 ) {
									$read       = strlen( fread( $this->archive, $toRead ) );
									$bytesRead += $read;
								}
							}

							$rslt['bytesRead']  = $bytesRead;
							$rslt['readOffset'] = $previousFtell;

							$this->log( 'Will append this: ' . print_r( $rslt, 1 ) ); // phpcs:ignore -- debug feature.

							return $rslt;
						}
					} elseif ( ( 'tar' == $this->type ) && ( ( false === $ftell ) || ( -1 == $ftell ) ) ) {
						$this->log( 'Will append this: ' . print_r( $rslt, 1 ) ); // phpcs:ignore -- debug feature.

						return $rslt;
					}

					$this->log( 'Skipping file [' . $file['name'] . ']' );

					return true;
				} else {
					$this->log( 'Unexpected file [' . $file['name'] . ']' );
					throw new \Exception( 'Unexpected file' );
				}
			}

			$this->log( 'ERROR' );
			throw new \Exception( 'Should never get here?' );
		} catch ( \Exception $e ) {
			$this->log( $e->getMessage() );
			throw $e;
		}
	}

	public function log( $text ) {
		if ( $this->logHandle ) {
			fwrite( $this->logHandle, $text . "\n" );
		}
	}

	public function create( $filepath ) {
		$this->log( 'Creating ' . $filepath );
		if ( $this->debug ) {
			if ( 'tar.bz2' == $this->type ) {
				$this->archive = bzopen( $filepath, 'w' );
			} else {
				$this->archive = fopen( $filepath, 'wb+' );
			}

			return;
		}

		if ( 'tar.gz' == $this->type ) {
			$this->archive = gzopen( $filepath, 'wb' );
		} elseif ( 'tar.bz2' == $this->type ) {
			$this->archive = bzopen( $filepath, 'w' );
		} else {
			$this->archive = fopen( $filepath, 'wb+' );
		}
	}

	public function append( $filepath ) {
		$this->log( 'Appending to ' . $filepath );
		if ( $this->debug ) {
			if ( 'tar.bz2' == $this->type ) {
				$this->archive = bzopen( $filepath, 'a' );
			} else {
				$this->archive = fopen( $filepath, 'ab+' );
			}

			return;
		}

		if ( 'tar.gz' == $this->type ) {
			$this->archive = gzopen( $filepath, 'ab' );
		} elseif ( 'tar.bz2' == $this->type ) {
			$this->archive = bzopen( $filepath, 'a' );
		} else {
			$this->archive = fopen( $filepath, 'ab+' );
		}
	}

	public function is_open() {
		return ! empty( $this->archive );
	}

	public function prepare_append( $filepath ) {
		if ( $this->debug ) {
			if ( 'tar.gz' == substr( $filepath, - 6 ) ) {
				$text        = chr( 31 ) . chr( 139 ) . chr( 8 ) . chr( 0 ) . chr( 0 ) . chr( 0 ) . chr( 0 ) . chr( 0 ) . chr( 0 );
				$fh          = fopen( $filepath, 'rb' );
				$read        = '';
				$lastCorrect = 0;
				try {
					while ( ! feof( $fh ) ) {
						$read .= fread( $fh, 1000 );
						while ( ( $pos = strpos( $read, $text, 2 ) ) !== false ) {
							for ( $i = 0; $i < 10; $i ++ ) {
								echo ord( $read[ $i ] ) . "\n";
							}

							if ( ! $this->is_valid_block( substr( $read, 10, $pos - 10 ) ) ) {
								throw new \Exception( 'invalid!' );
							}

							$lastCorrect += $pos;
							$read         = substr( $read, $pos );
						}
					}

					if ( ! $this->is_valid_block( substr( $read, 10 ) ) ) {
						throw new \Exception( 'invalid!' );
					}

					fclose( $fh );
				} catch ( \Exception $e ) {
					fclose( $fh );
					$fh = fopen( $filepath, 'ab+' );
					fseek( $fh, $lastCorrect );
					ftruncate( $fh, $lastCorrect );
					fclose( $fh );
				}
			}
		}

		$this->read( $filepath );
	}

	public function read( $filepath ) {
		$this->log( 'Reading ' . $filepath );
		$this->archiveSize = false;

		if ( 'tar.gz' == substr( $filepath, - 6 ) ) {
			$this->type    = 'tar.gz';
			$this->archive = gzopen( $filepath, 'r' );
		} elseif ( 'tar.bz2' == substr( $filepath, - 7 ) ) {
			$this->type    = 'tar.bz2';
			$this->archive = bzopen( $filepath, 'r' );
		} else {
			$currentPos = ftell( $this->archive );
			fseek( $this->archive, 0, SEEK_END );
			$lastPos = ftell( $this->archive );
			fseek( $this->archive, $currentPos );

			$this->archiveSize = $lastPos;

			$this->type    = 'tar';
			$this->archive = fopen( $filepath, 'rb' );
		}
	}

	public function close( $closeLog = true ) {
		$this->write_chunk();
		$this->log( 'Closing archive' );

		if ( $closeLog && $this->logHandle ) {
			fclose( $this->logHandle );
		}

		if ( $this->archive ) {
			if ( 'tar.gz' == $this->type ) {
				gzclose( $this->archive );
			} elseif ( 'tar.bz2' == $this->type ) {
				bzclose( $this->archive );
			} else {
				fclose( $this->archive );
			}
		}
	}

	public function get_from_name( $entryName ) {
		if ( ! $this->archive ) {
			return false;
		}
		if ( empty( $entryName ) ) {
			return false;
		}
		$content = false;
		fseek( $this->archive, 0 );
		while ( $block = fread( $this->archive, 512 ) ) {
			$temp = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
			if ( 'L' == $temp['type'] ) {
				$fname          = trim( fread( $this->archive, 512 ) );
				$block          = fread( $this->archive, 512 );
				$temp           = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
				$temp['prefix'] = '';
				$temp['name']   = $fname;
			}
			$file = array(
				'name'     => trim( $temp['prefix'] ) . trim( $temp['name'] ),
				'stat'     => array(
					2 => $temp['mode'],
					4 => octdec( $temp['uid'] ),
					5 => octdec( $temp['gid'] ),
					7 => octdec( $temp['size'] ),
					9 => octdec( $temp['mtime'] ),
				),
				'checksum' => octdec( $temp['checksum'] ),
				'type'     => $temp['type'],
				'magic'    => $temp['magic'],
			);

			if ( 0x00000000 == $file['checksum'] ) {
				break;
			} elseif ( 'ustar' != substr( $file['magic'], 0, 5 ) ) {
				break;
			}

			$block    = substr_replace( $block, '        ', 148, 8 );
			$checksum = 0;
			for ( $i = 0; $i < 512; $i ++ ) {
				$checksum += ord( substr( $block, $i, 1 ) );
			}

			if ( 0 == $file['type'] ) {
				if ( 0 == strcmp( trim( $file['name'] ), trim( $entryName ) ) ) {
					if ( $file['stat'][7] > 0 ) {
						$content = fread( $this->archive, $file['stat'][7] );
					} else {
						$content = '';
					}
					break;
				} else {
					$bytes = $file['stat'][7] + ( ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 ) );
					fseek( $this->archive, ftell( $this->archive ) + $bytes );
				}
			}

			unset( $file );
		}

		return $content;
	}

	public function file_exists( $entryName ) {
		if ( ! $this->archive ) {
			return false;
		}
		$entryName = untrailingslashit( $entryName );
		if ( empty( $entryName ) ) {
			return false;
		}
		fseek( $this->archive, 0 );
		while ( $block = fread( $this->archive, 512 ) ) {
			$temp = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
			if ( 'L' == $temp['type'] ) {
				$fname          = trim( fread( $this->archive, 512 ) );
				$block          = fread( $this->archive, 512 );
				$temp           = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
				$temp['prefix'] = '';
				$temp['name']   = $fname;
			}
			$file = array(
				'name'     => trim( $temp['prefix'] ) . trim( $temp['name'] ),
				'stat'     => array(
					2 => $temp['mode'],
					4 => octdec( $temp['uid'] ),
					5 => octdec( $temp['gid'] ),
					7 => octdec( $temp['size'] ),
					9 => octdec( $temp['mtime'] ),
				),
				'checksum' => octdec( $temp['checksum'] ),
				'type'     => $temp['type'],
				'magic'    => $temp['magic'],
			);

			if ( 0x00000000 == $file['checksum'] ) {
				break;
			} elseif ( 'ustar' != substr( $file['magic'], 0, 5 ) ) {
				break;
			}

			$block    = substr_replace( $block, '        ', 148, 8 );
			$checksum = 0;
			for ( $i = 0; $i < 512; $i ++ ) {
				$checksum += ord( substr( $block, $i, 1 ) );
			}

			if ( 5 == $file['type'] ) {
				if ( 0 == strcmp( trim( $file['name'] ), trim( $entryName ) ) ) {
					return true;
				}
			} elseif ( 0 == $file['type'] ) {
				if ( 0 == strcmp( trim( $file['name'] ), trim( $entryName ) ) ) {
					return true;
				} else {
					$bytes = $file['stat'][7] + ( ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 ) );
					fseek( $this->archive, ftell( $this->archive ) + $bytes );
				}
			}

			unset( $file );
		}

		return false;
	}

	public function extract_to( $to ) {
		/** @var $wp_filesystem WP_Filesystem_Base */
		global $wp_filesystem;

		$to = trailingslashit( $to );
		fseek( $this->archive, 0 );
		while ( $block = fread( $this->archive, 512 ) ) {
			$temp = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
			if ( 'L' == $temp['type'] ) {
				$fname          = trim( fread( $this->archive, 512 ) );
				$block          = fread( $this->archive, 512 );
				$temp           = unpack( 'a100name/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1type/a100symlink/a6magic/a2temp/a32temp/a32temp/a8temp/a8temp/a155prefix/a12temp', $block );
				$temp['prefix'] = '';
				$temp['name']   = $fname;
			}
			$file = array(
				'name'     => trim( $temp['prefix'] ) . trim( $temp['name'] ),
				'stat'     => array(
					2 => $temp['mode'],
					4 => octdec( $temp['uid'] ),
					5 => octdec( $temp['gid'] ),
					7 => octdec( $temp['size'] ),
					9 => octdec( $temp['mtime'] ),
				),
				'checksum' => octdec( $temp['checksum'] ),
				'type'     => $temp['type'],
				'magic'    => $temp['magic'],
			);

			if ( 0x00000000 == $file['checksum'] ) {
				break;
			} elseif ( 'ustar' != substr( $file['magic'], 0, 5 ) ) {
				break;
			}
			$block    = substr_replace( $block, '        ', 148, 8 );
			$checksum = 0;
			for ( $i = 0; $i < 512; $i ++ ) {
				$checksum += ord( substr( $block, $i, 1 ) );
			}
			if ( 5 == $file['type'] ) {
				if ( ! is_dir( $to . $file['name'] ) ) {
					if ( ! empty( $wp_filesystem ) ) {
						$wp_filesystem->mkdir( $to . $file['name'], FS_CHMOD_DIR );
					} else {
						mkdir( $to . $file['name'], 0777, true );
					}
				}
			} elseif ( 0 == $file['type'] ) {
				if ( ! is_dir( dirname( $to . $file['name'] ) ) ) {
					if ( ! empty( $wp_filesystem ) ) {
						$wp_filesystem->mkdir( dirname( $to . $file['name'] ), FS_CHMOD_DIR );
					} else {
						mkdir( dirname( $to . $file['name'] ), 0777, true );
					}
				}

				if ( ! empty( $wp_filesystem ) && ( $file['stat'][7] < 2000000 ) ) {
					$contents    = '';
					$bytesToRead = $file['stat'][7];
					while ( $bytesToRead > 0 ) {
						$readNow      = $bytesToRead > 1024 ? 1024 : $bytesToRead;
						$contents    .= fread( $this->archive, $readNow );
						$bytesToRead -= $readNow;
					}

					$toRead = ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 );
					if ( $toRead > 0 ) {
						fread( $this->archive, ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 ) );
					}

					if ( 'wp-config.php' != $file['name'] ) {
						$wp_filesystem->put_contents( $to . $file['name'], $contents, FS_CHMOD_FILE );
					}
				} else {
					if ( 'wp-config.php' != $file['name'] ) {
						$new = fopen( $to . $file['name'], 'wb+' );
					} else {
						$new = false;
					}
					$bytesToRead = $file['stat'][7];
					while ( $bytesToRead > 0 ) {
						$readNow = $bytesToRead > 1024 ? 1024 : $bytesToRead;
						if ( false !== $new ) {
							fwrite( $new, fread( $this->archive, $readNow ) );
						} else {
							fread( $this->archive, $readNow );
						}
						$bytesToRead -= $readNow;
					}

					$toRead = ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 );
					if ( $toRead > 0 ) {
						fread( $this->archive, ( 512 - $file['stat'][7] % 512 ) == 512 ? 0 : ( 512 - $file['stat'][7] % 512 ) );
					}
					if ( false != $new ) {
						fclose( $new );
					}
				}
			}
			unset( $file );
		}

		return null;
	}

	public function is_valid_block( $block ) {
		$test = gzinflate( $block );
		if ( false === $test ) {
			return false;
		}
		$crc      = crc32( $test );
		$crcFound = substr( $block, strlen( $block ) - 8, 4 );
		$crcFound = ( ord( $crcFound[3] ) << 24 ) + ( ord( $crcFound[2] ) << 16 ) + ( ord( $crcFound[1] ) << 8 ) + ( ord( $crcFound[0] ) );

		return $crcFound == $crc;
	}
}