facebook.php

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

<?
 
use Bitrix\Main\Web\Json;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Web\HttpClient;
use Bitrix\Main\Localization\Loc;
 
IncludeModuleLangFile(__FILE__);
 
class CSocServFacebook extends CSocServAuth
{
    const ID = "Facebook";
    const CONTROLLER_URL = "https://www.bitrix24.ru/controller";
    const LOGIN_PREFIX = "FB_";
 
    protected $entityOAuth = null;

    public function getEntityOAuth($code = false)
    {
        if(!$this->entityOAuth)
        {
            $this->entityOAuth = new CFacebookInterface();
        }
 
        if($code !== false)
        {
            $this->entityOAuth->setCode($code);
        }
 
        return $this->entityOAuth;
    }

    public function GetSettings(): array
    {
        $urlPreviewEnable = Option::get('main', 'url_preview_enable', 'Y');
        $result = [
            ['facebook_appid', Loc::getMessage('socserv_fb_id'), '', ['text', 40]],
            ['facebook_appsecret', Loc::getMessage('socserv_fb_secret'), '', ['text', 40]],
            ['note' => Loc::getMessage('socserv_fb_sett_note1', ['#URL#'=>$this->getEntityOAuth()->GetRedirectURI()])],
        ];
 
        if($urlPreviewEnable === 'Y')
        {
            $result[] = ['facebook_instagram_url_preview_enable', Loc::getMessage('socserv_fb_instagram_url_preview'), '', ['checkbox']];
            $result[] = ['note' => Loc::getMessage('socserv_fb_sett_note_oembed_2')];
        }
 
        return $result;
    }
 
    public function GetFormHtml($arParams)
    {
        $url = $this->getUrl($arParams);
 
        $phrase = ($arParams["FOR_INTRANET"])
            ? GetMessage("socserv_fb_note_intranet")
            : GetMessage("socserv_fb_note");
 
        return $arParams["FOR_INTRANET"]
            ? array("ON_CLICK" => 'onclick="BX.util.popup(\''.htmlspecialcharsbx(CUtil::JSEscape($url)).'\', 580, 400)"')
            : '<a href="javascript:void(0)" onclick="BX.util.popup(\''.htmlspecialcharsbx(CUtil::JSEscape($url)).'\', 580, 400)" class="bx-ss-button facebook-button"></a><span class="bx-spacer"></span><span>'.$phrase.'</span>';
    }
 
    public function GetOnClickJs($arParams)
    {
        $url = $this->getUrl($arParams);
        return "BX.util.popup('".CUtil::JSEscape($url)."', 680, 600)";
    }
 
    public function getUrl($arParams)
    {
        global $APPLICATION;
 
        if(IsModuleInstalled('bitrix24') && defined('BX24_HOST_NAME'))
        {
            $redirect_uri = static::CONTROLLER_URL."/redirect.php";
            $state = $this->getEntityOAuth()->GetRedirectURI()."?check_key=".\CSocServAuthManager::getUniqueKey()."&state=";
            $backurl = $APPLICATION->GetCurPageParam('', array("logout", "auth_service_error", "auth_service_id", "backurl"));
            $state .= urlencode("state=".urlencode("backurl=".urlencode($backurl).(isset($arParams['BACKURL']) ? '&redirect_url='.urlencode($arParams['BACKURL']) : '')));
        }
        else
        {
            $state = 'site_id='.SITE_ID.'&backurl='.urlencode($APPLICATION->GetCurPageParam('check_key='.\CSocServAuthManager::getUniqueKey(), array("logout", "auth_service_error", "auth_service_id", "backurl"))).(isset($arParams['BACKURL']) ? '&redirect_url='.urlencode($arParams['BACKURL']) : '');
            $redirect_uri = $this->getEntityOAuth()->GetRedirectURI();
        }
 
        return $this->getEntityOAuth()->GetAuthUrl($redirect_uri, $state);
    }
 
