mpatie_import.php

<?php
/**
 *
 * Copyright (c) 2017 MPAT Consortium , All rights reserved.
 * Fraunhofer FOKUS, Fincons Group, Telecom ParisTech, IRT, Lacaster University, Leadin, RBB, Mediaset
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library. If not, see <http://www.gnu.org/licenses/>.
 *
 * Authors:
 * Aurelien David https://github.com/aureliendavid/
 * Jean-Claude Dufourd (jean-claude.dufourd@telecom-paristech.fr)
 * Jean-Philippe Ruijs https://github.com/jeanphilipperuijs/
 **/
namespace MPAT\ImportExport;

use MPAT\ImportExport\ImportExport;

$nullGuard = null;

function getcontents($postType, $zipped){
	$json = null;
	$data = file_get_contents( $_FILES[$postType]['tmp_name']);
	if($zipped) {
		set_error_handler(function() {});
		$json = gzuncompress($data);
		restore_error_handler();
	}
	if($json == null) { // fallback to uncompressed import
		$json = $data;
	}
	$page = json_decode($json, true);
	return $page;
}

function handle_import($zipped) {

	if ( isset($_FILES['layout']) ) {

		$message = "Upload error";
        switch( $_FILES['layout']['error'] ) {
            case UPLOAD_ERR_OK:
                $message = false;;
                break;
            case UPLOAD_ERR_INI_SIZE:
            case UPLOAD_ERR_FORM_SIZE:
                $message .= ' - file too large (limit is '.ini_get('upload_max_filesize').' bytes).';
                break;
            case UPLOAD_ERR_PARTIAL:
                $message .= ' - file upload was not completed.';
                break;
            case UPLOAD_ERR_NO_FILE:
                $message .= ' - zero-length file uploaded.';
                break;
            default:
                $message .= ' - internal error #'.$_FILES['layout']['error'];
                break;
        }
        if ($message) {
			return $message;
        }


		$page = getcontents('layout', $zipped);

		if (isset($page["page_layout"])) {

			$title = $layout["page_layout"]['post_title'];
			$id = importSingleLayout($layout);

			if ($id == -1) {
				return "Layout $title already exists.\n";
			}
			else {
				return "Imported page $title with id=$id.\n";
			}

		}
		else {

			$ok = 0;
			$ko = 0;

			foreach($layout as $l) {

				$id=-1;
				if (isset($l["page_layout"])) {
					$id = importSingleLayout($l);
				}

				if ($id == -1) {
					$ko++;
				}
				else {
					$ok++;
				}

			}

			return "Added $ok layouts and $ko already existed.\n";

		}
		//echo '<script type="text/javascript">window.top.location.reload();</script>';
	}
	else if ( isset($_FILES['page']) ) {

		$message = "Upload error";
        switch( $_FILES['page']['error'] ) {
            case UPLOAD_ERR_OK:
                $message = false;;
                break;
            case UPLOAD_ERR_INI_SIZE:
            case UPLOAD_ERR_FORM_SIZE:
                $message .= ' - file too large (limit is '.ini_get('upload_max_filesize').' bytes).';
                break;
            case UPLOAD_ERR_PARTIAL:
                $message .= ' - file upload was not completed.';
                break;
            case UPLOAD_ERR_NO_FILE:
                $message .= ' - zero-length file uploaded.';
                break;
            default:
                $message .= ' - internal error #'.$_FILES['page']['error'];
                break;
        }
        if ($message) {
			return $message;
        }


		$page = getcontents("page", $zipped);

		if (isset($page["page"])) {

			$title = $page["page"]['post_title'];
			$id = importSinglePage($page);

			if ($id == -1) {
				return "Page $title already exists\n";
			}
			else {
				return "Imported page $title with id=$id\n";
			}

		}
		else {

			$ok = 0;
			$ko = 0;
			$message = "";
			$dict = array();

			$mediadata = findMediaData($page);

			foreach($page as $p) {

				if (!isset($p['page']) && isset($p['options'])) {
					handle_options($p['options']);
					continue;
				}

				$id=-1;
				if (isset($p["page"])) {
					$old_id = $p["page"]["ID"];
					$id = importSinglePage($p, $mediadata);
				}

				if ($id == -1) {
					$ko++;
				}
				else {
					$ok++;
					$dict[ $old_id ] = $id;
				}

			}

			// second pass to update page links
			foreach($page as $p) {

				if (!isset($p['page']) && isset($p['options'])) {
					continue;
				}

				$old_id = $p["page"]["ID"];

				if (isset($dict[ $old_id ])) {

					$new_id = $dict[ $old_id ];

					///////// update parent ////////////

					$old_parent = $p["page"]["post_parent"];

					if ($old_parent) {

						if ( isset($dict[$old_parent]) ) {

							$new_parent = $dict[$old_parent];

							$updated_page = array(
							  'ID'          => $new_id,
							  'post_parent'	=> $new_parent,
							);

							wp_update_post( $updated_page );

						}
						else {
							$message .= "Page $new_id has parent $old_parent which wasn't imported.<br />\n";
						}
					}



					///////// update page links ////////////

					$meta = get_post_meta($new_id, 'mpat_content', true);

					$needs_update = 0;

                    foreach ($p["page_links"] as $l) {

                        if (isset($dict[ $l["id"] ])) {

                            $new_link_id = $dict[ $l["id"] ] ;
                            $new_value = "page://" . $new_link_id;

                            updateMetaFromPath($meta["content"], $l["path"], $new_value);

                            $needs_update = 1;

                        }
                        else {
                            $message .= "Page $new_id points to page ".$l["id"]." which wasn't imported.<br />\n";
                        }
                    }

                    foreach ($p["clones"] as $l) {

                        if (isset($dict[ $l["id"] ])) {

                            $new_link_id = $dict[ $l["id"] ] ;

                            $meta["content"][$l['box']][$l['state']]['data']['pageId'] = $new_link_id;

                            $needs_update = 1;

                        }
                        else {
                            $message .= "Page $new_id points to page ".$l["id"]." which wasn't imported.<br />\n";
                        }
                    }

					if ($needs_update) {

						update_post_meta($new_id, 'mpat_content', $meta);

					}


				}

			}

			$message .= "Added $ok pages and $ko already existed.\n";

			return $message ;
		}


		//echo '<script type="text/javascript">window.top.location = window.top.location.href;</script>';

	}

}

