UpdateSteps.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Chatroom\Setup;

use ilDatabaseUpdateSteps;
use ilDBInterface;
use ilDBConstants;

class UpdateSteps implements ilDatabaseUpdateSteps
{
    protected ilDBInterface $db;

    public function prepare(ilDBInterface $db): void
    {
        $this->db = $db;
    }

    public function step_1(): void
    {
        $this->db->dropTable('chatroom_prooms', false);
        $this->db->dropTable('chatroom_proomaccess', false);
        $this->db->dropTable('chatroom_psessions', false);

        $this->dropColumnWhenExists('chatroom_history', 'sub_room');
        $this->dropColumnWhenExists('chatroom_settings', 'allow_private_rooms');
        $this->dropColumnWhenExists('chatroom_settings', 'private_rooms_enabled');
    }

    public function step_2(): void
    {
        $this->dropTableWhenExists('chatroom_smilies');
    }

    public function step_3(): void
    {
        $this->dropColumnWhenExists('chatroom_settings', 'restrict_history');
    }

    public function step_4(): void
    {
        $query = '
            UPDATE object_data
            INNER JOIN chatroom_settings ON object_data.obj_id = chatroom_settings.object_id
            SET object_data.offline = IF(chatroom_settings.online_status = 1, 0, 1)
            WHERE object_data.type = %s
        ';

        $this->db->manipulateF(
            $query,
            [ilDBConstants::T_TEXT],
            ['chtr']
        );
    }

    public function step_5(): void
    {
        $this->dropTableWhenExists('chatroom_uploads');
        $this->db->manipulate('DELETE FROM chatroom_bans WHERE user_id NOT IN (SELECT usr_id FROM usr_data)');
    }

    public function step_6(): void
    {
        $replace = [
            '&lt;' => '<',
            '&gt;' => '>',
            '&amp;' => '&',
            '&quot;' => '"',
        ];

        $s = 'JSON_VALUE(message, "$.content")';
        foreach ($replace as $from => $to) {
            $s = sprintf('REPLACE(%s, %s, %s)', $s, $this->db->quote($from, ilDBConstants::T_TEXT), $this->db->quote($to, ilDBConstants::T_TEXT));
        }

        $this->db->manipulate(
            'UPDATE chatroom_history SET message = JSON_SET(message, "$.content", ' . $s . ') ' .
            'WHERE JSON_VALID(message) = 1 AND JSON_VALUE(message, "$.type") = ' . $this->db->quote('message', ilDBConstants::T_TEXT)
        );
    }

    private function dropColumnWhenExists(string $table, string $column): void
    {
        if ($this->db->tableColumnExists($table, $column)) {
            $this->db->dropTableColumn($table, $column);
        }
    }

    private function dropTableWhenExists(string $table): void
    {
        if ($this->db->tableExists($table)) {
            $this->db->dropTable($table);
        }
    }
}