�PNG  IHDR22?�� pHYs  �� OiCCPPhotoshop ICC profilexڝSgTS�=���BK���KoR RB���&*! J�!��Q�EEȠ�����Q, � ��!���������{�kּ������>���� �H3Q5� �B�������.@� $p�d!s�#�~<<+"��x� �M��0���B�\���t�8K�@z�B�@F���&S�`�cb�P-`'������{[�!�� e�Dh;��V�EX0fK�9�-0IWfH���� � 0Q��){`�##x��F�W<�+��*x��<�$9E�[-qWW.(�I+6aa�@.�y�2�4���������x����6��_-��"bb���ϫp@�t~��,/��;�m��%�h^ �u��f�@����W�p�~<�5�j>{�-�]c�K'Xt����o��(�h���w��?�G�%�fI�q^D$.Tʳ?�D��*�A��,���� �`6�B$��BB d�r`)��B(�Ͱ*`/�@4�Qh��p.�U�=p�a��(�� A�a!ڈb�X#����!�H�$ ɈQ"K�5H1R�T UH�=r9�\F��;�2����G1���Q=� �C��7�F� �dt1�����r�=�6��Ыhڏ>C�0��3�l0.��B�8, �c˱"� ���V����cϱw�E� 6wB aAHXLXN�H� $4� 7 �Q�'"��K�&���b21�XH,#��/{�C�7$�C2'��I��T��F�nR#�,��4H#���dk�9�, +ȅ����3��!�[ �b@q��S�(R�jJ��4�e�2AU��Rݨ�T5�ZB���R�Q��4u�9̓IK�����hh�i��t�ݕN��W���G���w ��Ljg(�gw��L�Ӌ�T071���oUX*�*|�� �J�&�*/T����ު U�U�T��^S}�FU3S� Ԗ�U��P�SSg�;���g�oT?�~Y��Y�L�OC�Q��_�� c�x,!k ��u�5�&���|v*�����=���9C3J3W�R�f?�q��tN �(���~���)�)�4L�1e\k����X�H�Q�G�6������E�Y��A�J'\'Gg����S�Sݧ �M=:��.�k���Dw�n��^��Lo��y���}/�T�m���G X� $� �<�5qo</���QC]�@C�a�a�ᄑ��<��F�F�i�\�$�m�mƣ&&!&KM�M�RM��)�;L;L���͢�֙5�=1�2��כ߷`ZxZ,����eI��Z�Yn�Z9Y�XUZ]�F���%ֻ�����N�N���gð�ɶ�����ۮ�m�}agbg�Ů��}�}��= ���Z~s�r:V:ޚΜ�?}����/gX���3��)�i�S��Ggg�s�󈋉K��.�>.���Ƚ�Jt�q]�z���������ۯ�6�i�ܟ�4�)�Y3s���C�Q��? ��0k߬~OCO�g��#/c/�W�װ��w��a�>�>r��>�<7�2�Y_�7��ȷ�O�o�_��C#�d�z����%g��A�[��z|!��?:�e����A���AA�������!h�쐭!��Α�i�P~���a�a��~ '���W�?�p�X�1�5w��Cs�D�D�Dޛg1O9�-J5*>�.j<�7�4�?�.fY��X�XIlK9.*�6nl������� �{�/�]py�����.,:�@L�N8��A*��%�w%� y��g"/�6ш�C\*N�H*Mz�쑼5y$�3�,幄'���L Lݛ:��v m2=:�1����qB�!M��g�g�fvˬe����n��/��k���Y- �B��TZ(�*�geWf�͉�9���+��̳�ې7�����ᒶ��KW-X潬j9�������(�x��oʿ�ܔ���Ĺd�f�f���-�[����n �ڴ �V����E�/��(ۻ��C���<��e����;?T�T�T�T6��ݵa��n��{��4���[���>ɾ�UUM�f�e�I���?�������m]�Nmq����#�׹���=TR��+�G�����w- 6 U����#pDy��� �� :�v�{���vg/jB��F�S��[b[�O�>����z�G��499�?r����C�d�&����ˮ/~�����јѡ�򗓿m|������������x31^�V���w�w��O�| (�h���SЧ��������c3-� cHRMz%������u0�`:�o�_�F5IDATx��ytUս�?�;���fN$$��@B�!�k��� -*�gE���j�O�kQ�ʠ`U�B_ �AÐ0%�Ȕ�@r3ޛ;߳��$�@��v����^�s����������$��ߢ !�W��5�̱'-٘������4�>�Rƫ$�G��0U�H}�_ _� #��k�MJ/=�9Du *ڲ�k�PQ;0��j|�*�$�^컂脛y���>�z×� B��� ��(�:$�ʔ_�6��C!B����MVx��a��ζyY����j��ƋY2�9�F�{r��r�딟F��Q��hY6��� x��[l��RC��������nt@��;P��3��� F�w��7��:�P���ɋ'���mj���Bƪ�$�Q�L��y��߷g��\���z����v5�p�v$�v櫻�`6~K �Y�X����,�:��"�o�e0II"(��,������l_�C���/4�+f�E�!q��:����u����c��樼.UE�@� �]K�W���$-�h]�JG���Dz)�`��.�A/ ���mᏣc�3jK� �!�>���$�Q�!�_�? \�C2(E �M$Z I{�U���s�ǣ���=��@Բe ޻��W�����@ �w����}�9v,)��.}*|"�s��di���,���G�]W�AC�������|<����[��ߕ������K�*�G nߴ!��‹��J�!��6(L�a)��Am��������;adf��:�xm��nh�;֦I��(���o�C~ډa?�=��s����h��E������xp����)���_���t��W�����´;8���`dz=(��@@�+,�;�`�fhl��XȌ�3,uI�~z(J����� �ZX�A����H'�À�㜦�82|��a�n�z2��I���� ���EY�h�ε<�0�q�{��C��v�˅��?"@��χ�x�WS+��N�~�KQ�J�8ل�� _.W��� !TU{�����,��"�� �;�������HI S� ��))�o�1�H�D� ���� (� ;����"Ҕ��,���� �F=���O��&�Ph>�`���y��߲ &S��P�<��'��1s�1cĂ�N����2)����@�u��tv��<�+�-&�����h��[!FSG���' � z z0��<����8d&�����E0�,��<��"!P�b4��� �{S�����X����.�囤���T��hEF��X�q0"-<����h���]�Py*����F⩍��@v�˂�Y08�� .q��a��s����(!<̫1�3�L�H��7sYW�`��qtu�\7��?�@�Y�� %Ka�x�GZ�*W�P��y�����N0r9��Z�c�%���q,��k�����!!,��>���IB��� �x1�Xu�Y���v-���ֺ��N������JP��a�2`�e5��w��u;�6�i���̃��(K���ťa��(l51��JL��O'%���]���ٖ뿉!��{*�p+f ���i8��D�ȑ���ܩ�M��V��ӟz��x�7Z�1i}�^͜���6e����x��)u�d�ˏ�V�eG�\�X1�����=n�U'�~Y����L�\,�(d!x ,�:�TW8� M`r���@��r+v�Q0��>^;˴�VbF��('����� �*O��i��j�Ӆ����^�S3&� ���{������.ی�� N;��NU%d0�Ce\r"�C�b��&t7N�7��� �ȪD�[%l�۪�$��'m?�A9tI�9>��NVL ��� 6v~M�����ъ�B���0����9$&=ώm��W�0���L���&��E���f�f��'+�9��hv��7,���M��6�D�&�^� �����8 D֮�����o��k^z��O��hP�8q�5d*��YVq3�{��������#LX4�?��jP=3�~�؅c�ݰ�̱�ұ��8̲��2�G�����j��έ�9��w7���U�X�w�85C��?!I&���o&����L���I#�^�eV�,�^t5�k� �xs˛\��U�8��."���{���ǵ�l4��ݼ�;��r"���G�/~���gJV�N糦��ZZ^k+NN�D��I$�=OE�z����|*�*{��%k���G��>�`9��b;�s���8,�qs��c��.b��q�%�>r��n�R�Ƨ�%�,�A��le#�8���}; 21�0�b�&�QX�f���q�00����$>�h�N�'�a3��A���/�r ��L5�8�GԲ'�����w;��c#�q1���h$*��V^�k��QĽ�b:i������� ����H F#�_���,��]g����Ը����`RUU���� ��"�qD���>-��ϤI�~��3�̴�����NZ[[555�eeek7�m����YF#[��Đ��R��i��L�H�r ��@��J-�Pŝ��_|�-��6y��ks�V�U~��6���w.����(��0A� 4��f��� /���C�xŊ�ٳ����z=6�����rg���mKo��o�/����a�g���?'9%9��P��斓��~���L{�� �H��{AW��B��$����v�1b�&Mb�ر��ر#�0`�`xMBp! )Z�Nmo�mZ�g�}�eذaWTVV ���'99��C5��&�&+5�bT>|8��PUUETT����&���t��~TE%��'������b�tEGG;RSS�S�N�v��ѯ��t����u1@�ޚ"f��͈���r'L�Ph��m��ƌ�74o��`�x�q�P���NRSS�X,�����l&&&��MFFA!-��`��ҷ�n��Yuu�����x<I�LB%����KԒ50�!�3�bz�����ʸKL���;---�l6[��`��������Ȏ;�����egg4��!D�T��jWujyZ��������K����%����p�^���X,6��sV=�ܖ����6�3�X ���4ҿ��A2�&����_k�;d�� �VfOIEND�B`� 0x0x
0x0x
PHP 8.1.34
Preview: MemoryBlockStorage.php Size: 17.09 KB
/home2/astrociv/www/avadhutholidays.in/wp-content/plugins/imunify-security/inc/App/Bot/MemoryBlockStorage.php
<?php
/**
 * Copyright (с) Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2025 All Rights Reserved
 *
 * Licensed under CLOUD LINUX LICENSE AGREEMENT
 * https://www.cloudlinux.com/legal/
 */

namespace CloudLinux\Imunify\App\Bot;

/**
 * InnoDB + MEMORY dual-write block storage backed by WordPress `$wpdb`.
 *
 * Block records are written to both an InnoDB table (durable, survives restarts)
 * and a MEMORY-engine table (fast per-request lookup). Violation counters live
 * exclusively in InnoDB so they survive MariaDB/MySQL restarts.
 *
 * On first request, `isBlocked()` queries only the MEMORY table. If the IP is
 * not found AND the active table has not yet been repopulated this request,
 * the MEMORY table is rebuilt from InnoDB and the query is retried. This
 * handles both cold starts (MariaDB restart wiped MEMORY data) and the
 * first request after a plugin activation.
 *
 * Schema creation is lazy: each exec helper creates the relevant table(s) on
 * the first "doesn't exist" error and retries the original query once. A flag
 * prevents infinite retry loops.
 *
 * All methods are fail-open: errors return safe defaults (false / 0 / no-op)
 * rather than throwing, so a DB hiccup never takes down the plugin.
 *
 * @since 4.0.0
 */
class MemoryBlockStorage implements BlockStorageInterface {

	use DbErrorDetection;

	/**
	 * Session max_heap_table_size set before creating the MEMORY table (4 MB).
	 */
	const MAX_HEAP_TABLE_SIZE = 4194304;

	/**
	 * WordPress database handle.
	 *
	 * @var object
	 */
	private $wpdb;

	/**
	 * Full InnoDB blocks table name (with WP prefix).
	 *
	 * @var string
	 */
	private $blocks_table;

	/**
	 * Full MEMORY active-blocks table name (with WP prefix).
	 *
	 * @var string
	 */
	private $active_table;

	/**
	 * Full InnoDB violations table name (with WP prefix).
	 *
	 * @var string
	 */
	private $violations_table;

	/**
	 * Prevents multiple CREATE TABLE attempts for blocks/active per request.
	 *
	 * @var bool
	 */
	private $blocks_schema_init = false;

	/**
	 * Prevents multiple CREATE TABLE attempts for violations per request.
	 *
	 * @var bool
	 */
	private $violations_schema_init = false;

	/**
	 * Whether the MEMORY active table has been repopulated this request.
	 *
	 * @var bool
	 */
	private $repopulated = false;

	/**
	 * Wrap a WordPress database handle.
	 *
	 * @param object $wpdb Connected WordPress $wpdb instance.
	 */
	public function __construct( $wpdb ) {
		$this->wpdb             = $wpdb;
		$this->blocks_table     = $wpdb->prefix . 'imunify_bot_blocks';
		$this->active_table     = $wpdb->prefix . 'imunify_bot_blocks_active';
		$this->violations_table = $wpdb->prefix . 'imunify_bot_violations';
	}

	/**
	 * {@inheritdoc}
	 */
	public function isBlocked( $ip_key, $site_id ) {
		$result = $this->queryActiveTable( $ip_key, $site_id );

		if ( true === $result ) {
			return true;
		}

		// Table missing → DB restart wiped the MEMORY table. Recreate
		// schema, repopulate from InnoDB, and retry. Only attempt once
		// per request to avoid infinite loops.
		if ( 'missing' === $result && ! $this->repopulated ) {
			$this->repopulated = true;
			$suppress          = $this->wpdb->suppress_errors( true );
			if ( ! $this->blocks_schema_init ) {
				$this->blocks_schema_init = true;
				$this->createBlocksTable();
				$this->createActiveTable();
			}
			$this->repopulateActiveTable();
			$this->wpdb->suppress_errors( $suppress );
			return true === $this->queryActiveTable( $ip_key, $site_id );
		}

		// IP not in the MEMORY table but table exists → not blocked.
		return false;
	}

	/**
	 * {@inheritdoc}
	 */
	public function writeBlock( $ip_key, $site_id, $category, $preset, $ttl_seconds ) {
		$now     = time();
		$expires = $now + (int) $ttl_seconds;

		// Dual-write: InnoDB first, then MEMORY.
		$this->execBlocks( $this->prepareBlockUpsert( $this->blocks_table, $ip_key, $site_id, $category, $preset, $now, $expires ) );
		$this->execBlocks( $this->prepareBlockUpsert( $this->active_table, $ip_key, $site_id, $category, $preset, $now, $expires ) );
	}

	/**
	 * {@inheritdoc}
	 */
	public function incrementViolation( $key, $ttl_seconds ) {
		$now            = time();
		$expires        = $now + (int) $ttl_seconds;
		$violations_tbl = $this->violations_table;

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$insert_sql = $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"INSERT INTO `{$violations_tbl}` (`viol_key`, `counter`, `expires_at`) VALUES (%s, 1, %d)"
			. ' ON DUPLICATE KEY UPDATE `counter` = IF(`expires_at` > %d, `counter` + 1, 1), `expires_at` = IF(`expires_at` > %d, `expires_at`, %d)',
			$key,
			$expires,
			$now,
			$now,
			$expires
		);

		$result = $this->execViolations( $insert_sql );
		if ( false === $result ) {
			return 0;
		}

		return $this->getViolationCountAt( $key, $now );
	}

	/**
	 * {@inheritdoc}
	 */
	public function getViolationCount( $key ) {
		return $this->getViolationCountAt( $key, time() );
	}

	/**
	 * Read the violation counter using a fixed timestamp.
	 *
	 * Shared by getViolationCount() and incrementViolation() so the
	 * INSERT and SELECT use the same $now — avoids a TOCTOU window.
	 *
	 * @param string $key Counter key.
	 * @param int    $now Unix timestamp for the expiry check.
	 * @return int Current value, or 0 when missing/expired.
	 */
	private function getViolationCountAt( $key, $now ) {
		$violations_tbl = $this->violations_table;

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$sql = $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"SELECT `counter` FROM `{$violations_tbl}` WHERE `viol_key` = %s AND `expires_at` > %d",
			$key,
			$now
		);
		$suppress = $this->wpdb->suppress_errors( true );
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$value = $this->wpdb->get_var( $sql );
		$this->wpdb->suppress_errors( $suppress );
		return null !== $value ? (int) $value : 0;
	}

	/**
	 * {@inheritdoc}
	 *
	 * Deletes expired rows from InnoDB tables, then rebuilds the MEMORY
	 * active table to reclaim space (DROP + CREATE + repopulate).
	 */
	public function cleanup() {
		$blocks_tbl     = $this->blocks_table;
		$active_tbl     = $this->active_table;
		$violations_tbl = $this->violations_table;
		$now            = time();

		$suppress = $this->wpdb->suppress_errors( true );

		// LIMIT 0 resolves the table reference without touching rows; ob buffering
		// stops mysqli output from reaching error handlers that throw on E_WARNING.
		ob_start();
		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
		$this->wpdb->query( "SELECT 1 FROM `{$blocks_tbl}` LIMIT 0" );
		ob_end_clean();

		if ( $this->isTableMissing() ) {
			$this->wpdb->suppress_errors( $suppress );
			return;
		}

		// Delete expired InnoDB blocks.
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$sql = $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"DELETE FROM `{$blocks_tbl}` WHERE `expires_at` <= %d",
			$now
		);
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$this->wpdb->query( $sql );

		// Reclaim MEMORY space: DROP + CREATE + repopulate.
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
		$this->wpdb->query( "DROP TABLE IF EXISTS `{$active_tbl}`" );
		$this->createActiveTable();
		$this->repopulateActiveTable();

		// Delete expired violations.
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$viol_sql = $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"DELETE FROM `{$violations_tbl}` WHERE `expires_at` <= %d",
			$now
		);
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$this->wpdb->query( $viol_sql );

		$this->wpdb->suppress_errors( $suppress );
	}

	/**
	 * {@inheritdoc}
	 */
	public function name() {
		return 'db';
	}

	// -------------------------------------------------------------------------
	// Private helpers
	// -------------------------------------------------------------------------

	/**
	 * Build a prepared UPSERT statement for a blocks table.
	 *
	 * @param string $table    Full table name (with WP prefix).
	 * @param string $ip_key   Normalised IP key.
	 * @param string $site_id  Site scope identifier.
	 * @param string $category Bot category.
	 * @param string $preset   Active preset name.
	 * @param int    $now      Current Unix timestamp.
	 * @param int    $expires  Expiry Unix timestamp.
	 * @return string Prepared SQL.
	 */
	private function prepareBlockUpsert( $table, $ip_key, $site_id, $category, $preset, $now, $expires ) {
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		return $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"INSERT INTO `{$table}` (`ip_key`, `site_id`, `category`, `preset`, `blocked_at`, `expires_at`)"
			. ' VALUES (%s, %s, %s, %s, %d, %d)'
			. ' ON DUPLICATE KEY UPDATE `category` = %s, `preset` = %s, `blocked_at` = %d, `expires_at` = %d',
			$ip_key,
			$site_id,
			$category,
			$preset,
			$now,
			$expires,
			$category,
			$preset,
			$now,
			$expires
		);
	}

	/**
	 * Query the MEMORY active table for a live block record.
	 *
	 * @param string $ip_key  Normalised IP key.
	 * @param string $site_id Site scope identifier.
	 * @return true|false|'missing'  true = blocked, false = not found, 'missing' = table absent.
	 */
	private function queryActiveTable( $ip_key, $site_id ) {
		$active_tbl = $this->active_table;
		$now        = time();

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$sql = $this->wpdb->prepare(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			"SELECT 1 AS `found` FROM `{$active_tbl}` WHERE `ip_key` = %s AND `site_id` = %s AND `expires_at` > %d LIMIT 1",
			$ip_key,
			$site_id,
			$now
		);
		$suppress = $this->wpdb->suppress_errors( true );
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$value = $this->wpdb->get_var( $sql );
		$this->wpdb->suppress_errors( $suppress );

		if ( null !== $value ) {
			return true;
		}

		if ( $this->isTableMissing() ) {
			return 'missing';
		}

		return false;
	}

	/**
	 * Rebuild the MEMORY active table from the durable InnoDB blocks table.
	 *
	 * Only active (non-expired) rows are copied.
	 *
	 * @return void
	 */
	private function repopulateActiveTable() {
		$blocks_tbl = $this->blocks_table;
		$active_tbl = $this->active_table;
		$now        = time();

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$sql = $this->wpdb->prepare(
			'INSERT IGNORE INTO `' . $active_tbl . '` (`ip_key`, `site_id`, `category`, `preset`, `blocked_at`, `expires_at`)' // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
			. ' SELECT `ip_key`, `site_id`, `category`, `preset`, `blocked_at`, `expires_at`'
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
			. " FROM `{$blocks_tbl}` WHERE `expires_at` > %d",
			$now
		);
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$this->wpdb->query( $sql );
	}

	/**
	 * Execute a write query against the blocks/active tables with lazy schema init.
	 *
	 * If the query fails because either blocks table is missing and we haven't
	 * tried creating them yet, both tables are created and the query is retried.
	 *
	 * @param string $sql Prepared SQL string.
	 * @return int|false Number of affected rows, or false on failure.
	 */
	private function execBlocks( $sql ) {
		$suppress = $this->wpdb->suppress_errors( true );
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$result = $this->wpdb->query( $sql );
		if ( false === $result && ! $this->blocks_schema_init ) {
			if ( $this->isTableMissing() ) {
				$this->blocks_schema_init = true;
				$this->createBlocksTable();
				$this->createActiveTable();
				// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
				$result = $this->wpdb->query( $sql );
			} elseif ( $this->isTableFull() && false !== strpos( $sql, $this->active_table ) ) {
				// MEMORY engine: DELETE does not reclaim space — only
				// DROP + CREATE frees the memory (see MySQL docs).
				// Only rebuild when the MEMORY active table is full —
				// an InnoDB "table full" (disk) is not recoverable here.
				$this->blocks_schema_init = true;
				StorageEventBuffer::record(
					'MEMORY table full: imunify_bot_blocks_active — rebuilt from InnoDB',
					'bot_table_full_blocks_active',
					array( 'bot_storage_table_full', 'imunify_bot_blocks_active' )
				);
				$active_tbl = $this->active_table;
				// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
				$this->wpdb->query( "DROP TABLE IF EXISTS `{$active_tbl}`" );
				$this->createActiveTable();
				$this->repopulateActiveTable();
				// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
				$result = $this->wpdb->query( $sql );
			}
		}
		$this->wpdb->suppress_errors( $suppress );
		return $result;
	}

	/**
	 * Execute a write query against the violations table with lazy schema init.
	 *
	 * @param string $sql Prepared SQL string.
	 * @return int|false Number of affected rows, or false on failure.
	 */
	private function execViolations( $sql ) {
		$suppress = $this->wpdb->suppress_errors( true );
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$result = $this->wpdb->query( $sql );
		if ( false === $result && ! $this->violations_schema_init ) {
			if ( $this->isTableMissing() ) {
				$this->violations_schema_init = true;
				$this->createViolationsTable();
				// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
				$result = $this->wpdb->query( $sql );
			} elseif ( $this->isTableFull() ) {
				// InnoDB table full means disk/tablespace exhaustion —
				// not recoverable from the plugin. Record for Sentry so
				// ops can act; stop retrying this request.
				$this->violations_schema_init = true;
				StorageEventBuffer::record(
					'Violations table full (InnoDB) — violation tracking disabled until space is freed',
					'bot_violations_table_full',
					array( 'bot_storage_violations_full' ),
					array( 'table' => $this->violations_table )
				);
			}
		}
		$this->wpdb->suppress_errors( $suppress );
		return $result;
	}

	/**
	 * Create the durable InnoDB blocks table if it does not exist.
	 *
	 * All columns are ASCII-only (IPs, hex site-id, internal category/preset
	 * identifiers). ASCII charset avoids the 4-byte-per-char overhead of
	 * utf8mb4, which matters for the MEMORY-engine active table that shares
	 * the same schema.
	 *
	 * @return void
	 */
	private function createBlocksTable() {
		$table = $this->blocks_table;
		$sql   = 'CREATE TABLE IF NOT EXISTS `' . $table . '` ('
			. ' `ip_key`     VARCHAR(191) NOT NULL,'
			. ' `site_id`    CHAR(16) NOT NULL,'
			. ' `category`   VARCHAR(64) NOT NULL,'
			. ' `preset`     VARCHAR(32) NOT NULL,'
			. ' `blocked_at` BIGINT UNSIGNED NOT NULL,'
			. ' `expires_at` BIGINT UNSIGNED NOT NULL,'
			. ' PRIMARY KEY (`site_id`, `ip_key`),'
			. ' KEY `idx_expires` (`expires_at`)'
			. ') ENGINE=InnoDB DEFAULT CHARSET=ascii';
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$result = $this->wpdb->query( $sql );
		if ( false === $result ) {
			StorageEventBuffer::record(
				'Failed to create InnoDB table: ' . $table,
				'bot_create_table_failed_blocks',
				array( 'bot_storage_create_failed', 'imunify_bot_blocks' ),
				array( 'table' => $table )
			);
		}
	}

	/**
	 * Create the MEMORY active-blocks table if it does not exist.
	 *
	 * @return void
	 */
	private function createActiveTable() {
		$table = $this->active_table;
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared,WordPress.DB.DirectDatabaseQuery
		$this->wpdb->query( 'SET max_heap_table_size = ' . self::MAX_HEAP_TABLE_SIZE );
		$sql = 'CREATE TABLE IF NOT EXISTS `' . $table . '` ('
			. ' `ip_key`     VARCHAR(191) NOT NULL,'
			. ' `site_id`    CHAR(16) NOT NULL,'
			. ' `category`   VARCHAR(64) NOT NULL,'
			. ' `preset`     VARCHAR(32) NOT NULL,'
			. ' `blocked_at` BIGINT UNSIGNED NOT NULL,'
			. ' `expires_at` BIGINT UNSIGNED NOT NULL,'
			. ' PRIMARY KEY (`site_id`, `ip_key`)'
			. ') ENGINE=MEMORY DEFAULT CHARSET=ascii';
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$result = $this->wpdb->query( $sql );
		if ( false === $result ) {
			StorageEventBuffer::record(
				'Failed to create MEMORY table: ' . $table,
				'bot_create_table_failed_blocks_active',
				array( 'bot_storage_create_failed', 'imunify_bot_blocks_active' ),
				array( 'table' => $table )
			);
		}
	}

	/**
	 * Create the durable InnoDB violations table if it does not exist.
	 *
	 * @return void
	 */
	private function createViolationsTable() {
		$table = $this->violations_table;
		$sql   = 'CREATE TABLE IF NOT EXISTS `' . $table . '` ('
			. ' `viol_key`   VARCHAR(191) NOT NULL,'
			. ' `counter`    INT UNSIGNED NOT NULL DEFAULT 0,'
			. ' `expires_at` BIGINT UNSIGNED NOT NULL,'
			. ' PRIMARY KEY (`viol_key`),'
			. ' KEY `idx_expires` (`expires_at`)'
			. ') ENGINE=InnoDB DEFAULT CHARSET=ascii';
		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		$result = $this->wpdb->query( $sql );
		if ( false === $result ) {
			StorageEventBuffer::record(
				'Failed to create InnoDB table: ' . $table,
				'bot_create_table_failed_violations',
				array( 'bot_storage_create_failed', 'imunify_bot_violations' ),
				array( 'table' => $table )
			);
		}
	}
}

