<?php

/**
 * @package     Dotclear
 *
 * @copyright   Olivier Meunier & Association Dotclear
 * @copyright   AGPL-3.0
 */
declare(strict_types=1);

namespace Dotclear\Plugin\importExport;

use ArrayObject;
use Dotclear\App;
use Dotclear\Database\MetaRecord;
use Dotclear\Database\Record;
use Dotclear\Helper\Crypt;
use Dotclear\Helper\Html\Form\Checkbox;
use Dotclear\Helper\Html\Form\Div;
use Dotclear\Helper\Html\Form\Form;
use Dotclear\Helper\Html\Form\Hidden;
use Dotclear\Helper\Html\Form\Input;
use Dotclear\Helper\Html\Form\Label;
use Dotclear\Helper\Html\Form\Note;
use Dotclear\Helper\Html\Form\Number;
use Dotclear\Helper\Html\Form\Para;
use Dotclear\Helper\Html\Form\Password;
use Dotclear\Helper\Html\Form\Select;
use Dotclear\Helper\Html\Form\Set;
use Dotclear\Helper\Html\Form\Submit;
use Dotclear\Helper\Html\Form\Text;
use Dotclear\Helper\Html\Html;
use Dotclear\Helper\Network\Http;
use Dotclear\Helper\Text as Txt;
use Dotclear\Interface\Database\ConnectionInterface;
use Dotclear\Plugin\blogroll\Blogroll;
use Exception;

/**
 * @brief   The WP import module handler.
 * @ingroup importExport
 *
 * @todo switch to SqlStatement
 */
class ModuleImportWp extends Module
{
    protected ConnectionInterface $con;
    protected ConnectionInterface $wordpress_db;

    protected string $prefix;
    protected string $blog_id;

    protected ?string $action = null;
    protected int $step       = 1;

    protected int $post_offset = 0;
    protected int $post_limit  = 20;
    protected int $post_count  = 0;

    /**
     * @var array<string, bool>     $has_table
     */
    protected array $has_table = [];

    /**
     * @var array{
     *      db_host: string,
     *      db_name: string,
     *      db_user: string,
     *      db_pwd: string,
     *      db_prefix: string,
     *      ignore_first_cat: int,
     *      cat_import: int,
     *      cat_as_tags: int,
     *      cat_tags_prefix: string,
     *      post_limit: int,
     *      post_formater: string,
     *      comment_formater: string,
     *      user_ids: array<int, string>,
     *      cat_ids: array<int, int>,
     *      permalink_template: string,
     *      permalink_tags: array<array-key, string>
     * }    @vars
     */
    protected array $vars;

    /**
     * @var array{
     *      db_host: string,
     *      db_name: string,
     *      db_user: string,
     *      db_pwd: string,
     *      db_prefix: string,
     *      ignore_first_cat: int,
     *      cat_import: int,
     *      cat_as_tags: int,
     *      cat_tags_prefix: string,
     *      post_limit: int,
     *      post_formater: string,
     *      comment_formater: string,
     *      user_ids: array<int, string>,
     *      cat_ids: array<int, int>,
     *      permalink_template: string,
     *      permalink_tags: array<array-key, string>
     * }    @base_vars
     */
    protected array $base_vars = [
        'db_host'            => '',
        'db_name'            => '',
        'db_user'            => '',
        'db_pwd'             => '',
        'db_prefix'          => 'wp_',
        'ignore_first_cat'   => 1,
        'cat_import'         => 1,
        'cat_as_tags'        => 0,
        'cat_tags_prefix'    => 'cat: ',
        'post_limit'         => 20,
        'post_formater'      => 'xhtml',
        'comment_formater'   => 'xhtml',
        'user_ids'           => [],
        'cat_ids'            => [],
        'permalink_template' => 'p=%post_id%',
        'permalink_tags'     => [
            '%year%',
            '%monthnum%',
            '%day%',
            '%hour%',
            '%minute%',
            '%second%',
            '%postname%',
            '%post_id%',
            '%category%',
            '%author%',
        ],
    ];

    /**
     * @var array<string, array<string, string>|string>    $formaters
     */
    protected array $formaters;

    /**
     * Sets the module information.
     */
    protected function setInfo(): void
    {
        $this->type        = 'import';
        $this->name        = __('WordPress import');
        $this->description = __('Import a WordPress installation into your current blog.');
    }

    public function init(): void
    {
        $this->con     = App::db()->con();
        $this->prefix  = App::db()->con()->prefix();
        $this->blog_id = App::blog()->id();

        $this->readVars();

        if ($this->vars['post_limit'] > 0) {
            $this->post_limit = (int) $this->vars['post_limit'];
            $this->writeVars();
        }

        $this->formaters = App::backend()->combos()->getFormatersCombo();
    }

