Jake Vanderwerf
9 days ago 47e77f9fac1155c536b2b87fec552c7fcce66fa6
inc/managers/queue/TypeRegistry.php
@@ -3,6 +3,7 @@
if (!defined('ABSPATH')) {
   exit;
}
use JVBase\managers\queue\mergers\DefaultMerger;
final class TypeRegistry
{
@@ -10,6 +11,7 @@
   public function register(string $type, TypeConfig $config): void
   {
      $this->validateRegistration($type, $config);
      $this->configs[$type] = $config;
   }
@@ -20,12 +22,27 @@
   public function getExecutor(string $type): ?Executor
   {
      return $this->configs[$type]?->executor;
      return array_key_exists($type, $this->configs) ? $this->configs[$type]->executor : JVB()->queue()->executor;
   }
   public function getMergeable(string $type): ?Mergeable
   {
      return $this->configs[$type]?->mergeable;
      $config = $this->configs[$type] ?? null;
      if (!$config) {
         return null;
      }
      // Explicit mergeable always wins
      if ($config->mergeable) {
         return $config->mergeable;
      }
      // Default merge based on chunkKey
      if ($config->chunkKey) {
         return new DefaultMerger($config->chunkKey);
      }
      return null;
   }
   public function getConfig(string $type): ?TypeConfig
@@ -49,4 +66,16 @@
   {
      return $this->configs[$type]?->maxRetries ?? 3;
   }
   public function validateRegistration(string $type, TypeConfig $config): void
   {
      if ($config->executor && $config->chunkKey) {
         // Verify executor can handle chunked operations
         if (!method_exists($config->executor, 'execute')) {
            throw new \InvalidArgumentException(
               "Executor for '{$type}' must implement execute() method"
            );
         }
      }
   }
}