Merge pull request #115 from cego/lejo/remove-nbj-stopwatch

Remove nbj/stopwatch
cego · Nov 13, 2024 · c1253ba · c1253ba
2 parents 5a5480b + f9cfe8e
commit c1253ba
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/composer.json b/composer.json
@@ -18,7 +18,6 @@
         "ext-pcntl": "*",
         "ext-curl": "*",
         "nesbot/carbon": "^2.17|^3.0",
-        "nbj/stopwatch": "^0.0.5",
         "illuminate/view": "^7.0|^8.0|^9.0|^10.0|^11.0",
         "illuminate/http": "^7.0|^8.0|^9.0|^10.0|^11.0",
         "illuminate/routing": "^7.0|^8.0|^9.0|^10.0|^11.0",

diff --git a/src/RequestInsurance/RequestInsuranceWorker.php b/src/RequestInsurance/RequestInsuranceWorker.php
@@ -6,7 +6,6 @@
 use Exception;
 use Throwable;
 use Carbon\Carbon;
-use Nbj\Stopwatch;
 use Carbon\CarbonImmutable;
 use Illuminate\Support\Str;
 use Illuminate\Support\Collection;
@@ -74,12 +73,14 @@ public function run(bool $runOnlyOnce = false): void
                     DB::reconnect();
                 }
 
-                $executionTime = Stopwatch::time(function () {
-                    $this->processRequestInsurances();
-                    $this->atMostOnceEverySecond(fn () => $this->readyWaitingRequestInsurances());
-                });
+                $start = hrtime(true);
 
-                $waitTime = (int) max(Config::get('request-insurance.microSecondsToWait') - $executionTime->microseconds(), 0);
+                $this->processRequestInsurances();
+                $this->atMostOnceEverySecond(fn () => $this->readyWaitingRequestInsurances());
+
+                $executionTimeNs = hrtime(true) - $start;
+
+                $waitTime = (int) max(Config::get('request-insurance.microSecondsToWait') - ($executionTimeNs / 1000), 0);
 
                 usleep($waitTime);
             } catch (Throwable $throwable) {