Mokka\Exchange\Market\Binance

Complexity

Total Complexity

9

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getHistoricalPrices()	0	2	1
A	sellOrder()	0	19	1
A	buyOrder()	0	18	1
A	getBalance()	0	20	3
A	getPrice()	0	9	1
A	__construct()	0	3	1
A	getName()	0	3	1

<?php


namespace Mokka\Exchange\Market;

use GuzzleHttp\Client;
use Mokka\Action\BuyAction;
use Mokka\Action\SellAction;
use Mokka\Exchange\ExchangeInterface;

class Binance implements ExchangeInterface
{

    /**
     * @var
     */
    private static $apiService;

    public function __construct($config)
    {
        self::$apiService = new BinanceApiService($config['api_key'], $config['api_secret']);
    }

    /**
     * Get symbol price from source
     * @param $symbol
     * @return float
     */
    public function getPrice($symbol) : float
    {
        $client = new Client();

        $response = $client->get("https://api.binance.com/api/v3/ticker/price?symbol={$symbol}");

        $response = json_decode($response->getBody()->getContents(), TRUE);

        return (float) $response['price'];
    }

    /**
     * Get historical prices
     * @param $symbol
     * @return array
     */
    public function getHistoricalPrices($symbol): array
    {
        // TODO: Implement getHistoricalPrices() method.
    }

In this branch, the function will implicitly return null which is incompatible with the type-hinted return array. Consider adding a return statement or allowing null as return value.

    /**
     * Put buy order
     * @param BuyAction $action
     * @return mixed|\Psr\Http\Message\ResponseInterface
     */
    public function buyOrder(BuyAction $action)
    {

        $getServerTime = self::$apiService->getServerTime()->getBody()->getContents();
        $getServerTime = json_decode($getServerTime, true);

        $params = [
            'symbol' => $action->getSymbol(),
            'price' => $action->getActionPrice(),
            'quantity' => round($action->getQuantity(), 2),
            'side'  => 'BUY',
            'type'  => 'LIMIT',
            'timeInForce' => 'GTC',
            'recvWindow' => 5000,
            'timestamp' => $getServerTime['serverTime']
        ];

        return self::$apiService->postOrderTest($params);
    }

    /**
     * Put sell order
     * @param SellAction $action
     * @return mixed
     */
    public function sellOrder(SellAction $action)
    {

        $getServerTime = self::$apiService->getServerTime()->getBody()->getContents();
        $getServerTime = json_decode($getServerTime, true);

        $params = [
            'symbol' => $action->getSymbol(),
            'price' => $action->getActionPrice(),
            'quantity' => $action->getQuantity(),
            'side'  => 'SELL',
            'type'  => 'LIMIT',
            'timeInForce' => 'GTC',
            'recvWindow' => 10000000,
            'timestamp' => $getServerTime['serverTime']

        ];

        return self::$apiService->postOrderTest($params);
    }

    /**
     * @return string
     */
    public function getName()
    {
        return 'binance';
    }


    /**
     * @return mixed
     */
    public function getBalance()
    {
        //get server time. dont use user local machine time
        $client = new Client();
        $response = $client->get("https://api.binance.com/api/v1/time");
        $response = json_decode($response->getBody()->getContents(), TRUE);

        $account = self::$apiService->getAccount(['timestamp' => $response['serverTime']]);
        $account = json_decode($account->getBody()->getContents(), TRUE);

        $balance = null;
        //catch BTC balance
        foreach ($account['balances'] as $item) {
            if ($item['asset'] == 'BTC') {
                $balance = $item['free'];
                break;
            }
        }

        return $balance;

    }
}