refactor: use directive implementations instead of plugins

apps/cms/config/sync/graphql.graphql_servers.main.yml

@@ -15,6 +15,7 @@ query_complexity: null
 schema_configuration:
   directable:
     schema_definition: ../node_modules/@custom/schema/build/schema.graphql
+    autoload_registry: ../autoload.json
     extensions:
       silverback_campaign_urls: silverback_campaign_urls
       silverback_gatsby: silverback_gatsby

packages/drupal/custom/custom.services.yml

@@ -2,4 +2,11 @@ services:
   custom.route_subscriber:
     class: Drupal\custom\Routing\RouteSubscriber
     tags:
-      - { name: event_subscriber }
+      - { name: event_subscriber }
+  custom.content_hub:
+    class: Drupal\custom\ContentHub
+    arguments: ['@entity_type.manager']
+
+  custom.webform:
+    class: Drupal\custom\Webform
+    arguments: ['@renderer', '@entity_type.manager']

packages/drupal/custom/directives.graphql

@@ -1,2 +1,9 @@
-directive @contentHub on FIELD_DEFINITION
-directive @webformIdToUrl on FIELD_DEFINITION
+"""
+implementation(drupal): custom.content_hub::query
+"""
+directive @contentHub(pagination: String, query: String) on FIELD_DEFINITION
+
+"""
+implementation(drupal): custom.webform::url
+"""
+directive @webformIdToUrl(id: String!) on FIELD_DEFINITION

packages/drupal/custom/src/ContentHub.php

@@ -0,0 +1,70 @@
+<?php
+
+namespace Drupal\custom;
+
+use Drupal\Core\Entity\EntityTypeManagerInterface;
+use Drupal\graphql_directives\DirectiveArguments;
+
+/**
+ * Service to query content listings.
+ */
+class ContentHub {
+
+  /**
+   * The entity type manager, to query and load pages.
+   *
+   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
+   */
+  protected EntityTypeManagerInterface $entityTypeManager;
+
+  /**
+   * ContentHub constructor.
+   *
+   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entityTypeManager
+   *   The entity type manager, to query and load pages.
+   */
+  public function __construct(EntityTypeManagerInterface $entityTypeManager) {
+    $this->entityTypeManager = $entityTypeManager;
+  }
+
+  /**
+   * Query a list of pages.
+   *
+   * @param \Drupal\graphql_directives\DirectiveArguments $args
+   *   The graphql argument bag.
+   *
+   * @return array{'total': int, 'items': \Drupal\node\NodeInterface[]}
+   *   Result of the query.
+   */
+  public function query(DirectiveArguments $args) : array {
+    // @todo Switch this to views.
+    $offset = $args->args['pagination']['offset'];
+    $limit = $args->args['pagination']['limit'];
+    $nodeStorage = $this->entityTypeManager->getStorage('node');
+
+    $countQuery = $nodeStorage->getQuery();
+    $countQuery->condition('type', 'page');
+    $countQuery->condition('status', 1);
+    if (!empty($args->args['query'])) {
+      $countQuery->condition('title', $args->args['query'], 'CONTAINS');
+    }
+    $count = $countQuery->count()->accessCheck(TRUE)->execute();
+
+    $query = $nodeStorage->getQuery();
+    $query->condition('type', 'page');
+    $query->condition('status', 1);
+    if (!empty($args->args['query'])) {
+      $query->condition('title', $args->args['query'], 'CONTAINS');
+    }
+    $pageIds = $query->range($offset, $limit)
+      ->sort('title', 'ASC')
+      ->accessCheck(TRUE)
+      ->execute();
+    $posts = $pageIds ? $nodeStorage->loadMultiple($pageIds) : [];
+    return [
+      'total' => $count,
+      'items' => $posts,
+    ];
+  }
+
+}

packages/drupal/custom/src/Webform.php

@@ -0,0 +1,71 @@
+<?php
+
+namespace Drupal\custom;
+
+use Drupal\Core\Entity\EntityTypeManagerInterface;
+use Drupal\Core\Render\RenderContext;
+use Drupal\Core\Render\RendererInterface;
+use Drupal\graphql_directives\DirectiveArguments;
+
+/**
+ * Helper service for managing webforms with graphql.
+ */
+class Webform {
+
+  /**
+   * The renderer for collecting cache information.
+   */
+  protected RendererInterface $renderer;
+
+  /**
+   * The entity type manager, to query and load pages.
+   *
+   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
+   */
+  protected EntityTypeManagerInterface $entityTypeManager;
+
+  /**
+   * Webform constructor.
+   */
+  public function __construct(
+    RendererInterface $renderer,
+    EntityTypeManagerInterface $entityTypeManager
+  ) {
+    $this->entityTypeManager = $entityTypeManager;
+    $this->renderer = $renderer;
+  }
+
+  /**
+   * Generate the public url of a webform, based on its ID.
+   */
+  public function url(DirectiveArguments $args) : ?string {
+    $webformId = $args->args['id'];
+    if (!$webformId) {
+      return NULL;
+    }
+
+    $webFormStorage = $this->entityTypeManager->getStorage('webform');
+
+    /** @var \Drupal\Core\Render\RendererInterface $renderer */
+    $renderContext = new RenderContext();
+
+    $result = $this->renderer->executeInRenderContext(
+        $renderContext,
+        function () use ($args, $webformId, $webFormStorage) {
+          $webform = $webFormStorage->load($webformId);
+          if (!$webform || !$webform->isOpen()) {
+            return NULL;
+          }
+          $args->context->addCacheableDependency($webform);
+          return $webform->toUrl()->setAbsolute()->toString();
+        },
+      );
+
+    if (!$renderContext->isEmpty()) {
+      $args->context->addCacheableDependency($renderContext->pop());
+    }
+
+    return $result;
+  }
+
+}

packages/schema/src/schema.graphql

@@ -95,7 +95,7 @@ type Hero {
 union PageContent @resolveEditorBlockType = BlockMarkup | BlockMedia | BlockForm
 
 type BlockForm @type(id: "custom/form") {
-  url: Url @resolveEditorBlockAttribute(key: "formId") @webformIdToUrl
+  url: Url @resolveEditorBlockAttribute(key: "formId") @webformIdToUrl(id: "$")
 }
 
 type BlockMarkup @type(id: "core/paragraph") {
@@ -130,7 +130,7 @@ type Query {
   previewPage(id: ID!, rid: ID, locale: String!): Page
     @fetchEntity(type: "node", id: "$id", rid: "$rid", language: "$locale")
   contentHub(query: String, pagination: PaginationInput!): ContentHubResult!
-    @contentHub
+    @contentHub(query: "$query", pagination: "$pagination")
 }
 
 type MetaTag {