Compare commits
No commits in common. "3845bf12c17155977a7b829b06bc1de16a28e2c4" and "6730ac8adac05c9c1d5bbbdddb6256776c56c61f" have entirely different histories.
3845bf12c1
...
6730ac8ada
|
|
@ -26,9 +26,9 @@
|
||||||
"illuminate/contracts": "^10.0||^11.0||^12.0||^13.0"
|
"illuminate/contracts": "^10.0||^11.0||^12.0||^13.0"
|
||||||
},
|
},
|
||||||
"require-dev": {
|
"require-dev": {
|
||||||
"larastan/larastan": "^3.0",
|
"laravel/pint": "^1.14",
|
||||||
"laravel/pint": "^1.29",
|
|
||||||
"nunomaduro/collision": "^8.8",
|
"nunomaduro/collision": "^8.8",
|
||||||
|
"larastan/larastan": "^3.0",
|
||||||
"orchestra/testbench": "^10.0.0||^9.0.0",
|
"orchestra/testbench": "^10.0.0||^9.0.0",
|
||||||
"pestphp/pest": "^4.0",
|
"pestphp/pest": "^4.0",
|
||||||
"pestphp/pest-plugin-arch": "^4.0",
|
"pestphp/pest-plugin-arch": "^4.0",
|
||||||
|
|
@ -55,8 +55,7 @@
|
||||||
"analyse": "vendor/bin/phpstan analyse",
|
"analyse": "vendor/bin/phpstan analyse",
|
||||||
"test": "vendor/bin/pest",
|
"test": "vendor/bin/pest",
|
||||||
"test-coverage": "vendor/bin/pest --coverage",
|
"test-coverage": "vendor/bin/pest --coverage",
|
||||||
"format": "vendor/bin/pint",
|
"format": "vendor/bin/pint"
|
||||||
"pint": "vendor/bin/pint --ansi"
|
|
||||||
},
|
},
|
||||||
"config": {
|
"config": {
|
||||||
"sort-packages": true,
|
"sort-packages": true,
|
||||||
|
|
@ -75,7 +74,7 @@
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"version": "1.2.3",
|
"version": "1.2.2",
|
||||||
"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;
|
|
||||||
}
|
|
||||||
|
|
@ -4,7 +4,6 @@ namespace Msr\LaravelBitunixApi;
|
||||||
|
|
||||||
use GuzzleHttp\Client;
|
use GuzzleHttp\Client;
|
||||||
use GuzzleHttp\Exception\GuzzleException;
|
use GuzzleHttp\Exception\GuzzleException;
|
||||||
use Msr\LaravelBitunixApi\Contracts\RateLimiterContract as RateLimiter;
|
|
||||||
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;
|
||||||
|
|
@ -20,11 +19,16 @@ use Msr\LaravelBitunixApi\Requests\PlacePositionTpSlOrderRequestContract;
|
||||||
use Msr\LaravelBitunixApi\Requests\PlaceTpSlOrderRequestContract;
|
use Msr\LaravelBitunixApi\Requests\PlaceTpSlOrderRequestContract;
|
||||||
use Psr\Http\Message\ResponseInterface;
|
use Psr\Http\Message\ResponseInterface;
|
||||||
|
|
||||||
class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginModeRequestContract, FlashClosePositionRequestContract, FutureKLineRequestContract, GetHistoryPositionsRequestContract, GetHistoryTradesRequestContract, GetPendingPositionsRequestContract, GetSingleAccountRequestContract, GetTradingPairsRequestContract, PlaceOrderRequestContract, PlacePositionTpSlOrderRequestContract, PlaceTpSlOrderRequestContract
|
class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginModeRequestContract,
|
||||||
|
FlashClosePositionRequestContract, FutureKLineRequestContract,
|
||||||
|
GetPendingPositionsRequestContract, GetSingleAccountRequestContract,
|
||||||
|
GetTradingPairsRequestContract, PlaceOrderRequestContract,
|
||||||
|
PlacePositionTpSlOrderRequestContract, PlaceTpSlOrderRequestContract,
|
||||||
|
GetHistoryPositionsRequestContract, GetHistoryTradesRequestContract
|
||||||
{
|
{
|
||||||
private Client $publicFutureClient;
|
private Client $publicFutureClient;
|
||||||
|
|
||||||
public function __construct(protected RateLimiter $rateLimiter)
|
public function __construct()
|
||||||
{
|
{
|
||||||
$this->publicFutureClient = new Client([
|
$this->publicFutureClient = new Client([
|
||||||
'base_uri' => config('bitunix-api.future_base_uri') . '/api/v1/futures/market/',
|
'base_uri' => config('bitunix-api.future_base_uri') . '/api/v1/futures/market/',
|
||||||
|
|
@ -207,13 +211,6 @@ class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginMo
|
||||||
int $skip = 0,
|
int $skip = 0,
|
||||||
int $limit = 100
|
int $limit = 100
|
||||||
): ResponseInterface {
|
): ResponseInterface {
|
||||||
$this->rateLimiter->throttle(
|
|
||||||
'futures::get_history_trades',
|
|
||||||
$this->resolveRateLimitIdentity(),
|
|
||||||
maxRequests: 8,
|
|
||||||
perSeconds: 1
|
|
||||||
);
|
|
||||||
|
|
||||||
$queryParams = [
|
$queryParams = [
|
||||||
'skip' => $skip,
|
'skip' => $skip,
|
||||||
'limit' => $limit,
|
'limit' => $limit,
|
||||||
|
|
@ -246,6 +243,7 @@ class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginMo
|
||||||
return $response;
|
return $response;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public function getPendingPositions(?string $symbol = null, ?string $positionId = null): ResponseInterface
|
public function getPendingPositions(?string $symbol = null, ?string $positionId = null): ResponseInterface
|
||||||
{
|
{
|
||||||
$queryParams = [];
|
$queryParams = [];
|
||||||
|
|
@ -275,13 +273,6 @@ class LaravelBitunixApi implements ChangeLeverageRequestContract, ChangeMarginMo
|
||||||
int $skip = 0,
|
int $skip = 0,
|
||||||
int $limit = 100
|
int $limit = 100
|
||||||
): ResponseInterface {
|
): ResponseInterface {
|
||||||
$this->rateLimiter->throttle(
|
|
||||||
'futures::get_history_positions',
|
|
||||||
$this->resolveRateLimitIdentity(),
|
|
||||||
maxRequests: 8,
|
|
||||||
perSeconds: 1
|
|
||||||
);
|
|
||||||
|
|
||||||
$queryParams = [
|
$queryParams = [
|
||||||
'skip' => $skip,
|
'skip' => $skip,
|
||||||
'limit' => $limit,
|
'limit' => $limit,
|
||||||
|
|
@ -402,13 +393,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,
|
||||||
]);
|
]);
|
||||||
}
|
|
||||||
|
|
||||||
protected function resolveRateLimitIdentity(): string
|
return $response;
|
||||||
{
|
|
||||||
return (string) config('bitunix-api.api_key');
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -2,9 +2,7 @@
|
||||||
|
|
||||||
namespace Msr\LaravelBitunixApi;
|
namespace Msr\LaravelBitunixApi;
|
||||||
|
|
||||||
use Illuminate\Contracts\Cache\Factory as CacheFactory;
|
|
||||||
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;
|
||||||
|
|
@ -17,7 +15,6 @@ 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;
|
||||||
|
|
||||||
|
|
@ -54,11 +51,5 @@ class LaravelBitunixApiServiceProvider extends PackageServiceProvider
|
||||||
$this->app->bind(GetTradingPairsRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(GetTradingPairsRequestContract::class, LaravelBitunixApi::class);
|
||||||
$this->app->bind(GetHistoryTradesRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(GetHistoryTradesRequestContract::class, LaravelBitunixApi::class);
|
||||||
$this->app->bind(GetHistoryPositionsRequestContract::class, LaravelBitunixApi::class);
|
$this->app->bind(GetHistoryPositionsRequestContract::class, LaravelBitunixApi::class);
|
||||||
|
|
||||||
$this->app->bind(RateLimiterContract::class, function ($app) {
|
|
||||||
return new CacheRateLimiter(
|
|
||||||
$app->make(CacheFactory::class)->store()
|
|
||||||
);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,56 +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)
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue