Fix unpublishing of documents

Author: chx

src/Controller/PantheonContentPublisherController.php

@@ -50,6 +50,7 @@ public function webhook(Request $request): Response {
       if ($decoded['event'] === 'article.unpublish') {
         $this->entityQueue->createItem([
           'entity_type' => 'pantheon_document',
+          'bundle' => $collection_id,
           'entity_id' => $entity_id,
           'delete' => 1,
         ]);

src/Plugin/QueueWorker/EntityQueueWorker.php

@@ -46,16 +46,20 @@ public static function create(ContainerInterface $container, array $configuratio
    */
   public function processItem($data): void {
     $entity_type_id = $data['entity_type'];
-    $entity = $this->entityTypeManager
-      ->getStorage($entity_type_id)
-      ->load($data['entity_id']);
-    if ($entity) {
-      if (empty($data['delete'])) {
-        $entity->save();
-      }
-      else {
-        $entity->delete();
-      }
+    $storage = $this->entityTypeManager->getStorage($entity_type_id);
+
+    if (empty($data['delete'])) {
+      $entity = $storage->load($data['entity_id']);
+      $entity->save();
+    }
+    else {
+      $entityType = $this->entityTypeManager->getDefinition($entity_type_id);
+      $entity = $storage->create([
+        $entityType->getKey('bundle') => $data['bundle'],
+        $entityType->getKey('id') => $data['entity_id'],
+      ]);
+      $entity->enforceIsNew(FALSE);
+      $entity->delete();
     }
     $index_storage = $this->entityTypeManager->getStorage('search_api_index');
     $datasource_id = "entity:$entity_type_id";