xref: /plugin/hideip/admin.php (revision 047cf1274130bf2cc2a8d4fd101f0662c03da350)

<?php
if (!defined('DOKU_INC')) die();

/**
 * Hide IP — admin component.
 *
 * Admin-only page that walks the historical IP-bearing files DokuWiki has
 * accumulated and rewrites every IP field with the placeholder used by the
 * action component. Scope is intentionally narrow:
 *
 *   - $conf['metadir']/**.changes        page changelogs (per-page + master)
 *   - $conf['mediametadir']/**.changes   media changelogs (per-media + master)
 *   - $conf['metadir']/**.meta           page metadata (last_change.ip)
 *
 * NOT touched (per the project's explicit scope):
 *   - data/attic/, data/media_attic/     historical .gz revision archives
 *   - data/cache/, data/tmp/, data/log/  ephemeral / regenerated
 *
 * Authorship (user field) and timestamps (date field) are preserved; only
 * the IP field is rewritten. File mtimes are preserved across the rewrite.
 *
 * Atomicity: every write goes to a sibling tmp file with a random suffix and
 * is then rename()d into place. rename() is atomic on a single filesystem,
 * so a concurrent reader either sees the old file or the new file.
 *
 * Idempotent: running scrub twice is a no-op on lines that already hold the
 * placeholder.
 */

use dokuwiki\Extension\AdminPlugin;
use dokuwiki\Form\Form;

class admin_plugin_hideip extends AdminPlugin
{
    /** Mirror of action_plugin_hideip::PLACEHOLDER_IP. Kept inline so this
     *  admin component can run without the action component being loaded. */
    public const PLACEHOLDER_IP = '0.0.0.0';

    /** Random suffix length for tmp files; .hideip_tmp_<8 hex>. */
    public const TMP_SUFFIX_BYTES = 4;

    /**
     * @return bool
     */
    public function forAdminOnly()
    {
        return true;
    }

    /**
     * @return int
     */
    public function getMenuSort()
    {
        return 1000;
    }

    /**
     * @param string $language
     * @return string
     */
    public function getMenuText($language)
    {
        return $this->getLang('menu');
    }

    /* ----------------------------------------------------------------- *
     *  Dispatch
     * ----------------------------------------------------------------- */

    /** @var array|null per-section preview results: [section => [files, ipLines]] */
    protected $preview = null;

    /** @var array|null per-section scrub results: [section => [files, ipLines, errors]] */
    protected $scrub = null;

    /**
     * Process form submissions (preview and scrub actions).
     *
     * @return void
     */
    public function handle()
    {
        global $INPUT;

        if (!$INPUT->has('hideip_action')) return;
        if (!checkSecurityToken()) return;

        $action = $INPUT->str('hideip_action');
        if ($action !== 'preview' && $action !== 'scrub') return;

        if ($action === 'scrub' && $INPUT->server->str('REQUEST_METHOD', 'GET') !== 'POST') {
            msg('Hide IP: scrub must be submitted via POST.', -1);
            return;
        }

        if ($action === 'preview') {
            $this->preview = $this->runScan(false);
        } else {
            // Defense-in-depth admin re-check (framework already gates via
            // forAdminOnly + isAccessibleByCurrentUser, but the scrub mutates
            // production data; one more check is cheap).
            if (!auth_isadmin()) {
                msg('Hide IP: admin access required.', -1);
                return;
            }
            $this->scrub = $this->runScan(true);
        }
    }

    /**
     * Render the admin page.
     *
     * @return void
     */
    public function html()
    {
        echo '<h1>Hide IP</h1>';
        echo '<p>This page rewrites historical IP addresses on disk to '
            . '<code>' . hsc(self::PLACEHOLDER_IP) . '</code>.<br>New edits are already '
            . 'anonymised by the action component of this plugin (loads on every request).<br>'
            . 'Timestamps and authorship are preserved.</p>';

        echo '<p style="background:#fff3cd; border:1px solid #ffeeba; padding:8px; border-radius:4px;">'
            . '<strong>This action is destructive.</strong><br>Real IP addresses recorded in '
            . 'page and media changelogs and in page metadata will be replaced and cannot '
            . 'be recovered from these files.<br>The <code>data/attic/</code> revision archives are '
            . 'not modified — if your wiki retains those, IPs from saved revisions remain '
            . 'inside them.<br>Take a backup with the Site Backup plugin first if you want '
            . 'a recovery point.'
            . '</p>';

        $this->renderForm();

        if ($this->preview !== null) {
            $this->renderResults('Preview', $this->preview, false);
        }
        if ($this->scrub !== null) {
            $this->renderResults('Scrub complete', $this->scrub, true);
        }
    }

    /* ----------------------------------------------------------------- *
     *  Form
     * ----------------------------------------------------------------- */

