. * */ namespace Vvveb\Plugins\ImportWordpress\Controller; use \Vvveb\System\Import\Rss; use function Vvveb\__; use Vvveb\Controller\Base; use function Vvveb\htmlToText; use function Vvveb\nl2p; use Vvveb\Sql\categorySQL; use Vvveb\Sql\postSQL; class Settings extends Base { private $cats = []; private $postTypes = ['post', 'page', 'attachment']; function formatHtml($html) { //remove comments $html = preg_replace('//mi', '', $html); //fix align classes $html = str_replace( ['aligncenter', 'alignleft', 'alignright', '

', '
• '], ['align-center', 'align-left', 'align-right', '
  ', '
  • '], $html); return $html; } private function addCategories($slug, $name) { $cat = $this->categories->getCategoryBySlug(['slug' => $category_slug, 'taxonomy_id' => 1, 'parent_id' => $prev_category, 'site_id' => $this->global['site_id']]); if ($cat) { $prev_category = $cat['taxonomy_item_id']; } else { $cat = $this->categories->addCategory([ 'taxonomy_item' => $this->global + [ 'parent_id' => $prev_category, ], 'taxonomy_item_content' => $this->global + ['slug'=> $slug, 'name' => $name, 'content' => ''], ] + $this->global); $category_id = $cat['taxonomy_item']; } } private function add($data) { //$category_id = $this->cats[$category] ?? false; //$post_data = $this->post->get(['slug' => $data['slug']]) ?? []; $post_data = false; $category_id = false; $data['excerpt'] = $data['excerpt'] ? $data['excerpt'] : ''; //substr(htmlToText($data['content']), 0, 200); $language_id = $this->global['language_id']; if (! $post_data) { $data = [ 'post' => $data + $this->global, 'post_content' => [ $language_id => $data + $this->global, ], 'site_id' => [$this->global['site_id']], ] + $this->global; $post_data = $this->post->add($data); if ($category_id) { $taxonomy_item = ['post_id' => $post_data['post'], 'taxonomy_item' => ['taxonomy_item_id' => $category_id]]; $this->post->setPostTaxonomy($taxonomy_item); } } else { //if slug already exists update post $data = [ 'post' => $post_data + $data + $this->global, 'post_content' => [ $language_id => $post_data + $data + $this->global, ], 'post_id' => $post_data['post_id'], 'site_id' => [$this->global['site_id']], ] + $this->global; $result = $this->post->edit($data); if ($category_id) { $taxonomy_item = ['post_id' => $post_data['post_id'], 'taxonomy_item' => ['taxonomy_item_id' => $category_id]]; $this->post->setPostTaxonomy($taxonomy_item); } } } private function processPost($posts) { foreach ($posts as &$post) { $data['content'] = nl2p($this->formatHtml($post['content:encoded'])); $data['excerpt'] = $this->formatHtml($post['excerpt:encoded']); $data['name'] = $post['title']; $data['slug'] = $post['wp:post_name']; $data['type'] = $post['wp:post_type']; $data['created_at'] = $post['wp:post_date']; $data['updated_at'] = $post['wp:post_date']; $data['status'] = $post['wp:status']; $this->add($data); } } private function processPage($posts) { return $this->processPost($posts); } private function processAttachment($posts) { } private function import($file) { $this->categories = new categorySQL(); $this->post = new postSQL(); $rss = new Rss(file_get_contents($file)); foreach ($this->postTypes as $postType) { $posts = $rss->get(null, null, [['wp:post_type' => $postType]]); $fn = 'process' . ucfirst($postType); $this->$fn($posts); } return true; } function importFile($file, $name = '') { $result = false; if ($file) { try { // use temorary file, php cleans temporary files on request finish. $result = $this->import($file); } catch (\Exception $e) { $error = $e->getMessage(); $this->view->errors[] = $error; } } if ($result) { $successMessage = sprintf(__('Import `%s` was successful!'), $name); $this->view->success[] = $successMessage; } else { $errorMessage = sprintf(__('Failed to import `%s` file!'), $name); $this->view->errors[] = $errorMessage; } } function upload() { $files = $this->request->files; //check for uploaded files if ($files) { foreach ($files as $file) { $this->importFile($file['tmp_name'], $file['name']); } } //check if filename is given (from cli) $file = $this->request->post['file'] ?? false; if (is_array($file)) { foreach ($file as $f) { $this->importFile($f, basename($f)); } } else { if ($file) { $this->importFile($file, basename($file)); } } return $this->index(); } function index() { } }