Update records (#6)

Update records

Author: WyriHaximus

etc/db/seeds/BlogPostsSeed.php

@@ -20,7 +20,7 @@ public function run(): void
                 'publisher_id' => '15f25357-4b3d-4d4d-b6a5-2ceb93864b77',
                 'title' => 'Moar Cats!',
                 'contents' => 'qlqweofu b02qw yu9   dqiwuhe uofq2hep fuoq2pho fp2uhu pu2p 2qpoh weh uwqhfu wqif',
-                'views' => 133,
+                'views' => 166,
             ],
         ];
 

src/Hydrator.php

@@ -4,6 +4,7 @@
 
 use GeneratedHydrator\Configuration;
 use WyriHaximus\React\SimpleORM\Entity\Field;
+use Zend\Hydrator\HydratorInterface;
 
 final class Hydrator
 {
@@ -48,6 +49,15 @@ public function hydrate(InspectedEntity $inspectedEntity, array $data): EntityIn
         return $this->hydrators[$class]->hydrate($data, new $class());
     }
 
+    public function extract(InspectedEntity $inspectedEntity, EntityInterface $entity): array
+    {
+        $class = $inspectedEntity->getClass();
+        /** @var HydratorInterface $hydrator */
+        $hydrator = $this->hydrators[$class];
+
+        return $hydrator->extract($entity);
+    }
+
     /**
      * @param Field $field
      * @param mixed $value

src/Repository.php

@@ -78,6 +78,29 @@ public function create(array $fields): PromiseInterface
         });
     }
 
+    public function update(EntityInterface $entity): PromiseInterface
+    {
+        $fields = $this->hydrator->extract($this->entity, $entity);
+        foreach ($fields as $key => $value) {
+            if (\is_scalar($value)) {
+                continue;
+            }
+
+            unset($fields[$key]);
+        }
+
+        return $this->client->query(
+            QueryBuilder::create()->
+                update($fields)->
+                into($this->entity->getTable())->
+                where('id', '=', $entity->getId())
+        )->toPromise()->then(function () use ($entity) {
+            return $this->fetch([
+                ['id', '=', $entity->getId()],
+            ])->take(1)->toPromise();
+        });
+    }
+
     private function buildSelectQuery(array $where = [], array $order = []): QueryBuilder
     {
         $query = $this->getBaseQuery();

src/RepositoryInterface.php

@@ -16,4 +16,6 @@ public function page(int $page, array $where = [], array $order = [], int $perPa
     public function fetch(array $where = [], array $order = []): Observable;
 
     public function create(array $fields): PromiseInterface;
+
+    public function update(EntityInterface $entity): PromiseInterface;
 }

tests/FunctionalTest.php

@@ -245,4 +245,24 @@ public function createUser(): void
 
         self::assertSame($name, $user->getName());
     }
+
+    /**
+     * @test
+     */
+    public function increaseViews(): void
+    {
+        $repository = $this->client->getRepository(BlogPostStub::class);
+
+        self::assertSame(
+            167,
+            $this->await(
+                $repository->fetch()->takeLast(1)->toPromise()->then(function (BlogPostStub $blogPost) {
+                    return $blogPost->withViews($blogPost->getViews() + 1);
+                })->then(function (BlogPostStub $blogPost) use ($repository) {
+                    return $repository->update($blogPost);
+                }),
+                $this->loop
+            )->getViews()
+        );
+    }
 }

tests/Stub/BlogPostStub.php

@@ -93,4 +93,12 @@ public function getViews(): int
     {
         return $this->views;
     }
+
+    public function withViews(int $views): self
+    {
+        $clone = clone $this;
+        $clone->views = $views;
+
+        return $clone;
+    }
 }