    /**
     * Render the preview/scrub action form.
     *
     * @return void
     */
    protected function renderForm()
    {
        $form = new Form(['method' => 'POST', 'id' => 'hideip_form']);
        $form->setHiddenField('do', 'admin');
        $form->setHiddenField('page', 'hideip');

        $form->addTagOpen('p');
        $form->addButton('hideip_action', 'Preview (count only)')->val('preview');
        $form->addHTML(' &nbsp;&nbsp; ');
        $form->addButton('hideip_action', 'Scrub now')->val('scrub');
        $form->addTagClose('p');

        echo $form->toHTML();
    }

    /* ----------------------------------------------------------------- *
     *  Scan/scrub orchestrator
     * ----------------------------------------------------------------- */

    /**
     * Walk all target files and either count IP-bearing entries or rewrite them.
     *
     * @param bool $mutate  false = preview only, true = rewrite on disk
     * @return array[]      [section_label => [files, lines, errors]]
     */
    protected function runScan($mutate)
    {
        global $conf;

        if (function_exists('set_time_limit')) set_time_limit(0);
        if (function_exists('ignore_user_abort')) ignore_user_abort(true);

        $sections = [
            'Page changelogs (data/meta/*.changes)' => [
                'root' => $conf['metadir'],
                'kind' => 'changes',
            ],
            'Media changelogs (data/media_meta/*.changes)' => [
                'root' => $conf['mediametadir'],
                'kind' => 'changes',
            ],
            'Page metadata (data/meta/*.meta)' => [
                'root' => $conf['metadir'],
                'kind' => 'meta',
            ],
        ];

        $results = [];
        foreach ($sections as $label => $cfg) {
            $results[$label] = $this->walkSection($cfg['root'], $cfg['kind'], $mutate);
        }
        return $results;
    }

    /**
     * Walk one section root, dispatching each candidate file to the right scrubber.
     *
     * @return array{files:int,lines:int,errors:array}
     */
    protected function walkSection($root, $kind, $mutate)
    {
        $stats = ['files' => 0, 'lines' => 0, 'errors' => []];

        if (!is_dir($root)) return $stats;

        try {
            $it = new RecursiveIteratorIterator(
                new RecursiveDirectoryIterator(
                    $root,
                    FilesystemIterator::SKIP_DOTS | FilesystemIterator::UNIX_PATHS
                ),
                RecursiveIteratorIterator::LEAVES_ONLY
            );
        } catch (Exception $e) {
            $stats['errors'][] = $root . ': ' . $e->getMessage();
            return $stats;
        }

        foreach ($it as $info) {
            try {
                if (!$info->isFile() || !$info->isReadable()) continue;
                $path = $info->getPathname();
                $base = basename($path);

                // Filter by extension matching the section we're walking.
                if ($kind === 'changes' && !str_ends_with($base, '.changes')) continue;
                if ($kind === 'meta'    && !str_ends_with($base, '.meta'))    continue;

                $count = ($kind === 'changes')
                    ? $this->processChangelog($path, $mutate)
                    : $this->processMetaFile($path, $mutate);

                if ($count > 0) {
                    $stats['files']++;
                    $stats['lines'] += $count;
                }
            } catch (Exception $e) {
                $stats['errors'][] = ($path ?? '?') . ': ' . $e->getMessage();
            }
        }
        return $stats;
    }

    /* ----------------------------------------------------------------- *
     *  Changelog (.changes) scrubber — TSV format
     * ----------------------------------------------------------------- */

    /**
     * Process one .changes file.
     *
     * Line format (DokuWiki convention, tab-separated):
     *   timestamp \t ip \t type \t pageid \t user \t summary \t extra \t sizechange \n
     *
     * The IP field is field index 1. We rewrite it to PLACEHOLDER_IP unless it
     * already equals the placeholder (idempotent) or is empty (already scrubbed
     * by an older tool like the GDPR plugin which blanked it).
     *
     * @param string $path
     * @param bool   $mutate  false = count lines that would change, true = rewrite
     * @return int            number of lines counted/changed
     */
    protected function processChangelog($path, $mutate)
    {
        $content = file_get_contents($path);
        if ($content === false) {
            throw new RuntimeException('cannot read');
        }

        // Use \n split so we can rejoin without modification. Trailing newline
        // (if any) becomes an empty final element we filter when rebuilding.
        $lines = explode("\n", $content);
        $hadTrailingNewline = ($content !== '' && substr($content, -1) === "\n");
        if ($hadTrailingNewline) array_pop($lines);   // drop the empty tail

        $changed = 0;
        foreach ($lines as $i => $line) {
            if ($line === '') continue;                 // skip blank lines in-place
            $fields = explode("\t", $line);
            if (count($fields) < 2) continue;           // malformed; leave alone

            $ip = $fields[1];
            if ($ip === self::PLACEHOLDER_IP) continue; // already scrubbed
            if (trim($ip) === '') continue;             // already blanked (GDPR-style)

            $fields[1] = self::PLACEHOLDER_IP;
            $lines[$i] = implode("\t", $fields);
            $changed++;
        }

        if ($changed === 0) return 0;
        if (!$mutate)       return $changed;

        $newContent = implode("\n", $lines);
        if ($hadTrailingNewline) $newContent .= "\n";

        $this->atomicWrite($path, $newContent);
        return $changed;
    }

