RecentlyUsed.php

<?php
namespace Bitrix\UI\Avatar\Mask;
 
use Bitrix\Main;
use Bitrix\Main\ORM;
use Bitrix\Main\ORM\Fields\DatetimeField;
use Bitrix\Main\ORM\Fields\IntegerField;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Fields\StringField;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\Type\DateTime;
use Bitrix\UI\Avatar;
 
class RecentlyUsedTable extends OrmDataManager
{
    public static function getTableName(): string
    {
        return 'b_ui_avatar_mask_recently_used';
    }
 
    public static function getMap(): array
    {
        return array(
            (new IntegerField('ID'))
                ->configurePrimary()
                ->configureAutocomplete(),
 
            (new IntegerField('ITEM_ID'))->configureRequired(),
            (new IntegerField('USER_ID', []))->configureRequired(),
 
            (new DatetimeField('TIMESTAMP_X'))
                ->configureDefaultValue(function() {
                    return new DateTime();
                }),
 
            (new Reference(
                'MASK',
                ItemTable::class,
                Join::on('this.ITEM_ID', 'ref.ID')
            ))->configureJoinType(Join::TYPE_INNER),
        );
    }
 
    public static function addFromUser($itemId, $userId)
    {
        $entity = static::getEntity();
        $sqlTableName = static::getTableName();
        $sqlHelper = $entity->getConnection()->getSqlHelper();
        $filter = ['ITEM_ID' => $itemId, 'USER_ID' => $userId];
 
        $where = Main\ORM\Query\Query::buildFilterSql($entity, $filter);
        if ($where !== '')
        {
            $sql = "DELETE FROM {$sqlHelper->quote($sqlTableName)} WHERE " . $where;
            $entity->getConnection()->queryExecute($sql);
        }
        static::add($filter);
        //Delete excessive data
        $counter = 10;
        $filter = ['=USER_ID' => $userId];
        $records = static::getList([
            'select' => ['ID'],
            'filter' => $filter,
            'limit' => $counter + 1,
            'order' => [
                'ID' => 'ASC'
            ]
        ])->fetchAll();
        if (count($records) > $counter)
        {
            $lastRecord = end($records);
            $filter['<ID'] = $lastRecord['ID'];
            $where = Main\ORM\Query\Query::buildFilterSql($entity, $filter);
            if ($where !== '')
            {
                $sql = "DELETE FROM {$sqlHelper->quote($sqlTableName)} WHERE " . $where;
                $entity->getConnection()->queryExecute($sql);
            }
        }
    }
}