    public function addScope($scope)
    {
        return $this->getEntityOAuth()->addScope($scope);
    }
 
    public function prepareUser($arFBUser, $short = false)
    {
        $arFields = array(
            'EXTERNAL_AUTH_ID' => self::ID,
            'XML_ID' => $arFBUser["id"],
            'LOGIN' => static::LOGIN_PREFIX.$arFBUser["id"],
            'EMAIL' => ($arFBUser["email"] != '') ? $arFBUser["email"] : '',
            'NAME'=> $arFBUser["first_name"],
            'LAST_NAME'=> $arFBUser["last_name"],
            'OATOKEN' => $this->entityOAuth->getToken(),
            'OATOKEN_EXPIRES' => $this->entityOAuth->getAccessTokenExpires(),
        );
 
        if(!$short && isset($arFBUser['picture']['data']['url']) && !$arFBUser['picture']['data']['is_silhouette'])
        {
            $picture_url = CFacebookInterface::GRAPH_URL.'/'.$arFBUser['id'].'/picture?type=large';
            $temp_path = CFile::GetTempName('', 'picture.jpg');
 
            $ob = new HttpClient(array(
                "redirect" => true
            ));
            $ob->download($picture_url, $temp_path);
 
            $arPic = CFile::MakeFileArray($temp_path);
            if($arPic)
            {
                $arFields["PERSONAL_PHOTO"] = $arPic;
            }
        }
 
        if(isset($arFBUser['birthday']))
        {
            if($date = MakeTimeStamp($arFBUser['birthday'], "MM/DD/YYYY"))
            {
                $arFields["PERSONAL_BIRTHDAY"] = ConvertTimeStamp($date);
            }
        }
 
        if(isset($arFBUser['gender']) && $arFBUser['gender'] != '')
        {
            if($arFBUser['gender'] == 'male')
            {
                $arFields["PERSONAL_GENDER"] = 'M';
            }
            elseif($arFBUser['gender'] == 'female')
            {
                $arFields["PERSONAL_GENDER"] = 'F';
            }
        }
 
        $arFields["PERSONAL_WWW"] = $this->getProfileUrl($arFBUser['id']);
 
        if(SITE_ID <> '')
        {
            $arFields["SITE_ID"] = SITE_ID;
        }
 
        return $arFields;
    }
 
