una/inc/classes/BxDolAIProvider.php

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

class BxDolAIProvider extends BxDol
{
    protected $_oDb;
    protected $_iId;
    protected $_sProviderName;
    protected $_sName;
    protected $_sPrefix;
    protected $_aOptions;

    public function __construct($aProvider)
    {
        parent::__construct();

        if(empty($aProvider) || !is_array($aProvider) || strcmp($aProvider['type']['name'], $this->_sProviderName) != 0)
            $this->_log("Unexpected value provided for the credentials");

        $this->_oDb = new BxDolAIQuery();

        $this->_iId = (int)$aProvider['id'];
        $this->_sProviderName = $aProvider['type']['name'];
        $this->_sName = _t($aProvider['name']);
        $this->_sPrefix = $aProvider['type']['option_prefix'];

        $this->_aOptions = [];
        if(!empty($aProvider['options']) && is_array($aProvider['options']))
            $this->initOptions($aProvider['options']);
    }

    /**
     * Get provider object instance by provider unique name
     * @param $sName provider unique name
     * @return object instance or false on error
     */
    public static function getObjectInstanceByName($sName)
    {
        $iId = BxDolAIQuery::getProviderIdByName($sName);
        if(!$iId)
            return false;

        return self::getObjectInstance($iId);
    }

    /**
     * Get provider object instance by provider ID
     * @param $iId provider ID
     * @return object instance or false on error
     */
    public static function getObjectInstance($iId)
    {
        $sPrefix = 'BxDolAIProvider!';

        if(isset($GLOBALS['bxDolClasses'][$sPrefix . $iId]))
            return $GLOBALS['bxDolClasses'][$sPrefix . $iId];

        $aProvider = BxDolAIQuery::getProviderObject($iId);
        if(!$aProvider || !is_array($aProvider))
            return false;

        $sClass = 'BxDolAIProvider';
        if(!empty($aProvider['type']['class_name'])) {
            $sClass = $aProvider['type']['class_name'];
            if(!empty($aProvider['type']['class_file']))
                require_once(BX_DIRECTORY_PATH_ROOT . $aProvider['type']['class_file']);
        }

        $o = new $sClass($aProvider);
        return ($GLOBALS['bxDolClasses'][$sPrefix . $iId] = $o);
    }

    public function initOptions($aOptions)
    {
    	$this->_aOptions = $aOptions;
    }

    public function getInfo()
    {
        $aInfo = $this->_oDb->getProvidersBy(['sample' => 'id', 'id' => $this->_iId]);
        $aInfo['options'] = $this->getOptions();

        return $aInfo;
    }

    public function getOptions()
    {
        $aOptions = $this->_oDb->getProvidersBy(['sample' => 'options_by_id', 'id' => $this->_iId]);
        foreach($aOptions as &$aOption)
            $aOption['value'] = $this->getOption($aOption['name']);

        return $aOptions;
    }

    public function getOption($sName)
    {
        $sCustomMethod = 'getOption' . bx_gen_method_name(str_replace($this->_sPrefix, '', $sName));
        if(method_exists($this, $sCustomMethod))
             return $this->$sCustomMethod();
        
    	if(substr($sName, 0, strlen($this->_sPrefix)) != $this->_sPrefix)
            $sName = $this->_sPrefix . $sName;

        return isset($this->_aOptions[$sName]) ? $this->_aOptions[$sName]['value'] : '';
    }

    public function processActionWebhook()
    {
        // Should be overwritten to process webhooks.
    }

    public function call($sRequest, $aParams, $sMethod = 'post-json', $aHeaders = [])
    {
        // Should be overwritten to process calls.
    }

    /**
     * Internal methods.
     */
    protected function _log($mixedError, $bUseLog = true)
    {
        if(!$bUseLog) {
            $sMessage = 'Error occurred';
            if(is_string($mixedError))
                $sMessage = $mixedError;
            else if(is_array($mixedError) && isset($mixedError['message']))
                $sMessage = $mixedError['message'];

            throw new Exception($sMessage);
        }
        else
            BxDolAI::getInstance()->log($mixedError, 'Providers');

        return false;
    }    
}