event_handler = $event_handler;
$this->container = Container::getInstance();
}
public function copy($source, $destination, $allowed_mimes = null, $filetype = null)
{
if (!file_exists($source)) {
Logger::write('File doesn`t exist on local filesystem: ' . $source);
return new \WP_Error('IWP_FS_7', __('File doesn`t exist on local filesystem.', 'jc-importer'));
}
if (is_null($filetype)) {
$filetype = $this->get_filetype($source);
}
if (!is_null($allowed_mimes)) {
if (!$filetype) {
Logger::write('Unable to determine filetype: ' . $source);
return new \WP_Error('IWP_FS_6', __('Unable to determine filetype.', 'jc-importer'));
}
if (!in_array($filetype, $allowed_mimes, true)) {
Logger::write('Invalid filetype: ' . $filetype . ', allowed(' . implode(', ', $allowed_mimes) . ')');
return new \WP_Error('IWP_FS_4', __('Invalid filetype.', 'jc-importer'));
}
}
if (!copy($source, $destination)) {
return new \WP_Error('IWP_FS_4', sprintf(__('Unable to copy file: %s.', 'jc-importer'), $source));
}
$type = $this->get_file_mime($source);
Logger::write('Copied file: ' . $destination . ' -type=' . $filetype . ' -mime=' . $type);
return true;
}
public function upload_file($attachment, $allowed_mimes = null)
{
// use built in wordpress file upload
if (!function_exists('wp_handle_upload')) {
require_once ABSPATH . "wp-admin" . '/includes/file.php';
}
$uploaded_file = wp_handle_upload($attachment, ['test_form' => false, 'test_type' => false]);
if (isset($uploaded_file['error'])) {
Logger::write($uploaded_file['error']);
return new \WP_Error('IWP_FS_UF', $uploaded_file['error']);
}
$file = $uploaded_file['file'];
$type = $uploaded_file['type'];
$filetype = $this->check_mime_header($uploaded_file['type']);
// if header doesnt match check for file extension.
if (!$filetype) {
$filetype = $this->get_filetype_from_ext($attachment['name']);
}
// determine file type from mimetype.
if (!is_null($allowed_mimes) && !in_array($filetype, $allowed_mimes, true)) {
Logger::write('Invalid filetype: ' . $filetype . ', allowed(' . implode(', ', $allowed_mimes) . ')');
return new \WP_Error('IWP_FS_4', __('Invalid filetype.', 'jc-importer'));
}
Logger::write('Uploaded file: ' . $file . ' -type=' . $filetype . ' -mime=' . $type);
return array(
'dest' => $file,
'type' => $filetype,
'mime' => $type
);
}
public function download_file($remote_url, $filetype = null, $allowed_mimes = null, $override_filename = null, $prefix = '')
{
$remote_url_temp = strtok($remote_url, '?');
if (!is_null($allowed_mimes)) {
if (is_null($filetype)) {
$filetype = $this->get_filetype_from_ext($remote_url_temp);
}
if (!in_array($filetype, $allowed_mimes, true)) {
Logger::write('Invalid filetype: ' . $filetype . ', allowed(' . implode(', ', $allowed_mimes) . ')');
return new \WP_Error('IWP_FS_4', __('Invalid filetype.', 'jc-importer'));
}
}
$wp_upload_dir = wp_upload_dir();
$filename = !empty($override_filename) ? $override_filename : $prefix . basename($remote_url_temp);
// force extension of file if it doesnt match
if ($filetype === 'xml') {
if (preg_match('/\.(xml|zip|gz)$/', $filename) === 0) {
$filename .= '.xml';
}
} elseif ($filetype === 'csv') {
if (preg_match('/\.(csv|zip|gz)$/', $filename) === 0) {
$filename .= '.csv';
}
}
$dest = wp_unique_filename($wp_upload_dir['path'], $filename);
$wp_dest = $wp_upload_dir['path'] . '/' . $dest;
touch($wp_dest);
/**
* @var Http $http
*/
$http = Container::getInstance()->get('http');
$headers = [];
if ($filetype === 'xml') {
$headers['Content-Type'] = 'text/xml';
$headers['Accept'] = 'text/xml';
} elseif ($filetype === 'csv') {
$headers['Content-Type'] = 'text/csv';
$headers['Accept'] = 'text/csv';
}
$result = $http->download_file_stream($remote_url, $wp_dest, $headers);
if (is_wp_error($result)) {
@unlink($wp_dest);
Logger::write($result->get_error_message());
return $result;
}
if (is_string($result)) {
$filename = !empty($override_filename) ? $override_filename : $prefix . basename($result);
$dest = wp_unique_filename($wp_upload_dir['path'], $filename);
$wp_tmp_dest = $wp_upload_dir['path'] . '/' . $dest;
if (copy($wp_dest, $wp_tmp_dest)) {
Logger::write('Rename file: ' . $wp_dest . ' -output=' . $wp_tmp_dest);
unlink($wp_dest);
$wp_dest = $wp_tmp_dest;
}
}
$exists = $this->file_exists($wp_dest);
if (is_wp_error($exists)) {
return $exists;
}
$type = $this->get_file_mime($wp_dest);
Logger::write('Downloaded file: ' . $wp_dest . ' -type=' . $filetype . ' -mime=' . $type);
return array(
'dest' => $wp_dest,
'type' => $filetype,
'mime' => $type
);
}
public function file_exists($src)
{
try {
if (!file_exists($src)) {
throw new \Exception(sprintf(__("File not found: %s", 'jc-importer'), $src));
}
$size = filesize($src);
if ($size == 0) {
unlink($src);
throw new \Exception(sprintf(__("File not found or empty: %s", 'jc-importer'), $src));
}
} catch (\Exception $e) {
return new \WP_Error('IWP_FS_8', $e->getMessage());
}
return true;
}
public function copy_file($remote_url, $allowed_mimes = null, $override_filename = null, $prefix = '', $filetype = null)
{
$remote_url = strtok($remote_url, '?');
$wp_upload_dir = wp_upload_dir();
$filename = !empty($override_filename) ? $override_filename : $prefix . basename($remote_url);
$dest = wp_unique_filename($wp_upload_dir['path'], $filename);
$wp_dest = $wp_upload_dir['path'] . '/' . $dest;
$result = $this->copy($remote_url, $wp_dest, $allowed_mimes, $filetype);
if (is_wp_error($result)) {
return $result;
}
return array(
'dest' => $wp_dest,
'type' => is_null($filetype) ? $this->get_filetype($wp_dest) : $filetype,
'mime' => $this->get_file_mime($wp_dest)
);
}
public function string_to_file($string, $filename)
{
$wp_upload_dir = wp_upload_dir();
$dest = wp_unique_filename($wp_upload_dir['path'], $filename);
$wp_dest = $wp_upload_dir['path'] . '/' . $dest;
if (file_put_contents($wp_dest, $string) === false) {
return new \WP_Error('IWP_FS_SF', __("Unable to write string to file", 'jc-importer'));
}
return array(
'dest' => $wp_dest,
'type' => $this->get_filetype($wp_dest),
'mime' => $this->get_file_mime($wp_dest)
);
}
/**
* Get and/or create the plugins tmp directory
*
* @return string
*/
public function get_temp_directory($url = false, $folder = 'importwp')
{
$dir = wp_upload_dir();
$base = $url ? $dir['baseurl'] : $dir['basedir'];
$ds = $url ? '/' : DIRECTORY_SEPARATOR;
$path = $base . $ds . $folder;
// create folders and files if required, force to be dir path instead of url.
$dir_path = $dir['basedir'] . DIRECTORY_SEPARATOR . $folder;
if (!is_dir($dir_path)) {
mkdir($dir_path);
}
if (!file_exists($dir_path . '/.htaccess')) {
file_put_contents($dir_path . '/.htaccess', "# Apache 2.4+
Require all denied
# Apache 2.2 and older (or when mod_authz_core isn't available)
Deny from all
");
}
if (!file_exists($dir_path . '/index.html')) {
touch($dir_path . '/index.html');
}
return $path;
}
/**
* Whether a path looks absolute (Unix or Windows).
*
* @param string $path
* @return bool
*/
public static function is_absolute_path($path)
{
if (!is_string($path) || $path === '') {
return false;
}
if ($path[0] === '/' || $path[0] === '\\') {
return true;
}
return strlen($path) > 2 && ctype_alpha($path[0]) && $path[1] === ':';
}
/**
* Convert an absolute path under the uploads basedir to a relative path.
* Paths outside uploads are returned unchanged.
*
* @param string $path
* @return string
*/
public static function to_uploads_relative_path($path)
{
$path = wp_normalize_path((string) $path);
$basedir = wp_normalize_path(untrailingslashit(wp_upload_dir()['basedir']));
if ($path === $basedir) {
return '';
}
if (strpos($path, $basedir . '/') === 0) {
return ltrim(substr($path, strlen($basedir)), '/');
}
return $path;
}
/**
* Resolve a stored importer file path to an absolute path under the current uploads directory.
*
* Avoids calling file_exists() on legacy absolute paths that may sit outside open_basedir
* after a site move / hosting path change.
*
* @param string $stored
* @return string|false Absolute filesystem path if the file exists, otherwise false.
*/
public static function resolve_importer_file_path($stored)
{
if (!is_string($stored) || $stored === '') {
return false;
}
$stored = wp_normalize_path(trim($stored));
$basedir = wp_normalize_path(untrailingslashit(wp_upload_dir()['basedir']));
$candidates = [];
if (self::is_absolute_path($stored)) {
if (strpos($stored, $basedir . '/') === 0 || $stored === $basedir) {
$candidates[] = $stored;
} else {
// Remap legacy absolute paths that still contain the importwp suffix.
if (preg_match('#/(importwp(?:/[^/]+)*/.+)$#', $stored, $matches)) {
$candidates[] = $basedir . '/' . ltrim($matches[1], '/');
}
$candidates[] = $basedir . '/importwp/uploads/' . basename($stored);
}
} else {
$candidates[] = $basedir . '/' . ltrim($stored, '/');
}
foreach (array_unique($candidates) as $candidate) {
$candidate = wp_normalize_path($candidate);
// Never probe paths outside the current uploads basedir (open_basedir safe).
if ($candidate !== $basedir && strpos($candidate, $basedir . '/') !== 0) {
continue;
}
if (file_exists($candidate)) {
return $candidate;
}
}
return false;
}
public function check_mime_header($mime)
{
switch ($mime) {
case 'text/comma-separated-values':
case 'text/csv':
case 'application/csv':
case 'application/excel':
case 'application/vnd.ms-excel':
case 'application/vnd.msexcel':
case 'text/anytext':
case 'text/plain':
return 'csv';
case 'text/xml':
case 'application/xml':
case 'application/x-xml':
return 'xml';
}
return $this->event_handler->run('importer.allowed_mime_types', [false, $mime]);
}
public function get_filetype($file)
{
$mime_type = $this->get_file_mime($file);
if ($mime_type) {
return $this->check_mime_header($mime_type);
}
return $this->get_filetype_from_ext($file);
}
public function get_file_mime($file)
{
$check = wp_check_filetype_and_ext($file, basename($file));
return $check['type'];
}
public function get_filetype_from_ext($file)
{
$filetype = null;
if (stripos($file, '.csv')) {
$filetype = 'csv';
} elseif (stripos($file, '.xml')) {
$filetype = 'xml';
}
$filetype = apply_filters('iwp/get_filetype_from_ext', $filetype, $file);
return $filetype;
}
}