Appino\Blockchain\Classes\Receive

Complexity

Total Complexity

12

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	CallbackLogs()	0	8	2
A	Generate()	0	9	1
A	__construct()	0	2	1
A	BlockNotification()	0	11	2
A	Uri()	0	2	1
A	BalanceNotification()	0	11	1
A	AddressGap()	0	4	1
A	DeleteBalanceNotification()	0	3	1
A	DeleteBlockNotification()	0	3	1
A	call()	0	2	1

<?php


namespace Appino\Blockchain\Classes;


use Appino\Blockchain\Classes\Blockchain;
use Appino\Blockchain\Interfaces\Notification;
use Appino\Blockchain\Interfaces\Operation;
use Appino\Blockchain\Objects\LogResponse;
use Appino\Blockchain\Objects\NotificationResponse;
use Appino\Blockchain\Objects\ReceiveResponse;
use GuzzleHttp\Client;

class Receive{

    /**
     * @var array
     */
    private $params;
    /**
     * @var Blockchain
     */
    private $blockchain;

    const URL = 'https://api.blockchain.info/v2/receive';


    /**
     * Receive constructor.
     *
     * @param Blockchain $blockchain
     */

    public function __construct(Blockchain $blockchain){
        $this->blockchain = $blockchain;
    }

    private function Uri($uri){
        return self::URL.'/'.$uri;
    }

    /**
     * @param string $method
     * @param string $uri
     * @param array $params
     * @return array
     * @throws \Appino\Blockchain\Exception\HttpError
     */
    private function call($method, $uri, $params = array()){
        return $this->blockchain->Request($method, $this->Uri($uri), $params);
    }

    /**
     * Generates a receive address.
     *
     * @param string $xpub The public key.
     * @param string $callback The callback URL.
     * @param int $gap_limit How many unused addresses are allowed.
     * @return ReceiveResponse
     */
    public function Generate($xpub, $callback, $gap_limit = 20){
        $params = [
            'xpub' => $xpub,
            'callback' => $callback,
            'gap_limit' => $gap_limit
        ];
        $params = array_merge($this->params, $params);
        $response = $this->call('GET','',$params);
        return new ReceiveResponse($response);
    }

    /**
     * Get the xpub gap
     *
     * @param $xpub string
     * @return integer
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function AddressGap($xpub){
        $params = array_merge(['xpub'=>$xpub],$this->params);
        $response = $this->call('GET','checkgap',$params);
        return $response['gap'];
    }

    /**
     * This method monitors an address of your choice for received and / or spent payments.
     * You will be sent an HTTP notification immediately when a transaction is made,
     * and subsequently when it reaches the number of confirmations specified in the request.
     *
     * @param string $address
     * @param string $callback
     * @param Notification|string $on
     * @param int $confs
     * @param Operation|string $op
     * @return NotificationResponse
     */

    public function BalanceNotification($address, $callback, $on = Notification::KEEP, $confs = 3, $op = Operation::ALL){
        $params = [
            'address' => $address,
            'callback' => $callback,
            'onNotification' => $on,
            'confs' => $confs,
            'op' => $op
        ];
        $params = array_merge($this->params, $params);
        $response = $this->call('POST','balance_update',$params);
        return new NotificationResponse($response);
    }

    /**
     * This method delete the balance notification
     *
     * @param $id int
     * @return bool
     * @throws \GuzzleHttp\Exception\GuzzleException
     */

    public function DeleteBalanceNotification($id){
       $response = $this->call('DELETE','balance_update/'.$id, $this->params);
       return $response['deleted'];
    }

    /**
     * This method allows you to request callbacks when a new block of a specified height and confirmation number is added to the blockchain.
     *
     * @param $callback string
     * @param string $on
     * @param int $confs
     * @param int|null $height
     * @return NotificationResponse
     * @throws \GuzzleHttp\Exception\GuzzleException
     */

    public function BlockNotification($callback, $on = Notification::KEEP, $confs = 1, $height = null){
        $params = [
            'callback' => $callback,
            'onNotification' => $on,
            'confs' => $confs,
        ];
        if(!is_null($height))
            $params['height'] = $height;
        $params = array_merge($this->params, $params);
        $response = $this->call('POST','block_notification',$params);
        return new NotificationResponse($response);
    }

    /**
     * This method delete block notification
     *
     * @param $id int
     * @return bool
     * @throws \GuzzleHttp\Exception\GuzzleException
     */

    public function DeleteBlockNotification($id){
        $response = $this->call('DELETE','block_notification/'.$id,$this->params);
        return $response['deleted'];
    }

    /**
     * See logs related to callback attempts.
     *
     * @param $callback string
     * @return array<LogResponse>
     * @throws \GuzzleHttp\Exception\GuzzleException
     */

    public function CallbackLogs($callback){
        $params = array_merge(['callback'=>$callback],$this->params);
        $logs = $this->call('GET','callback_log',['query'=>$params]);
        $response = array();
        foreach ($logs as $log){
            $response[] = new LogResponse($log);
        }
        return $response;
    }

}