una/modules/boonex/notifications/classes/BxNtfsResponse.php

<?php defined('BX_DOL') or die('hack attempt');
/**
 * Copyright (c) UNA, Inc - https://una.io
 * MIT License - https://opensource.org/licenses/MIT
 *
 * @defgroup    Notifications Notifications
 * @ingroup     UnaModules
 *
 * @{
 */

class BxNtfsResponse extends BxBaseModNotificationsResponse
{
    public function __construct()
    {
        $this->_sModule = 'bx_notifications';

        parent::__construct();
    }

    /**
     * Overwritten method of parent class.
     *
     * @param BxDolAlerts $oAlert an instance of alert.
     */
    public function response($oAlert)
    {
        /**
         * @hooks
         * @hookdef hook-bx_notifications-before_register_alert 'bx_notifications', 'before_register_alert' - hook to override alert (hook) before processing
         * - $unit_name - equals `bx_notifications`
         * - $action - equals `before_register_alert`
         * - $object_id - not used
         * - $sender_id - not used
         * - $extra_params - array of additional params with the following array keys:
         *      - `unit` - [string] alert (hook) unit
         *      - `action` - [string] alert (hook) action
         *      - `alert` - [array] by ref, an instance of alert (hook), @see BxDolAlerts, can be overridden in hook processing        
         * @hook @ref hook-bx_notifications-before_register_alert
         */
        bx_alert($this->_oModule->getName(), 'before_register_alert', 0, 0, [
            'unit' => $oAlert->sUnit,
            'action' => $oAlert->sAction,
            'alert' => &$oAlert,
        ]);

    	$iObjectPrivacyView = $this->_getObjectPrivacyView($oAlert->aExtras);
        if($iObjectPrivacyView == BX_DOL_PG_HIDDEN)
            return;

        $aHandler = $this->_oModule->_oConfig->getHandlers($oAlert->sUnit . '_' . $oAlert->sAction);
        if(empty($aHandler) || !is_array($aHandler))
            return;

        $iSilentMode = $this->_oModule->getSilentMode($oAlert->aExtras);
        if(in_array($iSilentMode, array(BX_BASE_MOD_NTFS_SLTMODE_ABSOLUTE, BX_NTFS_SLTMODE_ABSOLUTE)))
            return;

        switch($aHandler['type']) {
            case BX_BASE_MOD_NTFS_HANDLER_TYPE_INSERT:
                $sMethod = 'getInsertData' . bx_gen_method_name($oAlert->sUnit . '_' . $oAlert->sAction);
                if(!method_exists($this, $sMethod)) {
                    $sMethod = 'getInsertData' . bx_gen_method_name('any_' . $oAlert->sAction);
                    if(!method_exists($this, $sMethod))
                        $sMethod = 'getInsertData';
                }

                $aDataItems = $this->$sMethod($oAlert, $aHandler);

                $sMethod = 'get_notifications_insert_data';
                if(bx_is_srv($oAlert->sUnit, $sMethod)) 
                    $aDataItems = bx_srv($oAlert->sUnit, $sMethod, [$oAlert, $aHandler, $aDataItems]);

                foreach($aDataItems as $aDataItem) {
                    $iId = $this->_oModule->_oDb->insertEvent($aDataItem);
                    if(empty($iId))
                        continue;

                    $this->_oModule->onPost($iId);
                }
                break;

            case BX_BASE_MOD_NTFS_HANDLER_TYPE_UPDATE:
                $aEvent = $this->_getEventUpdate($oAlert, $aHandler);
                if(empty($aEvent) || !is_array($aEvent))
                    break;

                $aDataItem = [
                    'object_privacy_view' => $iObjectPrivacyView
                ];

                $sMethod = 'get_notifications_update_data';
                if(bx_is_srv($oAlert->sUnit, $sMethod)) 
                    $aDataItem = bx_srv($oAlert->sUnit, $sMethod, [$oAlert, $aHandler, $aEvent, $aDataItem]);

                $this->_oModule->_oDb->updateEvent($aDataItem, ['type' => $oAlert->sUnit, 'object_id' => $oAlert->iObject]);
                break;

            case BX_BASE_MOD_NTFS_HANDLER_TYPE_DELETE:
                if($oAlert->sUnit == 'profile' && $oAlert->sAction == 'delete') {
                    $this->_oModule->_oDb->deleteEvent(array('owner_id' => $oAlert->iObject));

                    $this->_oModule->_oDb->deleteEvent(array('action' => 'connection_added', 'object_id' => $oAlert->iObject));
                    break;
            	}

                $sMethod = 'getDeleteData' . bx_gen_method_name($oAlert->sUnit . '_' . $oAlert->sAction);           	
                if(!method_exists($this, $sMethod))
                    $sMethod = 'getDeleteData';

                $aDataItems = $this->$sMethod($oAlert, $aHandler);

                $sMethod = 'get_notifications_delete_data';
                if(bx_is_srv($oAlert->sUnit, $sMethod)) 
                    $aDataItems = bx_srv($oAlert->sUnit, $sMethod, [$oAlert, $aHandler, $aDataItems]);

                foreach($aDataItems as $aDataItem)
                    $this->_oModule->_oDb->deleteEvent($aDataItem);
                break;
        }
    }

