mailjet-8.x-2.7/src/MailjetApi.php

src/MailjetApi.php
mailjet
<?php

namespace Drupal\mailjet;

require_once __DIR__ . '/../vendor/autoload.php';

use Mailjet\Client;
use Mailjet\Resources;

/**
 *
 */
class MailjetApi
{
  private static ?Client $mjApiClient = NULL;
  public static ?string $mjApiKey = NULL;

  /**
   * @param string|null $mailjetApikey
   * @param string|null $mailjetApiSecret
   * @return Client|string|null
   * @throws \Exception
   */
  public static function getApiClient(?string $mailjetApikey = NULL, ?string $mailjetApiSecret = NULL) {
    if (self::$mjApiClient instanceof Client) {
      return self::$mjApiClient;
    }
    if (empty($mailjetApikey) || empty($mailjetApiSecret)) {
      throw new \Exception('Missing Mailjet API credentials');
    }

    $mjClient = new Client($mailjetApikey, $mailjetApiSecret);
    if (\Drupal::installProfile() === 'standard') {
      $mjClient->addRequestOption(CURLOPT_USERAGENT, 'drupal-8.x-2.7');
      $mjClient->addRequestOption('headers', ['User-Agent' => 'drupal-8.x-2.7']);
    }
    elseif (\Drupal::installProfile() == 'commerce_kickstart') {
      $mjClient->addRequestOption(CURLOPT_USERAGENT, 'kickstart');
      $mjClient->addRequestOption('headers', ['User-Agent' => 'kickstart']);
    }
    else {
      $mjClient->addRequestOption(CURLOPT_USERAGENT, 'drupal-8.x-2.7');
      $mjClient->addRequestOption('headers', ['User-Agent' => 'drupal-8.x-2.7']);
    }

    // We turn of secure protocol for API requests if the wordpress does not support it.
    if (empty($_SERVER['HTTPS']) || (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] === 'off') || $_SERVER['SERVER_PORT'] != 443) {
      $mjClient->setSecureProtocol(FALSE);
    }
    self::$mjApiKey = $mailjetApikey;
    self::$mjApiClient = $mjClient;

