lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-04-23 19:37:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

announce dual not insert peer

Browse Source
This commit is contained in:
xiaomlove
2022-04-23 03:14:12 +08:00
parent 5b427005d2
commit d8f6b0d464
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Repositories/TrackerRepository.php
+5 -2
View File
@@ -104,7 +104,7 @@ class TrackerRepository extends BaseRepository
* Update: Will not change $peerSelf any more * Update: Will not change $peerSelf any more
*/ */
if ($isReAnnounce == self::ANNOUNCE_FIRST || ($isReAnnounce == self::ANNOUNCE_DUAL && $queries['event'] !== 'stopped')) { if ($isReAnnounce == self::ANNOUNCE_FIRST || ($isReAnnounce == self::ANNOUNCE_DUAL && $queries['event'] !== 'stopped')) {
$this->updatePeer($peerSelf, $queries); $this->updatePeer($peerSelf, $queries, $isReAnnounce);
} }
if ($isReAnnounce === self::ANNOUNCE_FIRST) { if ($isReAnnounce === self::ANNOUNCE_FIRST) {
@@ -782,13 +782,16 @@ class TrackerRepository extends BaseRepository
do_log(last_query()); do_log(last_query());
} }
private function updatePeer(Peer $peer, $queries) private function updatePeer(Peer $peer, $queries, $isReAnnounce)
{ {
if ($queries['event'] == 'stopped') { if ($queries['event'] == 'stopped') {
Peer::query()->where('torrent', $peer->torrent)->where('peer_id', $queries['peer_id'])->delete(); Peer::query()->where('torrent', $peer->torrent)->where('peer_id', $queries['peer_id'])->delete();
do_log(last_query()); do_log(last_query());
return; return;
} }
if (!$peer->exists && $isReAnnounce == self::ANNOUNCE_DUAL) {
do_log('[ANNOUNCE_DUAL_AND_PEER_NOT_EXISTS], return');
}
$nowStr = Carbon::now()->toDateTimeString(); $nowStr = Carbon::now()->toDateTimeString();
//torrent, userid, peer_id, ip, port, connectable, uploaded, downloaded, to_go, started, last_action, seeder, agent, downloadoffset, uploadoffset, passkey //torrent, userid, peer_id, ip, port, connectable, uploaded, downloaded, to_go, started, last_action, seeder, agent, downloadoffset, uploadoffset, passkey