    public function Authorize()
    {
        global $APPLICATION;
        $APPLICATION->RestartBuffer();
 
        $authError = SOCSERV_AUTHORISATION_ERROR;
 
        if(
            isset($_REQUEST["code"]) && $_REQUEST["code"] <> ''
            && CSocServAuthManager::CheckUniqueKey()
        )
        {
            if(IsModuleInstalled('bitrix24') && defined('BX24_HOST_NAME'))
            {
                $redirect_uri = static::CONTROLLER_URL."/redirect.php";
            }
            else
            {
                $redirect_uri = $this->getEntityOAuth()->GetRedirectURI();
            }
 
            $this->entityOAuth = $this->getEntityOAuth($_REQUEST['code']);
            if($this->entityOAuth->GetAccessToken($redirect_uri) !== false)
            {
                $arFBUser = $this->entityOAuth->GetCurrentUser();
                if(is_array($arFBUser) && isset($arFBUser["id"]))
                {
                    $arFields = self::prepareUser($arFBUser);
                    $authError = $this->AuthorizeUser($arFields);
                }
            }
        }
 
        $bSuccess = $authError === true;
 
        $url = ($APPLICATION->GetCurDir() == "/login/") ? "" : $APPLICATION->GetCurDir();
        $aRemove = array("logout", "auth_service_error", "auth_service_id", "code", "error_reason", "error", "error_description", "check_key", "current_fieldset");
 
        if(isset($_REQUEST["state"]) && $bSuccess)
        {
            $arState = array();
            parse_str($_REQUEST["state"], $arState);
 
            if(isset($arState['backurl']) || isset($arState['redirect_url']))
            {
                $url = !empty($arState['redirect_url']) ? $arState['redirect_url'] : $arState['backurl'];
                if(mb_substr($url, 0, 1) !== "#")
                {
                    $parseUrl = parse_url($url);
 
                    $urlPath = $parseUrl["path"];
                    $arUrlQuery = explode('&', $parseUrl["query"]);
 
                    foreach($arUrlQuery as $key => $value)
                    {
                        foreach($aRemove as $param)
                        {
                            if(mb_strpos($value, $param."=") === 0)
                            {
                                unset($arUrlQuery[$key]);
                                break;
                            }
                        }
                    }
 
                    $url = (!empty($arUrlQuery)) ? $urlPath.'?'.implode("&", $arUrlQuery) : $urlPath;
                }
            }
        }
 
        if($authError === SOCSERV_REGISTRATION_DENY)
        {
            $url = (preg_match("/\?/", $url)) ? $url.'&' : $url.'?';
            $url .= 'auth_service_id='.self::ID.'&auth_service_error='.$authError;
        }
        elseif($bSuccess !== true)
        {
            $url = (isset($urlPath)) ? $urlPath.'?auth_service_id='.self::ID.'&auth_service_error='.$authError : $GLOBALS['APPLICATION']->GetCurPageParam(('auth_service_id='.self::ID.'&auth_service_error='.$authError), $aRemove);
        }
 
        if(CModule::IncludeModule("socialnetwork") && mb_strpos($url, "current_fieldset=") === false)
        {
            $url .= ((mb_strpos($url, "?") === false) ? '?' : '&')."current_fieldset=SOCSERV";
        }
?>
<script>
if(window.opener)
    window.opener.location = '<?=CUtil::JSEscape($url)?>';
window.close();
</script>
<?
        CMain::FinalActions();
    }
 
    public function setUser($userId)
    {
        $this->getEntityOAuth()->setUser($userId);
    }
 
