303 lines
9.7 KiB
PHP
303 lines
9.7 KiB
PHP
<?php
|
|
/**
|
|
* Main class for the Daemon setup
|
|
*
|
|
* @package LBRYPress
|
|
*/
|
|
|
|
class LBRY_Daemon
|
|
{
|
|
/**
|
|
* The address of the Lbry Daemon
|
|
* @var string
|
|
*/
|
|
private $address = 'localhost:5279';
|
|
|
|
/**
|
|
* The Daemon Logger
|
|
* @var LBRY_Daemon_Logger
|
|
*/
|
|
public $logger = null;
|
|
|
|
/**
|
|
* LBRY Daemon Object constructor
|
|
*/
|
|
public function __construct()
|
|
{
|
|
$this->logger = new LBRY_Daemon_Logger();
|
|
}
|
|
|
|
/**
|
|
* Returns an unused address
|
|
* https://lbry.tech/api/sdk#address_unused
|
|
* @return string Unused wallet address in base58
|
|
*/
|
|
public function wallet_unused_address()
|
|
{
|
|
try {
|
|
$result = $this->request('address_unused');
|
|
return $result->result;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('address_unused error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
LBRY()->notice->set_notice('error', 'Issue getting unused address.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns an paginated array of Address lists
|
|
* https://lbry.tech/api/sdk#address_list
|
|
* @param int $page Pagination page number
|
|
* @return array Array of address lists linked to this account
|
|
*/
|
|
public function address_list($page = 1)
|
|
{
|
|
// Get 20 per page
|
|
$params = array(
|
|
'page' => $page,
|
|
'page_size' => 20
|
|
);
|
|
try {
|
|
$result = $this->request('address_list', $params);
|
|
return $result->result->items;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('address_list error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
LBRY()->notice->set_notice('error', 'Issue getting address list.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the available balance of a current LBRY account
|
|
* https://lbry.tech/api/sdk#wallet_balance
|
|
* @param string $address Wallet Address
|
|
* @return array $wallet_balance Wallet Balance
|
|
*
|
|
*/
|
|
public function wallet_balance()
|
|
{
|
|
try { // Convert JSON string to an object
|
|
$result = $this->request('wallet_balance');
|
|
return $result;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('wallet_balance error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
LBRY()->notice->set_notice('error', 'Issue getting wallet balance.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns a list of channels for this account
|
|
* https://lbry.tech/api/sdk#channel_list
|
|
* @param int $page Pagination page number
|
|
* @return array claim dictionary or null if empty
|
|
*/
|
|
public function channel_list($page = 1)
|
|
{
|
|
$params = array(
|
|
'page' => $page,
|
|
'page_size' => 20
|
|
);
|
|
|
|
try {
|
|
$result = $this->request('channel_list', $params)->result->items;
|
|
return empty($result) ? null : $result;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('channel_list error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
LBRY()->notice->set_notice('error', 'Issue retrieving channel list.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create a claim for a new channel
|
|
* https://lbry.tech/api/sdk#channel_create
|
|
* @return array dictionary containing result of the request
|
|
*/
|
|
public function channel_new($channel_name, $channel_bid)
|
|
{
|
|
// TODO: Sanitize channel name and bid
|
|
// Make sure no @ sign, as we will add that
|
|
if (strpos($channel_name, '@')) {
|
|
throw new \Exception('Illegal character "@" in channel name', 1);
|
|
}
|
|
|
|
// No white space allowed
|
|
if (strpos($channel_name, ' ')) {
|
|
throw new \Exception("No spaces allowed in channel name", 1);
|
|
}
|
|
|
|
$channel_name = '@' . $channel_name;
|
|
|
|
try {
|
|
$result = $this->request(
|
|
'channel_create',
|
|
array(
|
|
'name' => $channel_name,
|
|
'bid' => $channel_bid
|
|
)
|
|
);
|
|
|
|
$this->logger->log( 'channel_create success!', 'Successfully created channel with result: ' . print_r( $result->result, true ) );
|
|
return $result->result;
|
|
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('channel_new error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
throw new \Exception('Issue creating new channel.', 1);
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the canonical URL for the supplied claim ID, null otherwise
|
|
* @param string $claim_id
|
|
* @return string Canonical URL, null if not found
|
|
*/
|
|
public function canonical_url($claim_id = null)
|
|
{
|
|
if (!$claim_id) {
|
|
return null;
|
|
}
|
|
|
|
try {
|
|
$result = $this->request(
|
|
'claim_search',
|
|
array(
|
|
'claim_id' => $claim_id,
|
|
'no_totals' => true
|
|
)
|
|
);
|
|
|
|
$items = $result->result->items;
|
|
if (!$items) {
|
|
return null;
|
|
}
|
|
|
|
return $items[0]->canonical_url;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('canonical_url error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Publishes a post to the LBRY Network
|
|
* https://lbry.tech/api/sdk#publish
|
|
* @param array $args An array containing necessary data for publish post
|
|
*
|
|
* Available params:
|
|
* ['name', 'bid', 'file_path', 'title', 'description', 'language', 'license', 'channel_id', 'thumbnail']
|
|
*
|
|
* @return object $result
|
|
*/
|
|
public function publish($args)
|
|
{
|
|
try {
|
|
$result = $this->request(
|
|
'publish',
|
|
$args
|
|
);
|
|
$this->logger->log('publish success!', 'Successfully published post with result: ' . print_r($result->result, true));
|
|
return $result->result;
|
|
} catch (LBRYDaemonException $e) {
|
|
$this->logger->log('publish error', $e->getMessage() . ' | Code: ' . $e->getCode());
|
|
LBRY()->notice->set_notice('error', 'Issue publishing / updating post to LBRY Network.');
|
|
return;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Sends a cURL request to the LBRY Daemon
|
|
* @param string $method The method to call on the LBRY API
|
|
* @param array $params The Parameters to send the LBRY API Call
|
|
* @return string The cURL response
|
|
*/
|
|
private function request($method, $params = array())
|
|
{
|
|
// JSONify our request data
|
|
$data = array(
|
|
'method' => $method,
|
|
'params' => $params
|
|
);
|
|
$data = json_encode($data);
|
|
|
|
// Send it via curl
|
|
$ch = curl_init();
|
|
curl_setopt($ch, CURLOPT_URL, $this->address);
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
|
|
curl_setopt($ch, CURLOPT_AUTOREFERER, false);
|
|
curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
|
|
curl_setopt($ch, CURLOPT_HEADER, 0);
|
|
|
|
$result = curl_exec($ch);
|
|
$response_code = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
|
|
curl_close($ch);
|
|
|
|
if ($response_code != '200') {
|
|
$this->logger->log("Damon Connection Issue", "Daemon connection returned response code $response_code");
|
|
throw new LBRYDaemonException("Daemon Connection Issue", $response_code);
|
|
}
|
|
|
|
|
|
$result = json_decode($result);
|
|
$this->check_for_errors($result);
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Checks for erros in decoded daemon response and throws an exception if it finds one
|
|
* @param $response
|
|
*/
|
|
private function check_for_errors($response)
|
|
{
|
|
if (property_exists($response, 'error')) {
|
|
$message = $response->error->message;
|
|
$code = $response->error->code;
|
|
$this->logger->log("Daemon error code $code", $message);
|
|
throw new LBRYDaemonException($message, $code);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Temporary placeholder function for daemon. Not currently in use.
|
|
* @return [type] [description]
|
|
*/
|
|
// private function download_daemon()
|
|
// {
|
|
// $output_filename = "lbrydaemon";
|
|
//
|
|
// // HACK: Shouldn't just directly download, need to know OS, etc
|
|
// // TODO: Make sure we are only installing if not there or corrupted
|
|
// $host = "http://build.lbry.io/daemon/build-6788_commit-5099e19_branch-lbryum-refactor/mac/lbrynet";
|
|
// $fp = fopen(LBRY_URI . '/' . $output_filename, 'w+');
|
|
// $ch = curl_init();
|
|
// curl_setopt($ch, CURLOPT_URL, $host);
|
|
// curl_setopt($ch, CURLOPT_VERBOSE, 1);
|
|
// curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
// curl_setopt($ch, CURLOPT_FILE, $fp);
|
|
// curl_setopt($ch, CURLOPT_AUTOREFERER, false);
|
|
// curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
|
|
// curl_setopt($ch, CURLOPT_HEADER, 0);
|
|
//
|
|
// $result = curl_exec($ch);
|
|
// curl_close($ch);
|
|
// fclose($fp);
|
|
//
|
|
// $filepath = LBRY_URI . '/' . $output_filename;
|
|
//
|
|
// `chmod +x {$filepath}`;
|
|
// error_log(`{$filepath} status`);
|
|
// `{$filepath} start &`;
|
|
// }
|
|
}
|
|
|
|
class LBRYDaemonException extends Exception
|
|
{
|
|
public function __contstruct($message = '', $code = 0, Exception $previous = null)
|
|
{
|
|
parent::__construct($message, $code, $previous);
|
|
}
|
|
}
|