Content.inc in GatherContent 7.3

Contains GatherContent\Accont class.

Namespace

GatherContent

File

includes/Content.inc

<?php

/**
 * @file
 * Contains GatherContent\Accont class.
 */
namespace GatherContent;

use GuzzleHttp\Client;
use GuzzleHttp\Pool;
use GuzzleHttp\Exception\RequestException;

/**
 * Class Account.
 *
 * @package GatherContent
 */
class Content {
  private $client;

  /**
   * Account constructor.
   *
   * @param string $username
   *   API username.
   * @param string $api_key
   *   API key.
   */
  public function __construct($username = NULL, $api_key = NULL) {
    if (is_null($username)) {
      $username = variable_get('gathercontent_username', '');
    }
    if (is_null($api_key)) {
      $api_key = variable_get('gathercontent_api_key', '');
    }
    if (empty($username || $api_key)) {
      watchdog('gathercontent', "Trying to call API without credentials.", array(), WATCHDOG_ERROR);
    }
    $this->client = new Client(array(
      'base_url' => 'https://api.gathercontent.com',
      'defaults' => array(
        'auth' => array(
          $username,
          $api_key,
        ),
        'headers' => array(
          'Accept' => 'application/vnd.gathercontent.v0.5+json',
        ),
      ),
    ));
  }

  /**
   * Update status of content.
   *
   * @param int $content_id
   *   ID of content we want to update.
   * @param int $status_id
   *   Status ID.
   *
   * @return bool
   *   Return TRUE on success.
   */
  public function updateStatus($content_id, $status_id) {
    try {
      $response = $this->client
        ->post('/items/' . $content_id . '/choose_status', array(
        'body' => array(
          'status_id' => $status_id,
        ),
      ));
      if ($response
        ->getStatusCode() === 202) {
        return TRUE;
      }
      else {
        return FALSE;
      }
    } catch (\Exception $e) {
      drupal_set_message($e
        ->getMessage(), 'error');
      watchdog('gathercontent', $e
        ->getMessage(), array(), WATCHDOG_ERROR);
      return FALSE;
    }
  }

  /**
   * Get list of content.
   *
   * @param int $project_id
   *   ID of project we want items from.
   *
   * @return array
   *   Array with accounts.
   */
  public function getContents($project_id) {
    $accounts = array();
    try {
      $response = $this->client
        ->get('/items?project_id=' . $project_id);
      if ($response
        ->getStatusCode() === 200) {
        $data = json_decode($response
          ->getBody());
        $accounts = $data->data;
      }
      else {
        drupal_set_message(t("User with provided credentials wasn't found."), 'error');
      }
    } catch (\Exception $e) {
      if ($e instanceof RequestException) {
        $level = floor($e
          ->getResponse()
          ->getStatusCode() / 100);
        if ($level == '4' || $level == '5') {
          drupal_set_message(t('Some content could not be accessed in
        GatherContent and updated. This could be due to the Items being deleted
        in GatherContent or a change in module authentication details.'), 'error');
        }
        else {
          drupal_set_message($e
            ->getMessage(), 'error');
          watchdog('gathercontent', $e
            ->getMessage(), array(), WATCHDOG_ERROR);
        }
      }
      else {
        drupal_set_message($e
          ->getMessage(), 'error');
        watchdog('gathercontent', $e
          ->getMessage(), array(), WATCHDOG_ERROR);
      }
    }
    return $accounts;
  }

  /**
   * Get single piece of content.
   *
   * @param int $content_id
   *   ID of content, we want to fetch.
   *
   * @return array
   *   Array with accounts.
   */
  public function getContent($content_id) {
    $accounts = array();
    try {
      $response = $this->client
        ->get('/items/' . $content_id);
      if ($response
        ->getStatusCode() === 200) {
        $data = json_decode($response
          ->getBody());
        $accounts = $data->data;
      }
      else {
        drupal_set_message(t("User with provided credentials wasn't found."), 'error');
      }
    } catch (\Exception $e) {
      drupal_set_message($e
        ->getMessage(), 'error');
      watchdog('gathercontent', $e
        ->getMessage(), array(), WATCHDOG_ERROR);
    }
    return $accounts;
  }

  /**
   * Update content in GatherContent.
   *
   * @param int $content_id
   *   ID of content we want to update.
   * @param array $config
   *   Configration array.
   *
   * @return bool
   *   Return boolean value.
   */
  public function postContent($content_id, array $config) {
    try {
      $response = $this->client
        ->post('/items/' . $content_id . '/save', array(
        'body' => array(
          'config' => base64_encode(json_encode($config)),
        ),
      ));
      if ($response
        ->getStatusCode() === 202) {
        return TRUE;
      }
      else {
        return FALSE;
      }
    } catch (\Exception $e) {
      return FALSE;
    }
  }

  /**
   * Get list of files.
   *
   * @param int $content_id
   *   ID of content, we want to fetch files for.
   *
   * @return array
   *   Array with accounts.
   */
  public function getFiles($content_id) {
    $accounts = array();
    try {
      $response = $this->client
        ->get('/items/' . $content_id . '/files');
      if ($response
        ->getStatusCode() === 200) {
        $data = json_decode($response
          ->getBody());
        $accounts = $data->data;
      }
      else {
        drupal_set_message(t("User with provided credentials wasn't found."), 'error');
      }
    } catch (\Exception $e) {
      drupal_set_message($e
        ->getMessage(), 'error');
      watchdog('gathercontent', $e
        ->getMessage(), array(), WATCHDOG_ERROR);
    }
    return $accounts;
  }

  /**
   * Downloads all files asynchronously.
   *
   * @param array $files
   *   Files object array.
   * @param array $fieldInfo
   *   Field info.
   *
   * @return array
   *   Imported files array.
   */
  public function downloadFiles(array $files, $fieldInfo) {
    $files = array_values($files);
    $importedFiles = [];
    foreach ($files as $file) {
      $url = "files/{$file->id}/download";
      $response = $this->client
        ->get($url);
      if ($response
        ->getStatusCode() === 200) {
        $importedFile = file_save_data($response
          ->getBody(), 'public://' . $file->fileName);
        if ($importedFile) {
          $importedFile->gathercontent_id = $file->id;
          file_save($importedFile);
          if ($fieldInfo['type'] === 'file') {
            $fileData = array(
              'fid' => $importedFile->fid,
              'display' => TRUE,
            );
          }
          else {
            $fileData = array(
              'fid' => $importedFile->fid,
            );
          }
          $importedFiles[] = $fileData;
        }
      }
    }
    ksort($importedFiles);
    return $importedFiles;
  }

}

Classes

Name	Description
Content	Class Account.