View source
<?php
namespace Drupal\gathercontent\DAO;
use GuzzleHttp\Client;
class Project {
private $client;
private $local;
public function __construct($username = NULL, $api_key = NULL, $local = FALSE) {
$this->local = $local;
if (!$local) {
if (is_null($username)) {
$username = \Drupal::config('gathercontent.settings')
->get('gathercontent_username');
}
if (is_null($api_key)) {
$api_key = \Drupal::config('gathercontent.settings')
->get('gathercontent_api_key');
}
if (empty($username) || empty($api_key)) {
\Drupal::logger('gathercontent')
->error("Trying to call API without credentials.", []);
}
$this->client = new Client([
'base_uri' => 'https://api.gathercontent.com',
'auth' => [
$username,
$api_key,
],
'headers' => [
'Accept' => 'application/vnd.gathercontent.v0.5+json',
],
]);
}
}
public function getProjects() {
if (!$this->local) {
$account = \Drupal::config('gathercontent.settings')
->get('gathercontent_account');
$account = unserialize($account);
$projects = [];
reset($account);
$account_id = key($account);
try {
$response = $this->client
->get('/projects?account_id=' . $account_id);
if ($response
->getStatusCode() === 200) {
$data = json_decode($response
->getBody());
foreach ($data->data as $project) {
if ($project->active) {
$projects[$project->id] = $project->name;
}
}
}
} catch (\Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
\Drupal::logger('gathercontent')
->error($e
->getMessage(), []);
}
return $projects;
}
else {
drupal_set_message(t('Error occured, please contact your system administrator'), 'error');
\Drupal::logger('gathercontent')
->alert('Object Project created as local, but trying to reach remote data.', []);
}
}
public function getProjectObjects() {
if (!$this->local) {
$account = \Drupal::config('gathercontent.settings')
->get('gathercontent_account');
$account = unserialize($account);
$projects = [];
reset($account);
$account_id = key($account);
try {
$response = $this->client
->get('/projects?account_id=' . $account_id);
if ($response
->getStatusCode() === 200) {
$data = json_decode($response
->getBody());
foreach ($data->data as $project) {
if ($project->active) {
$projects[$project->id] = $project;
}
}
}
} catch (\Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
\Drupal::logger('gathercontent')
->error($e
->getMessage(), []);
}
return $projects;
}
else {
drupal_set_message(t('Error occured, please contact your system administrator'), 'error');
\Drupal::logger('gathercontent')
->alert('Object Project created as local, but trying to reach remote data.', []);
}
}
public function getStatuses($project_id) {
if (!$this->local) {
try {
$response = $this->client
->get('/projects/' . $project_id . '/statuses');
if ($response
->getStatusCode() === 200) {
$data = json_decode($response
->getBody());
return $data->data;
}
} catch (\Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
\Drupal::logger('gathercontent')
->error($e
->getMessage(), []);
}
}
else {
drupal_set_message(t('Error occured, please contact your system administrator'), 'error');
\Drupal::logger('gathercontent')
->alert('Object Project created as local, but trying to reach remote data.', []);
}
}
public function getStatus($project_id, $status_id) {
if (!$this->local) {
try {
$response = $this->client
->get('/projects/' . $project_id . '/statuses/' . $status_id);
if ($response
->getStatusCode() === 200) {
$data = json_decode($response
->getBody());
return $data->data;
}
} catch (\Exception $e) {
drupal_set_message($e
->getMessage(), 'error');
\Drupal::logger('gathercontent')
->error($e
->getMessage(), []);
}
}
else {
drupal_set_message(t('Error occured, please contact your system administrator'), 'error');
\Drupal::logger('gathercontent')
->alert('Object Project created as local, but trying to reach remote data.', []);
}
}
}