Merge internal code

Author: olragon

includes/graphql_api_page_callback.inc

@@ -1,12 +1,14 @@
 <?php
-use Drupal\graphql_api\Schema;
 use GraphQL\GraphQL;
+use GraphQL\Utils\SchemaPrinter;
 
 /**
  * Page callback for /graphql
  */
 function graphql_api_page_callback() {
+  $_startTime = microtime(TRUE);
   $is_introspec = FALSE;
+  $is_batch = FALSE;
   $variables = [];
   if (isset($_SERVER['CONTENT_TYPE']) && strpos(strtolower($_SERVER['CONTENT_TYPE']), 'application/json') > -1) {
     $rawBody = file_get_contents('php://input');
@@ -16,52 +18,93 @@ function graphql_api_page_callback() {
   }
 
   $requestString = isset($data['query']) ? $data['query'] : null;
-  $operationName = isset($data['operation']) ? $data['operation'] : null;
+  $operationName = isset($data['operationName']) ? $data['operationName'] : null;
   $variableValues = isset($data['variables']) ? $data['variables'] : [];
+  $is_mutation = true;
+  if ($operationName === 'Introspection') {
+    $operationName = null;
+  }
 
   try {
-    if (empty($requestString)) {
-      if( user_access('use graphql_api introspection') ) {
-        $requestString = file_get_contents(__DIR__ . '/../tests/fixtures/instrospec.graphql');
-        $is_introspec = TRUE;
+    $result = [];
+    $is_batched = false;
+    // Define your schema:
+    $_startBuildTime = microtime(true);
 
-      } else {
-        throw new Exception(t("User without permission `use graphql_api introspection` cannot browse the schema"));
+    $typeLoader = function($typeName) use($is_mutation) {
+      $schemaBuilder = graphql_api();
+      $type = $schemaBuilder->buildType($typeName, $is_mutation);
+      if ($type) {
+        return $type;
       }
-    }
+      return null;
+    };
+    $schemaBuilder = graphql_api();
+    $schema = $schemaBuilder->build([
+      'typeLoader' => $typeLoader
+    ], $is_mutation);
 
-    $is_introspec = FALSE; // @FIXME
-    if ($is_introspec && $cache = cache_get('graphql_api_introspec') && empty($_GET['nocache'])) {
-      $result = $cache->data;
-    } else {
-      // Define your schema:
-      $schemaBuilder = graphql_api();
-      $schema = $schemaBuilder->build();
+    $_endBuildTime = microtime(true) - $_startBuildTime;
 
-      $result = GraphQL::execute(
+    $_startQueryTime = microtime(true);
+
+    // execute single query
+    if ($requestString) {
+      $result = GraphQL::executeQuery(
         $schema,
         $requestString,
         /* $rootValue */ null,
         /* $context */ null, // A custom context that can be used to pass current User object etc to all resolvers.
         $variableValues,
         $operationName
-      );
-
-      if (!empty($schemaBuilder->errors)) {
-        $result['schema_errors'] = $schemaBuilder->errors;
+      )->toArray(true);
+    } else if (count($data) > 0 && !empty($data[0]['query']) && !empty($data[0]['operationName'])) {
+      $is_batched = true;
+      foreach ($data as $index => $batch_query) {
+        $batch_query['variables'] = isset($batch_query['variables']) ? $batch_query['variables'] : [];
+        $batch_result = GraphQL::executeQuery(
+          $schema,
+          $batch_query['query'],
+          /* $rootValue */ null,
+          /* $context */ null, // A custom context that can be used to pass current User object etc to all resolvers.
+          $batch_query['variables'],
+          $batch_query['operationName']
+        );
+        $result[$index] = $batch_result->toArray(true);
       }
+    }
 
-      if ($is_introspec) {
-        cache_set('graphql_api_introspec', $result);
-      }
+    $_endQueryTime = microtime(true) - $_startQueryTime;
+
+    $debug = [
+        'schemaBuildTime' => $_endBuildTime,
+        'queryTime' => $_endQueryTime,
+        'totalTime' => microtime(true) - $_startTime,
+      ] + $schemaBuilder->getMetrics();
+
+    if (!$is_batched) {
+      $result['debug'] = $debug;
     }
+
+    if (variable_get('graphql_debug')) {
+      watchdog('GraphQL', 'Execute query ' . json_encode($data, JSON_PRETTY_PRINT) . "\nDebug: " . json_encode($debug, JSON_PRETTY_PRINT));
+    }
+
+    drupal_json_output($result);
+    exit;
   } catch (Exception $exception) {
+    dump($exception);
+    die();
     $result = [
       'errors' => [
         ['message' => $exception->getMessage(), 'backtrace' => debug_backtrace()]
       ]
     ];
   }
+  if (!empty($_GET['raw'])) {
+    echo $result;
+    exit;
+  }
 
   drupal_json_output($result);
   exit;