    protected function getInsertData(&$oAlert, &$aHandler)
    {
        $iOwnerId = $oAlert->iSender;
        $iObjectPrivacyView = $this->_getObjectPrivacyView($oAlert->aExtras);

        if($iObjectPrivacyView < 0)
            $iOwnerId = abs($iObjectPrivacyView);

        $mixedSubobjectId = $this->_getSubObjectId($oAlert->aExtras);
        if(!is_array($mixedSubobjectId))
            $mixedSubobjectId = array($mixedSubobjectId);

        $aResult = array();
        foreach($mixedSubobjectId as $iSubobjectId)
            $aResult[] = array(
                'author_id' => $oAlert->iSender,
                'owner_id' => $iOwnerId,
                'type' => $oAlert->sUnit,
                'action' => $oAlert->sAction,
                'object_id' => $oAlert->iObject,
                'object_owner_id' => $this->_getObjectOwnerId($oAlert->aExtras),
                'object_privacy_view' => $iObjectPrivacyView,
                'subobject_id' => $iSubobjectId,
                'content' => $this->_getContent($oAlert->aExtras),
                'source' => $this->_getSource($oAlert->aExtras),
                'source_mac' => $this->_getSourceMac($oAlert->aExtras),
                'allow_view_event_to' => $this->_oModule->_oConfig->getPrivacyViewDefault('event'),
                'date' => $this->_getDate($oAlert->aExtras),
                'processed' => 0
    	    );

    	return $aResult;
    }

    protected function getDeleteData(&$oAlert, &$aHandler)
    {
        $aHandlers = $this->_oModule->_oDb->getHandlers(array('type' => 'by_group_key_type', 'group' => $aHandler['group']));

    	return array(
    	    array(
            	'type' => $oAlert->sUnit, 
            	'action' => $aHandlers[BX_BASE_MOD_NTFS_HANDLER_TYPE_INSERT]['alert_action'], 
            	'object_id' => $oAlert->iObject,
            	'subobject_id' => $this->_getSubObjectId($oAlert->aExtras)
            )
        );
    }

    protected function getDeleteDataBxTimelineDelete(&$oAlert, &$aHandler)
    {
        $aHandlers = $this->_oModule->_oDb->getHandlers(array('type' => 'by_group_key_type', 'group' => $aHandler['group']));

    	return array(
    	    array(
            	'type' => $oAlert->sUnit, 
            	'action' => $aHandlers[BX_BASE_MOD_NTFS_HANDLER_TYPE_INSERT]['alert_action'], 
            	'object_id' => $oAlert->iObject,
            	'subobject_id' => $this->_getSubObjectId($oAlert->aExtras)
            ),
            array(
            	'action' => 'timeline_post_common', 
            	'subobject_id' => $oAlert->iObject
            )
        );
    }

    /*
     * Custom insert data getter for any module -> commentPost alerts. 
     */
    protected function getInsertDataAnyCommentPost(&$oAlert, &$aHandler)
    {
        $CNF = &$this->_oModule->_oConfig->CNF;

        if(getParam($CNF['PARAM_REPLY_AS_COMMENT']) != 'on' && isset($oAlert->aExtras['comment_parent_id']) && (int)$oAlert->aExtras['comment_parent_id'] != 0)
            return [];

        return $this->getInsertData($oAlert, $aHandler);
    }
    
