trader.php

<?php 
define('DS', DIRECTORY_SEPARATOR);
define('ROOT', dirname(__FILE__));

//check if this is really run by CLI, not a webserver
if(php_sapi_name() !== 'cli')
    exit('This script is meant to be run from the command line!<br/>It can\'t be used on a webserver.<br/><br/>
    For more information go to the <a href="https://github.com/chrisiaut/phptrader">official github repo</a>');

if(!file_exists(ROOT.DS.'config.inc.php'))
    exit('Error! set up config.inc.php first');
include_once(ROOT.DS.'config.inc.php');
//catch legacy configurations
if(!defined('CRYPTO'))
    define('CRYPTO','BTC');
date_default_timezone_set((TIMEZONE?TIMEZONE:'Europe/London'));
include_once(ROOT.DS.'vendor/autoload.php');
use Coinbase\Wallet\Client;
use Coinbase\Wallet\Configuration;
use Coinbase\Wallet\Resource\Sell;
use Coinbase\Wallet\Resource\Buy;
use Coinbase\Wallet\Value\Money;

$t = new trader(($argv[1]==='debug'?true:false));

$myname = $argv[0];
    
switch($argv[1])
{    
    case 'buy':
        $amount = $argv[2];
        $sellat = $argv[3];
        $t->buyBTC($amount,$sellat);
    break;

    case 'autotrade':
    case 'autotrader':
    case 'auto':
        $stake = $argv[2];
        $t->autotrade($stake,$argv[3]);
    break;
    
    case 'sell':
        $amount = $argv[2];
        $cyproprice = $argv[3];
        $t->addSellTransaction($amount,$cyproprice);
    break;
    
    case 'order':
        $amount = $argv[2];
        $sellat = $argv[3];
        $buyat = $argv[4];
        $t->addBuyTransaction($amount,$buyat,$sellat);
    break;

    case 'list':
        $t->listTransactions();
    break;

    case 'delete':
        $id = $argv[2];
        $t->deleteTransaction($id);
    break;

    case 'watchdog':
        $t->watchdog();
    break;

    case 'check':
        $t->mainCheck();
    break;

    case 'report':
        $t->report();
    break;

    case 'debug':
        $t->debug();
    break;

    default:
        echo "Usage info\n---------------\n";
        echo "php $myname buy <amount in ".CURRENCY."> <sell when price increases by ".CURRENCY.">\n";
        echo "php $myname sell <amount in ".CURRENCY."> <sell when this ".CRYPTO." price is reached >\n";
        echo "php $myname order <amount in ".CURRENCY."> <sell when price increases by ".CURRENCY."> <buy at ".CRYPTO." price>\n";
        echo "php $myname watchdog\t\tStarts infinite loop and checks for buys/sells. This is the main run method\n";
        echo "php $myname check\t\tThis will check all transactions as if it were run from the watchdog, but exits after one check so you can do it via cron\n";
        echo "php $myname list\t\tList all transactions with IDs\n";
        echo "php $myname delete <item id>\t\tDelete the transaction ID according to the list command\n";
        echo "\nExamples:\n---------------\n";
        echo "Buy 10 ".CURRENCY." in ".CRYPTO." and sell when it will be worth 12 ".CURRENCY.":\n  php $myname buy 10 2\n";
        echo "Sell 100 ".CURRENCY." of your ".CRYPTO." when 1 ".CRYPTO." is worth 2000 ".CURRENCY.":\n  php $myname sell 100 2000\n";
        echo "Add buy order for 15 ".CURRENCY." when 1 ".CRYPTO." is worth 1000 ".CURRENCY." and sell when the 15 ".CURRENCY." are worth 17 ".CURRENCY.":\n  php $myname order 15 2 1000\n";
    break;
}

class trader
{
    public $buyPrice;
    public $sellPrice;
    public $spotPrice;
    public $lastSellPrice;
    
    private $client;
    private $account;
    private $wallet;
    private $transactions;
    private $traderID;
    private $currencyWallet;

    private $redis;


    function __construct($noinit=false)
    {
        
        $configuration = Configuration::apiKey(COINBASE_KEY, COINBASE_SECRET);
        $this->client = Client::create($configuration);
        if($noinit===true) return;

        $accounts = $this->client->getAccounts();
        foreach($accounts as $account)
        {
            //echo "[W] Found wallet:\t '".$account->getName()."'\n";
            if($account->getCurrency()==CRYPTO)
            {
                $this->account = $account;

                echo "[i] Will use '".$account->getName()."' as crypto wallet :)\n";
            }
            else if($account->getCurrency()==CURRENCY)
            {
                $this->currencyWallet = $account;
                echo "[i] Will use '".$account->getName()."' as currency wallet :)\n";
            }
        }
        if(!$this->account)
        {
            $this->account = $this->client->getPrimaryAccount();
            echo "[W] Didn't find your '".CRYPTO." Wallet' Account.. falling back to default\n";
        }

        $this->transactions = array();
        $this->traderID = CURRENCY.' - '.CRYPTO;//substr(md5(time().microtime()."hello".rand(1,19999)),-3);

        //setup Redis connection if user has configured it
        if(defined('REDIS_SERVER') && REDIS_SERVER != '')
        {
            $this->redis = new Predis\Client(array(
                'scheme'   => 'tcp',
                'host'     => REDIS_SERVER,
                'port'     => REDIS_PORT,
                'database' => REDIS_DB,
                'password' => REDIS_PASS
            ));

            //var_dump($this->redis->get('1234:quota'));
        }

        //load previous data
        $this->loadTransactions();

        $paymentMethods = $this->client->getPaymentMethods();

        // legacy support so users won't have to change their config
        if (!defined('PAYMENT_METHOD_NAME')) {
            define('PAYMENT_METHOD_NAME',CURRENCY.' Wallet');
        }

        //find wallet ID
        foreach($paymentMethods as $pm)
        {
            if($pm->getName() == PAYMENT_METHOD_NAME)
            {
                $this->wallet = $pm;
                echo "[i] Will use ".$pm->getName()." for payments\n";
                break;
            }
        }
        if(!$this->wallet)
            exit("[ERR] Could not find your payment method: '".PAYMENT_METHOD_NAME."'.\n");

        echo "\n";

        //$this->checkBalanceOfAccount($this->account);

        $this->updatePrices();
    }

    function debug()
    {
        echo "############ DEBUG START ############\n\n";
        echo "[i] Listing accounts\n\n";
        $accounts = $this->client->getAccounts();
        foreach($accounts as $account)
        {
            echo "  [W] Wallet:\t '".$account->getName()."'\n";
            echo "    [Wi] ID: ".$account->getId()."\n";
            echo "    [Wi] currency: ".$account->getCurrency()."\n";
            echo "    [Wi] Amount: ".$account->getBalance()->getAmount()."\n\n";
        }

        echo "[i] Listing Payment methods\n\n";
        $paymentMethods = $this->client->getPaymentMethods();
        foreach($paymentMethods as $pm)
        {
            echo "  [PM] Wallet:\t '".$pm->getName()."'\n";
            echo "    [PMi] ID: ".$pm->getId()."\n";
            echo "    [PMi] currency: ".$pm->getCurrency()."\n\n";
        }

        echo "\n############ DEBUG END ############\n";
    }

    function checkBalanceOfAccount($account)
    {
        $data = $account->getBalance();
        $amount = $data->getAmount();
        $currency = $data->getCurrency();

        return $amount;
    }

    function loadTransactions()
    {
        //clearing transactions array so we don't have any legacy data
        $this->transactions = array();
        if(defined('REDIS_SERVER') && REDIS_SERVER != '')
        {
            if(file_exists(ROOT.DS.'transactions'.(CRYPTO!='BTC'?'-'.CRYPTO:'').'.json')) //migrate to redis
            {
                 echo "[C] Found transactions".(CRYPTO!='BTC'?'-'.CRYPTO:'').".json and Redis is configured. Converting json to Redis.. ";
                $transactions = json_decode(file_get_contents(ROOT.DS.'transactions'.(CRYPTO!='BTC'?'-'.CRYPTO:'').'.json'), true);
                foreach($transactions as $key=>$transaction)
                {
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':btc',$transaction['btc']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':eur',$transaction['eur']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':buyprice',$transaction['buyprice']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':sellat',$transaction['sellat']);
                }
                unlink(ROOT.DS.'transactions'.(CRYPTO!='BTC'?'-'.CRYPTO:'').'.json');
                 echo "done\n";
            }

             echo "[i] Loading data from Redis.. ";
            $data = $this->redis->keys('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':*');
            if(is_array($data))
                foreach($data as $d)
                {
                    $a = explode(':',$d);
                    $key = $a[1];
                    $var = $a[2];
                    $val = $this->redis->get("phptrader".(CRYPTO!='BTC'?'-'.CRYPTO:'').":$key:$var");
                    $this->transactions[$key][$var] = $val;
                }
            
             echo "done! Found ".count($this->transactions)." data points.\n";
        }
        else if(file_exists(ROOT.DS.'transactions'.(CRYPTO!='BTC'?'-'.CRYPTO:'').'.json'))
            $this->transactions = json_decode(file_get_contents(ROOT.DS.'transactions'.(CRYPTO!='BTC'?'-'.CRYPTO:'').'.json'), true);

    }

    function deleteTransaction($id)
    {
         echo "[i] Deleting transaction ID $id\n";

        if(defined('REDIS_SERVER') && REDIS_SERVER != '')
        {
            if(!$this->redis->exists("phptrader".(CRYPTO!='BTC'?'-'.CRYPTO:'').":$id:buyprice") && DEV===true)
                echo " [!ERR!] Key $id does not exist in Redis!\n";
            else
            {
                $keys = $this->redis->keys("phptrader".(CRYPTO!='BTC'?'-'.CRYPTO:'').":$id:*");
                foreach ($keys as $key) {
                    $this->redis->del($key);
                }
            }
        }
        else
            unset($this->transactions[$id]);

        $this->saveTransactions();
    }

    function saveTransactions()
    {
        if(defined('REDIS_SERVER') && REDIS_SERVER != '')
        {
            foreach($this->transactions as $key=>$transaction)
                {
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':btc',$transaction['btc']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':eur',$transaction['eur']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':buyprice',$transaction['buyprice']);
                    $this->redis->set('phptrader'.(CRYPTO!='BTC'?'-'.CRYPTO:'').':'.$key.':sellat',$transaction['sellat']);
                }
        }
        else
            file_put_contents(ROOT.DS."transactions".(CRYPTO!='BTC'?'-'.CRYPTO:'').".json",json_encode($this->transactions));
    }

    function updatePrices($silent=false)
    {
        $this->lastSellPrice = $this->sellPrice;
        $this->buyPrice =  floatval($this->client->getBuyPrice(CRYPTO.'-'.CURRENCY)->getAmount());
        $this->sellPrice = floatval($this->client->getSellPrice(CRYPTO.'-'.CURRENCY)->getAmount());
        $this->spotPrice = floatval($this->client->getSpotPrice(CRYPTO.'-'.CURRENCY)->getAmount());

        if(!$this->lastSellPrice)
            $this->lastSellPrice = $this->sellPrice;

        if($silent===false)
        {
            echo "[i] Buy price: $this->buyPrice ".CURRENCY."\n";
            echo "[i] Sell price: $this->sellPrice ".CURRENCY."\n";
            echo "[i] Spot price: $this->spotPrice ".CURRENCY."\n";
            echo "[i] Difference buy/sell: ".round(abs($this->buyPrice-$this->sellPrice),2)." ".CURRENCY."\n\n";
        }
    }

    function addBuyTransaction($eur,$buyat,$sellat)
    {
        $this->loadTransactions();
        echo "[i] Adding BUY order for $eur ".CURRENCY." in ".CRYPTO." when price is <= $buyat ".CURRENCY."\n";
        $id = @max(array_keys($this->transactions))+1;
        $this->transactions[$id] = array('eur'=>$eur,'buyprice'=>$buyat,'sellat'=>$sellat);
        $this->saveTransactions();
        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Added BUY order for *$eur ".CURRENCY."* when ".CRYPTO." price hits *$buyat ".CURRENCY."*. Currently it's at: *$this->sellPrice ".CURRENCY."*. Only *".($this->sellPrice-$buyat).' '.CURRENCY.'* to go',':raised_hands:');
    }

    function addSellTransaction($eur,$sellat)
    {
        $this->loadTransactions();
        echo "[i] Adding SELL order for $eur ".CURRENCY." in ".CRYPTO." when price is >= $sellat ".CURRENCY."\n";
        $id = @max(array_keys($this->transactions))+1;
        $this->transactions[$id] = array('eur'=>$eur,'sellat'=>$sellat);
        $this->saveTransactions();
        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Added SELL order for *$eur ".CURRENCY."* when ".CRYPTO." price hits *$sellat ".CURRENCY."*. Currently it's at: *$this->sellPrice ".CURRENCY."*. Only *".($sellat-$this->sellPrice).' '.CURRENCY.'* to go',':raised_hands:');
    }

    /*
    * Buys the configured crypto for real money
    * $money is $ or €, not some other crypto
    */
    function buyCryptoInMoney($money)
    {
        if(SIMULATE===false)
        {
            echo " [B] Buying $money ".CURRENCY.' of '.CRYPTO."\n";
            $buy = new Buy([
                'amount' => new Money($money, CURRENCY),
                'paymentMethodId' => $this->wallet->getId()
            ]);

            //check if account has enough currency
            if($this->checkBalanceOfAccount($this->currencyWallet)<$money)
            {
                echo " [ERR] You don't have enough ".CURRENCY." in your '".$this->currencyWallet->getName()."'. Cancelling buy\n";
                return;
            }
            else
                $this->client->createAccountBuy($this->account, $buy);

        }
        else
            echo " [S] Simulating buy of $money ".CURRENCY.' in '.CRYPTO."\n";
    }

    function buyBTC($amount,$sellat,$btc=false)
    {
        $eur = ($btc===true?($this->buyPrice*$amount):$amount);
        $btc = ($btc===true?$amount:($amount/$this->buyPrice));

        if(SIMULATE===false)
        {
            $buy = new Buy([
                'amount' => new Money($btc, CRYPTO),
                'paymentMethodId' => $this->wallet->getId()
            ]);

            //check if account has enough currency
            if($this->checkBalanceOfAccount($this->currencyWallet)<$eur)
            {
                echo " [ERR] You don't have enough ".CURRENCY." in your '".$this->currencyWallet->getName()."'. Cancelling buy\n";
                return;
            }
            else
                $this->client->createAccountBuy($this->account, $buy);
        }
        $this->loadTransactions();
        $id = @max(array_keys($this->transactions))+1;
        $this->transactions[$id] = array('btc'=>$btc,'eur'=>$eur,'buyprice'=>$this->buyPrice,'sellat'=>$sellat);

        
            echo "[B #$id] Buying $eur €\t=\t$btc ".CRYPTO."\n";

        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Buying *$btc ".CRYPTO."* for *$eur ".CURRENCY."*",':moneybag:');

        $this->saveTransactions();

        return $id;
    }

    function sellBTCID($id)
    {
        $data = $this->transactions[$id];
        $this->deleteTransaction($id);
        echo "[S #$id] Removed transaction #$id from list\n";
        $this->sellBTC($data['btc'],true);

        $profit = round(($data['btc']*$this->sellPrice)-($data['btc']*$data['buyprice']),2);

        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Selling *".$data['btc']." ".CRYPTO."* for *".$data['eur']." ".CURRENCY."*. Profit: *$profit ".CURRENCY."*",':money_with_wings:');
    }

    function sellBTC($amount,$btc=false)
    {
        $eur = ($btc===true?($this->sellPrice*$amount):$amount);
        $btc = ($btc===true?$amount:($amount/$this->sellPrice));

        $sell = new Sell([
            'bitcoinAmount' => $btc 
            //'amount' => new Money($btc, CRYPTO)
        ]);
        
            echo "[S] Selling $eur € =\t$btc ".CRYPTO."\n";
        if(SIMULATE===false)
        {
            if($this->checkBalanceOfAccount($this->account)<$btc)
            {
                echo " [ERR] You don't have enough ".CRYPTO." in your '".$this->account->getName()."'. Cancelling sell\n";
                return;
            }
            else
                $this->client->createAccountSell($this->account, $sell);            
        }
        
    }

    function listTransactions()
    {
        $this->loadTransactions(); //update transactions since the data could have changed by now

        if(count($this->transactions)<1)
            $message = "No transactions at the moment\n";
        else
            foreach($this->transactions as $id=>$td)
            {
                $btc = $td['btc'];
                $eur = $td['eur'];
                $buyprice = $td['buyprice'];
                $sellat = $td['sellat']+$eur;
                $newprice = $btc*$this->sellPrice;
                $diff = round(($this->sellPrice-$buyprice)*$btc,2);

                $message = "ID: $id\t";
                //is this a SELL order?
                if(!$buyprice) 
                {
                    $message.="SELL order for $eur ".CURRENCY." when ".CRYPTO." will reach a price of ".$td['sellat']." ".CURRENCY."\n";
                }
                //is this a BUY order?
                else if(!$btc)
                {
                    $message.="BUY order for $eur in ".CRYPTO." when 1 ".CRYPTO." will be worth $buyprice ".CURRENCY." and sell when it's worth $sellat ".CURRENCY."\n";
                }
                else
                {
                    $message.="Holding $btc ".CRYPTO." (".($buyprice*$btc)." ".CURRENCY." at buy), will sell when it's worth $sellat ".CURRENCY."\n";
                }
                echo $message;
            }

        

    }

    function watchdog()
    {
        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Starting watchdog",':wave:');
        while(1)
        {
            $this->mainCheck();

            sleep((defined('SLEEPTIME')?SLEEPTIME:10));
            echo "------\n";
        }
    }

    function mainCheck()
    {
        $this->loadTransactions(); //update transactions since the data could have changed by now

            echo "[i] Currently watching ".count($this->transactions)." transactions\n";

            //only update prices if we have active transactions to watch
            if(count($this->transactions)>0)
                $this->updatePrices();

            if($this->lastSellPrice!=$this->sellPrice && round(abs($this->sellPrice-$this->lastSellPrice),2) > 0)
                echo "[".CRYPTO."] Price went ".($this->sellPrice>$this->lastSellPrice?'up':'down')." by ".round($this->sellPrice-$this->lastSellPrice,2)." ".CURRENCY."\n";
                

            foreach($this->transactions as $id=>$td)
            {
                $btc = $td['btc'];
                $eur = $td['eur'];
                $buyprice = $td['buyprice'];
                $sellat = $td['sellat']+$eur;
                $newprice = $btc*$this->sellPrice;
                
                $diff = round(($this->sellPrice-$buyprice)*$btc,2);

                    //is this a SELL order?
                if(!$buyprice) 
                {
                    if($this->sellPrice >= $td['sellat']) //time to sell?
                    {
                        $btc = (1/$this->sellPrice) * $eur;
                        $this->deleteTransaction($id);
                        $this->sellBTC($btc,true);
                        if(ROCKETCHAT_REPORTING===true) sendToRocketchat("Selling *".$btc." ".CRYPTO."* for *".$eur." ".CURRENCY."*. Forefilling and deleting this sell order.",':money_with_wings:');
                    }
                    else
                        echo " [#$id] Watching SELL order for \t$eur ".CURRENCY.". Will sell when ".CRYPTO." price reaches ".$td['sellat']." ".CRYPTO.".\n";
                        
                }
                    //is this a BUY order?
                else if(!$btc)
                {
                    if($this->buyPrice <= $buyprice) //time to buy?
                    {
                        $this->deleteTransaction($id);
                        $this->buyBTC($eur, ($sellat-$eur) );
                    }
                    else
                        echo " [#$id] Watching BUY order for \t$eur ".CURRENCY.". Will buy when ".CRYPTO." price reaches $buyprice.\n";
                        
                }
                else
                {
                    $message = " [#$id] Holding \t$eur ".CURRENCY." at buy. Now worth:\t ".round($newprice,2)." ".CURRENCY.". Change: ".($diff)." ".CURRENCY.". Will sell at \t$sellat ".CURRENCY."\n";
                    echo $message;

                    if( ($this->sellPrice*$btc) >= $sellat )
                    {
                        echo "  [#$id] AWWYEAH time to sell $btc ".CRYPTO." since it hit ".($this->sellPrice*$btc)." ".CURRENCY.". Bought at $eur ".CURRENCY."\n";
                        $this->sellBTCID($id);
                    }
                }

            }
    }

    function report()
    {
        ob_start();
        $this->mainCheck();
        $out = ob_get_contents();
        ob_end_clean();

        sendToRocketchat($out,':information_source:');
    }

    function autotrade($stake=10,$sellpercent=115)
    {
        if(!$stake || !is_numeric($stake) || $stake < 1) $stake = 10;
        if(!$sellpercent || !is_numeric($sellpercent) || $sellpercent < 1) $sellpercent = 115;
        if(file_exists('autotrader.txt'))
        {
            $data = trim(file_get_contents('autotrader.txt'));
            $a = explode(';',$data);
            $boughtat = $a[0];
            $coins = $a[1];
            $stake = $a[2];
            echo "[A] Loading existing autotrader with stake of $stake ".CURRENCY.". Holding ".$coins.' '.CRYPTO." at $boughtat ".CURRENCY." per ".CRYPTO."\n";
        }
        else
        {
            $boughtat = $this->buyPrice;
            $coins = $stake/$boughtat;
            $this->buyCryptoInMoney($stake);
            file_put_contents('autotrader.txt',"$boughtat;$coins;$stake");
            echo "[A] Starting autotrader with stake of $stake ".CURRENCY.".".($nobuy===true?' NOT':'')." Buying ".$coins.' '.CRYPTO." at $boughtat ".CURRENCY." per ".CRYPTO."\n";
        }
        $targetprice = round(($stake/100)*$sellpercent);

        while(1)
        {
            $diff = ($this->sellPrice*$coins)-($boughtat*$coins);
            $percentdiff = round((($this->sellPrice*$coins)/($boughtat*$coins))*100,2);
            if($percentdiff>=115)
            {
                echo "\n  [!] Price is now $percentdiff % of buy price. Selling $stake ".CURRENCY."\n";
                $this->sellBTC($stake);

                //aaand here we go again
                $boughtat = $this->buyPrice;
                $coins = $stake/$boughtat;
                $this->buyCryptoInMoney($stake);
                file_put_contents('autotrader.txt',"$boughtat;$coins;$stake");
                echo "\n[A] Re-buying with stake of $stake ".CURRENCY.". Buying ".$coins.' '.CRYPTO." at $boughtat ".CURRENCY." per ".CRYPTO."\n";
            }
            else
                echo "\r [".date("d.m H:i")."] Current price: ".round($this->sellPrice*$coins)." ".CURRENCY.". $percentdiff% of target. Will sell at ".$sellpercent."% for $targetprice ".CURRENCY."         ";

            sleep(SLEEPTIME);
            $this->updatePrices(true);
        }
    }

}


//rocketchat
function sendToRocketchat($message,$icon=':ghost:')
{
    $username = CURRENCY.' - '.CRYPTO.' trader'.(SIMULATE===true?' (simulation)':'');
  $data = array("icon_emoji"=>$icon,
                "username"=>$username,
		        "text"=>$message);
  makeRequest(ROCKETCHAT_WEBHOOK,array('payload'=>json_encode($data)));
}

function makeRequest($url,$data,$headers=false,$post=true)
{
    $headers[] = 'Content-type: application/x-www-form-urlencoded';
    $options = array(
        'http' => array(
            'header'  => $headers,
            'method'  => $post?'POST':'GET',
            'content' => http_build_query($data)
        )
    );
    $context  = stream_context_create($options);
    $result = file_get_contents($url, false, $context);
    if ($result === FALSE) { /* Handle error */ }
    return json_decode($result,true);
}