Jake Vanderwerf
2026-07-18 de317675a8069b747cb253ba3e2b5dc394ca36ef
inc/managers/queue/Storage.php
@@ -19,7 +19,7 @@
   public function __construct()
   {
      $this->defineTables();
      $this->cache = Cache::for('queue', DAY_IN_SECONDS);
      $this->cache = Cache::for('queue', DAY_IN_SECONDS)->user();
   }
   public function hasProcessingOperations(): bool
@@ -168,10 +168,15 @@
   public function insert(Operation $op): bool
   {
      $result = $this->table->insert([
         'id'              => $op->id,
         'type'            => $op->type,
         'user_id'         => $op->userId,
      $existing = $this->find($op->id);
      if ($existing && in_array($existing->state, ['completed', 'processing'] )) {
         $op->id = Queue::generateId($op->userId);
      }
      $result = $this->table->findOrCreate([
            'id'     => $op->id,
            'type'      => $op->type,
            'user_id'   => $op->userId,
         ],[
         'request_data'    => json_encode($op->requestData),
         'total_items'     => $op->totalItems,
         'processed_items' => $op->processedItems,
@@ -548,7 +553,7 @@
         $s = $stats[0] ?? null;
         if (!$s) continue;
         $this->stats->table->query("
         $this->stats->queryResults("
            INSERT INTO {table} (date, type, total_operations, successful_operations, failed_permanent_operations, total_items_processed)
            VALUES (%s, %s, %d, %d, %d, %d)
            ON DUPLICATE KEY UPDATE