Use synthetic logs for probe replay

Author: durable-workflow-ops

src/Exception.php

@@ -15,6 +15,7 @@
 use Workflow\Exceptions\TransitionNotFound;
 use Workflow\Middleware\WithoutOverlappingMiddleware;
 use Workflow\Models\StoredWorkflow;
+use Workflow\Models\StoredWorkflowLog;
 use Workflow\Serializers\Serializer;
 
 final class Exception implements ShouldBeEncrypted, ShouldQueue
@@ -100,11 +101,8 @@ private function shouldPersistAfterProbeReplay(): bool
         }
 
         $previousContext = WorkflowStub::getContext();
-        $connection = $this->storedWorkflow->getConnection();
         $shouldPersist = false;
 
-        $connection->beginTransaction();
-
         try {
             $tentativeWorkflow = $this->createTentativeWorkflowState();
             $workflow = new $workflowClass($tentativeWorkflow, ...$tentativeWorkflow->workflowArguments());
@@ -130,27 +128,39 @@ private function shouldPersistAfterProbeReplay(): bool
             $shouldPersist = WorkflowStub::probeMatched();
         } finally {
             WorkflowStub::setContext($previousContext);
-
-            if ($connection->transactionLevel() > 0) {
-                $connection->rollBack();
-            }
         }
 
         return $shouldPersist;
     }
 
     private function createTentativeWorkflowState(): StoredWorkflow
     {
-        $this->storedWorkflow->createLog([
-            'index' => $this->index,
-            'now' => $this->now,
-            'class' => self::class,
-            'result' => Serializer::serialize($this->exceptionPayload()),
-        ]);
-
         $storedWorkflowClass = $this->storedWorkflow::class;
 
-        return $storedWorkflowClass::query()->findOrFail($this->storedWorkflow->id);
+        /** @var StoredWorkflow $tentativeWorkflow */
+        $tentativeWorkflow = $storedWorkflowClass::query()
+            ->findOrFail($this->storedWorkflow->id);
+
+        $tentativeWorkflow->loadMissing(['logs', 'signals']);
+
+        /** @var StoredWorkflowLog $tentativeLog */
+        $tentativeLog = $tentativeWorkflow->logs()
+            ->make([
+                'index' => $this->index,
+                'now' => $this->now,
+                'class' => self::class,
+                'result' => Serializer::serialize($this->exceptionPayload()),
+            ]);
+
+        $tentativeWorkflow->setRelation(
+            'logs',
+            $tentativeWorkflow->getRelation('logs')
+                ->push($tentativeLog)
+                ->sortBy(static fn ($log): string => sprintf('%020d:%020d', $log->index, $log->id ?? PHP_INT_MAX))
+                ->values()
+        );
+
+        return $tentativeWorkflow;
     }
 
     private function exceptionPayload()