View source
<?php
namespace Drupal\google_analytics_reports;
use GuzzleHttp\Exception\RequestException;
class GoogleAnalyticsReports {
public static $googleAnalyticsColumnsDefinitionUrl = 'https://www.googleapis.com/analytics/v3/metadata/ga/columns';
public static function checkUpdates() {
if (!defined('MAINTENANCE_MODE')) {
$etag_old = \Drupal::config('google_analytics_reports.settings')
->get('metadata_etag');
try {
$response = \Drupal::httpClient()
->request('GET', self::$googleAnalyticsColumnsDefinitionUrl . '?fields=etag', [
'timeout' => 2.0,
]);
} catch (RequestException $e) {
\Drupal::logger('google_analytics_reports')
->error('Failed to Google Analytics metadata definitions due to "%error".', [
'%error' => $e
->getMessage(),
]);
return;
}
if ($response
->getStatusCode() == 200) {
$data = $response
->getBody()
->getContents();
if (empty($data)) {
\Drupal::logger('google_analytics_reports')
->error('Failed to Google Analytics Column metadata definitions. Received empty content.');
return;
}
$data = json_decode($data, TRUE);
if ($etag_old == $data['etag']) {
\Drupal::messenger()
->addMessage(t('All Google Analytics fields is up to date.'));
}
else {
\Drupal::messenger()
->addMessage(t('New Google Analytics fields has been found. Press "Import fields" button to update Google Analytics fields.'));
}
}
else {
\Drupal::messenger()
->addMessage(t('An error has occurred: @error.', [
'@error' => $response
->getStatusCode(),
]), 'error');
}
}
}
public static function importFields() {
if (!defined('MAINTENANCE_MODE')) {
try {
$response = \Drupal::httpClient()
->request('GET', self::$googleAnalyticsColumnsDefinitionUrl, [
'timeout' => 2.0,
]);
} catch (RequestException $e) {
\Drupal::logger('google_analytics_reports')
->error('Failed to Google Analytics Column metadata definitions due to "%error".', [
'%error' => $e
->getMessage(),
]);
return;
}
if ($response
->getStatusCode() == 200) {
$data = $response
->getBody()
->getContents();
if (empty($data)) {
\Drupal::logger('google_analytics_reports')
->error('Failed to Google Analytics Column metadata definitions. Received empty content.');
return;
}
$data = json_decode($data, TRUE);
if (\Drupal::database()
->schema()
->tableExists('google_analytics_reports_fields')) {
\Drupal::database()
->truncate('google_analytics_reports_fields')
->execute();
}
$google_analytics_reports_settings = \Drupal::config('google_analytics_reports.settings')
->get();
$google_analytics_reports_settings['metadata_last_time'] = \Drupal::time()
->getRequestTime();
if (!empty($data['etag'])) {
$google_analytics_reports_settings['metadata_etag'] = $data['etag'];
}
\Drupal::configFactory()
->getEditable('google_analytics_reports.settings')
->setData($google_analytics_reports_settings)
->save();
if (!empty($data['items'])) {
$operations = [];
foreach ($data['items'] as $item) {
if ($item['attributes']['status'] == 'PUBLIC') {
$operations[] = [
[
GoogleAnalyticsReports::class,
'saveFields',
],
[
$item,
],
];
}
}
$batch = [
'operations' => $operations,
'title' => t('Importing Google Analytics fields'),
'finished' => [
GoogleAnalyticsReports::class,
'importFieldsFinished',
],
];
batch_set($batch);
}
}
else {
\Drupal::messenger()
->addMessage(t('There is a error during request to Google Analytics Metadata API: @error', [
'@error' => $response
->getStatusCode(),
]), 'error');
}
}
}
public static function saveFields(array $field, &$context) {
$attributes =& $field['attributes'];
$field['id'] = str_replace('ga:', '', $field['id']);
$attributes['type'] = strtolower($attributes['type']);
$attributes['dataType'] = strtolower($attributes['dataType']);
$attributes['status'] = strtolower($attributes['status']);
$attributes['description'] = isset($attributes['description']) ? $attributes['description'] : '';
$attributes['calculation'] = isset($attributes['calculation']) ? $attributes['calculation'] : NULL;
\Drupal::moduleHandler()
->alter('google_analytics_reports_field_import', $field);
\Drupal::database()
->insert('google_analytics_reports_fields')
->fields([
'gaid' => $field['id'],
'type' => $attributes['type'],
'data_type' => $attributes['dataType'],
'column_group' => $attributes['group'],
'ui_name' => $attributes['uiName'],
'description' => $attributes['description'],
'calculation' => $attributes['calculation'],
])
->execute();
$context['results'][] = $field['id'];
}
public static function importFieldsFinished(bool $success, array $results) {
if ($success) {
\Drupal::messenger()
->addMessage(t('Imported @count Google Analytics fields.', [
'@count' => count($results),
]));
drupal_flush_all_caches();
}
else {
\Drupal::messenger()
->addMessage(t('An error has occurred during importing Google Analytics fields.'), 'error');
}
}
}