fix migrate cron service

Author: thomas-kl1

Model/Migrate.php

@@ -66,6 +66,7 @@ public function migrateQueue(): void
         // Start migration
         $this->migrateDb->updateState($typeIds, 'running');
 
+        // Todo: handle batch management to avoid out of memory on large dataset with tons of files
         $documentCollection = $this->createDocumentCollection($typeIds);
         $docTypeCollection = $this->createDocTypeCollection($typeIds);
 
@@ -99,7 +100,7 @@ private function createDocTypeCollection(array $typeIds): DocTypeCollection
     {
         $docTypeCollection = $this->docTypeCollectionFactory->create();
         $docTypeCollection->addFieldToSelect(['entity_id', 'file_dest_path', 'sub_path_length', 'is_restricted']);
-        $docTypeCollection->addFieldToFilter('type_id', ['in' => $typeIds]);
+        $docTypeCollection->addFieldToFilter('entity_id', ['in' => $typeIds]);
 
         return $docTypeCollection;
     }

etc/crontab.xml

@@ -8,10 +8,10 @@
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:module:Magento_Cron:etc/crontab.xsd">
     <group id="opengento_document">
         <job name="opengento_document_type_restrict_migrate" instance="Opengento\DocumentRestrict\Cron\Migrate" method="execute">
-            <config_path>opengento_document/migrate/schedule_migrate</config_path>
+            <config_path>opengento_document/migrate/migrate_schedule</config_path>
         </job>
         <job name="opengento_document_type_restrict_migrate_rotate" instance="Opengento\DocumentRestrict\Cron\Rotate" method="execute">
-            <config_path>opengento_document/migrate/schedule_rotate</config_path>
+            <config_path>opengento_document/migrate/rotate_schedule</config_path>
         </job>
     </group>
 </config>

etc/db_schema.xml

@@ -40,10 +40,10 @@
         <constraint xsi:type="primary" referenceId="PRIMARY">
             <column name="entity_id"/>
         </constraint>
-        <constraint xsi:type="foreign" referenceId="OPENGENTO_DOCUMENT_RESTRICT_TYPE_ID_OPENGENTO_DOCUMENT_TYPE_ENTITY_ID" table="opengento_document_type_restrict_migrate" column="type_id" referenceTable="opengento_document_type" referenceColumn="entity_id" onDelete="CASCADE"/>
-        <constraint xsi:type="unique" referenceId="OPENGENTO_DOCUMENT_TYPE_RESTRICT_TYPE_ID">
+        <constraint xsi:type="foreign" referenceId="OPENGENTO_DOCUMENT_RESTRICT_MIGRATE_TYPE_ID_OPENGENTO_DOCUMENT_TYPE_ENTITY_ID" table="opengento_document_type_restrict_migrate" column="type_id" referenceTable="opengento_document_type" referenceColumn="entity_id" onDelete="CASCADE"/>
+        <index referenceId="OPENGENTO_DOCUMENT_TYPE_RESTRICT_MIGRATE_TYPE_ID" indexType="btree">
             <column name="type_id"/>
-        </constraint>
+        </index>
     </table>
     <!-- opengento_document_type_restrict_customer -->
     <!-- new relations in (document type or document) -->