twisterarmy/twister-analytics-crawler
1
0
Fork 0
mirror of https://github.com/twisterarmy/twister-analytics-crawler.git synced 2025-01-30 16:34:18 +00:00
Code Issues Projects Releases Wiki Activity

add full peer info

Browse Source
This commit is contained in:
D4708 2021-05-30 04:23:15 +03:00
parent 84ecbdf07a
commit 777016df66
2 changed files with 42 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
model/ip.php
View File

@ -82,7 +82,18 @@ class ModelIp extends Model {
} }
} }
public function addOnline($ipId, $startingHeight, $timeConnection, $timeLastSend, $timeLastReceive) { public function addOnline($ipId,
$startingHeight,
$timeConnection,
$timeLastSend,
$timeLastReceive,
$bytesSent,
$bytesReceive,
$banscore,
$inbound,
$version,
$subVersion,
$syncNode) {
try { try {
@ -91,10 +102,28 @@ class ModelIp extends Model {
`timeConnection` = ?, `timeConnection` = ?,
`timeLastSend` = ?, `timeLastSend` = ?,
`timeLastReceive` = ?, `timeLastReceive` = ?,
`bytesSent` = ?,
`bytesReceive` = ?,
`banscore` = ?,
`inbound` = ?,
`version` = ?,
`subVersion` = ?,
`syncNode` = ?,
`timeAdded` = UNIX_TIMESTAMP()'); `timeAdded` = UNIX_TIMESTAMP()');
$query->execute([$ipId, $startingHeight, $timeConnection, $timeLastSend, $timeLastReceive]); $query->execute([ $ipId,
$startingHeight,
$timeConnection,
$timeLastSend,
$timeLastReceive,
$bytesSent,
$bytesReceive,
$banscore,
$inbound,
$version,
$subVersion,
$syncNode]);
return $this->db->lastInsertId(); return $this->db->lastInsertId();

15
peer.php
View File

@ -83,10 +83,17 @@ if ($peers = $curlPeer->getAll()) {
// Update online time // Update online time
$modelIp->addOnline($ipId, $modelIp->addOnline($ipId,
$peer['startingheight'], (int) $peer['startingheight'],
$peer['conntime'], (int) $peer['conntime'],
$peer['lastsend'], (int) $peer['lastsend'],
$peer['lastrecv']); (int) $peer['lastrecv'],
(int) $peer['bytessent'],
(int) $peer['bytesrecv'],
(int) $peer['banscore'],
(int) $peer['inbound'],
(int) $peer['version'],
preg_replace('/[^\d]/', '', $peer['subver']),
(isset($peer['syncnode']) ? (int) $peer['syncnode'] : 0));
} else { } else {
$modelLog->add(_('Could not extract peer address or port')); $modelLog->add(_('Could not extract peer address or port'));
} }