Directory Contents

Dirs: 1 × Files: 77
Name Size Perms Modified Actions
data DIR
- drwxr-xr-x 2026-11-03 01:06:32
Edit Download
AllowlistCheck.php
11.48 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
AllowlistMatch.php
2.43 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
AllowlistMatcher.php
1.47 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
AllowlistType.php
1.38 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
AtomicFileWriter.php
4.45 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BasePath.php
1.17 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BlockStorageInterface.php
2.01 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotDataConverter.php
21.21 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotIpStats.php
7.34 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotLifecycle.php
17.81 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotSettingsWriter.php
3.38 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotShimManager.php
2.79 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotStatsExporter.php
13.17 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotTrafficStats.php
8.77 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BotTrafficSummary.php
5.67 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
BundledData.php
14.53 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Category.php
4.25 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
CdnDetector.php
1.72 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
CidrMatcher.php
7.58 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Classification.php
1.55 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Classifier.php
14.00 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
CounterStorageInterface.php
1.58 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
DailyBotAggregator.php
5.99 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
DailyCounter.php
2.88 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
DatacenterDetector.php
1.41 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
DbErrorDetection.php
1.53 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
DbStorageFactory.php
2.61 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
HeaderAnomalyScorer.php
4.73 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Honeypot.php
7.49 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
HourlyIpStatsStorage.php
17.86 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
HourlyStatsStorage.php
14.97 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
HttpClient.php
1.47 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
HttpResponse.php
4.76 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
IpNormalizer.php
2.06 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
IpRangeLookup.php
5.26 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
IpWhitelist.php
5.64 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
LoopbackResult.php
2.68 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
LoopbackSafetyTest.php
10.47 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
LoopbackStatus.php
2.49 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MemoryBlockStorage.php
17.09 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MemoryCounterStorage.php
8.51 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MirrorDownloader.php
12.60 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MirrorDownloadResult.php
3.46 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MonitoringUaMatcher.php
835 B lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MonitoringUserAgents.php
1.71 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MuLoader.php
22.44 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MuPluginInstaller.php
5.65 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
MuPluginSelfHealer.php
7.33 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
NullBlockStorage.php
892 B lrw-r--r-- 2026-11-03 01:06:32
Edit Download
NullCounterStorage.php
924 B lrw-r--r-- 2026-11-03 01:06:32
Edit Download
OptOutFlag.php
4.69 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Pipeline.php
18.57 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Preset.php
6.92 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RateLimitDecision.php
3.87 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RateLimiter.php
7.94 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RdnsVerifier.php
18.17 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RealIpResolver.php
8.48 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RequestAllowlist.php
1.80 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
Responder.php
9.49 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RestNamespaceMatcher.php
2.84 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
RestRouteResolver.php
7.45 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SafeInclude.php
1.28 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SameServerMatcher.php
2.27 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SelfOriginDetector.php
9.90 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SignatureRefresher.php
15.82 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteAllowlist.php
20.41 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteAllowlistFile.php
7.79 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteAllowlistStore.php
5.61 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteAllowlistValidation.php
1.80 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteAllowlistValidator.php
30.46 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteOwnerMatcher.php
2.79 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
SiteScope.php
1.41 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
StorageEventBuffer.php
3.72 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
UserAgentSignatures.php
9.60 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
WooCommerceMatcher.php
5.05 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
WordPressInternalsMatcher.php
6.56 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
WpHttpClient.php
5.16 KB lrw-r--r-- 2026-11-03 01:06:32
Edit Download
If ZipArchive is unavailable, a .tar will be created (no compression).
© 2026 0xNothings — Secure File Manager. All rights reserved. Built with ❤️ & Tailwind x Dark UI