@@ -21,6 +21,9 @@ class QueueTest extends TestCase
21
21
/** @var AdapterInterface */
22
22
private $ connection ;
23
23
24
+ /** @var Queue */
25
+ private $ queue ;
26
+
24
27
public function setUp (): void
25
28
{
26
29
parent ::setUp ();
@@ -30,13 +33,15 @@ public function setUp(): void
30
33
/** @var ResourceConnection $resouce */
31
34
$ resouce = $ this ->getObjectManager ()->create (ResourceConnection::class);
32
35
$ this ->connection = $ resouce ->getConnection ();
36
+
37
+ $ this ->queue = $ this ->getObjectManager ()->create (Queue::class);
33
38
}
34
39
35
40
public function testFill ()
36
41
{
37
42
$ this ->resetConfigs ([
38
43
'algoliasearch_queue/queue/number_of_job_to_run ' ,
39
- 'algoliasearch_advanced/advanced /number_of_element_by_page ' ,
44
+ 'algoliasearch_advanced/queue /number_of_element_by_page ' ,
40
45
]);
41
46
42
47
$ this ->setConfig ('algoliasearch_queue/queue/active ' , '1 ' );
@@ -136,7 +141,7 @@ public function testSettings()
136
141
137
142
$ this ->resetConfigs ([
138
143
'algoliasearch_queue/queue/number_of_job_to_run ' ,
139
- 'algoliasearch_advanced/advanced /number_of_element_by_page ' ,
144
+ 'algoliasearch_advanced/queue /number_of_element_by_page ' ,
140
145
'algoliasearch_instant/instant/facets ' ,
141
146
'algoliasearch_products/products/product_additional_attributes ' ,
142
147
]);
@@ -172,13 +177,14 @@ public function testSettings()
172
177
$ this ->assertFalse (empty ($ settings ['searchableAttributes ' ]), 'SearchableAttributes should be set, but they are not. ' );
173
178
}
174
179
180
+ /**
181
+ * @magentoDbIsolation disabled
182
+ */
175
183
public function testMergeSettings ()
176
184
{
177
- $ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
178
-
179
185
$ this ->setConfig ('algoliasearch_queue/queue/active ' , '1 ' );
180
186
$ this ->setConfig ('algoliasearch_queue/queue/number_of_job_to_run ' , 1 );
181
- $ this ->setConfig ('algoliasearch_advanced/advanced /number_of_element_by_page ' , 300 );
187
+ $ this ->setConfig ('algoliasearch_advanced/queue /number_of_element_by_page ' , 300 );
182
188
183
189
$ this ->connection ->query ('DELETE FROM algoliasearch_queue ' );
184
190
@@ -213,10 +219,11 @@ public function testMergeSettings()
213
219
$ this ->assertEquals (['sku ' ], $ settings ['disableTypoToleranceOnAttributes ' ]);
214
220
}
215
221
222
+ /**
223
+ * @magentoDbIsolation disabled
224
+ */
216
225
public function testMerging ()
217
226
{
218
- $ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
219
-
220
227
$ this ->connection ->query ('DELETE FROM algoliasearch_queue ' );
221
228
222
229
$ data = [
@@ -357,13 +364,10 @@ public function testMerging()
357
364
358
365
$ this ->connection ->insertMultiple ('algoliasearch_queue ' , $ data );
359
366
360
- /** @var Queue $queue */
361
- $ queue = $ this ->getObjectManager ()->create (Queue::class);
362
-
363
367
$ jobs = $ this ->jobsCollectionFactory ->create ()->getItems ();
364
368
// $jobs = $this->connection->query('SELECT * FROM algoliasearch_queue')->fetchAll();
365
369
366
- $ mergedJobs = array_values ($ this ->invokeMethod ($ queue , 'mergeJobs ' , [$ jobs ]));
370
+ $ mergedJobs = array_values ($ this ->invokeMethod ($ this -> queue , 'mergeJobs ' , [$ jobs ]));
367
371
$ this ->assertEquals (6 , count ($ mergedJobs ));
368
372
369
373
$ expectedCategoryJob = [
@@ -389,6 +393,7 @@ public function testMerging()
389
393
],
390
394
],
391
395
'locked_at ' => null ,
396
+ 'debug ' => null ,
392
397
];
393
398
394
399
/** @var Job $categoryJob */
@@ -417,13 +422,17 @@ public function testMerging()
417
422
],
418
423
],
419
424
'locked_at ' => null ,
425
+ 'debug ' => null ,
420
426
];
421
427
422
428
/** @var Job $productJob */
423
429
$ productJob = $ mergedJobs [3 ];
424
430
$ this ->assertEquals ($ expectedProductJob , $ productJob ->toArray ());
425
431
}
426
432
433
+ /**
434
+ * @magentoDbIsolation disabled
435
+ */
427
436
public function testMergingWithStaticMethods ()
428
437
{
429
438
$ this ->connection ->query ('TRUNCATE TABLE algoliasearch_queue ' );
@@ -552,15 +561,12 @@ public function testMergingWithStaticMethods()
552
561
],
553
562
];
554
563
555
- /** @var Queue $queue */
556
- $ queue = $ this ->getObjectManager ()->create (Queue::class);
557
-
558
564
$ this ->connection ->insertMultiple ('algoliasearch_queue ' , $ data );
559
565
560
566
/** @var Job[] $jobs */
561
567
$ jobs = $ this ->jobsCollectionFactory ->create ()->getItems ();
562
568
563
- $ jobs = array_values ($ this ->invokeMethod ($ queue , 'mergeJobs ' , [$ jobs ]));
569
+ $ jobs = array_values ($ this ->invokeMethod ($ this -> queue , 'mergeJobs ' , [$ jobs ]));
564
570
$ this ->assertEquals (12 , count ($ jobs ));
565
571
566
572
$ this ->assertEquals ('rebuildStoreCategoryIndex ' , $ jobs [0 ]->getMethod ());
@@ -577,6 +583,9 @@ public function testMergingWithStaticMethods()
577
583
$ this ->assertEquals ('rebuildStoreProductIndex ' , $ jobs [11 ]->getMethod ());
578
584
}
579
585
586
+ /**
587
+ * @magentoDbIsolation disabled
588
+ */
580
589
public function testGetJobs ()
581
590
{
582
591
$ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
@@ -721,11 +730,8 @@ public function testGetJobs()
721
730
722
731
$ this ->connection ->insertMultiple ('algoliasearch_queue ' , $ data );
723
732
724
- /** @var Queue $queue */
725
- $ queue = $ this ->getObjectManager ()->create (Queue::class);
726
-
727
733
$ pid = getmypid ();
728
- $ jobs = $ this ->invokeMethod ($ queue , 'getJobs ' , ['maxJobs ' => 10 ]);
734
+ $ jobs = $ this ->invokeMethod ($ this -> queue , 'getJobs ' , ['maxJobs ' => 10 ]);
729
735
$ this ->assertEquals (6 , count ($ jobs ));
730
736
731
737
$ expectedFirstJob = [
@@ -751,6 +757,7 @@ public function testGetJobs()
751
757
],
752
758
],
753
759
'locked_at ' => null ,
760
+ 'debug ' => null ,
754
761
];
755
762
756
763
$ expectedLastJob = [
@@ -775,6 +782,7 @@ public function testGetJobs()
775
782
],
776
783
],
777
784
'locked_at ' => null ,
785
+ 'debug ' => null ,
778
786
];
779
787
780
788
/** @var Job $firstJob */
@@ -795,10 +803,11 @@ public function testGetJobs()
795
803
}
796
804
}
797
805
806
+ /**
807
+ * @magentoDbIsolation disabled
808
+ */
798
809
public function testHugeJob ()
799
810
{
800
- $ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
801
-
802
811
// Default value - maxBatchSize = 1000
803
812
$ this ->setConfig ('algoliasearch_queue/queue/number_of_job_to_run ' , 10 );
804
813
$ this ->setConfig ('algoliasearch_advanced/advanced/number_of_element_by_page ' , 100 );
@@ -811,12 +820,9 @@ public function testHugeJob()
811
820
(1, NULL, \'class \', \'rebuildStoreProductIndex \', \'{"store_id":"1","product_ids": ' . $ jsonProductIds . '} \', 3, 0, \'\', 5000),
812
821
(2, NULL, \'class \', \'rebuildStoreProductIndex \', \'{"store_id":"2","product_ids":["9","22"]} \', 3, 0, \'\', 2); ' );
813
822
814
- /** @var Queue $queue */
815
- $ queue = $ this ->getObjectManager ()->create (Queue::class);
816
-
817
823
$ pid = getmypid ();
818
824
/** @var Job[] $jobs */
819
- $ jobs = $ this ->invokeMethod ($ queue , 'getJobs ' , ['maxJobs ' => 10 ]);
825
+ $ jobs = $ this ->invokeMethod ($ this -> queue , 'getJobs ' , ['maxJobs ' => 10 ]);
820
826
821
827
$ this ->assertEquals (1 , count ($ jobs ));
822
828
@@ -835,13 +841,14 @@ public function testHugeJob()
835
841
$ this ->assertNull ($ lastJob ['pid ' ]);
836
842
}
837
843
844
+ /**
845
+ * @magentoDbIsolation disabled
846
+ */
838
847
public function testMaxSingleJobSize ()
839
848
{
840
- $ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
841
-
842
849
// Default value - maxBatchSize = 1000
843
850
$ this ->setConfig ('algoliasearch_queue/queue/number_of_job_to_run ' , 10 );
844
- $ this ->setConfig ('algoliasearch_advanced/advanced /number_of_element_by_page ' , 100 );
851
+ $ this ->setConfig ('algoliasearch_advanced/queue /number_of_element_by_page ' , 100 );
845
852
846
853
$ productIds = range (1 , 99 );
847
854
$ jsonProductIds = json_encode ($ productIds );
@@ -851,13 +858,10 @@ public function testMaxSingleJobSize()
851
858
(1, NULL, \'class \', \'rebuildStoreProductIndex \', \'{"store_id":"1","product_ids": ' . $ jsonProductIds . '} \', 3, 0, \'\', 99),
852
859
(2, NULL, \'class \', \'rebuildStoreProductIndex \', \'{"store_id":"2","product_ids":["9","22"]} \', 3, 0, \'\', 2); ' );
853
860
854
- /** @var Queue $queue */
855
- $ queue = $ this ->getObjectManager ()->create (Queue::class);
856
-
857
861
$ pid = getmypid ();
858
862
859
863
/** @var Job[] $jobs */
860
- $ jobs = $ this ->invokeMethod ($ queue , 'getJobs ' , ['maxJobs ' => 10 ]);
864
+ $ jobs = $ this ->invokeMethod ($ this -> queue , 'getJobs ' , ['maxJobs ' => 10 ]);
861
865
862
866
$ this ->assertEquals (2 , count ($ jobs ));
863
867
@@ -881,19 +885,20 @@ public function testMaxSingleJobSize()
881
885
$ this ->assertEquals ($ pid , $ lastJob ['pid ' ]);
882
886
}
883
887
888
+ /**
889
+ * @magentoDbIsolation disabled
890
+ */
884
891
public function testMaxSingleJobsSizeOnProductReindex ()
885
892
{
886
- $ this ->markTestIncomplete (self ::INCOMPLETE_REASON );
887
-
888
893
$ this ->resetConfigs ([
889
894
'algoliasearch_queue/queue/number_of_job_to_run ' ,
890
- 'algoliasearch_advanced/advanced /number_of_element_by_page ' ,
895
+ 'algoliasearch_advanced/queue /number_of_element_by_page ' ,
891
896
]);
892
897
893
898
$ this ->setConfig ('algoliasearch_queue/queue/active ' , '1 ' );
894
899
895
900
$ this ->setConfig ('algoliasearch_queue/queue/number_of_job_to_run ' , 10 );
896
- $ this ->setConfig ('algoliasearch_advanced/advanced /number_of_element_by_page ' , 100 );
901
+ $ this ->setConfig ('algoliasearch_advanced/queue /number_of_element_by_page ' , 100 );
897
902
898
903
$ this ->connection ->query ('TRUNCATE TABLE algoliasearch_queue ' );
899
904
0 commit comments