    public function getFriendsList($limit, &$next)
    {
        if(IsModuleInstalled('bitrix24') && defined('BX24_HOST_NAME'))
        {
            $redirect_uri = self::CONTROLLER_URL."/redirect.php?redirect_to=".urlencode(CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code")));
        }
        else
        {
            $redirect_uri = CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code"));
        }
 
        $fb = $this->getEntityOAuth();
        if($fb->GetAccessToken($redirect_uri) !== false)
        {
            $res = $fb->GetCurrentUserFriends($limit, $next);
            if(is_array($res))
            {
                foreach($res['data'] as $key => $value)
                {
                    $res['data'][$key]['uid'] = $value['id'];
                    $res['data'][$key]['url'] = $this->getProfileUrl($value['id']);
 
                    if(is_array($value['picture']))
                    {
                        if(!$value['picture']['data']['is_silhouette'])
                        {
                            $res['data'][$key]['picture'] = CFacebookInterface::GRAPH_URL.'/'.$value['id'].'/picture?type=large';
                        }
                        else
                        {
                            $res['data'][$key]['picture'] = '';
                        }
                        //$res['data'][$key]['picture'] = $value['picture']['data']['url'];
                    }
                }
 
                return $res['data'];
            }
        }
 
        return false;
    }
 
    public function sendMessage($uid, $message)
    {
        $fb = new CFacebookInterface();
 
        if(IsModuleInstalled('bitrix24') && defined('BX24_HOST_NAME'))
        {
            $redirect_uri = self::CONTROLLER_URL."/redirect.php?redirect_to=".urlencode(CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code")));
        }
        else
        {
            $redirect_uri = CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code"));
        }
 
        if($fb->GetAccessToken($redirect_uri) !== false)
        {
            $res = $fb->sendMessage($uid, $message);
        }
 
 
        return $res;
    }
 
    public function getMessages($uid)
    {
        $fb = new CFacebookInterface();
 
        if(IsModuleInstalled('bitrix24') && defined('BX24_HOST_NAME'))
        {
            $redirect_uri = self::CONTROLLER_URL."/redirect.php?redirect_to=".urlencode(CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code")));
        }
        else
        {
            $redirect_uri = CSocServUtil::GetCurUrl('auth_service_id='.self::ID, array("code"));
        }
 
        if($fb->GetAccessToken($redirect_uri) !== false)
        {
            $res = $fb->getMessages($uid);
        }
 
        return $res;
    }
    public function getProfileUrl($uid)
    {
        return "http://www.facebook.com/".$uid;
    }
 
    public static function SendUserFeed($userId, $message, $messageId)
    {
        $fb = new CFacebookInterface();
        return $fb->SendFeed($userId, $message, $messageId);
    }
 
}
 
class CFacebookInterface extends CSocServOAuthTransport
{
    const SERVICE_ID = "Facebook";
 
    const AUTH_URL = "https://www.facebook.com/dialog/oauth";
    const GRAPH_URL = "https://graph.facebook.com";
 
    protected $userId = false;
    protected $responseData = array();
 
    protected $scope = array(
        "email",
    );
 
    public function __construct($appID = false, $appSecret = false, $code=false)
    {
        if($appID === false)
        {
            $appID = trim(CSocServFacebook::GetOption("facebook_appid"));
        }
 
        if($appSecret === false)
        {
            $appSecret = trim(CSocServFacebook::GetOption("facebook_appsecret"));
        }
 
        parent::__construct($appID, $appSecret, $code);
    }
 
    public function GetRedirectURI()
    {
        return \CHTTP::URN2URI("/bitrix/tools/oauth/facebook.php");
    }
 
    public function GetAuthUrl($redirect_uri, $state = '')
    {
/*      if(IsModuleInstalled('oauth'))
        {
            $_SESSION["FACEBOOK_OAUTH_LAST_REDIRECT_URI"] = $redirect_uri;
        }*/
 
        return self::AUTH_URL .
            "?client_id=" . $this->appID .
            "&redirect_uri=" . urlencode($redirect_uri) .
            "&scope=".$this->getScopeEncode()."&display=popup" .
            ($state <> '' ? '&state=' . urlencode($state) : '');
    }
 
    public function getResult()
    {
        return $this->responseData;
    }
 
    public function GetAccessToken($redirect_uri)
    {
        $token = $this->getStorageTokens();
        if(is_array($token))
        {
            $this->access_token = $token["OATOKEN"];
            $this->accessTokenExpires = $token["OATOKEN_EXPIRES"];
 
            if($this->checkAccessToken())
            {
                return true;
            }
        }
 
        if($this->code === false)
        {
            return false;
        }
 
        $result = CHTTP::sGetHeader(self::GRAPH_URL.'/oauth/access_token?client_id='.$this->appID.'&client_secret='.$this->appSecret.'&redirect_uri='.urlencode($redirect_uri).'&code='.urlencode($this->code), array(), $this->httpTimeout);
 
        $arResult = Json::decode($result);
        $this->responseData = $arResult;
 
        if(isset($arResult["access_token"]) && $arResult["access_token"] <> '')
        {
            $result = CHTTP::sGetHeader(self::GRAPH_URL."/oauth/access_token?grant_type=fb_exchange_token&client_id=".$this->appID."&client_secret=".$this->appSecret."&fb_exchange_token=".$arResult["access_token"], array(), $this->httpTimeout);
 
            $arResultLongLive = Json::decode($result);
 
            if(isset($arResultLongLive["access_token"]) && $arResultLongLive["access_token"] <> '')
            {
                $arResult["access_token"] = $arResultLongLive["access_token"];
                $arResult["expires"] = isset($arResultLongLive["expires_in"]) ? $arResultLongLive["expires_in"] : 86400 * 60;
                $_SESSION["OAUTH_DATA"] = array(
                    "OATOKEN" => $arResultLongLive["access_token"],
                    "OATOKEN_EXPIRES" => time() + $arResultLongLive['expires'],
                );
            }
 
            $this->access_token = $arResult["access_token"];
            $this->accessTokenExpires = time() + $arResult["expires"];
 
            return true;
        }
 
        if (isset($this->responseData['error']))
        {
            $this->responseData = array(
                'error' => $this->responseData['error']['type'],
                'error_description' => $this->responseData['error']['message'],
            );
        }
 
        return false;
    }
 
    public function GetCurrentUser()
    {
        if($this->access_token === false)
            return false;
 
        $http = new HttpClient();
        $http->setTimeout($this->httpTimeout);
 
        $result = $http->get(self::GRAPH_URL.'/me?access_token='.$this->access_token."&fields=picture,id,name,first_name,last_name,gender,email");
 
        return Json::decode($result);
    }
 
    public function GetAppInfo()
    {
        if($this->access_token === false)
            return false;
 
        $http = new HttpClient();
        $http->setTimeout($this->httpTimeout);
 
        $result = $http->get(self::GRAPH_URL.'/debug_token?input_token='.$this->access_token.'&access_token='.$this->appID."|".$this->appSecret);
        $result = Json::decode($result);
 
        if($result["data"]["app_id"])
        {
            $result["id"] = $result["data"]["app_id"];
        }
 
        return $result;
    }
 
    public function GetCurrentUserFriends($limit, &$next)
    {
        if($this->access_token === false)
            return false;
 
        if(empty($next))
        {
            $url = self::GRAPH_URL.'/me/friends?access_token='.$this->access_token."&fields=picture,id,name,first_name,last_name,gender,email";
 
            if($limit > 0)
            {
                $url .= "&limit=".intval($limit)."&offset=".intval($next);
            }
        }
        else
        {
            $url = $next;
        }
 
        $http = new HttpClient();
        $http->setTimeout($this->httpTimeout);
 
        $result = $http->get($url);
 
        $result = Json::decode($result);
 
        if(is_array($result['paging']) && !empty($result['paging']['next']))
        {
            $next = $result['paging']['next'];
        }
        else
        {
            $next = '';
        }
 
        return $result;
    }
 
    public function SendFeed($socServUserId, $message, $messageId)
    {
        $isSetOauthKeys = true;
        if(!$this->access_token || !$this->userId)
            $isSetOauthKeys = self::SetOauthKeys($socServUserId);
 
        if($isSetOauthKeys === false)
        {
            CSocServMessage::Delete($messageId);
            return false;
        }
 
        $arPost = array("access_token" => $this->access_token, "message"=> $message);
        $result = @CHTTP::sPostHeader($this::GRAPH_URL."/".$this->userId."/feed", $arPost, array(), $this->httpTimeout);
        if($result !== false)
        {
            return CUtil::JsObjectToPhp($result);
        }
        else
            return false;
    }
 
    public function sendMessage($uid, $message)
    {
        if($this->access_token === false)
            return false;
 
        $url = self::GRAPH_URL.'/'.$uid.'/apprequests';
 
        $arPost = array("access_token" => $this->access_token, "message"=> $message);
 
        $ob = new HttpClient();
        return $ob->post($url, $arPost);
    }
 
    public function getMessages($uid)
    {
        if($this->access_token === false)
            return false;
 
        $url = self::GRAPH_URL.'/'.$uid.'/apprequests?access_token='.$this->access_token;
 
        $ob = new HttpClient();
        return $ob->get($url);
    }
 
    private function SetOauthKeys($socServUserId)
    {
        $dbSocservUser = \Bitrix\Socialservices\UserTable::getList([
            'filter' => ['=ID' => $socServUserId],
            'select' => ["OATOKEN", "XML_ID"]
        ]);
        while($arOauth = $dbSocservUser->fetch())
        {
            $this->access_token = $arOauth["OATOKEN"];
            $this->userId = $arOauth["XML_ID"];
        }
        if(!$this->access_token || !$this->userId)
            return false;
        return true;
    }
}
?>