migrations/Version20241227210638.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Schema\Schema;
  9. use Doctrine\Migrations\AbstractMigration;
  11. /**
  12.  * Auto-generated Migration: Please modify to your needs!
  13.  */
  14. final class Version20241227210638 extends AbstractMigration
  15. {
  16.     public function getDescription(): string
  17.     {
  18.         return '';
  19.     }
  21.     public function up(Schema $schema): void
  22.     {
  23.         // this up() migration is auto-generated, please modify it to your needs
  25.         // Fetch all users with non-empty params
  26.         $users = $this->connection->fetchAllAssociative('SELECT id, params FROM user WHERE params IS NOT NULL');
  28.         foreach ($users as $user) {
  29.             $userId = $user['id'];
  30.             $params = unserialize($user['params']);
  32.             // Check if params is a valid array
  33.             if (!\is_array($params)) {
  34.                 continue;
  35.             }
  37.             // Extract all stream IDs referenced in this user's params
  38.             $streamIds = $this->getStreamIdsFromParams($params);
  40.             // Clone params to track updates
  41.             $updatedParams = $params;
  43.             // Add "streams" property to each workspace if not already present
  44.             if (isset($params['workspaces']) && \is_array($updatedParams['workspaces'])) {
  45.                 foreach ($updatedParams['workspaces'] as &$workspace) {
  46.                     // Ensure streams is set for the workspace
  47.                     $workspace['streams'] = $workspace['streams'] ?? $streamIds;
  48.                 }
  49.             }
  51.             // Update the user params in the database if changes were made
  52.             if ($updatedParams !== $params) {
  53.                 $this->addSql('UPDATE user SET params = ? WHERE id = ?', [serialize($updatedParams), $userId]);
  54.             }
  55.         }
  56.     }
  58.     public function down(Schema $schema): void
  59.     {
  60.         // this down() migration is auto-generated, please modify it to your needs
  62.         // Fetch all users with non-empty params
  63.         $users = $this->connection->fetchAllAssociative('SELECT id, params FROM user WHERE params IS NOT NULL');
  65.         foreach ($users as $user) {
  66.             $userId = $user['id'];
  67.             $params = unserialize($user['params']);
  69.             // Check if params is a valid array
  70.             if (!\is_array($params)) {
  71.                 continue;
  72.             }
  74.             // Clone params to track updates
  75.             $updatedParams = $params;
  77.             // Remove "streams" property from each workspace if present
  78.             if (isset($params['workspaces']) && \is_array($updatedParams['workspaces'])) {
  79.                 foreach ($updatedParams['workspaces'] as &$workspace) {
  80.                     // Remove the "streams" property if it exists
  81.                     if (isset($workspace['streams'])) {
  82.                         unset($workspace['streams']);
  83.                     }
  84.                 }
  85.             }
  87.             // Update the user params in the database if changes were made
  88.             if ($updatedParams !== $params) {
  89.                 $this->addSql('UPDATE user SET params = ? WHERE id = ?', [serialize($updatedParams), $userId]);
  90.             }
  91.         }
  92.     }
  94.     /**
  95.      * Extract stream IDs from user's params.
  96.      */
  97.     private function getStreamIdsFromParams(array $params): array
  98.     {
  99.         $streamIds = [];
  101.         if (isset($params['workspaces']) && \is_array($params['workspaces'])) {
  102.             foreach ($params['workspaces'] as $workspace) {
  103.                 // Collect stream IDs from favorites
  104.                 if (isset($workspace['favorites'])) {
  105.                     $streamIds = array_merge($streamIds, $workspace['favorites']);
  106.                 }
  108.                 // Collect stream IDs from folders
  109.                 if (isset($workspace['folders']) && \is_array($workspace['folders'])) {
  110.                     foreach ($workspace['folders'] as $folder) {
  111.                         $streamIds = array_merge($streamIds, $folder);
  112.                     }
  113.                 }
  115.                 // Collect stream IDs from unassigned
  116.                 if (isset($workspace['unassigned'])) {
  117.                     $streamIds = array_merge($streamIds, $workspace['unassigned']);
  118.                 }
  119.             }
  120.         }
  122.         // Remove duplicates
  123.         $streamIds = array_unique($streamIds);
  125.         // Fetch and sort streams by modified_at
  126.         $streams = $this->connection->fetchAllAssociative(
  127.             'SELECT id, modified_at FROM w_stream WHERE id IN (:ids) ORDER BY modified_at DESC',
  128.             ['ids' => $streamIds],
  129.             ['ids' => Connection::PARAM_STR_ARRAY]
  130.         );
  132.         // Return sorted stream IDs
  133.         return array_column($streams, 'id');
  134.     }
  135. }