function updateMetaFromPath(&$meta, $path, $new_value) {

	$sub = &$meta;

	while (!empty($path)) {
		$p = array_shift($path);
		$sub = &$sub[$p];
	}

	$sub = $new_value;

}

function &findMediaData(&$page) {

	$last = array_pop($page);

	if (isset($last['mediadata'])) {
		return $last['mediadata'];
	}
	else {
		array_push($page, $last);
		// can't directly return null by reference
		return $nullGuard;
	}


}


function importSingleLayout(&$layout) {

	$meta = $layout["page_layout"]["meta"]["mpat_content"];
	$title = $layout["page_layout"]['post_title'];

	if (($old = get_page_by_title($title, ARRAY_A, "page_layout")) && $old["post_status"] == "publish") {
		return -1;
	}


	$page = array(
		'post_type' => 'page_layout',
		'post_status' => 'publish',
		'post_slug' => 'page_layout',
		'post_title' => $title,
		'meta_input' => $layout["page_layout"]["meta"]
	);
	$page_id = @wp_insert_post($page);

	return $page_id;

}

function importSinglePage(&$page, &$mediadata = null) {

	$meta = $page["page"]["meta"]["mpat_content"];
	$title = $page["page"]['post_title'];

	if (($old = get_page_by_title($title, ARRAY_A, $page["page"]['post_type'])) && $old["post_status"] == "publish")
	{
		return -1;
	}

	// affect the new page to a corresponding layout with the same name as the original if possible
	// or import the one contained in the exported page
	if (isset($page["page_layout"]) && isset($page["page_layout"]["post_title"])) {

		$layout_name = $page["page_layout"]["post_title"];

		if (($layout = get_page_by_title($layout_name, ARRAY_A, "page_layout")) && $layout["post_status"] == "publish") {
			$meta["layoutId"] = $layout["ID"];
		}
		else {
			$l = array(
				'post_type' => 'page_layout',
				'post_status' => 'publish',
				'post_slug' => 'page_layout',
				'post_title' => $layout_name,
				'meta_input' => $page["page_layout"]["meta"]
			);

			$meta["layoutId"] = wp_insert_post($l);
		}
	}


	// import media
	//     a. extract name from url (last path - ext - resolution-if-image)
	//     b. check local media by that name
	//         i. if exist, use this url instead
	//        ii. if not, create new attachment and use it
	if (isset($page["media"])) {

		foreach ($page["media"] as $media) {

			$url = $media['url'];


			$fileinfo = pathinfo( parse_url($url)['path'] );
			$filename = $fileinfo['filename'];

			if ($media['type'] == "image") {
				$filename = preg_replace('/-\d+x\d+$/', '', $filename);
			}

			$filename .= '.' . $fileinfo['extension'];

			global $wpdb;
			$query = "SELECT post_id FROM $wpdb->postmeta WHERE meta_key = '_wp_attached_file' AND ( meta_value LIKE '%/$filename' OR meta_value = '$filename' )" ;
			$results = $wpdb->get_results($query);


			if ( !empty($results) ) {

				$attachment = get_post($results[0]->post_id);
				$new_url = $attachment->guid;

				if ($media['type'] == "image") {

					if ($img = image_get_intermediate_size($results[0]->post_id, 'large')) {
						$new_url = $img['url'];
					}

				}

				if (isset($media['zone'])) {

					$meta['content'][ $media['zone'] ][ $media['state'] ]['data'][ $media['key'] ] = $new_url;
				}
				else if (isset($media['path'])) {

					updateMetaFromPath($meta, $media["path"], $new_url);
				}
			}
			else {

				if ( !function_exists('media_handle_sideload') ) {
					require_once(ABSPATH . "wp-admin" . '/includes/image.php');
					require_once(ABSPATH . "wp-admin" . '/includes/file.php');
					require_once(ABSPATH . "wp-admin" . '/includes/media.php');
				}

				$fpath = sys_get_temp_dir().DIRECTORY_SEPARATOR.$filename;
				$fh = fopen( $fpath, 'wb' );
				chmod($fpath, 0666);
				$stop = false;
				if (isset($media['data']) && !empty($media['data'])) {

					fwrite( $fh, base64_decode($media['data']) );
				}
				else if ($mediadata && isset($media['url']) && isset($mediadata[ $media['url'] ]) && !empty($mediadata[ $media['url'] ]) ) {

					fwrite( $fh, base64_decode( $mediadata[ $media['url'] ] ) );
				}
				else {
					$stop = true;
				}


				if (!$stop) {

					$file = array(
						'name'     => basename($filename),
						'tmp_name' => $fpath,
					);

					$id = @media_handle_sideload( $file, 0 );
					if (!is_wp_error($id)) {

						fclose($fh);
						if (file_exists($fpath))
							@unlink($fpath);

						$new_url = wp_get_attachment_url( $id );

						if ($media['type'] == "image") {

							if ($img = image_get_intermediate_size($id, 'large')) {
								$new_url = $img['url'];
							}

						}

						if (isset($media['zone'])) {

							$meta['content'][ $media['zone'] ][ $media['state'] ]['data'][ $media['key'] ] = $new_url;
						}
						else if (isset($media['path'])) {

							updateMetaFromPath($meta, $media["path"], $new_url);
						}
					}
				}
			}

    	}

	}

  $pt = 'page';
	if (array_key_exists('post_type', $page["page"])) $pt = $page["page"]['post_type'];
	$new_page = array(
		'post_type' => $pt,
		'post_status' => 'publish',
		'post_slug' => 'page',
		'post_title' => $title,
		'meta_input' => array( "mpat_content" => $meta )
	);
	$page_id = wp_insert_post($new_page);

	return $page_id;

}

