Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5be8a66ba7 |
No files matched your search
@@ -14,7 +14,7 @@ jobs:
|
|||||||
|
|
||||||
- name: Dependabot metadata
|
- name: Dependabot metadata
|
||||||
id: metadata
|
id: metadata
|
||||||
uses: dependabot/fetch-metadata@v2.5.0
|
uses: dependabot/fetch-metadata@v3.0.0
|
||||||
with:
|
with:
|
||||||
github-token: "${{ secrets.GITHUB_TOKEN }}"
|
github-token: "${{ secrets.GITHUB_TOKEN }}"
|
||||||
|
|
||||||
|
|||||||
+3
-8
@@ -1,5 +1,5 @@
|
|||||||
{
|
{
|
||||||
"name": "moltox/laravel-bitunix-api",
|
"name": "mahdimsr/laravel-bitunix-api",
|
||||||
"description": "composer package for using bitunix api trading",
|
"description": "composer package for using bitunix api trading",
|
||||||
"keywords": [
|
"keywords": [
|
||||||
"msr",
|
"msr",
|
||||||
@@ -13,17 +13,12 @@
|
|||||||
"name": "mahdi mansouri",
|
"name": "mahdi mansouri",
|
||||||
"email": "mahdi.msr4@gmail.com",
|
"email": "mahdi.msr4@gmail.com",
|
||||||
"role": "Developer"
|
"role": "Developer"
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "Maik Mueller ",
|
|
||||||
"email": "mueller.maik1@gmail.com",
|
|
||||||
"role": "Developer"
|
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"require": {
|
"require": {
|
||||||
"php": "^8.4",
|
"php": "^8.4",
|
||||||
"spatie/laravel-package-tools": "^1.16",
|
"spatie/laravel-package-tools": "^1.16",
|
||||||
"illuminate/contracts": "^10.0||^11.0||^12.0||^13.0"
|
"illuminate/contracts": "^11.0||^12.0||^10.0"
|
||||||
},
|
},
|
||||||
"require-dev": {
|
"require-dev": {
|
||||||
"laravel/pint": "^1.14",
|
"laravel/pint": "^1.14",
|
||||||
@@ -74,7 +69,7 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"version": "1.2.2",
|
"version": "1.1.0",
|
||||||
"minimum-stability": "stable",
|
"minimum-stability": "stable",
|
||||||
"prefer-stable": true
|
"prefer-stable": true
|
||||||
}
|
}
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
<?php
|
|
||||||
|
|
||||||
namespace Msr\LaravelBitunixApi\Contracts;
|
|
||||||
|
|
||||||
interface RateLimiterContract
|
|
||||||
{
|
|
||||||
public function throttle(
|
|
||||||
string $bucket,
|
|
||||||
string $identity,
|
|
||||||
int $maxRequests,
|
|
||||||
float $perSeconds
|
|
||||||
): void;
|
|
||||||
}
|
|
||||||
@@ -305,8 +305,10 @@ class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginMo
|
|||||||
$body['slStopType'] = $slStopType;
|
$body['slStopType'] = $slStopType;
|
||||||
}
|
}
|
||||||
|
|
||||||
return $this->getPrivateFutureClient([], $body)->post('tpsl/position/place_order', [
|
$response = $this->getPrivateFutureClient([], $body)->post('tpsl/position/place_order', [
|
||||||
'json' => $body,
|
'json' => $body,
|
||||||
]);
|
]);
|
||||||
|
|
||||||
|
return $response;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -3,7 +3,6 @@
|
|||||||
namespace Msr\LaravelBitunixApi;
|
namespace Msr\LaravelBitunixApi;
|
||||||
|
|
||||||
use Msr\LaravelBitunixApi\Commands\LaravelBitunixApiCommand;
|
use Msr\LaravelBitunixApi\Commands\LaravelBitunixApiCommand;
|
||||||
use Msr\LaravelBitunixApi\Contracts\RateLimiterContract;
|
|
||||||
use Msr\LaravelBitunixApi\Requests\ChangeLeverageRequestContract;
|
use Msr\LaravelBitunixApi\Requests\ChangeLeverageRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Requests\ChangeMarginModeRequestContract;
|
use Msr\LaravelBitunixApi\Requests\ChangeMarginModeRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Requests\FlashClosePositionRequestContract;
|
use Msr\LaravelBitunixApi\Requests\FlashClosePositionRequestContract;
|
||||||
@@ -14,10 +13,8 @@ use Msr\LaravelBitunixApi\Requests\GetTradingPairsRequestContract;
|
|||||||
use Msr\LaravelBitunixApi\Requests\PlaceOrderRequestContract;
|
use Msr\LaravelBitunixApi\Requests\PlaceOrderRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Requests\PlacePositionTpSlOrderRequestContract;
|
use Msr\LaravelBitunixApi\Requests\PlacePositionTpSlOrderRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Requests\PlaceTpSlOrderRequestContract;
|
use Msr\LaravelBitunixApi\Requests\PlaceTpSlOrderRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Support\CacheRateLimiter;
|
|
||||||
use Spatie\LaravelPackageTools\Package;
|
use Spatie\LaravelPackageTools\Package;
|
||||||
use Spatie\LaravelPackageTools\PackageServiceProvider;
|
use Spatie\LaravelPackageTools\PackageServiceProvider;
|
||||||
use Illuminate\Contracts\Cache\Factory as CacheFactory;
|
|
||||||
|
|
||||||
class LaravelBitunixApiServiceProvider extends PackageServiceProvider
|
class LaravelBitunixApiServiceProvider extends PackageServiceProvider
|
||||||
{
|
{
|
||||||
@@ -50,11 +47,5 @@ class LaravelBitunixApiServiceProvider extends PackageServiceProvider
|
|||||||
$this->app->bind(PlaceTpSlOrderRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(PlaceTpSlOrderRequestContract::class, LaravelBitunixApi::class);
|
||||||
$this->app->bind(PlacePositionTpSlOrderRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(PlacePositionTpSlOrderRequestContract::class, LaravelBitunixApi::class);
|
||||||
$this->app->bind(GetTradingPairsRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(GetTradingPairsRequestContract::class, LaravelBitunixApi::class);
|
||||||
|
|
||||||
$this->app->bind(RateLimiterContract::class, function ($app) {
|
|
||||||
return new CacheRateLimiter(
|
|
||||||
$app->make(CacheFactory::class)->store()
|
|
||||||
);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1,57 +0,0 @@
|
|||||||
<?php
|
|
||||||
|
|
||||||
namespace Msr\LaravelBitunixApi\Support;
|
|
||||||
|
|
||||||
use Illuminate\Contracts\Cache\Repository;
|
|
||||||
use Msr\LaravelBitunixApi\Contracts\RateLimiterContract;
|
|
||||||
|
|
||||||
class CacheRateLimiter implements RateLimiterContract
|
|
||||||
{
|
|
||||||
public function __construct(
|
|
||||||
protected Repository $cache,
|
|
||||||
) {
|
|
||||||
}
|
|
||||||
|
|
||||||
public function throttle(
|
|
||||||
string $bucket,
|
|
||||||
string $identity,
|
|
||||||
int $maxRequests,
|
|
||||||
float $perSeconds
|
|
||||||
): void {
|
|
||||||
if ($maxRequests <= 0 || $perSeconds <= 0) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
$cacheKey = $this->makeCacheKey($bucket, $identity);
|
|
||||||
$minIntervalMicroseconds = (int) (($perSeconds / $maxRequests) * 1_000_000);
|
|
||||||
|
|
||||||
$lastRequestAt = $this->cache->get($cacheKey);
|
|
||||||
|
|
||||||
if (is_numeric($lastRequestAt)) {
|
|
||||||
$elapsedMicroseconds = (int) ((microtime(true) - (float) $lastRequestAt) * 1_000_000);
|
|
||||||
|
|
||||||
if ($elapsedMicroseconds < $minIntervalMicroseconds) {
|
|
||||||
$sleepMicroseconds = $minIntervalMicroseconds - $elapsedMicroseconds;
|
|
||||||
|
|
||||||
if ($sleepMicroseconds > 0) {
|
|
||||||
usleep($sleepMicroseconds);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
$this->cache->put(
|
|
||||||
$cacheKey,
|
|
||||||
microtime(true),
|
|
||||||
now()->addSeconds((int) max(1, ceil($perSeconds * 2)))
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
protected function makeCacheKey(string $bucket, string $identity): string
|
|
||||||
{
|
|
||||||
return sprintf(
|
|
||||||
'laravel_bitunix_api:rate_limit:%s:%s',
|
|
||||||
$bucket,
|
|
||||||
sha1($identity)
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in new issue
Block a user