שילוב 1C-Bitrix עם SendPulse להודעות רב-ערוציות

class SendPulseClient {
    private string $apiId;
    private string $apiSecret;
    private ?string $token = null;

    public function __construct() {
        $this->apiId = COption::GetOptionString('site', 'sendpulse_id');
        $this->apiSecret = COption::GetOptionString('site', 'sendpulse_secret');
    }

    private function getToken(): string {
        $cached = \Bitrix\Main\Data\Cache::createInstance();
        if ($cached->initCache(3500, 'sendpulse_token', '/sendpulse/')) {
            return $cached->getVars()['token'];
        }

        $http = new \Bitrix\Main\Web\HttpClient();
        $response = json_decode($http->post('https://api.sendpulse.com/oauth/access_token', [
            'grant_type' => 'client_credentials',
            'client_id' => $this->apiId,
            'client_secret' => $this->apiSecret,
        ]), true);
        $token = $response['access_token'];

        $cached->startDataCache();
        $cached->endDataCache(['token' => $token]);

        return $token;
    }

    public function call(string $method, string $endpoint, array $data = []): array {
        $http = new \Bitrix\Main\Web\HttpClient();
        $http->setHeader('Authorization', 'Bearer ' . $this->getToken());
        $http->setHeader('Content-Type', 'application/json');

        $url = 'https://api.sendpulse.com/' . ltrim($endpoint, '/');
        $response = $method === 'POST' ? $http->post($url, json_encode($data)) : $http->get($url);

        return json_decode($response, true) ?? [];
    }
}

שמירת מטמון מתויגת פירושה שאם הגדרות המודול (ID/Secret) משתנות, המטמון נפסל אוטומטית. זה מבטיח שהטוקן תמיד עדכני אך לא נוצר מחדש בכל בקשה.

היתרונות של שמירת מטמון מתויגת עבור הטוקן

טעות אופיינית היא בקשת טוקן חדש בכל קריאת API. SendPulse מגביל את מספר בקשות הטוקן (תיעוד ה-API של SendPulse מציין 50 לשעה). אם חנות מעבדת 1000 הזמנות בשעה, ללא שמירת מטמון האינטגרציה תיכשל תוך 3 דקות. שמירת מטמון מתויגת פותרת את הבעיה: הטוקן נבקש פעם אחת בכל 58 דקות (קצת פחות מאורך חייו), ואם מתרחש כשל, הוא נבקש מחדש מיד.

ניהול ספרי כתובות

ספר כתובות (רשימת תפוצה) ב-SendPulse הוא רשימת נמענים. קבלו את מזהה הספר דרך class SendPulseClient { private string $apiId; private string $apiSecret; private ?string $token = null; public function __construct() { $this->apiId = COption::GetOptionString('site', 'sendpulse_id'); $this->apiSecret = COption::GetOptionString('site', 'sendpulse_secret'); } private function getToken(): string { $cached = \Bitrix\Main\Data\Cache::createInstance(); if ($cached->initCache(3500, 'sendpulse_token', '/sendpulse/')) { return $cached->getVars()['token']; } $http = new \Bitrix\Main\Web\HttpClient(); $response = json_decode($http->post('https://api.sendpulse.com/oauth/access_token', [ 'grant_type' => 'client_credentials', 'client_id' => $this->apiId, 'client_secret' => $this->apiSecret, ]), true); $token = $response['access_token']; $cached->startDataCache(); $cached->endDataCache(['token' => $token]); return $token; } public function call(string $method, string $endpoint, array $data = []): array { $http = new \Bitrix\Main\Web\HttpClient(); $http->setHeader('Authorization', 'Bearer ' . $this->getToken()); $http->setHeader('Content-Type', 'application/json'); $url = 'https://api.sendpulse.com/' . ltrim($endpoint, '/'); $response = $method === 'POST' ? $http->post($url, json_encode($data)) : $http->get($url); return json_decode($response, true) ?? []; } } , שמרו אותו ב-GET /addressbooks. הוספת מנוי:

public function addContact(string $email, array $variables = []): void {
    $this->call('POST', '/addressbooks/' . $this->listId . '/emails', [
        'emails' => [[
            'email' => $email,
            'variables' => $variables,
        ]],
    ]);
}

<script>
  (function(d,w) {
    var n = d.getElementsByTagName('script')[0];
    var s = d.createElement('script');
    s.type = 'text/javascript';
    s.async = true;
    s.src = 'https://cdn.sendpulse.com/push/scripts/push.js';
    n.parentNode.insertBefore(s, n);
    w.PushwooshSDK_onLoad = function() {
      Pushwoosh.init({
        'applicationCode': '<?= COption::GetOptionString("site","sendpulse_push_id") ?>'
      });
    };
  })(document, window);
</script>

$sp->call('POST', '/push/tasks', [
    'task' => [
        'list_id' => $pushListId,
        'subject' => 'Заказ #' . $orderId . ' принят',
        'body' => 'Ваш заказ на сумму ' . $orderPrice . ' руб. принят в обработку',
        'send_date' => 'now',
        'filter' => [
            'variable' => 'user_id',
            'operator' => '=',
            'value' => $userId,
        ],
    ],
]);

$sp->call('POST', '/flows/run', [
    'flow_id' => 'FLOW_ID_FROM_SENDPULSE',
    'email' => $email,
    'variables' => [
        'order_id' => $orderId,
        'product_name' => $productName,
    ],
]);