_disablePostbackLog = (bool)$flag;
return $this;
}
function setInvoice(Invoice $invoice)
{
$this->invoice_id = $invoice->invoice_id;
$this->user_id = $invoice->user_id;
return $this;
}
function setProcessed()
{
if (!$this->_disablePostbackLog)
$this->updateQuick('is_processed', true);
}
function renderTable($kvRows)
{
$h = "\n";
foreach ($kvRows as $k => $v)
$h .= sprintf("| %s | %s |
|---|
\n",
Am_Controller::escape($k), Am_Controller::escape($v));
$h .= "
\n";
return $h;
}
function serializeItem($vars)
{
$x = new XMLWriter();
$x->openMemory();
$x->setIndent(true);
$x->startElement('invoice-log-item');
if (is_array($vars)) {
$x->writeAttribute('type', 'array');
$x->startElement('params');
foreach ($vars as $k => $v)
{
$x->startElement('param');
$x->writeAttribute('name', $k);
$x->text(serialize($v));
$x->endElement();
}
$x->endElement();
} elseif ($vars instanceof Am_Request) {
$x->writeAttribute('type', 'incoming-request');
$vars->toXml($x);
} elseif ($vars instanceof Am_Paysystem_Action) {
$x->writeAttribute('type', 'paysystem-action');
$x->writeAttribute('class', get_class($vars));
$vars->toXml($x);
} elseif ($vars instanceof Am_HttpRequest) {
$x->writeAttribute('type', 'outgoing-request');
$vars->toXml($x, false);
} elseif ($vars instanceof HTTP_Request2_Response) {
$x->writeAttribute('type', 'outgoing-request-response');
$x->startElement('headers');
foreach ($vars->getHeader(null) as $k => $v)
{
$x->startElement('header');
$x->writeAttribute('name', $k);
$x->text($v);
$x->endElement();
}
$x->endElement();
$x->startElement('body');
$x->writeCdata($vars->getBody());
$x->endElement();
$x->endElement();
}
elseif ($vars instanceof Exception)
{
$x->writeAttribute('type', 'exception');
$x->writeElement('type', get_class($vars));
$x->writeElement('message', $vars->getMessage());
$x->startElement('trace');
foreach ($vars->getTrace() as $t)
{
$x->startElement('call');
if (isset($t['class']))
{
$x->writeElement('function', $t['class'] . $t['type'] . $t['function']);
} else {
$x->writeElement('function', $t['function']);
}
$x->writeElement('file', @$t['file']);
$x->writeElement('line', @$t['line']);
$x->endElement();
}
$x->endElement();
} else {
$x->writeAttribute('type', gettype($vars));
$x->writeCdata((string)$vars);
}
$x->endElement(); // invoice-log-item
return $x->flush();
}
function add($vars, $commit = true)
{
if ($vars instanceof Am_Request)
{
$vars = $this->serializeItem($vars);
}
else
{
$vars = $this->serializeItem($vars);
if (!$this->_disableMask)
{
// credit card# has length from 13 to 16 as defined in ccvs
$vars = preg_replace('/(?\d{3}***<', $vars);
$vars = preg_replace('/CDATA\[\d{3}\]\]/', 'CDATA[***]]', $vars);
$vars = preg_replace_callback('/(>)(\d{13,16})(<)/', array($this, '_maskCc'), $vars);
$vars = preg_replace_callback('/(CDATA\[)(\d{13,16})(\]\])/', array($this, '_maskCc'), $vars);
$vars = str_replace(array_keys($this->_mask), array_values($this->_mask), $vars);
}
}
if (!empty($this->details))
{
$this->details = str_replace('', $vars."", $this->details);
} else {
$this->details =
''.PHP_EOL
.''.PHP_EOL
.$vars
.'';
}
if ($commit && !$this->_disablePostbackLog) $this->save();
}
public function update()
{
if (!$this->_disablePostbackLog)
parent::update();
return $this;
}
public function insert($reload = true)
{
if (!$this->_disablePostbackLog)
parent::insert($reload);
return $this;
}
/**
* Automatically replace occurences of $data in log records to $replacement (***)
* @link add()
*/
function mask($data, $replacement=null)
{
$this->_mask[(string)$data] = $replacement ? $replacement : str_repeat('*', strlen($data));
return $this;
}
function _maskCc($regs)
{
$cc = $regs[2];
return $regs[1].str_repeat('*', strlen($cc)-4) . substr($cc, -4).$regs[3];
}
function getRenderedDetails()
{
if (empty($this->details)) return array();
$ret = array();
foreach ($this->getXmlDetails() as $a)
{
$popup = null;
list($type, $source) = $a;
if (preg_match('|^\s*<.*>\s*$|ms', $source))
{
$x = new SimpleXMLElement($source);
if ($body = (string)$x->body)
{
$popup = $this->renderVars($body);
}
}
$source = highlight_string($source, true);
$ret[] = array($type, $source, $popup);
}
return $ret;
}
/**
* return @array details as array(type,xmlsource)
*/
function getXmlDetails()
{
$ret = array();
$x = simplexml_load_string($this->details);
foreach($x->{'invoice-log-item'} as $i)
{
$ret[] = array((string)$i->attributes()->type, $i->asXML());
}
return $ret;
}
function renderVars($body)
{
$str = urldecode($body);
parse_str($str, $arr);
if (get_magic_quotes_gpc())
$arr = Am_Request::ss($arr);
if (!count($arr)) return "";
return print_r($arr, true);
}
/** @return Am_Request|null */
function getFirstRequest()
{
if (empty($this->details)) return;
$x = new SimpleXMLElement($this->details);
$k = 'invoice-log-item';
foreach ($x->{'invoice-log-item'} as $item)
{
if ($item['type'] == 'incoming-request')
return Am_Request::fromXml($item);
}
}
function toggleMask($flag = false)
{
$this->_disableMask = !$flag;
}
}
class InvoiceLogTable extends Am_Table {
protected $_key = 'log_id';
protected $_table = '?_invoice_log';
protected $_recordClass = 'InvoiceLog';
public function insert(array $values, $returnInserted = false)
{
if (empty($values['tm']))
$values['tm'] = $this->getDi()->sqlDateTime;
if (empty($values['remote_addr']))
$values['remote_addr'] = $_SERVER['REMOTE_ADDR'];
return parent::insert($values, $returnInserted);
}
function log($invoice_id, $paysys_id,
$title, $vars=null, $type='info', $remote_addr=null, $tm=null){
$r = $this->createRecord();
$r->setInvoice($this->getDi()->invoiceTable->load($invoice_id, false));
$r->paysys_id = $paysys_id;
$r->title = $title;
$r->remote_addr = get_first($remote_addr, $_SERVER['REMOTE_ADDR']);
$r->add($vars, false);
$r->insert();
return $r;
}
}