Merge pull request #178 from wayofdev/feat/factories

Author: lotyp

composer.lock

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace WayOfDev\Cycle\Bridge\Laravel\Factories;
+
+use Illuminate\Contracts\Container\BindingResolutionException;
+use Illuminate\Contracts\Foundation\Application;
+use Spiral\Core\FactoryInterface;
+
+final class SpiralFactory implements FactoryInterface
+{
+    public function __construct(private readonly Application $app)
+    {
+    }
+
+    /**
+     * @throws BindingResolutionException
+     */
+    public function make(string $alias, array $parameters = []): mixed
+    {
+        return $this->app->make($alias, $parameters);
+    }
+}

src/Bridge/Laravel/Factories/SpiralFactory.php

@@ -22,7 +22,7 @@ public function __invoke(Application $app): void
             $config = $app->get(MigrationConfig::class);
 
             return new FileRepository(
-                config: $config
+                config: $config,
             );
         });
 

src/Bridge/Laravel/Providers/Registrators/RegisterMigrations.php

@@ -14,6 +14,7 @@
 use Cycle\ORM\ORMInterface;
 use Cycle\ORM\SchemaInterface;
 use Illuminate\Contracts\Foundation\Application;
+use WayOfDev\Cycle\Bridge\Laravel\Factories\SpiralFactory;
 use WayOfDev\Cycle\Schema\Config\SchemaConfig;
 
 /**
@@ -32,6 +33,7 @@ public function __invoke(Application $app): void
             return new Factory(
                 dbal: $app->get(DatabaseProviderInterface::class),
                 config: $app->get(RelationConfig::class),
+                factory: $app->get(SpiralFactory::class),
                 defaultCollectionFactory: $factory
             );
         });

src/Bridge/Laravel/Providers/Registrators/RegisterORM.php

@@ -0,0 +1,44 @@
+<?php
+
+declare(strict_types=1);
+
+namespace WayOfDev\Cycle;
+
+use Cycle\ORM\EntityManagerInterface;
+use Cycle\ORM\Select;
+use Cycle\ORM\Select\Repository as CycleRepository;
+use Throwable;
+
+/**
+ * Repository provides ability to load entities and construct queries.
+ *
+ * @template TEntity of object
+ */
+class Repository extends CycleRepository
+{
+    /**
+     * Create repository linked to one specific selector.
+     *
+     * @param Select<TEntity> $select
+     */
+    public function __construct(
+        // @phpstan-ignore-next-line
+        protected Select $select,
+        protected EntityManagerInterface $entityManager
+    ) {
+        parent::__construct($select);
+    }
+
+    /**
+     * @throws Throwable
+     */
+    public function persist(object $entity, bool $cascade = true): void
+    {
+        $this->entityManager->persist(
+            $entity,
+            $cascade
+        );
+
+        $this->entityManager->run();
+    }
+}

src/Repository.php

@@ -4,33 +4,13 @@
 
 namespace WayOfDev\App\Repositories;
 
-use Cycle\ORM\EntityManager;
-use Cycle\ORM\ORMInterface;
-use Cycle\ORM\Select;
-use Cycle\ORM\Select\Repository;
-use Throwable;
 use WayOfDev\App\Entities\User;
+use WayOfDev\Cycle\Repository;
 
-class UserRepository extends Repository
+class UserRepository extends Repository implements UserRepositoryInterface
 {
-    private EntityManager $entityManager;
-
-    public function __construct(Select $select, ORMInterface $orm)
+    public function findByUsername(string $username): ?User
     {
-        parent::__construct($select);
-        $this->entityManager = new EntityManager($orm);
-    }
-
-    /**
-     * @throws Throwable
-     */
-    public function persist(User $user, bool $cascade = true): void
-    {
-        $this->entityManager->persist(
-            $user,
-            $cascade
-        );
-
-        $this->entityManager->run();
+        return $this->findOne(['username' => $username]);
     }
 }

tests/app/Repositories/UserRepository.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace WayOfDev\App\Repositories;
+
+use Cycle\ORM\RepositoryInterface;
+
+interface UserRepositoryInterface extends RepositoryInterface
+{
+}