    protected function readVars(): void
    {
        if (is_array(App::session()->get('wp_import_vars'))) {
            /**
             * @var array{
             *      db_host: string,
             *      db_name: string,
             *      db_user: string,
             *      db_pwd: string,
             *      db_prefix: string,
             *      ignore_first_cat: int,
             *      cat_import: int,
             *      cat_as_tags: int,
             *      cat_tags_prefix: string,
             *      post_limit: int,
             *      post_formater: string,
             *      comment_formater: string,
             *      user_ids: array<int, string>,
             *      cat_ids: array<int, int>,
             *      permalink_template: string,
             *      permalink_tags: array<array-key, string>
             * }    @vars
             */
            $vars       = App::session()->get('wp_import_vars');
            $this->vars = $vars;
        } else {
            $this->resetVars();
        }
    }

    protected function writeVars(): void
    {
        App::session()->set('wp_import_vars', $this->vars);
    }

    public function resetVars(): void
    {
        $this->vars = $this->base_vars;
        $this->writeVars();
    }

    public function process(string $do): void
    {
        $this->action = $do;
    }

    /**
     * Processes the import/export with GUI feedback.
     *
     * We handle process in another way to always display something to user
     *
     * @param   string  $do     action
     */
    protected function guiprocess(string $do): void
    {
        switch ($do) {
            case 'step1':
                $post_formater    = is_string($post_formater = $_POST['post_formater']) ? $post_formater : '';
                $comment_formater = is_string($comment_formater = $_POST['comment_formater']) ? $comment_formater : '';

                $this->vars['db_host']          = is_string($_POST['db_host']) ? $_POST['db_host'] : '';
                $this->vars['db_name']          = is_string($_POST['db_name']) ? $_POST['db_name'] : '';
                $this->vars['db_user']          = is_string($_POST['db_user']) ? $_POST['db_user'] : '';
                $this->vars['db_pwd']           = is_string($_POST['db_pwd']) ? $_POST['db_pwd'] : '';
                $this->vars['db_prefix']        = is_string($_POST['db_prefix']) ? $_POST['db_prefix'] : '';
                $this->vars['ignore_first_cat'] = (int) isset($_POST['ignore_first_cat']);
                $this->vars['cat_import']       = (int) isset($_POST['cat_import']);
                $this->vars['cat_as_tags']      = (int) isset($_POST['cat_as_tags']);
                $this->vars['cat_tags_prefix']  = is_string($_POST['cat_tags_prefix']) ? $_POST['cat_tags_prefix'] : '';
                $this->vars['post_limit']       = is_numeric($_POST['post_limit']) ? (int) $_POST['post_limit'] : 0;
                $this->vars['post_formater']    = isset($this->formaters[$post_formater]) ? $post_formater : 'xhtml';
                $this->vars['comment_formater'] = isset($this->formaters[$comment_formater]) ? $comment_formater : 'xhtml';

                $db = $this->db();
                $db->close();
                $this->writeVars();
                $this->step = 2;
                echo $this->progressBar(1);

                break;
            case 'step2':
                $this->step = 2;
                $this->importUsers();
                $this->step = 3;
                echo $this->progressBar(3);

                break;
            case 'step3':
                $this->step = 3;
                $this->importCategories();
                if (App::plugins()->moduleExists('blogroll')) {
                    $this->step = 4;
                    echo $this->progressBar(5);
                } else {
                    $this->step = 5;
                    echo $this->progressBar(7);
                }

                break;
            case 'step4':
                $this->step = 4;
                $this->importLinks();
                $this->step = 5;
                echo $this->progressBar(7);

                break;
            case 'step5':
                $this->step        = 5;
                $this->post_offset = is_numeric($_REQUEST['offset']) ? (int) $_REQUEST['offset'] : 0;
                $percent           = 0;
                if ($this->importPosts($percent) === -1) {
                    Http::redirect($this->getURL() . '&do=ok');
                } else {
                    echo $this->progressBar((int) ceil((float) $percent * 0.93) + 7);
                }

                break;
            case 'ok':
                $this->resetVars();
                App::blog()->triggerBlog();
                $this->step = 6;
                echo $this->progressBar(100);

                break;
        }
    }

