pushtable.php

См. документацию.

<?php
namespace Bitrix\Pull\Model;
 
use Bitrix\Main;
use Bitrix\Main\Entity\Event;
use Bitrix\Main\Entity\FieldError;
use Bitrix\Main\Entity\Result;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Entity;
 

 
class PushTable extends Main\Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_pull_push';
    }

    public static function getMap()
    {
        return array(
            'ID' => array(
                'data_type' => 'integer',
                'primary' => true,
                'autocomplete' => true,
                //'title' => Loc::getMessage('PUSH_ENTITY_ID_FIELD'),
            ),
            'USER_ID' => array(
                'data_type' => 'integer',
                'required' => true,
                //'title' => Loc::getMessage('PUSH_ENTITY_USER_ID_FIELD'),
            ),
            'DEVICE_TYPE' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateDeviceType'),
                //'title' => Loc::getMessage('PUSH_ENTITY_DEVICE_TYPE_FIELD'),
            ),
            'APP_ID' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateAppId'),
                //'title' => Loc::getMessage('PUSH_ENTITY_APP_ID_FIELD'),
            ),
            'UNIQUE_HASH' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateUniqueHash'),
                //'title' => Loc::getMessage('PUSH_ENTITY_UNIQUE_HASH_FIELD'),
            ),
            'DEVICE_ID' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateDeviceId'),
                //'title' => Loc::getMessage('PUSH_ENTITY_DEVICE_ID_FIELD'),
            ),
            'DEVICE_NAME' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateDeviceName'),
                //'title' => Loc::getMessage('PUSH_ENTITY_DEVICE_NAME_FIELD'),
            ),
            'DEVICE_TOKEN' => array(
                'data_type' => 'string',
                'required' => false,
                'validation' => array(__CLASS__, 'validateDeviceToken'),
                //'title' => Loc::getMessage('PUSH_ENTITY_DEVICE_TOKEN_FIELD'),
            ),
            'VOIP_TYPE' => array(
                'data_type' => 'string',
            ),
            'VOIP_TOKEN' => array(
                'data_type' => 'string',
            ),
            'DATE_CREATE' => array(
                'data_type' => 'datetime',
                'required' => true,
                'default_value' => new \Bitrix\Main\Type\DateTime,
                //'title' => Loc::getMessage('PUSH_ENTITY_DATE_CREATE_FIELD'),
            ),
            'DATE_AUTH' => array(
                'data_type' => 'datetime',
                'default_value' => new \Bitrix\Main\Type\DateTime,
                //'title' => Loc::getMessage('PUSH_ENTITY_DATE_AUTH_FIELD'),
            ),
            'USER' => array(
                'data_type' => 'Bitrix\Main\User',
                'reference' => array('=this.USER_ID' => 'ref.ID'),
            ),
        );
    }

    public static function validateDeviceType()
    {
        return array(
            new Main\Entity\Validator\Length(null, 50),
        );
    }

    public static function validateAppId()
    {
        return array(
            new Main\Entity\Validator\Length(null, 50),
        );
    }

    public static function validateUniqueHash()
    {
        return array(
            new Main\Entity\Validator\Length(null, 50),
        );
    }

    public static function checkFields(Result $result, $primary, array $data)
    {
        parent::checkFields($result, $primary, $data);
        $pushManager = new \CPushManager();
        $availableDataTypes = array_keys($pushManager->getServices());
 
        if ($result instanceof Entity\AddResult)
        {
            $entity = self::getEntity();
            $tokensReceived = !empty($data["DEVICE_TOKEN"]) || !empty($data["VOIP_TOKEN"]);
            $checkToken = function($token) {
                return $token == null || preg_match('~^[a-f0-9]{64}$~i', $token);
            };
 
            if (!$data["DEVICE_TYPE"] || !in_array($data["DEVICE_TYPE"], $availableDataTypes))
            {
                $result->addError(new Entity\FieldError($entity->getField("DEVICE_TYPE"), "Wrong field value", FieldError::INVALID_VALUE));
            }
            if(!$tokensReceived)
            {
                $result->addError(new Entity\FieldError($entity->getField("DEVICE_TYPE"), "Tokens were not received", FieldError::INVALID_VALUE));
            }
 
            if ($data["DEVICE_TYPE"] == "APPLE")
            {
                if (!$checkToken($data["DEVICE_TOKEN"]) || !$checkToken($data["DEVICE_TOKEN_VOIP"]))
                    $result->addError(new Entity\FieldError($entity->getField("DEVICE_TYPE"), "Wrong format of token for iOS", FieldError::INVALID_VALUE));
            }
        }
    }
 
 
    public static function onBeforeAdd(Event $event)
    {
        $result = new Entity\EventResult;
        $data = $event->getParameter("fields");
 
        if(!isset($data["APP_ID"]))
        {
            $data["APP_ID"] = defined("MOBILEAPP_DEFAULT_APP_ID") ? MOBILEAPP_DEFAULT_APP_ID : "unknown";
        }
 
        if(!isset($data["DEVICE_NAME"]))
        {
            $data["DEVICE_NAME"] = $data["DEVICE_ID"];
        }
 
        $data["UNIQUE_HASH"] = \CPullPush::getUniqueHash($data["USER_ID"], $data["APP_ID"]);
        $data["DATE_AUTH"] = new Main\Type\DateTime();
        $result->modifyFields($data);
 
        return $result;
    }
 
    public static function onAfterAdd(Event $event)
    {
        parent::onAfterAdd($event);
        \CAgent::AddAgent("CPullPush::cleanTokens();", "pull", "N", 43200, "", "Y", ConvertTimeStamp(time() + \CTimeZone::GetOffset() + 30, "FULL"));
    }
 
 
    public static function onBeforeUpdate(Event $event)
    {
        parent::onBeforeUpdate($event);
 
        $result = new Entity\EventResult;
        $data = $event->getParameter("fields");
        $data["UNIQUE_HASH"] = \CPullPush::getUniqueHash($data["USER_ID"], $data["APP_ID"]);
        $data["DATE_AUTH"] = new Main\Type\DateTime();
        $result->modifyFields($data);
 
        return $result;
    }
 

    public static function validateDeviceId()
    {
        return array(
            new Main\Entity\Validator\Length(null, 255),
        );
    }

    public static function validateDeviceName()
    {
        return array(
            new Main\Entity\Validator\Length(null, 50),
        );
    }

    public static function validateDeviceToken()
    {
        return array(
            new Main\Entity\Validator\Length(null, 255),
        );
    }
}
 
class_alias("Bitrix\\Pull\\Model\\PushTable", "Bitrix\\Pull\\PushTable", false);