function isUrlReachable($url){

	if(! $url || ! is_string($url)){
		return false;
	}

	$url = ImportExport::getFullUrl($url);

	$ch = @curl_init($url);
	if($ch === false){
		return false;
	}

	@curl_setopt($ch, CURLOPT_HEADER         ,true);
	@curl_setopt($ch, CURLOPT_NOBODY         ,true);
	@curl_setopt($ch, CURLOPT_RETURNTRANSFER ,true);
	@curl_setopt($ch, CURLOPT_FOLLOWLOCATION ,true);
	@curl_setopt($ch, CURLOPT_MAXREDIRS      ,10);
	@curl_setopt($ch, CURLOPT_TIMEOUT        ,5);

	@curl_exec($ch);

	if (@curl_errno($ch)) {
		@curl_close($ch);
		return false;
	}

	$code = @curl_getinfo($ch, CURLINFO_HTTP_CODE);
	@curl_close($ch);

	return ($code >= 200 && $code < 300);
}


function handle_options($opt) {

	if (isset($opt['dsmcc']))
		update_option('dsmcc', $opt['dsmcc'] );

	if (isset($opt['timeline_scenario']))
		update_option('timeline_scenario', $opt['timeline_scenario'] );

	$css_post_id = -1;

    if (isset($opt['custom_css'])) {
        $css_post = wp_update_custom_css_post( $opt['custom_css'] );
        if (isset($css_post->ID)) {
            $css_post_id = $css_post->ID;
        }

    }

    if (isset($opt['theme_mods_mpat-theme'])) {

        $opt['theme_mods_mpat-theme']['custom_css_post_id'] = $css_post_id ;
        update_option('theme_mods_mpat-theme', $opt['theme_mods_mpat-theme'] );

    }

    if (isset($opt['mpat_application_manager'])) {

        update_option('mpat_application_manager', $opt['mpat_application_manager'] );

    }

}


?>