    public function gui(): void
    {
        try {
            $this->guiprocess((string) $this->action);
        } catch (Exception $e) {
            $this->error($e);
        }

        switch ($this->step) {
            case 1:
                echo (new Para())
                    ->items([
                        (new Text(null, sprintf(
                            __('This will import your WordPress content as new content in the current blog: %s.'),
                            '<strong>' . Html::escapeHTML(App::blog()->name()) . '</strong>'
                        ))),
                    ])
                ->render();

                echo (new Note())
                    ->class('warning')
                    ->text(__('Please note that this process will empty your categories, blogroll, entries and comments on the current blog.'))
                ->render();

                $text = (new Set())
                    ->items([
                        (new Para())
                            ->items([
                                (new Text(null, __('We first need some information about your old WordPress installation.'))),
                            ]),
                        (new Para())
                            ->items([
                                (new Input('db_host'))
                                    ->size(30)
                                    ->maxlength(255)
                                    ->value(Html::escapeHTML($this->vars['db_host']))
                                    ->label((new Label(__('Database Host Name:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Para())
                            ->items([
                                (new Input('db_name'))
                                    ->size(30)
                                    ->maxlength(255)
                                    ->value(Html::escapeHTML($this->vars['db_name']))
                                    ->label((new Label(__('Database Name:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Para())
                            ->items([
                                (new Input('db_user'))
                                    ->size(30)
                                    ->maxlength(255)
                                    ->value(Html::escapeHTML($this->vars['db_user']))
                                    ->label((new Label(__('Database User Name:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Para())
                            ->items([
                                (new Password('db_pwd'))
                                    ->size(30)
                                    ->maxlength(255)
                                    ->value(Html::escapeHTML($this->vars['db_pwd']))
                                    ->label((new Label(__('Database Password:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Para())
                            ->items([
                                (new Input('db_prefix'))
                                    ->size(30)
                                    ->maxlength(255)
                                    ->value(Html::escapeHTML($this->vars['db_prefix']))
                                    ->label((new Label(__('Database Tables Prefix:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Text('h3', __('Entries import options')))->class('vertical-separator'),
                        (new Div())
                            ->class('two-cols')
                            ->items([
                                (new Div())
                                    ->class('col')
                                    ->items([
                                        (new Note())
                                            ->text(__('WordPress and Dotclear\'s handling of categories are quite different. You can assign several categories to a single post in WordPress. In the Dotclear world, we see it more like "One category, several tags." Therefore Dotclear can only import one category per post and will chose the lowest numbered one. If you want to keep a trace of every category, you can import them as tags, with an optional prefix.')),
                                        (new Note())
                                            ->text(__('On the other hand, in WordPress, a post can not be uncategorized, and a default installation has a first category labelised <i>"Uncategorized"</i>. If you did not change that category, you can just ignore it while importing your blog, as Dotclear allows you to actually keep your posts uncategorized.')),
                                    ]),
                                (new Div())
                                    ->class('col')
                                    ->items([
                                        (new Para())
                                            ->items([
                                                (new Checkbox('ignore_first_cat', (bool) $this->vars['ignore_first_cat']))
                                                    ->value(1)
                                                    ->label((new Label(__('Ignore the first category:'), Label::INSIDE_TEXT_BEFORE))),
                                            ]),
                                        (new Para())
                                            ->items([
                                                (new Checkbox('cat_import', (bool) $this->vars['cat_import']))
                                                    ->value(1)
                                                    ->label((new Label(__('Import lowest numbered category on posts:'), Label::INSIDE_TEXT_BEFORE))),
                                            ]),
                                        (new Para())
                                            ->items([
                                                (new Checkbox('cat_as_tags', (bool) $this->vars['cat_as_tags']))
                                                    ->value(1)
                                                    ->label((new Label(__('Import all categories as tags:'), Label::INSIDE_TEXT_BEFORE))),
                                            ]),
                                        (new Para())
                                            ->items([
                                                (new Input('cat_tags_prefix'))
                                                    ->size(10)
                                                    ->maxlength(20)
                                                    ->value(Html::escapeHTML($this->vars['cat_tags_prefix']))
                                                    ->label((new Label(__('Prefix such tags with:'), Label::OUTSIDE_TEXT_BEFORE))),
                                            ]),
                                        (new Para())
                                            ->items([
                                                (new Number('post_limit', 0, 999))
                                                    ->value(Html::escapeHTML((string) $this->vars['post_limit']))
                                                    ->label((new Label(__('Number of entries to import at once:'), Label::OUTSIDE_TEXT_BEFORE))),
                                            ]),
                                    ]),
                            ]),
                        (new Text('h3', __('Content filters')))->class('vertical-separator'),
                        (new Note())
                            ->text(__('You may want to process your post and/or comment content with the following filters.')),
                        (new Para())
                            ->items([
                                (new Select('post_formater'))
                                    ->items($this->formaters)
                                    ->default(Html::escapeHTML($this->vars['post_formater']))
                                    ->label((new Label(__('Post content formatter:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                        (new Para())
                            ->items([
                                (new Select('comment_formater'))
                                    ->items($this->formaters)
                                    ->default(Html::escapeHTML($this->vars['comment_formater']))
                                    ->label((new Label(__('Comment content formatter:'), Label::OUTSIDE_TEXT_BEFORE))),
                            ]),
                    ])
                ->render();

                printf(
                    $this->imForm(1, __('General information'), __('Import my blog now')),
                    $text
                );

                break;
            case 2:
                printf(
                    $this->imForm(2, __('Importing users')),
                    $this->autoSubmit()
                );

                break;
            case 3:
                printf(
                    $this->imForm(3, __('Importing categories')),
                    $this->autoSubmit()
                );

                break;
            case 4:
                printf(
                    $this->imForm(4, __('Importing blogroll')),
                    $this->autoSubmit()
                );

                break;
            case 5:
                $text = sprintf(
                    __('Importing entries from %d to %d / %d'),
                    $this->post_offset,
                    min([$this->post_offset + $this->post_limit, $this->post_count]),
                    $this->post_count
                );
                printf(
                    $this->imForm(5, $text),
                    (new Hidden(['offset'], (string) $this->post_offset))->render() .
                    $this->autoSubmit()
                );

                break;
            case 6:
                echo (new Set())
                    ->items([
                        (new Text('h3', __('Please read carefully')))->class('vertical-separator'),
                        (new Note())
                            ->class('message')
                            ->text(__('Every newly imported user has received a random password ' .
                            'and will need to ask for a new one by following the "I forgot my password" link on the login page ' .
                            '(Their registered email address has to be valid.)')),
                    ])
                ->render();

                $this->congratMessage();

                break;
        }
    }

    /**
     * Return a simple form for step by step process.
     *
     * @param   int     $step           The step
     * @param   string  $legend         The legend
     * @param   string  $submit_value   The submit value
     */
    protected function imForm(int $step, string $legend, ?string $submit_value = null): string
    {
        if (!$submit_value) {
            $submit_value = __('next step') . ' >';
        }

        return (new Form('im-form'))
            ->method('post')
            ->action($this->getURL(true))
            ->fields([
                (new Text('h3', $legend))->class('vertical-separator'),
                ...My::hiddenFields(),
                (new Div())->items([
                    (new Hidden(['do'], 'step' . $step)),
                    (new Text(null, '%s')),
                ]),
                (new Para())->class('vertical-separator')->items([
                    (new Submit('im-form-submit', $submit_value)),
                ]),
                (new Note())
                    ->class(['form-note', 'info'])
                    ->text(__('Depending on the size of your blog, it could take a few minutes.')),
            ])
        ->render();
    }

    /**
     * Error display.
     *
     * @param   Exception   $e  The error
     */
    protected function error(Exception $e): void
    {
        App::backend()->notices()->error('<strong>' . __('Errors:') . '</strong>' . '<p>' . $e->getMessage() . '</p>', false, false);
    }

    /**
     * DB init.
     *
     * @throws  Exception
     */
    protected function db(): ConnectionInterface
    {
        if (isset($this->wordpress_db)) {
            return $this->wordpress_db;
        }

        $db = App::db()->newCon('mysqli', $this->vars['db_host'], $this->vars['db_name'], $this->vars['db_user'], $this->vars['db_pwd']);

        $rs = $db->select("SHOW TABLES LIKE '" . $this->vars['db_prefix'] . "%'");
        if ($rs->isEmpty()) {
            throw new Exception(__('WordPress tables not found'));
        }

        while ($rs->fetch()) {
            $table = is_string($rs->f(0)) ? $rs->f(0) : '';
            if ($table !== '') {
                $this->has_table[$table] = true;
            }
        }

        # Set this to read data as they were written
        try {
            $db->execute('SET NAMES DEFAULT');
        } catch (Exception) {
        }

        $db->execute('SET CHARACTER SET DEFAULT');
        $db->execute('SET COLLATION_CONNECTION = DEFAULT');
        $db->execute('SET COLLATION_SERVER = DEFAULT');
        $db->execute('SET CHARACTER_SET_SERVER = DEFAULT');
        $db->execute('SET CHARACTER_SET_DATABASE = DEFAULT');

        $this->post_count = is_numeric($post_count = $db->select(
            'SELECT COUNT(ID) FROM ' . $this->vars['db_prefix'] . 'posts ' .
            'WHERE post_type = \'post\' OR post_type = \'page\''
        )->f(0)) ? (int) $post_count : 0;

        $this->wordpress_db = $db;

        return $db;
    }

    /**
     * Users import.
     */
    protected function importUsers(): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];
        $rs        = $db->select('SELECT * FROM ' . $wp_prefix . 'users');

        try {
            $this->con->begin();

            while ($rs->fetch()) {
                $user_id = is_string($user_id = $rs->user_login) ? $user_id : '';
                $user_id = (string) preg_replace('/[^A-Za-z0-9@._-]/', '-', $user_id);
                $wp_id   = is_numeric($rs->ID) ? (int) $rs->ID : 0;
                if ($user_id !== '' && $wp_id !== 0 && !App::users()->userExists($user_id)) {
                    $this->vars['user_ids'][$wp_id] = $user_id;

                    $cur                   = App::auth()->openUserCursor();
                    $cur->user_id          = $user_id;
                    $cur->user_pwd         = Crypt::createPassword();
                    $cur->user_displayname = $rs->user_nicename;
                    $cur->user_email       = $rs->user_email;
                    $cur->user_url         = $rs->user_url;
                    $cur->user_creadt      = $rs->user_registered;
                    $cur->user_lang        = App::blog()->settings()->system->lang;
                    $cur->user_tz          = App::blog()->settings()->system->blog_timezone;

                    $permissions = [];
                    $rs_meta     = $db->select('SELECT * FROM ' . $wp_prefix . 'usermeta WHERE user_id = ' . $wp_id);
                    while ($rs_meta->fetch()) {
                        switch ($rs_meta->meta_key) {
                            case 'first_name':
                                $meta_value          = is_string($meta_value = $rs_meta->meta_value) ? $meta_value : '';
                                $cur->user_firstname = Txt::cleanStr($meta_value);

                                break;
                            case 'last_name':
                                $meta_value     = is_string($meta_value = $rs_meta->meta_value) ? $meta_value : '';
                                $cur->user_name = Txt::cleanStr($meta_value);

                                break;
                            case 'description':
                                $meta_value     = is_string($meta_value = $rs_meta->meta_value) ? $meta_value : '';
                                $cur->user_desc = Txt::cleanStr($meta_value);

                                break;
                            case 'rich_editing':
                                $meta_value        = is_string($meta_value = $rs_meta->meta_value) ? $meta_value : '';
                                $cur->user_options = new ArrayObject([
                                    'enable_wysiwyg' => $meta_value === 'true',
                                ]);

                                break;
                            case 'wp_user_level':
                                $meta_value = is_numeric($meta_value = $rs_meta->meta_value) ? (int) $meta_value : 0;
                                switch ($meta_value) {
                                    case '0': # Subscriber
                                        $cur->user_status = App::status()->user()::DISABLED;

                                        break;
                                    case '1': # Contributor
                                        $permissions['usage']   = true;
                                        $permissions['publish'] = true;
                                        $permissions['delete']  = true;

                                        break;
                                    case '2': # Author
                                    case '3':
                                    case '4':
                                        $permissions['contentadmin'] = true;
                                        $permissions['media']        = true;

                                        break;
                                    case '5': # Editor
                                    case '6':
                                    case '7':
                                        $permissions['contentadmin'] = true;
                                        $permissions['categories']   = true;
                                        $permissions['media_admin']  = true;
                                        $permissions['pages']        = true;
                                        $permissions['blogroll']     = true;

                                        break;
                                    case '8': # Administrator
                                    case '9':
                                    case '10':
                                        $permissions['admin'] = true;

                                        break;
                                }

                                break;
                        }
                    }
                    App::users()->addUser($cur);
                    App::users()->setUserBlogPermissions(
                        $cur->user_id,
                        $this->blog_id,
                        $permissions
                    );
                }
            }
            $this->con->commit();
            $db->close();
            $this->writeVars();
        } catch (Exception $e) {
            $this->con->rollback();
            $db->close();

            throw $e;
        }
    }

    /**
     * Categories import.
     */
    protected function importCategories(): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];
        $rs        = $db->select(
            'SELECT * FROM ' . $wp_prefix . 'terms AS t, ' . $wp_prefix . 'term_taxonomy AS x ' .
            'WHERE x.taxonomy = \'category\' ' .
            'AND t.term_id = x.term_id ' .
            ($this->vars['ignore_first_cat'] ? 'AND t.term_id <> 1 ' : '') .
            'ORDER BY t.term_id ASC'
        );

        try {
            $this->con->execute(
                'DELETE FROM ' . $this->prefix . App::blog()->categories()::CATEGORY_TABLE_NAME . ' ' .
                "WHERE blog_id = '" . $this->con->escapeStr($this->blog_id) . "' "
            );

            $ord = 2;
            while ($rs->fetch()) {
                $cat_title = is_string($cat_title = $rs->name) ? $cat_title : '';
                $cat_desc  = is_string($cat_desc = $rs->description) ? $cat_desc : '';
                $cat_url   = is_string($cat_url = $rs->slug) ? $cat_url : '';
                $cat_id    = is_numeric($rs->term_id) ? (int) $rs->term_id : 0;

                $cur            = App::blog()->categories()->openCategoryCursor();
                $cur->blog_id   = $this->blog_id;
                $cur->cat_title = Txt::cleanStr($cat_title);
                $cur->cat_desc  = Txt::cleanStr($cat_desc);
                $cur->cat_url   = Txt::cleanStr($cat_url);
                $cur->cat_lft   = $ord++;
                $cur->cat_rgt   = $ord++;

                $new_cat_id = is_numeric($new_cat_id = (new MetaRecord($this->con->select(
                    'SELECT MAX(cat_id) FROM ' . $this->prefix . App::blog()->categories()::CATEGORY_TABLE_NAME
                )))->f(0)) ? (int) $new_cat_id : 0;
                $new_cat_id++;

                $cur->cat_id                    = $new_cat_id;
                $this->vars['cat_ids'][$cat_id] = $new_cat_id;
                $cur->insert();
            }

            $db->close();
            $this->writeVars();
        } catch (Exception $e) {
            $db->close();

            throw $e;
        }
    }

    /**
     * Blogroll import.
     */
    protected function importLinks(): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];
        $rs        = $db->select('SELECT * FROM ' . $wp_prefix . 'links ORDER BY link_id ASC');

        try {
            $this->con->execute(
                'DELETE FROM ' . $this->prefix . Blogroll::LINK_TABLE_NAME . ' ' .
                "WHERE blog_id = '" . $this->con->escapeStr($this->blog_id) . "' "
            );

            while ($rs->fetch()) {
                $link_href  = is_string($link_href = $rs->link_url) ? $link_href : '';
                $link_title = is_string($link_title = $rs->link_name) ? $link_title : '';
                $link_desc  = is_string($link_desc = $rs->link_description) ? $link_desc : '';
                $link_xfn   = is_string($link_xfn = $rs->link_rel) ? $link_xfn : '';

                $cur             = $this->con->openCursor($this->prefix . Blogroll::LINK_TABLE_NAME);
                $cur->blog_id    = $this->blog_id;
                $cur->link_href  = Txt::cleanStr($link_href);
                $cur->link_title = Txt::cleanStr($link_title);
                $cur->link_desc  = Txt::cleanStr($link_desc);
                $cur->link_xfn   = Txt::cleanStr($link_xfn);

                $link_id = is_numeric($link_id = (new MetaRecord($this->con->select(
                    'SELECT MAX(link_id) FROM ' . $this->prefix . Blogroll::LINK_TABLE_NAME
                )))->f(0)) ? (int) $link_id : 0;
                $link_id++;

                $cur->link_id = $link_id;
                $cur->insert();
            }

            $db->close();
        } catch (Exception $e) {
            $db->close();

            throw $e;
        }
    }

    /**
     * Entries import.
     *
     * @param   int     $percent    The percent
     */
    protected function importPosts(int &$percent): ?int
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];

        $plink = $db->select(
            'SELECT option_value FROM ' . $wp_prefix . 'options ' .
            "WHERE option_name = 'permalink_structure'"
        )->option_value;
        $plink = is_string($plink) ? $plink : '';
        if ($plink !== '') {
            $this->vars['permalink_template'] = substr($plink, 1);
            $this->writeVars();
        }

        $rs = $db->select(
            'SELECT * FROM ' . $wp_prefix . 'posts ' .
            'WHERE post_type = \'post\' OR post_type = \'page\' ' .
            'ORDER BY ID ASC ' .
            $db->limit($this->post_offset, $this->post_limit)
        );

        try {
            if ($this->post_offset === 0) {
                $this->con->execute(
                    'DELETE FROM ' . $this->prefix . App::blog()::POST_TABLE_NAME . ' ' .
                    "WHERE blog_id = '" . $this->con->escapeStr($this->blog_id) . "' "
                );
            }

            while ($rs->fetch()) {
                $this->importPost($rs);
            }
        } catch (Exception $e) {
            throw $e;
        } finally {
            $db->close();
        }

        if ($rs->count() < $this->post_limit) {
            return -1;
        }
        $this->post_offset += $this->post_limit;

        $percent = $this->post_offset > $this->post_count ? 100 : (int) ($this->post_offset * 100 / $this->post_count);

        return null;
    }

    /**
     * Entry import.
     *
     * @param   Record                  $rs     The record
     */
    protected function importPost(Record $rs): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];

        $post_dt    = is_string($post_dt = $rs->post_date) ? $post_dt : '1970-01-01 00:00';
        $wp_id      = is_numeric($rs->post_author) ? (int) $rs->post_author : 0;
        $user_id    = $this->vars['user_ids'][$wp_id] ?? App::auth()->userID();
        $post_title = is_string($post_title = $rs->post_titre) ? $post_title : '';
        $object_id  = is_numeric($object_id = $rs->ID) ? (int) $rs->ID : 0;

        $cur              = App::blog()->openPostCursor();
        $cur->blog_id     = $this->blog_id;
        $cur->user_id     = $user_id;
        $cur->post_dt     = $post_dt;
        $cur->post_creadt = $post_dt;
        $cur->post_upddt  = $rs->post_modified;
        $cur->post_title  = Txt::cleanStr($post_title);

        if ($cur->post_title === '') {
            $cur->post_title = 'No title';
        }

        if ($this->vars['cat_import'] || $this->vars['cat_as_tags']) {
            $old_cat_ids = $db->select(
                'SELECT * FROM ' . $wp_prefix . 'terms AS t, ' .
                $wp_prefix . 'term_taxonomy AS x, ' .
                $wp_prefix . 'term_relationships AS r ' .
                'WHERE t.term_id = x.term_id ' .
                ($this->vars['ignore_first_cat'] ? 'AND t.term_id <> 1 ' : '') .
                'AND x.taxonomy = \'category\' ' .
                'AND t.term_id = r.term_taxonomy_id ' .
                'AND r.object_id =' . $object_id . ' ' .
                'ORDER BY t.term_id ASC'
            );
            if (!$old_cat_ids->isEmpty() && $this->vars['cat_import']) {
                $term_id     = is_numeric($term_id = $old_cat_ids->term_id) ? (int) $term_id : 0;
                $cur->cat_id = $this->vars['cat_ids'][$term_id];
            }
        }

        /**
         * @var array<array-key, string>    $permalink_infos
         */
        $permalink_infos = [
            date('Y', (int) strtotime($post_dt)),
            date('m', (int) strtotime($post_dt)),
            date('d', (int) strtotime($post_dt)),
            date('H', (int) strtotime($post_dt)),
            date('i', (int) strtotime($post_dt)),
            date('s', (int) strtotime($post_dt)),
            $rs->post_name,
            (string) $object_id,
            is_numeric($cur->cat_id) ? (string) $cur->cat_id : '',
            $cur->user_id,
        ];

        $post_url = str_replace(
            $this->vars['permalink_tags'],
            $permalink_infos,
            $rs->post_type === 'post' ? $this->vars['permalink_template'] : '%postname%'
        );
        $post_url      = substr($post_url, 0, 255);
        $cur->post_url = $post_url !== '' ? $post_url : (string) $object_id;

        $cur->post_format = $this->vars['post_formater'];

        $post_content  = is_string($post_content = $rs->post_content) ? $post_content : '';
        $_post_content = explode('<!--more-->', $post_content, 2);
        if (count($_post_content) === 1) {
            $cur->post_excerpt       = null;
            $cur->post_excerpt_xhtml = null;
            $cur->post_content       = Txt::cleanStr($_post_content[0]);
        } else {
            $cur->post_excerpt = Txt::cleanStr($_post_content[0]);
            $cur->post_content = Txt::cleanStr($_post_content[1]);
        }

        $cur->post_content_xhtml = App::formater()->callEditorFormater('dcLegacyEditor', $this->vars['post_formater'], $cur->post_content);
        if (!is_null($cur->post_excerpt)) {
            $cur->post_excerpt_xhtml = App::formater()->callEditorFormater('dcLegacyEditor', $this->vars['post_formater'], $cur->post_excerpt);
        }

        $cur->post_status = match ($rs->post_status) {
            'publish' => App::status()->post()::PUBLISHED,
            'draft'   => App::status()->post()::UNPUBLISHED,
            default   => App::status()->post()::PENDING,
        };
        $cur->post_type         = $rs->post_type;
        $cur->post_password     = $rs->post_password ?: null;
        $cur->post_open_comment = $rs->comment_status == 'open' ? 1 : 0;
        $cur->post_open_tb      = $rs->ping_status    == 'open' ? 1 : 0;

        $cur->post_words = implode(' ', Txt::splitWords(
            $cur->post_title . ' ' .
            $cur->post_excerpt_xhtml . ' ' .
            $cur->post_content_xhtml
        ));

        $new_post_id = is_numeric($new_post_id = (new MetaRecord($this->con->select(
            'SELECT MAX(post_id) FROM ' . $this->prefix . App::blog()::POST_TABLE_NAME
        )))->f(0)) ? (int) $new_post_id : 0;
        $new_post_id++;

        $cur->post_id = $new_post_id;

        $cur->post_url = App::blog()->getPostURL($cur->post_url, $cur->post_dt, $cur->post_title, $cur->post_id);

        $cur->insert();
        $this->importComments($object_id, $new_post_id);
        $this->importPings($object_id, $new_post_id);

        # Create tags
        $this->importTags($object_id, $new_post_id);

        if (isset($old_cat_ids) && !$old_cat_ids->isEmpty() && $this->vars['cat_as_tags']) {
            $old_cat_ids->moveStart();
            while ($old_cat_ids->fetch()) {
                $name = is_string($old_cat_ids->name) ? $old_cat_ids->name : '';
                if ($name !== '') {
                    App::meta()->setPostMeta($new_post_id, 'tag', Txt::cleanStr($this->vars['cat_tags_prefix'] . $name));
                }
            }
        }
    }

    /**
     * Comments import.
     *
     * @param   int                     $post_id        The post identifier
     * @param   int                     $new_post_id    The new post identifier
     */
    protected function importComments(int $post_id, int $new_post_id): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];

        $count_c = $count_t = 0;

        $rs = $db->select(
            'SELECT * FROM ' . $wp_prefix . 'comments ' .
            'WHERE comment_post_ID = ' . $post_id . ' '
        );

        while ($rs->fetch()) {
            $comment_author  = is_string($comment_author = $rs->comment_author) ? $comment_author : '';
            $comment_status  = is_numeric($comment_status = $rs->comment_approved) ? (int) $comment_status : App::status()->comment()::UNPUBLISHED;
            $comment_email   = is_string($comment_email = $rs->comment_author_email) ? $comment_email : '';
            $comment_content = is_string($comment_content = $rs->comment_content) ? $comment_content : '';
            $comment_site    = is_string($comment_site = $rs->comment_author_url) ? $comment_site : '';

            $cur                    = App::blog()->openCommentCursor();
            $cur->post_id           = $new_post_id;
            $cur->comment_author    = Txt::cleanStr($comment_author);
            $cur->comment_status    = $comment_status;
            $cur->comment_dt        = $rs->comment_date;
            $cur->comment_email     = Txt::cleanStr($comment_email);
            $cur->comment_content   = App::formater()->callEditorFormater('dcLegacyEditor', $this->vars['comment_formater'], Txt::cleanStr($comment_content));
            $cur->comment_ip        = $rs->comment_author_IP;
            $cur->comment_trackback = $rs->comment_type == 'trackback' ? 1 : 0;
            $cur->comment_site      = substr(Txt::cleanStr($comment_site), 0, 255);
            if ($cur->comment_site === '') {
                $cur->comment_site = null;
            }

            if ($rs->comment_approved === 'spam') {
                $cur->comment_status = App::status()->comment()::JUNK;
            }

            $cur->comment_words = implode(' ', Txt::splitWords($cur->comment_content));

            $new_comment_id = is_numeric($new_comment_id = (new MetaRecord($this->con->select(
                'SELECT MAX(comment_id) FROM ' . $this->prefix . App::blog()::COMMENT_TABLE_NAME
            )))->f(0)) ? (int) $new_comment_id : 0;
            $new_comment_id++;

            $cur->comment_id = $new_comment_id;
            $cur->insert();

            if ($cur->comment_status === App::status()->comment()::PUBLISHED) {
                if ($cur->comment_trackback !== 0) {
                    $count_t++;
                } else {
                    $count_c++;
                }
            }
        }

        if ($count_t > 0 || $count_c > 0) {
            $this->con->execute(
                'UPDATE ' . $this->prefix . App::blog()::POST_TABLE_NAME . ' SET ' .
                'nb_comment = ' . $count_c . ', ' .
                'nb_trackback = ' . $count_t . ' ' .
                'WHERE post_id = ' . $new_post_id . ' '
            );
        }
    }

    /**
     * Pings import.
     *
     * @param   int                     $post_id        The post identifier
     * @param   int                     $new_post_id    The new post identifier
     */
    protected function importPings(int $post_id, int $new_post_id): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];

        $urls  = [];
        $pings = [];

        $rs = $db->select(
            'SELECT pinged FROM ' . $wp_prefix . 'posts ' .
            'WHERE ID = ' . $post_id
        );
        $pings = explode("\n", is_string($rs->pinged) ? $rs->pinged : '') ;
        unset($pings[0]);

        foreach ($pings as $ping_url) {
            $url = Txt::cleanStr($ping_url);
            if (isset($urls[$url])) {
                continue;
            }

            $cur           = $this->con->openCursor($this->prefix . App::trackback()::PING_TABLE_NAME);
            $cur->post_id  = $new_post_id;
            $cur->ping_url = $url;
            $cur->insert();

            $urls[$url] = true;
        }
    }

    /**
     * Meta import.
     *
     * @param   int                     $post_id        The post identifier
     * @param   int                     $new_post_id    The new post identifier
     */
    protected function importTags(int $post_id, int $new_post_id): void
    {
        $db        = $this->db();
        $wp_prefix = $this->vars['db_prefix'];

        $rs = $db->select(
            'SELECT * FROM ' . $wp_prefix . 'terms AS t, ' .
            $wp_prefix . 'term_taxonomy AS x, ' .
            $wp_prefix . 'term_relationships AS r ' .
            'WHERE t.term_id = x.term_id ' .
            'AND x.taxonomy = \'post_tag\' ' .
            'AND t.term_id = r.term_taxonomy_id ' .
            'AND r.object_id =' . $post_id .
            ' ORDER BY t.term_id ASC'
        );

        if ($rs->isEmpty()) {
            return;
        }

        while ($rs->fetch()) {
            $name = is_string($rs->name) ? $rs->name : '';
            if ($name !== '') {
                App::meta()->setPostMeta($new_post_id, 'tag', Txt::cleanStr($name));
            }
        }
    }
}
