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

improve announce api updatePeer&updateSnatch

Browse Source
This commit is contained in:
xiaomlove
2022-04-12 02:26:51 +08:00
parent 58abda6d1a
commit 998fcb3dfa
1 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
app/Repositories/TrackerRepository.php
View File

@@ -758,6 +758,13 @@ class TrackerRepository extends BaseRepository
if ($peer->exists) {
$peer->prev_action = $peer->last_action;
if ($queries['event'] == 'completed') {
$peer->finishedat = time();
}
} else {
$peer->started = $nowStr;
$peer->uploadoffset = $queries['uploaded'];
$peer->downloadoffset = $queries['downloaded'];
}
$peer->to_go = $queries['left'];
@@ -766,14 +773,6 @@ class TrackerRepository extends BaseRepository
$peer->uploaded = $queries['uploaded'];
$peer->downloaded = $queries['downloaded'];
if ($queries['event'] == 'started' || !$peer->exists) {
$peer->started = $nowStr;
$peer->uploadoffset = $queries['uploaded'];
$peer->downloadoffset = $queries['downloaded'];
} elseif ($queries['event'] == 'completed') {
$peer->finishedat = time();
}
$peer->save();
do_log(last_query());
}
@@ -803,7 +802,7 @@ class TrackerRepository extends BaseRepository
$snatch->uploaded = $queries['uploaded'];
$snatch->downloaded = $queries['downloaded'];
$snatch->startdat = $nowStr;
} else {
} elseif ($peer->exists) {
//increase, use the increment value
$snatch->uploaded = DB::raw("uploaded + " . $dataTraffic['uploaded_increment']);
$snatch->downloaded = DB::raw("downloaded + " . $dataTraffic['downloaded_increment']);
@@ -815,6 +814,10 @@ class TrackerRepository extends BaseRepository
$timeField = 'leechtime';
}
$snatch->{$timeField} = DB::raw("$timeField + $timeIncrease");
if ($queries['event'] == 'completed') {
$snatch->completedat = $nowStr;
$snatch->finished = 'yes';
}
}
//always update
@@ -822,10 +825,6 @@ class TrackerRepository extends BaseRepository
$snatch->port = $queries['port'];
$snatch->to_go = $queries['left'];
$snatch->last_action = $nowStr;
if ($queries['event'] == 'completed' && $peer->exists) {
$snatch->completedat = $nowStr;
$snatch->finished = 'yes';
}
$snatch->save();
do_log(last_query());