Merge pull request #19 from justbetter/feature/fixes

Small fixes

Author: VincentBean

README.md

@@ -171,7 +171,6 @@ After you've created and configured the repository you have to set it in your co
 return [
     'repository' => \App\Integrations\MagentoStock\MyStockRepository::class,
 ];
-
 ```
 
 ### Usage

src/Actions/ProcessStocks.php

@@ -18,6 +18,7 @@ public function process(): void
         $repository = BaseRepository::resolve();
 
         Stock::query()
+            ->where('sync', '=', true)
             ->where('retrieve', '=', true)
             ->select(['sku'])
             ->take($repository->retrieveLimit())
@@ -26,6 +27,7 @@ public function process(): void
 
         if (config('magento-stock.async')) {
             $stocks = Stock::query()
+                ->where('sync', '=', true)
                 ->where('update', '=', true)
                 ->whereHas('product', function (Builder $query): void {
                     $query->where('exists_in_magento', '=', true);
@@ -37,6 +39,7 @@ public function process(): void
             UpdateStockAsyncJob::dispatch($stocks);
         } else {
             Stock::query()
+                ->where('sync', '=', true)
                 ->where('update', '=', true)
                 ->select(['id', 'sku'])
                 ->take($repository->updateLimit())

src/Models/Stock.php

@@ -80,6 +80,7 @@ public function failed(): void
         if (! $shouldRetry) {
             $this->update = false;
             $this->retrieve = false;
+            $this->fail_count = 0;
         }
 
         $this->save();

src/Repositories/Repository.php

@@ -20,6 +20,8 @@ public function skus(?Carbon $from = null): Collection
         /** @var Collection<int, string> $skus */
         $skus = MagentoProduct::query()
             ->where('exists_in_magento', '=', true)
+            ->select(['sku'])
+            ->distinct()
             ->pluck('sku');
 
         return $skus;

tests/Models/StockModelTest.php

@@ -39,7 +39,7 @@ public function it_will_set_retrieve_update_too_many_failures(): void
 
         $model->failed();
 
-        $this->assertEquals(101, $model->fail_count);
+        $this->assertEquals(0, $model->fail_count);
         $this->assertFalse($model->retrieve);
         $this->assertFalse($model->update);
     }