Host = '192.168.10.234';
break;
default:
$this->Host = '192.168.10.152';
break;
}
$this->RiakClient = new RiakClient($this->Host);
$this->RiakBucket = $this->RiakClient->bucket('op'); # op = Order Proofs
$this->ProofData = array();
$this->OrderProductId= 0;
}
public function GetProofData($OrderProductId)
{
$obj = $this->RiakBucket->get($OrderProductId);
$Result = false;
if ( $obj->exists() )
{
$this->OrderProductId = $OrderProductId;
$this->ProofData = $obj->getData();
return $this->ProofData;
} else {
return $Result;
}
}
public function SaveProofData($orderProductId, $arrProofData)
{
$this->ProofData = json_encode($arrProofData);
//echo "ProofData: " . $this->ProofData . "\n";
$this->OrderProductId = $orderProductId;
$obj = $this->RiakBucket->newObject($this->OrderProductId, $this->ProofData);
return $obj->store();
}
public function GetProofPart($Key)
{
//echo "GetProofPart($Key)
";
$data = false;
$obj = $this->RiakBucket->getBinary($Key);
if ( $obj->exists() )
{
//echo "Found something
";
$data = $obj->getData();
//echo "returned bytes: " . strlen($data) . "
";
}
return $data;
}
public function SaveProofPart($Key, $binData)
{
$obj = $this->RiakBucket->newBinary($Key, $binData);
//echo "SaveProofPart::obj = " . print_r($obj, true) . "\n";
return $obj->store();
}
}
?>