133 lines
3.6 KiB
PHP
133 lines
3.6 KiB
PHP
<?php
|
|
namespace MobilizonConnector;
|
|
|
|
// Exit if this file is called directly.
|
|
if (!defined('ABSPATH')) {
|
|
exit;
|
|
}
|
|
|
|
final class GraphQlClient {
|
|
|
|
public static function query(string $endpoint, string $query, array $variables = [], ?string $token = null): array
|
|
{
|
|
$headers = ['Content-Type: application/json'];
|
|
if ($token !== null) {
|
|
$headers[] = "Authorization: bearer $token";
|
|
}
|
|
|
|
$context = stream_context_create([
|
|
'http' => [
|
|
'method' => 'POST',
|
|
'header' => $headers,
|
|
'content' => json_encode(['query' => $query, 'variables' => $variables]),
|
|
]
|
|
]);
|
|
$data = @file_get_contents($endpoint, false, $context);
|
|
|
|
if ($data === false) {
|
|
$error = error_get_last();
|
|
throw new \ErrorException($error['message'], $error['type']);
|
|
}
|
|
|
|
return json_decode($data, true);
|
|
}
|
|
|
|
public static function get_upcoming_events(string $url, int $limit): array {
|
|
$query = <<<'GRAPHQL'
|
|
query ($limit: Int) {
|
|
events(limit: $limit) {
|
|
elements {
|
|
id,
|
|
title,
|
|
url,
|
|
beginsOn,
|
|
endsOn,
|
|
physicalAddress {
|
|
description,
|
|
locality
|
|
}
|
|
},
|
|
total
|
|
}
|
|
}
|
|
GRAPHQL;
|
|
|
|
$endpoint = $url . '/api';
|
|
// const dataInCache = SessionCache.get(sessionStorage, {
|
|
// url,
|
|
// query,
|
|
// variables: { limit },
|
|
// })
|
|
// if (dataInCache !== null) {
|
|
// return Promise.resolve(dataInCache)
|
|
// }
|
|
$data = self::query($endpoint, $query, ['limit' => $limit]);
|
|
self::checkData($data);
|
|
|
|
// SessionCache.add(sessionStorage, { url, query, variables: { limit } }, data)
|
|
return $data;
|
|
}
|
|
|
|
public static function get_upcoming_events_by_group_name(string $url, int $limit, string $groupName): array {
|
|
$query = <<<'GRAPHQL'
|
|
query ($afterDatetime: DateTime, $groupName: String!, $limit: Int) {
|
|
group(preferredUsername: $groupName) {
|
|
organizedEvents(afterDatetime: $afterDatetime, limit: $limit) {
|
|
elements {
|
|
id,
|
|
title,
|
|
url,
|
|
beginsOn,
|
|
endsOn,
|
|
physicalAddress {
|
|
description,
|
|
locality
|
|
}
|
|
},
|
|
total
|
|
}
|
|
}
|
|
}
|
|
GRAPHQL;
|
|
|
|
$endpoint = $url . '/api';
|
|
|
|
// const afterDatetime = DateTimeWrapper.getCurrentDatetimeAsString()
|
|
// const dataInCache = SessionCache.get(sessionStorage, {
|
|
// url,
|
|
// query,
|
|
// variables: { afterDatetime, groupName, limit },
|
|
// })
|
|
// if (dataInCache !== null) {
|
|
// return Promise.resolve(dataInCache)
|
|
// }
|
|
$afterDatetime = date(\DateTime::ISO8601);
|
|
$data = self::query($endpoint, $query, ['afterDatetime' => $afterDatetime, 'groupName' => $groupName, 'limit' => $limit]);
|
|
self::checkData($data);
|
|
|
|
// return request(url, query, { afterDatetime, groupName, limit }).then(
|
|
// (data) => {
|
|
// SessionCache.add(
|
|
// sessionStorage,
|
|
// { url, query, variables: { afterDatetime, groupName, limit } },
|
|
// data
|
|
// )
|
|
// return Promise.resolve(data)
|
|
// }
|
|
// )
|
|
return $data;
|
|
}
|
|
|
|
private static function checkData($data) {
|
|
if (isset($data['errors'])) {
|
|
if (count($data['errors']) > 0 &&
|
|
isset($data['errors'][0]['code']) &&
|
|
$data['errors'][0]['code'] === 'group_not_found') {
|
|
throw new GroupNotFoundException(serialize($data['errors'][0]));
|
|
} else {
|
|
throw new GeneralException(serialize($data['errors']));
|
|
}
|
|
}
|
|
}
|
|
}
|