    /* ----------------------------------------------------------------- *
     *  Page metadata (.meta) scrubber — PHP serialize format
     * ----------------------------------------------------------------- */

    /**
     * Process one .meta file.
     *
     * .meta is a serialize()d ['current' => [...], 'persistent' => [...]]
     * structure (see inc/parserutils.php::p_save_metadata). The IP can live
     * under last_change.ip in either branch.
     *
     * @param string $path
     * @param bool   $mutate
     * @return int   number of ip slots changed (0..2 per file)
     */
    protected function processMetaFile($path, $mutate)
    {
        $raw = file_get_contents($path);
        if ($raw === false) throw new RuntimeException('cannot read');
        if ($raw === '')    return 0;

        $meta = unserialize($raw, ['allowed_classes' => false]);
        if (!is_array($meta)) return 0;   // corrupt or non-meta - leave alone

        $changed = 0;
        foreach (['current', 'persistent'] as $branch) {
            if (
                isset($meta[$branch]['last_change']['ip'])
                && $meta[$branch]['last_change']['ip'] !== self::PLACEHOLDER_IP
            ) {
                $meta[$branch]['last_change']['ip'] = self::PLACEHOLDER_IP;
                $changed++;
            }
        }

        if ($changed === 0) return 0;
        if (!$mutate)       return $changed;

        $this->atomicWrite($path, serialize($meta));
        return $changed;
    }

    /* ----------------------------------------------------------------- *
     *  Safe write helper
     * ----------------------------------------------------------------- */

    /**
     * Write $content to $path atomically, preserving the original mtime.
     *
     * @throws RuntimeException on any unrecoverable failure
     */
    protected function atomicWrite($path, $content)
    {
        $origMtime = filemtime($path);
        $tmp = $path . '.hideip_tmp_' . bin2hex(random_bytes(self::TMP_SUFFIX_BYTES));

        $ok = file_put_contents($tmp, $content, LOCK_EX);
        if ($ok === false) {
            @unlink($tmp);
            throw new RuntimeException('failed to write temp file');
        }

        // Copy permissions from the original so the rename doesn't change them.
        $origPerms = fileperms($path);
        if ($origPerms !== false) chmod($tmp, $origPerms & 0777);

        if (!rename($tmp, $path)) {
            @unlink($tmp);
            throw new RuntimeException('atomic rename failed');
        }

        if ($origMtime !== false) touch($path, $origMtime);
    }

    /* ----------------------------------------------------------------- *
     *  Presentation
     * ----------------------------------------------------------------- */

    /**
     * Render the results table for a preview or scrub run.
     *
     * @param string  $heading
     * @param array[] $results   [section_label => [files, lines, errors]]
     * @param bool    $wasScrub
     * @return void
     */
    protected function renderResults($heading, array $results, $wasScrub)
    {
        echo '<h2>' . hsc($heading) . '</h2>';

        $totalFiles = 0;
        $totalLines = 0;
        $totalErrors = 0;
        foreach ($results as $stats) {
            $totalFiles  += $stats['files'];
            $totalLines  += $stats['lines'];
            $totalErrors += count($stats['errors']);
        }

        if ($wasScrub) {
            echo '<p><strong>Done.</strong> Rewrote ' . (int)$totalLines
                . ' IP slot(s) across ' . (int)$totalFiles . ' file(s).</p>';
        } else {
            echo '<p>Would rewrite ' . (int)$totalLines . ' IP slot(s) across '
                . (int)$totalFiles . ' file(s).</p>';
        }

        echo '<table class="inline"><thead><tr>'
            . '<th>Section</th>'
            . '<th>Files affected</th>'
            . '<th>IP slots ' . ($wasScrub ? 'rewritten' : 'to rewrite') . '</th>'
            . '<th>Errors</th>'
            . '</tr></thead><tbody>';
        foreach ($results as $label => $stats) {
            echo '<tr>'
                . '<td>' . hsc($label) . '</td>'
                . '<td style="text-align:right;">' . (int)$stats['files'] . '</td>'
                . '<td style="text-align:right;">' . (int)$stats['lines'] . '</td>'
                . '<td style="text-align:right;">' . count($stats['errors']) . '</td>'
                . '</tr>';
        }
        echo '</tbody></table>';

        if ($totalErrors > 0) {
            echo '<h3>Errors</h3><ul>';
            foreach ($results as $stats) {
                foreach ($stats['errors'] as $err) {
                    echo '<li><code>' . hsc($err) . '</code></li>';
                }
            }
            echo '</ul>';
        }
    }
}