QueryBuilder::update() implemented custom pipelines.

Author: TCB13

src/QueryBuilder.php

@@ -509,7 +509,12 @@ public function update($update): UpdateResult
             throw new Exception("You must set a filter (where query) to update records.");
         }
 
-        $pipeline = [];
+        // Build the pipeline
+        if (is_object($this->customPipeline) && !empty($this->customPipeline->pipeline) && $this->customPipeline->beforeQb) {
+            $pipeline = $this->customPipeline->pipeline;
+        } else {
+            $pipeline = [];
+        }
 
         if (is_array($update)) {
             $inc    = [];
@@ -562,6 +567,10 @@ public function update($update): UpdateResult
             }
         }
 
+        if (is_object($this->customPipeline) && !empty($this->customPipeline->pipeline) && !$this->customPipeline->beforeQb) {
+            $pipeline = array_merge($pipeline, $this->customPipeline->pipeline);
+        }
+
         // Run the update query
         return $this->collection->updateMany($this->getNormalizedFilters(), $pipeline);
     }