Resets transaction once processed by the onFlush event subscriber. F…

…ixes #44 (#48)

src/Model/Transaction.php

@@ -77,6 +77,16 @@ public function getDissociated(): array
         return $this->dissociated;
     }
 
+    public function reset(): void
+    {
+        $this->transaction_hash = null;
+        $this->inserted = [];
+        $this->updated = [];
+        $this->removed = [];
+        $this->associated = [];
+        $this->dissociated = [];
+    }
+
     public function trackAuditEvent(string $type, array $data): void
     {
         switch ($type) {

src/Provider/Doctrine/Auditing/Event/DoctrineSubscriber.php

@@ -45,6 +45,7 @@ public function onFlush(OnFlushEventArgs $args): void
             // flushes pending data
             $entityManager->getConnection()->getConfiguration()->setSQLLogger($this->loggerBackup);
             $this->transactionManager->process($transaction);
+            $transaction->reset();
         });
 
         // Initialize a new LoggerChain with the new AuditLogger + the existing SQLLoggers.

tests/Provider/Doctrine/Issues/Issue44Test.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace DH\Auditor\Tests\Provider\Doctrine\Issues;
+
+use DH\Auditor\Model\Transaction;
+use DH\Auditor\Tests\Provider\Doctrine\Fixtures\Entity\Standard\DummyEntity;
+use DH\Auditor\Tests\Provider\Doctrine\Traits\ReaderTrait;
+use DH\Auditor\Tests\Provider\Doctrine\Traits\Schema\SchemaSetupTrait;
+use PHPUnit\Framework\TestCase;
+
+/**
+ * @internal
+ */
+final class Issue44Test extends TestCase
+{
+    use ReaderTrait;
+    use SchemaSetupTrait;
+
+    public function testIssue44(): void
+    {
+        $reader = $this->createReader();
+
+        $em = $this->provider->getStorageServiceForEntity(DummyEntity::class)->getEntityManager();
+        $em->beginTransaction();
+        $entity = new DummyEntity();
+        $entity->setLabel('entity1');
+        $em->persist($entity);
+        $em->flush();
+        $em->flush();
+        $em->commit();
+        for ($n = 1; $n <= 10; ++$n) {
+            $em->beginTransaction();
+            $em->commit();
+        }
+
+        $audits = $reader->createQuery(DummyEntity::class)->execute();
+        self::assertCount(1, $audits, 'results count ok.');
+        self::assertSame(Transaction::INSERT, $audits[0]->getType(), 'Reader::INSERT operation.');
+    }
+
+    private function configureEntities(): void
+    {
+        $this->provider->getConfiguration()->setEntities([
+            DummyEntity::class => ['enabled' => true],
+        ]);
+    }
+}