Add support for eventsauce v3

composer.json

@@ -19,9 +19,9 @@
         }
     ],
     "require": {
-        "php": "^7.4|^8.0",
+        "php": "^8.0",
         "ext-json": "*",
-        "eventsauce/eventsauce": "^1.0|^2.0",
+        "eventsauce/eventsauce": "^1.0|^2.0|^3.0",
         "illuminate/bus": "^8.0|^9.0",
         "illuminate/container": "^8.0|^9.0",
         "illuminate/queue": "^8.0|^9.0.0",

src/LaravelMessageRepository.php

@@ -8,6 +8,8 @@
 use EventSauce\EventSourcing\Header;
 use EventSauce\EventSourcing\Message;
 use EventSauce\EventSourcing\MessageRepository;
+use EventSauce\EventSourcing\OffsetCursor;
+use EventSauce\EventSourcing\PaginationCursor;
 use EventSauce\EventSourcing\Serialization\MessageSerializer;
 use Exception;
 use Generator;
@@ -95,4 +97,25 @@ public function setTable(string $table): void
     {
         $this->table = $table;
     }
+
+    public function paginate(PaginationCursor|OffsetCursor $cursor): Generator
+    {
+        $payloads = $this->connection()->table($this->table)
+            ->orderBy('recorded_at')
+            ->offset($cursor->offset())
+            ->limit($cursor->limit())
+            ->get('payload');
+
+        foreach ($payloads as $payload) {
+            $messages = $this->serializer->unserializePayload(json_decode($payload->payload, true));
+
+            if ($messages instanceof Message) {
+                yield $messages;
+            } else {
+                yield from $messages;
+            }
+        }
+
+        return $payloads->count();
+    }
 }