    return self::$mjApiClient;
  }

  /**
   *
   */
  public static function getMailjetContactLists($limit = 0) {
    $mjApiClient = self::getApiClient();

    $filters = [
      'Limit' => $limit,
      'Sort' => 'Name ASC',
      ];
    $response = $mjApiClient->get(Resources::$Contactslist, ['filters' => $filters]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      // Return $response->getStatus();
      return FALSE;
    }
  }

  /**
   *
   */
  public static function getMailjetContactListByName($name) {
    $mjApiClient = self::getApiClient();

    $filters = [
      'Name' => $name,
      ];
    $response = $mjApiClient->get(Resources::$Contactslist, ['filters' => $filters]);
    if ($response->success() && $response->getCount() > 0) {
      return $response->getData();
    }
    else {
      // Return $response->getStatus();
      return FALSE;
    }
  }

  /**
   *
   */
  public static function getMailjetContactProperties($limit = 0) {
    $mjApiClient = self::getApiClient();

    $filters = [
      'Limit' => $limit,
      ];
    $response = $mjApiClient->get(Resources::$Contactmetadata, ['filters' => $filters]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      // Return $response->getStatus();
      return FALSE;
    }
  }

  /**
   *
   */
  public static function createMailjetContactList($listName) {
    if (empty($listName)) {
      return FALSE;
    }

    $mjApiClient = self::getApiClient();

    $body = [
      'Name' => $listName,
      ];
    $response = $mjApiClient->post(Resources::$Contactslist, ['body' => $body]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      // Return $response->getStatus();
      return FALSE;
    }
  }

  /**
   *
   */
  public static function isContactListActive($contactListId) {
    if (!$contactListId) {
      return FALSE;
    }
    try {
      $mjApiClient = self::getApiClient();
    }
    catch (\Exception $e) {
      return FALSE;
    }
    $filters = [
      'ID' => $contactListId,
      ];
    $response = $mjApiClient->get(Resources::$Contactslist, ['filters' => $filters]);
    if ($response->success()) {
      $data = $response->getData();
      if (isset($data[0]['IsDeleted'])) {
        // Return true if the list is not deleted.
        return !$data[0]['IsDeleted'];
      }
    }
    return FALSE;
  }

  /**
   *
   */
  public static function getContactProperties() {
    $mjApiClient = self::getApiClient();
    $filters = [
      'limit' => 0,
      'Sort' => 'Name ASC',
      ];
    $response = $mjApiClient->get(Resources::$Contactmetadata, ['filters' => $filters]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
      // Return $response->getStatus();
    }
  }

  /**
   *
   */
  public static function getPropertyIdByName($name) {
    if (!$name) {
      return FALSE;
    }
    $contactProperties = self::getContactProperties();
    if ($contactProperties) {
      foreach ($contactProperties as $property) {
        if ($property['Name'] === $name) {
          return $property['ID'];
        }
      }
    }
    return FALSE;
  }

  /**
   *
   */
  public static function createMailjetContactProperty($name, $type = "str") {
    if (empty($name)) {
      return FALSE;
    }

    $mjApiClient = self::getApiClient();

    // Name: the name of the custom data field
    //      DataType: the type of data that is being stored (this can be either a str, int, float or bool)
    //      NameSpace: this can be either static or historic.
    $body = [
      'Datatype' => $type,
      'Name' => $name,
      'NameSpace' => "static",
      ];
    $response = $mjApiClient->post(Resources::$Contactmetadata, ['body' => $body]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
      // Return $response->getStatus();
    }
  }

  /**
   *
   */
  public static function updateMailjetContactProperty($id, $name, $type = "str") {
    if (empty($name)) {
      return FALSE;
    }

    $mjApiClient = self::getApiClient();

    // Name: the name of the custom data field
    //      DataType: the type of data that is being stored (this can be either a str, int, float or bool)
    //      NameSpace: this can be either static or historic.
    $body = [
      'Datatype' => $type,
      'Name' => $name,
      'NameSpace' => "static",
      ];
    $response = $mjApiClient->put(Resources::$Contactmetadata, ['id' => $id, 'body' => $body]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
      // Return $response->getStatus();
    }
  }

  /**
   *
   */
  public static function getMailjetSenders() {
    $mjApiClient = self::getApiClient();

    $filters = [
      'Limit' => '0',
      'Sort' => 'ID DESC',
      ];

    $response = $mjApiClient->get(Resources::$Sender, ['filters' => $filters]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      // Return $response->getStatus();
      return FALSE;
    }
  }

  /**
   *
   */
  public static function isValidAPICredentials() {
    try {
      $mjApiClient = self::getApiClient();
    }
    catch (\Exception $e) {
      return FALSE;
    }

    $filters = [
      'Limit' => '1',
      ];

    $response = $mjApiClient->get(Resources::$Contactmetadata, ['filters' => $filters]);
    if ($response->success()) {
      return TRUE;
      // Return $response->getData();
    }
    else {
      return FALSE;
      // Return $response->getStatus();
    }
  }

  /**
   * Add or Remove a contact to a Mailjet contact list - It can process many or single contact at once.
   *
   * @param $contactListId
   *   - int - ID of the contact list to sync contacts
   * @param $contacts
   *   - array('Email' => ContactEmail, 'Name' => ContactName, 'Properties' => array(propertyName1 => propertyValue1, ...));
   * @param string $action
   *   - 'addforce', 'adnoforce', 'remove'.
   *
   * @return array|bool
   */
  public static function syncMailjetContacts($contactListId, $contacts, $action = 'addforce') {
    $mjApiClient = self::getApiClient();

    $body = [
      'Action' => $action,
      'Contacts' => $contacts,
      ];

    $response = $mjApiClient->post(Resources::$ContactslistManagemanycontacts, ['id' => $contactListId, 'body' => $body]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
      // Return $response->getStatus();
    }
  }

  /**
   * Add a contact to a Mailjet contact list.
   */
  public static function syncMailjetContact($contactListId, $contact, $action = 'addforce') {
    $mjApiClient = self::getApiClient();
    $body = [
      'Action' => $action,
      'Email' => $contact['Email'],
      ];
    if (!empty($contact['Properties'])) {
      $body['Properties'] = $contact['Properties'];
    }
    $response = $mjApiClient->post(Resources::$ContactslistManagecontact, ['id' => $contactListId, 'body' => $body]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
    }
  }

  /**
   * @param  array $params
   * @return array|false
   * @throws \Exception
   */
  public static function createApiToken(array $params): bool|array {
    $mjApiClient = self::getApiClient();
    $response = $mjApiClient->post(Resources::$Apitoken, ['body' => $params]);
    if ($response->success()) {
      return $response->getData();
    }
    return FALSE;
  }

  /**
   *
   */
  public static function getApiToken(string $id) {
    $mjApiClient = self::getApiClient();
    $response = $mjApiClient->get(Resources::$Apitoken, ['id' => $id]);
    if ($response->success()) {
      return $response->getData();
    }
    else {
      return FALSE;
    }
  }

  /**
   * @param  $username
   * @param  $password
   * @return MailjetIframe
   * @throws MailjetException
   * @throws \Exception
   */
  public static function getMailjetIframe($username, $password): MailjetIframe {
    $mailjetIframe = new MailjetIframe($username, $password, FALSE);

    $language = \Drupal::languageManager()->getCurrentLanguage();
    $lang_codes_map = [
      'en' => 'en_US',
      'fr' => 'fr_FR',
      'de' => 'de_DE',
      'es' => 'es_ES',
      'it' => 'it_IT',
      ];
    $default_lang = 'en';
    $locale = $lang_codes_map[$language->getId()] ?? $lang_codes_map[$default_lang];

    $mailjetIframe
        ->setCallback('')
        ->setTokenExpiration(600)
        ->setLocale($locale)
        ->setTokenAccess(
          [
              'campaigns',
              'contacts',
              'stats',
            ]
      )
        ->turnDocumentationProperties(MailjetIframe::OFF)
        ->turnNewContactListCreation(MailjetIframe::ON)
        ->turnMenu(MailjetIframe::OFF)
        ->turnFooter(MailjetIframe::ON)
        ->turnBar(MailjetIframe::ON)
        ->turnCreateCampaignButton(MailjetIframe::ON)
        ->turnSendingPolicy(MailjetIframe::ON);

    return $mailjetIframe;
  }

  /**
   * @return null
   */
  public static function getMjApiKey() {
    return self::$mjApiKey;
  }

}

Главная | Обратная связь

drupal hosting | друпал хостинг | it patrol .inc