mirror of
https://github.com/vrana/adminer.git
synced 2026-02-08 07:40:16 +01:00
437 lines
14 KiB
PHP
437 lines
14 KiB
PHP
<?php
|
|
/** Driver for https://api-docs.igdb.com/
|
|
* @link https://demo.adminer.org/igdb/?igdb=IGDB&db=api
|
|
* username: your Client-ID
|
|
* password: your access token from https://id.twitch.tv/oauth2/token
|
|
* @link https://www.adminer.org/static/plugins/igdb.png
|
|
*/
|
|
|
|
namespace Adminer;
|
|
|
|
add_driver("igdb", "APICalypse");
|
|
|
|
if (isset($_GET["igdb"])) {
|
|
define('Adminer\DRIVER', "igdb");
|
|
|
|
class Db extends SqlDb {
|
|
public $extension = "json";
|
|
public $server_info = "v4";
|
|
private $username;
|
|
private $password;
|
|
|
|
function attach($server, $username, $password): string {
|
|
$this->username = $username;
|
|
$this->password = $password;
|
|
return '';
|
|
}
|
|
|
|
function select_db($database) {
|
|
return ($database == "api");
|
|
}
|
|
|
|
function request($endpoint, $query, $method = 'POST') {
|
|
$context = stream_context_create(array('http' => array(
|
|
'method' => $method,
|
|
'header' => array(
|
|
"Content-Type: text/plain",
|
|
"Client-ID: $this->username",
|
|
"Authorization: Bearer $this->password",
|
|
),
|
|
'content' => $query,
|
|
'ignore_errors' => true,
|
|
)));
|
|
$response = file_get_contents("https://api.igdb.com/v4/$endpoint", false, $context);
|
|
$return = json_decode($response, true);
|
|
if ($http_response_header[0] != 'HTTP/1.1 200 OK') {
|
|
if (is_array($return)) {
|
|
foreach (is_array($return[0]) ? $return : array($return) as $rows) {
|
|
foreach ($rows as $key => $val) {
|
|
$this->error .= '<b>' . h($key) . ':</b> ' . (is_url($val) ? '<a href="' . h($val) . '"' . target_blank() . '>' . h($val) . '</a>' : h($val)) . '<br>';
|
|
}
|
|
}
|
|
} else {
|
|
$this->error = htmlspecialchars(strip_tags($response), 0, null, false);
|
|
}
|
|
return false;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function query($query, $unbuffered = false) {
|
|
if (preg_match('~^SELECT COUNT\(\*\) FROM (\w+)( WHERE ((MATCH \(search\) AGAINST \((.+)\))|.+))?$~', $query, $match)) {
|
|
return new Result(array($this->request("$match[1]/count", ($match[5] ? 'search "' . addcslashes($match[5], '\\"') . '";'
|
|
: ($match[3] ? 'where ' . str_replace(' AND ', ' & ', $match[3]) . ';'
|
|
: ''
|
|
)))));
|
|
}
|
|
if (preg_match('~^\s*(GET|POST|DELETE)\s+([\w/?=]+)\s*;\s*(.*)$~s', $query, $match)) {
|
|
$endpoint = $match[2];
|
|
$response = $this->request($endpoint, $match[3], $match[1]);
|
|
if ($response === false) {
|
|
return $response;
|
|
}
|
|
$return = new Result(is_array($response[0]) ? $response : array($response));
|
|
$return->table = $endpoint;
|
|
if ($endpoint == 'multiquery') {
|
|
$return->results = $response;
|
|
}
|
|
return $return;
|
|
}
|
|
$this->error = "Syntax:<br>POST <endpoint>; fields ...;";
|
|
return false;
|
|
}
|
|
|
|
function store_result() {
|
|
if ($this->multi && ($result = current($this->multi->results))) {
|
|
echo "<h3>" . h($result['name']) . "</h3>\n";
|
|
$this->multi->__construct($result['count'] ? array(array('count' => $result['count'])) : $result['result']);
|
|
}
|
|
return $this->multi;
|
|
}
|
|
|
|
function next_result(): bool {
|
|
return $this->multi && next($this->multi->results);
|
|
}
|
|
|
|
function quote($string): string {
|
|
return $string;
|
|
}
|
|
}
|
|
|
|
class Result {
|
|
public $num_rows;
|
|
public $table;
|
|
public $results = array();
|
|
private $result;
|
|
private $fields;
|
|
|
|
function __construct($result) {
|
|
$keys = array();
|
|
foreach ($result as $i => $row) {
|
|
foreach ($row as $key => $val) {
|
|
$keys[$key] = null;
|
|
if (is_array($val) && is_int($val[0])) {
|
|
$result[$i][$key] = "(" . implode(",", $val) . ")";
|
|
}
|
|
}
|
|
}
|
|
foreach ($result as $i => $row) {
|
|
$result[$i] = array_merge($keys, $row);
|
|
}
|
|
$this->result = $result;
|
|
$this->num_rows = count($result);
|
|
$this->fields = array_keys(idx($result, 0, array()));
|
|
}
|
|
|
|
function fetch_assoc() {
|
|
$row = current($this->result);
|
|
next($this->result);
|
|
return $row;
|
|
}
|
|
|
|
function fetch_row() {
|
|
$row = $this->fetch_assoc();
|
|
return ($row ? array_values($row) : false);
|
|
}
|
|
|
|
function fetch_field(): \stdClass {
|
|
$field = current($this->fields);
|
|
next($this->fields);
|
|
return ($field != '' ? (object) array('name' => $field, 'type' => 15, 'charsetnr' => 0, 'orgtable' => $this->table) : false);
|
|
}
|
|
}
|
|
|
|
class Driver extends SqlDriver {
|
|
static $extensions = array("json");
|
|
static $jush = "igdb";
|
|
private static $docsFilename = __DIR__ . DIRECTORY_SEPARATOR . 'igdb-api.html';
|
|
|
|
public $delimiter = ";;";
|
|
public $operators = array("=", "<", ">", "<=", ">=", "!=", "~");
|
|
|
|
public $tables = array();
|
|
public $links = array();
|
|
public $fields = array();
|
|
public $foreignKeys = array();
|
|
public $foundRows = null;
|
|
|
|
static function connect(string $server, string $username, string $password) {
|
|
if (!file_exists(self::$docsFilename)) {
|
|
return "Download https://api-docs.igdb.com/ and save it as " . self::$docsFilename; // copy() doesn't work - bot protection
|
|
}
|
|
return parent::connect($server, $username, $password);
|
|
}
|
|
|
|
function __construct($connection) {
|
|
parent::__construct($connection);
|
|
libxml_use_internal_errors(true);
|
|
$dom = new \DOMDocument();
|
|
$dom->loadHTMLFile(self::$docsFilename);
|
|
$xpath = new \DOMXPath($dom);
|
|
$els = $xpath->query('//div[@class="content"]/*');
|
|
$link = '';
|
|
foreach ($els as $i => $el) {
|
|
if ($el->tagName == 'h2') {
|
|
$link = $el->getAttribute('id');
|
|
}
|
|
if ($el->nodeValue == 'Request Path') {
|
|
$table = preg_replace('~^https://api.igdb.com/v4/~', '', $els[$i+1]->firstElementChild->nodeValue);
|
|
$comment = $els[$i-1]->tagName == 'p' ? $els[$i-1]->nodeValue : '';
|
|
if (preg_match('~^DEPRECATED!~', $comment)) {
|
|
continue;
|
|
}
|
|
$this->fields[$table]['id'] = array('full_type' => 'bigint', 'comment' => '');
|
|
$this->links[$link] = $table;
|
|
$this->tables[$table] = array('Name' => $table, 'Comment' => $comment);
|
|
foreach ($xpath->query('tbody/tr', $els[$i+2]) as $tr) {
|
|
$tds = $xpath->query('td', $tr);
|
|
$field = $tds[0]->nodeValue;
|
|
$comment = $tds[2]->nodeValue;
|
|
if ($field != 'checksum' && $field != 'content_descriptions' && !preg_match('~^DEPRECATED!~', $comment)) {
|
|
$this->fields[$table][$field] = array(
|
|
'full_type' => str_replace(' ', ' ', $tds[1]->nodeValue),
|
|
'comment' => str_replace(' ', ' ', $comment),
|
|
);
|
|
$ref = $xpath->query('a/@href', $tds[1]);
|
|
if (count($ref) && !in_array($ref[0]->value, array('#game-version-feature-enums', '#tag-numbers'))) {
|
|
$this->foreignKeys[$table][$field] = substr($ref[0]->value, 1);
|
|
} elseif ($field === 'game_id') { // game_time_to_beats, popularity_primitives
|
|
$this->foreignKeys[$table][$field] = 'game';
|
|
}
|
|
}
|
|
}
|
|
uksort($this->fields[$table], function ($a, $b) use ($table) {
|
|
return (($b == 'id') - ($a == 'id'))
|
|
?: (($b == 'name') - ($a == 'name'))
|
|
?: (($a == 'updated_at') - ($b == 'updated_at'))
|
|
?: (($a == 'created_at') - ($b == 'created_at'))
|
|
?: (!idx($this->foreignKeys[$table], $b) - !idx($this->foreignKeys[$table], $a))
|
|
?: ($a < $b ? -1 : 1)
|
|
;
|
|
});
|
|
}
|
|
}
|
|
$this->tables['webhooks'] = array('Name' => 'webhooks', 'Comment' => 'Webhooks allow us to push data to you when it is added, updated, or deleted');
|
|
$this->links['webhooks'] = 'webhooks';
|
|
$this->fields['webhooks'] = array(
|
|
'endpoint' => array(
|
|
'full_type' => 'String',
|
|
'comment' => 'Specify what type of data you want from your webhook',
|
|
'privileges' => array('insert' => 1),
|
|
),
|
|
'id' => array('comment' => 'A unique ID for the webhook'),
|
|
'url' => array(
|
|
'full_type' => 'String',
|
|
'length' => '100',
|
|
'comment' => 'Your prepared url that is ready to accept data from us',
|
|
'privileges' => array('select' => 1, 'insert' => 1),
|
|
),
|
|
'method' => array(
|
|
'full_type' => 'enum',
|
|
'length' => "('create','delete','update')",
|
|
'comment' => 'The type of data you are expecting to your url, there are three types of methods',
|
|
'privileges' => array('insert' => 1),
|
|
),
|
|
'category' => array('comment' => 'Based on the endpoint you chose'),
|
|
'sub_category' => array('comment' => 'Based on your method (can be 0, 1, 2)'),
|
|
'active' => array('comment' => 'Is the webhook currently active'),
|
|
'api_key' => array('comment' => 'Displays the api key the webhook is connected to'),
|
|
'secret' => array(
|
|
'full_type' => 'String',
|
|
'comment' => 'Your “secret” password for your webhook',
|
|
'privileges' => array('select' => 1, 'insert' => 1),
|
|
),
|
|
'created_at' => array('comment' => 'Created at date'),
|
|
'updated_at' => array('comment' => 'Updated at date'),
|
|
);
|
|
}
|
|
|
|
function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
|
|
$query = '';
|
|
$search = preg_match('~^MATCH \(search\) AGAINST \((.+)\)$~', $where[0], $match);
|
|
if ($search) {
|
|
$query = 'search "' . addcslashes($match[1], '\\"') . "\";\n";
|
|
unset($where[0]);
|
|
}
|
|
foreach ($where as $i => $val) {
|
|
$where[$i] = str_replace(' OR ', ' | ', $val);
|
|
}
|
|
$columns = ($select != array('*') ? $select : array_keys($this->fields[$table]));
|
|
$common = ($where ? "\nwhere " . implode(" & ", $where) . ";" : "");
|
|
if ($table != 'webhooks') {
|
|
$query .= "fields " . implode(",", $select) . ";"
|
|
. ($select == array('*') ? "\nexclude checksum;" : "")
|
|
. $common
|
|
. ($order ? "\nsort " . strtolower(implode(",", $order)) . ";" : "")
|
|
. "\nlimit $limit;"
|
|
. ($page ? "\noffset " . ($page * $limit) . ";" : "")
|
|
;
|
|
}
|
|
$start = microtime(true);
|
|
$multi = (!$search && $table != 'webhooks' && array_key_exists($table, driver()->tables));
|
|
$method = ($table == 'webhooks' ? 'GET' : 'POST');
|
|
$realQuery = str_replace("*;\nexclude checksum", implode(',', $columns), $query); // exclude deprecated columns
|
|
$return = ($multi
|
|
? $this->conn->request('multiquery', "query $table \"result\" { $realQuery };\nquery $table/count \"count\" { $common };")
|
|
: $this->conn->request($table, $realQuery, $method)
|
|
);
|
|
if ($print) {
|
|
echo adminer()->selectQuery("$method $table;\n$query", $start);
|
|
}
|
|
if ($return === false) {
|
|
return $return;
|
|
}
|
|
$this->foundRows = ($multi ? $return[1]['count'] : null);
|
|
$return = ($multi ? $return[0]['result'] : $return);
|
|
if ($return && $table != 'webhooks') {
|
|
$return[0] = array_merge(array_fill_keys($columns, null), $return[0]);
|
|
}
|
|
return new Result($return);
|
|
}
|
|
|
|
function insert($table, $set) {
|
|
$content = array();
|
|
foreach ($set as $key => $val) {
|
|
if ($key != 'endpoint') {
|
|
$content[] = urlencode($key) . '=' . urlencode($val);
|
|
}
|
|
}
|
|
return queries("POST $set[endpoint]/$table; " . implode('&', $content));
|
|
}
|
|
|
|
function delete($table, $queryWhere, $limit = 0) {
|
|
preg_match_all('~\bid = (\d+)~', $queryWhere, $matches);
|
|
$this->conn->affected_rows = 0;
|
|
foreach ($matches[1] as $id) {
|
|
$result = queries("DELETE $table/$id;");
|
|
if (!$result) {
|
|
return false;
|
|
}
|
|
$row = $result->fetch_row();
|
|
if (!$row[0]) {
|
|
$this->conn->error = "ID $id not found.";
|
|
return false;
|
|
}
|
|
$this->conn->affected_rows++;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function value($val, $field): ?string {
|
|
return ($val && in_array($field['full_type'], array('Unix Time Stamp', 'datetime')) ? str_replace(' 00:00:00', '', gmdate('Y-m-d H:i:s', $val)) : $val);
|
|
}
|
|
|
|
function tableHelp($name, $is_view = false) {
|
|
return strtolower("https://api-docs.igdb.com/#" . array_search($name, $this->links));
|
|
}
|
|
}
|
|
|
|
function logged_user() {
|
|
return $_GET["username"];
|
|
}
|
|
|
|
function get_databases($flush) {
|
|
return array("api");
|
|
}
|
|
|
|
function collations() {
|
|
return array();
|
|
}
|
|
|
|
function db_collation($db, $collations) {
|
|
}
|
|
|
|
function information_schema($db) {
|
|
}
|
|
|
|
function indexes($table, $connection2 = null) {
|
|
$return = array(array("type" => "PRIMARY", "columns" => array("id")));
|
|
if (in_array($table, array('characters', 'collections', 'games', 'platforms', 'themes'))) { // https://api-docs.igdb.com/#search-1
|
|
$return[] = array("type" => "FULLTEXT", "columns" => array("search"));
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function fields($table) {
|
|
$return = array();
|
|
foreach (driver()->fields[$table] ?: array() as $key => $val) {
|
|
$type = strtolower(preg_replace('~ .*~', '', $val['full_type']));
|
|
$return[$key] = $val + array(
|
|
"field" => $key,
|
|
"type" => ($type == 'reference' ? 'int' : $type), // align right reference columns
|
|
"privileges" => array("select" => 1) + ($table == 'webhooks' ? array() : array("where" => 1, "order" => 1)),
|
|
);
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function convert_field($field) {
|
|
}
|
|
|
|
function unconvert_field($field, $return) {
|
|
return $return;
|
|
}
|
|
|
|
function limit($query, $where, $limit, $offset = 0, $separator = " ") {
|
|
return $query;
|
|
}
|
|
|
|
function idf_escape($idf) {
|
|
return $idf;
|
|
}
|
|
|
|
function table($idf) {
|
|
return idf_escape($idf);
|
|
}
|
|
|
|
function foreign_keys($table) {
|
|
$return = array();
|
|
foreach (driver()->foreignKeys[$table] ?: array() as $key => $val) {
|
|
$return[] = array(
|
|
'table' => driver()->links[$val],
|
|
'source' => array($key),
|
|
'target' => array('id'),
|
|
);
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function tables_list() {
|
|
return array_fill_keys(array_keys(table_status()), 'table');
|
|
}
|
|
|
|
function table_status($name = "", $fast = false) {
|
|
$tables = driver()->tables;
|
|
return ($name != '' ? ($tables[$name] ? array($name => $tables[$name]) : array()) : $tables);
|
|
}
|
|
|
|
function count_tables($databases) {
|
|
return array(reset($databases) => count(tables_list()));
|
|
}
|
|
|
|
function error() {
|
|
return connection()->error;
|
|
}
|
|
|
|
function is_view($table_status) {
|
|
return false;
|
|
}
|
|
|
|
function found_rows($table_status, $where) {
|
|
return driver()->foundRows;
|
|
}
|
|
|
|
function fk_support($table_status) {
|
|
return true;
|
|
}
|
|
|
|
function last_id($result): string {
|
|
$row = $result->fetch_assoc();
|
|
return (string) $row['id'];
|
|
}
|
|
|
|
function support($feature) {
|
|
return in_array($feature, array('columns', 'comment', 'sql', 'table'));
|
|
}
|
|
}
|