    /*
     * Custom insert data getter for comment -> added and deleted alerts. 
     */
    protected function getInsertDataCommentAdded(&$oAlert, &$aHandler)
    {
        $CNF = &$this->_oModule->_oConfig->CNF;

        if(getParam($CNF['PARAM_COMMENT_POST_EXT']) != 'on')
            return [];

        $oCmts = BxDolCmts::getObjectInstance($oAlert->aExtras['object_system'], $oAlert->aExtras['object_id']);
        if(!$oCmts)
            return [];

        $iOwnerId = $oAlert->iSender;
        $iObjectId = $oAlert->aExtras['object_id'];
        $iObjectOwnerId = $this->_getObjectOwnerId($oAlert->aExtras);
        $iObjectPrivacyView = $this->_getObjectPrivacyView($oAlert->aExtras);

        $aResults = $aRecipients = [];        

        $aComments = $oCmts->getCommentsBy(['type' => 'object_id', 'object_id' => $iObjectId]);
        foreach($aComments as $aComment) {
            $iCmtAuthorId = (int)$aComment['cmt_author_id'];
            if(in_array($iCmtAuthorId, $aRecipients) || $iCmtAuthorId == $iOwnerId)
                continue;

            $aResults[] = [
                'author_id' => $oAlert->iSender,
                'owner_id' => $iOwnerId,
                'type' => $oAlert->sUnit,
                'action' => $oAlert->sAction,
                'object_id' => $iObjectId,
                'object_owner_id' => $iCmtAuthorId,
                'object_privacy_view' => $iObjectPrivacyView,
                'subobject_id' => $oAlert->aExtras['comment_uniq_id'],
                'content' => $this->_getContent($oAlert->aExtras),
                'source' => $this->_getSource($oAlert->aExtras),
                'source_mac' => $this->_getSourceMac($oAlert->aExtras),
                'allow_view_event_to' => $this->_oModule->_oConfig->getPrivacyViewDefault('event'),
                'processed' => 0
            ];

            $aRecipients[] = $iCmtAuthorId;
        }

        return $aResults;
    }

    /**
     * Custom insert data getter for sys_profiles_friends -> connection_added and connection_removed alerts. 
     */
    protected function getInsertDataSysProfilesFriendsConnectionAdded(&$oAlert, &$aHandler)
    {
        $iObjectPrivacyView = $this->_getObjectPrivacyView($oAlert->aExtras);
        $iPrivacyView = $this->_oModule->_oConfig->getPrivacyViewDefault('event');

    	return [[
            'author_id' => $oAlert->iSender,
            'owner_id' => $oAlert->aExtras['initiator'],
            'type' => $oAlert->sUnit,
            'action' => $oAlert->sAction,
            'object_id' => $oAlert->aExtras['content'],
            'object_owner_id' => $oAlert->aExtras['content'],
            'object_privacy_view' => $iObjectPrivacyView,
            'subobject_id' => 0,
            'content' => $this->_getContent($oAlert->aExtras, array(
                'request' => empty($oAlert->aExtras['mutual']) ? 1 : 0
            )),
            'source' => $this->_getSource($oAlert->aExtras),
            'source_mac' => $this->_getSourceMac($oAlert->aExtras),
            'allow_view_event_to' => $iPrivacyView,
            'processed' => 0
        ]];
    }
    
    protected function getInsertDataMetaMentionAdded(&$oAlert, &$aHandler)
    {
        $iOwnerId = $oAlert->iSender;
        $iObjectPrivacyView = $this->_getObjectPrivacyView($oAlert->aExtras);

        if($iObjectPrivacyView < 0)
            $iOwnerId = abs($iObjectPrivacyView);
        
         $aResult = [[
            'author_id' => $oAlert->iSender,
            'owner_id' => $iOwnerId,
            'type' => $oAlert->sUnit,
            'action' => $oAlert->sAction,
            'object_id' => $oAlert->iObject,
            'object_owner_id' => $this->_getObjectOwnerId($oAlert->aExtras),
            'object_privacy_view' => $iObjectPrivacyView,
            'subobject_id' => 0,
            'content' => $this->_getContent($oAlert->aExtras, array(
                'content_id' => $oAlert->aExtras['content_id'],
                'module' => $oAlert->aExtras['object']
            )),
            'source' => $this->_getSource($oAlert->aExtras),
            'source_mac' => $this->_getSourceMac($oAlert->aExtras),
            'allow_view_event_to' => $this->_oModule->_oConfig->getPrivacyViewDefault('event'),
            'processed' => 0
        ]];

    	return $aResult;
    }
    
