Code Duplication    Length = 61-65 lines in 3 locations

src/Package/MySqlPassportMigration.php 1 location

@@ 29-89 (lines=61) @@
26
/**
27
 * @package Limoncello\Passport
28
 */
29
class MySqlPassportMigration implements MigrationInterface
30
{
31
    use DatabaseSchemaMigrationTrait;
32
33
    /**
34
     * @var ContainerInterface
35
     */
36
    private $container;
37
38
    /**
39
     * @inheritdoc
40
     */
41
    public function init(ContainerInterface $container): MigrationInterface
42
    {
43
        $this->container = $container;
44
45
        return $this;
46
    }
47
48
    /**
49
     * @return void
50
     *
51
     * @throws DBALException
52
     */
53
    public function migrate(): void
54
    {
55
        $this->createDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
56
    }
57
58
    /**
59
     * @return void
60
     *
61
     * @throws DBALException
62
     */
63
    public function rollback(): void
64
    {
65
        $this->removeDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
66
    }
67
68
    /**
69
     * @return ContainerInterface
70
     */
71
    protected function getContainer(): ContainerInterface
72
    {
73
        assert($this->container !== null);
74
75
        return $this->container;
76
    }
77
78
    /**
79
     * @return Connection
80
     */
81
    protected function getConnection(): Connection
82
    {
83
        return $this->getContainer()->get(Connection::class);
84
    }
85
86
    /**
87
     * @return DatabaseSchemaInterface
88
     */
89
    protected function getDatabaseSchema(): DatabaseSchemaInterface
90
    {
91
        return $this->getContainer()->get(DatabaseSchemaInterface::class);
92
    }

src/Package/PassportMigration.php 1 location

@@ 29-89 (lines=61) @@
26
/**
27
 * @package Limoncello\Passport
28
 */
29
class PassportMigration implements MigrationInterface
30
{
31
    use DatabaseSchemaMigrationTrait;
32
33
    /**
34
     * @var ContainerInterface
35
     */
36
    private $container;
37
38
    /**
39
     * @inheritdoc
40
     */
41
    public function init(ContainerInterface $container): MigrationInterface
42
    {
43
        $this->container = $container;
44
45
        return $this;
46
    }
47
48
    /**
49
     * @return void
50
     *
51
     * @throws DBALException
52
     */
53
    public function migrate(): void
54
    {
55
        $this->createDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
56
    }
57
58
    /**
59
     * @return void
60
     */
61
    public function rollback(): void
62
    {
63
        $this->removeDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
64
    }
65
66
    /**
67
     * @return ContainerInterface
68
     */
69
    protected function getContainer(): ContainerInterface
70
    {
71
        assert($this->container !== null);
72
73
        return $this->container;
74
    }
75
76
    /**
77
     * @return Connection
78
     */
79
    protected function getConnection(): Connection
80
    {
81
        return $this->getContainer()->get(Connection::class);
82
    }
83
84
    /**
85
     * @return DatabaseSchemaInterface
86
     */
87
    protected function getDatabaseSchema(): DatabaseSchemaInterface
88
    {
89
        return $this->getContainer()->get(DatabaseSchemaInterface::class);
90
    }
91
}
92

src/Package/PostgreSqlPassportMigration.php 1 location

@@ 29-93 (lines=65) @@
26
/**
27
 * @package Limoncello\Passport
28
 */
29
class PostgreSqlPassportMigration implements MigrationInterface
30
{
31
    use DatabaseSchemaMigrationTrait;
32
33
    /**
34
     * @var ContainerInterface
35
     */
36
    private $container;
37
38
    /**
39
     * @inheritdoc
40
     */
41
    public function init(ContainerInterface $container): MigrationInterface
42
    {
43
        $this->container = $container;
44
45
        return $this;
46
    }
47
48
    /**
49
     * @return void
50
     *
51
     * @throws DBALException
52
     */
53
    public function migrate(): void
54
    {
55
        $this->createDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
56
    }
57
58
    /**
59
     * @return void
60
     *
61
     * @throws DBALException
62
     */
63
    public function rollback(): void
64
    {
65
        $this->removeDatabaseSchema($this->getConnection(), $this->getDatabaseSchema());
66
    }
67
68
    /**
69
     * @return ContainerInterface
70
     */
71
    protected function getContainer(): ContainerInterface
72
    {
73
        assert($this->container !== null);
74
75
        return $this->container;
76
    }
77
78
    /**
79
     * @return Connection
80
     */
81
    protected function getConnection(): Connection
82
    {
83
        return $this->getContainer()->get(Connection::class);
84
    }
85
86
    /**
87
     * @return DatabaseSchemaInterface
88
     */
89
    protected function getDatabaseSchema(): DatabaseSchemaInterface
90
    {
91
        return $this->getContainer()->get(DatabaseSchemaInterface::class);
92
    }
93
}
94