12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- <?php
- declare(strict_types=1);
- namespace OCA\OAuth2\Migration;
- use Closure;
- use OCP\DB\ISchemaWrapper;
- use OCP\DB\QueryBuilder\IQueryBuilder;
- use OCP\IDBConnection;
- use OCP\Migration\IOutput;
- use OCP\Migration\SimpleMigrationStep;
- use OCP\Security\ICrypto;
- class Version011601Date20230522143227 extends SimpleMigrationStep {
- public function __construct(
- private IDBConnection $connection,
- private ICrypto $crypto,
- ) {
- }
- public function changeSchema(IOutput $output, Closure $schemaClosure, array $options) {
-
- $schema = $schemaClosure();
- if ($schema->hasTable('oauth2_clients')) {
- $table = $schema->getTable('oauth2_clients');
- if ($table->hasColumn('secret')) {
- $column = $table->getColumn('secret');
- $column->setLength(512);
- return $schema;
- }
- }
- return null;
- }
- public function postSchemaChange(IOutput $output, Closure $schemaClosure, array $options) {
- $qbUpdate = $this->connection->getQueryBuilder();
- $qbUpdate->update('oauth2_clients')
- ->set('secret', $qbUpdate->createParameter('updateSecret'))
- ->where(
- $qbUpdate->expr()->eq('id', $qbUpdate->createParameter('updateId'))
- );
- $qbSelect = $this->connection->getQueryBuilder();
- $qbSelect->select('id', 'secret')
- ->from('oauth2_clients');
- $req = $qbSelect->executeQuery();
- while ($row = $req->fetch()) {
- $id = $row['id'];
- $secret = $row['secret'];
- $encryptedSecret = $this->crypto->encrypt($secret);
- $qbUpdate->setParameter('updateSecret', $encryptedSecret, IQueryBuilder::PARAM_STR);
- $qbUpdate->setParameter('updateId', $id, IQueryBuilder::PARAM_INT);
- $qbUpdate->executeStatement();
- }
- $req->closeCursor();
- }
- }
|