    protected function getDeleteDataSysProfilesFriendsConnectionRemoved(&$oAlert, &$aHandler)
    {
        $aHandlers = $this->_oModule->_oDb->getHandlers(array('type' => 'by_group_key_type', 'group' => $aHandler['group']));

        $sAction = $aHandlers[BX_BASE_MOD_NTFS_HANDLER_TYPE_INSERT]['alert_action'];
    	return [[
            'owner_id' => $oAlert->aExtras['initiator'],
            'type' => $oAlert->sUnit, 
            'action' => $sAction, 
            'object_id' => $oAlert->aExtras['content']
        ], [
            'owner_id' => $oAlert->aExtras['content'],
            'type' => $oAlert->sUnit, 
            'action' => $sAction, 
            'object_id' => $oAlert->aExtras['initiator']
        ]];
    }

    /**
     * Custom insert data getter for sys_profiles_subscriptions -> connection_added and connection_removed alerts. 
     */
    protected function getInsertDataSysProfilesSubscriptionsConnectionAdded(&$oAlert, &$aHandler)
    {
    	return [[
            'author_id' => $oAlert->iSender,
            'owner_id' => $oAlert->aExtras['initiator'],
            'type' => $oAlert->sUnit,
            'action' => $oAlert->sAction,
            'object_id' => $oAlert->aExtras['content'],
            'object_owner_id' => $oAlert->aExtras['content'],
            'object_privacy_view' => $this->_getObjectPrivacyView($oAlert->aExtras),
            'subobject_id' => 0,
            'content' => $this->_getContent($oAlert->aExtras),
            'source' => $this->_getSource($oAlert->aExtras),
            'source_mac' => $this->_getSourceMac($oAlert->aExtras),                
            'allow_view_event_to' => $this->_oModule->_oConfig->getPrivacyViewDefault('event'),
            'processed' => 0
        ]];
    }

    protected function getDeleteDataSysProfilesSubscriptionsConnectionRemoved(&$oAlert, &$aHandler)
    {
        $aHandlers = $this->_oModule->_oDb->getHandlers(array('type' => 'by_group_key_type', 'group' => $aHandler['group']));

    	return [[
            'owner_id' => $oAlert->aExtras['initiator'],
            'type' => $oAlert->sUnit, 
            'action' => $aHandlers[BX_BASE_MOD_NTFS_HANDLER_TYPE_INSERT]['alert_action'], 
            'object_id' => $oAlert->aExtras['content']
        ]];
    }

    protected function _getObjectOwnerId($aExtras)
    {
        $iResult = parent::_getObjectOwnerId($aExtras);
        if(!empty($iResult))
            return $iResult;

        if(isset($aExtras['meta']))
            return (int)$aExtras['meta'];

        return 0;
    }

    protected function _getContent($aExtras, $aAdd = array())
    {
        $aResult = array();

        $iSilentMode = $this->_oModule->getSilentMode($aExtras);
        if($iSilentMode != BX_BASE_MOD_NTFS_SLTMODE_DISABLED)
            $aResult['silent_mode'] = $iSilentMode;

        if(!empty($aAdd) && is_array($aAdd))
            $aResult = array_merge($aResult, $aAdd);

        return !empty($aResult) && is_array($aResult) ? serialize($aResult) : '';
    }

    protected function _getSource($aExtras)
    {
        return $aExtras['source'] ?? '';
    }

    protected function _getSourceMac($aExtras)
    {
        return $aExtras['source_mac'] ?? '';
    }

    protected function _getDate($aExtras)
    {
        return isset($aExtras['date']) ? $aExtras['date'] : time();
    }
}

/** @} */