Added BoltConvertible Implementations

Author: transistive

src/Contracts/BoltConvertibleInterface.php

@@ -1,8 +1,21 @@
 <?php
 
+declare(strict_types=1);
+
+/*
+ * This file is part of the Laudis Neo4j package.
+ *
+ * (c) Laudis technologies <http://laudis.tech>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
 namespace Laudis\Neo4j\Contracts;
 
+use Bolt\structures\IStructure;
+
 interface BoltConvertibleInterface
 {
-
+    public function convertToBolt(): IStructure;
 }

src/Types/Cartesian3DPoint.php

@@ -13,6 +13,9 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
+use Bolt\structures\Point3D;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 use Laudis\Neo4j\Contracts\PointInterface;
 
 /**
@@ -24,10 +27,15 @@
  *
  * @psalm-import-type Crs from \Laudis\Neo4j\Contracts\PointInterface
  */
-class Cartesian3DPoint extends CartesianPoint implements PointInterface
+class Cartesian3DPoint extends CartesianPoint implements PointInterface, BoltConvertibleInterface
 {
     private float $z;
 
+    public function convertToBolt(): IStructure
+    {
+        return new Point3D($this->getSrid(), $this->getX(), $this->getY(), $this->getZ());
+    }
+
     /**
      * @param Crs $crs
      */

src/Types/CartesianPoint.php

@@ -13,6 +13,9 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
+use Bolt\structures\Point2D;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 use Laudis\Neo4j\Contracts\PointInterface;
 
 /**
@@ -24,7 +27,7 @@
  *
  * @psalm-import-type Crs from \Laudis\Neo4j\Contracts\PointInterface
  */
-class CartesianPoint extends AbstractPropertyObject implements PointInterface
+class CartesianPoint extends AbstractPropertyObject implements PointInterface, BoltConvertibleInterface
 {
     private float $x;
     private float $y;
@@ -43,6 +46,11 @@ public function __construct(float $x, float $y, string $crs, int $srid)
         $this->srid = $srid;
     }
 
+    public function convertToBolt(): IStructure
+    {
+        return new Point2D($this->getSrid(), $this->getX(), $this->getY());
+    }
+
     public function getX(): float
     {
         return $this->x;

src/Types/Date.php

@@ -13,8 +13,10 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
 use DateTimeImmutable;
 use Exception;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 
 /**
  * A date represented by days since unix epoch.
@@ -23,7 +25,7 @@
  *
  * @extends AbstractPropertyObject<int, int>
  */
-final class Date extends AbstractPropertyObject
+final class Date extends AbstractPropertyObject implements BoltConvertibleInterface
 {
     private int $days;
 
@@ -59,4 +61,9 @@ public function toArray(): array
     {
         return ['days' => $this->days];
     }
+
+    public function convertToBolt(): IStructure
+    {
+        return new \Bolt\structures\Date($this->getDays());
+    }
 }

src/Types/DateTime.php

@@ -13,9 +13,11 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
 use DateTimeImmutable;
 use DateTimeZone;
 use Exception;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 use RuntimeException;
 use function sprintf;
 
@@ -26,7 +28,7 @@
  *
  * @extends AbstractPropertyObject<int, int>
  */
-final class DateTime extends AbstractPropertyObject
+final class DateTime extends AbstractPropertyObject implements BoltConvertibleInterface
 {
     private int $seconds;
     private int $nanoseconds;
@@ -100,4 +102,9 @@ public function getProperties(): CypherMap
     {
         return new CypherMap($this);
     }
+
+    public function convertToBolt(): IStructure
+    {
+        return new \Bolt\structures\DateTime($this->getSeconds(), $this->getNanoseconds(), $this->getTimeZoneOffsetSeconds());
+    }
 }

src/Types/Duration.php

@@ -13,8 +13,10 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
 use DateInterval;
 use Exception;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 
 /**
  * A temporal range represented in months, days, seconds and nanoseconds.
@@ -23,7 +25,7 @@
  *
  * @extends AbstractPropertyObject<int, int>
  */
-final class Duration extends AbstractPropertyObject
+final class Duration extends AbstractPropertyObject implements BoltConvertibleInterface
 {
     private int $months;
     private int $days;
@@ -97,4 +99,14 @@ public function getProperties(): CypherMap
     {
         return new CypherMap($this);
     }
+
+    public function convertToBolt(): IStructure
+    {
+        return new \Bolt\structures\Duration(
+            $this->getMonths(),
+            $this->getDays(),
+            $this->getSeconds(),
+            $this->getNanoseconds()
+        );
+    }
 }

src/Types/LocalDateTime.php

@@ -13,8 +13,10 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
 use DateTimeImmutable;
 use Exception;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
 use function sprintf;
 
 /**
@@ -24,7 +26,7 @@
  *
  * @extends AbstractPropertyObject<int, int>
  */
-final class LocalDateTime extends AbstractPropertyObject
+final class LocalDateTime extends AbstractPropertyObject implements BoltConvertibleInterface
 {
     private int $seconds;
     private int $nanoseconds;
@@ -75,4 +77,9 @@ public function getProperties(): CypherMap
     {
         return new CypherMap($this);
     }
+
+    public function convertToBolt(): IStructure
+    {
+        return new \Bolt\structures\LocalDateTime($this->getSeconds(), $this->getNanoseconds());
+    }
 }

src/Types/LocalTime.php

@@ -13,14 +13,17 @@
 
 namespace Laudis\Neo4j\Types;
 
+use Bolt\structures\IStructure;
+use Laudis\Neo4j\Contracts\BoltConvertibleInterface;
+
 /**
  * The time of day represented in nanoseconds.
  *
  * @psalm-immutable
  *
  * @extends AbstractPropertyObject<int, int>
  */
-final class LocalTime extends AbstractPropertyObject
+final class LocalTime extends AbstractPropertyObject implements BoltConvertibleInterface
 {
     private int $nanoseconds;
 
@@ -49,4 +52,9 @@ public function getProperties(): CypherMap
     {
         return new CypherMap($this);
     }
+
+    public function convertToBolt(): IStructure
+    {
+        return new \Bolt\structures\LocalTime($this->getNanoseconds());
+    }
 }