[api] add notifications

app/Repositories/AgentAllowRepository.php

@@ -4,6 +4,7 @@ namespace App\Repositories;
 use App\Exceptions\ClientNotAllowedException;
 use App\Models\AgentAllow;
 use App\Models\AgentDeny;
+use Nexus\Database\NexusDB;
 
 class AgentAllowRepository extends BaseRepository
 {
@@ -72,10 +73,12 @@ class AgentAllowRepository extends BaseRepository
     public function checkClient($peerId, $agent, $debug = false)
     {
         //check from high version to low version, if high version allow, stop!
-        $allows = AgentAllow::query()
-            ->orderBy('peer_id_start', 'desc')
-            ->orderBy('agent_start', 'desc')
-            ->get();
+        $allows = NexusDB::remember("all_agent_allows", 600, function () {
+            return AgentAllow::query()
+                ->orderBy('peer_id_start', 'desc')
+                ->orderBy('agent_start', 'desc')
+                ->get();
+        });
         $agentAllowPassed = null;
         $versionTooLowStr = '';
         foreach ($allows as $agentAllow) {

app/Repositories/AttendanceRepository.php

@@ -75,8 +75,8 @@ class AttendanceRepository extends BaseRepository
             ->where('uid', $uid)
             ->orderBy('id', 'desc');
         if (!empty($date)) {
-            $query->where('added', '>=', Carbon::today())
-                ->where('added', '<', Carbon::tomorrow());
+            $query->where('added', '>=', Carbon::parse($date)->startOfDay())
+                ->where('added', '<=', Carbon::parse($date)->endOfDay());
         }
         return $query->first();
     }

app/Repositories/CommentRepository.php

@@ -41,8 +41,9 @@ class CommentRepository extends BaseRepository
         $model = new $modelName;
         $target = $model->newQuery()->with('user')->find($params[$type]);
         return DB::transaction(function () use ($params, $user, $target) {
+            $params['added'] = Carbon::now();
             $comment = $user->comments()->create($params);
-            $commentCount = Comment::query()->type($params['type'])->count();
+            $commentCount = Comment::query()->type($params['type'], $params[$params['type']])->count();
             $target->comments = $commentCount;
             $target->save();
 
@@ -60,7 +61,7 @@ class CommentRepository extends BaseRepository
                     'receiver' => $target->user->id,
                     'subject' => $messageInfo['subject'],
                     'msg' => $messageInfo['body'],
-                    'added' => Carbon::now()
+                    'added' => $params['added'],
                 ];
                 Message::query()->insert($insert);
                 NexusDB::cache_del('user_'.$target->user->id.'_unread_message_count');
@@ -100,9 +101,8 @@ class CommentRepository extends BaseRepository
         $targetScript = Comment::TYPE_MAPS[$type]['target_script'];
         $targetNameField = Comment::TYPE_MAPS[$type]['target_name_field'];
         $body = sprintf(
-            '%s [url="%s/%s"]%s[/url]',
-            $trans[$type]['msg_torrent_receive_comment'],
-            getSchemeAndHttpHost(),
+            '%s [url=%s]%s[/url]',
+            $trans['msg_torrent_receive_comment'],
             sprintf($targetScript, $target->id),
             $target->{$targetNameField}
         );

app/Repositories/RewardRepository.php

@@ -30,10 +30,11 @@ class RewardRepository extends BaseRepository
         }
         $torrent = Torrent::query()->findOrFail($torrentId, Torrent::$commentFields);
         $torrent->checkIsNormal();
-        $torrentOwner = User::query()->findOrFail($torrent->owner, ['id', 'seedbonus']);
+        $torrentOwner = User::query()->findOrFail($torrent->owner);
         if ($user->id == $torrentOwner->id) {
             throw new \LogicException("you can't reward to yourself.");
         }
+        $torrentOwner->checkIsNormal();
         return DB::transaction(function () use ($torrentId, $value, $user, $torrentOwner) {
             $model = $user->reward_torrent_logs()->create([
                 'torrentid' => $torrentId,

app/Repositories/ToolRepository.php

@@ -1,7 +1,12 @@
 <?php
 namespace App\Repositories;
 
+use App\Models\Message;
+use App\Models\News;
+use App\Models\Poll;
+use App\Models\PollAnswer;
 use App\Models\Setting;
+use App\Models\User;
 use Illuminate\Encryption\Encrypter;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Storage;
@@ -192,4 +197,28 @@ class ToolRepository extends BaseRepository
             return false;
         }
     }
+
+    public function getNotificationCount(User $user): array
+    {
+        $result = [];
+        //attend or not
+        $attendRep = new AttendanceRepository();
+        $attendance = $attendRep->getAttendance($user->id, date('Ymd'));
+        $result['attendance'] = $attendance ? 0 : 1;
+
+        //unread news
+        $count = News::query()->where('added', '>', $user->last_home)->count();
+        $result['news'] = $count;
+
+        //unread messages
+        $count = Message::query()->where('receiver', $user->id)->where('unread', 'yes')->count();
+        $result['message'] = $count;
+
+        //un-vote poll
+        $total = Poll::query()->count();
+        $userVoteCount = PollAnswer::query()->where('userid', $user->id)->selectRaw('count(distinct(pollid)) as counts')->first()->counts;
+        $result['poll'] = $total - $userVoteCount;
+
+        return $result;
+    }
 }

app/Repositories/TorrentRepository.php

@@ -24,6 +24,7 @@ use Carbon\Carbon;
 use Hashids\Hashids;
 use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Support\Str;
+use Nexus\Database\NexusDB;
 
 class TorrentRepository extends BaseRepository
 {
@@ -372,12 +373,14 @@ class TorrentRepository extends BaseRepository
 
     private function getTrackerReportAuthKeySecret($id, $uid, $initializeIfNotExists = false)
     {
-        $secret = TorrentSecret::query()
-            ->where('uid', $uid)
-            ->whereIn('torrent_id', [0, $id])
-            ->orderBy('torrent_id', 'desc')
-            ->orderBy('id', 'desc')
-            ->first();
+        $secret = NexusDB::remember("tracker_report_authkey_secret:$id:$uid", 3600*24, function () use ($id, $uid) {
+            return TorrentSecret::query()
+                ->where('uid', $uid)
+                ->whereIn('torrent_id', [0, $id])
+                ->orderBy('torrent_id', 'desc')
+                ->orderBy('id', 'desc')
+                ->first();
+        });
         if ($secret) {
             return $secret->secret;
         }

app/Repositories/TrackerRepository.php

@@ -104,7 +104,7 @@ class TrackerRepository extends BaseRepository
             $repDict = $this->generateFailedAnnounceResponse($exception->getMessage());
         } catch (TrackerException $exception) {
             $repDict = $this->generateFailedAnnounceResponse($exception->getMessage());
-        } catch (\Exception $exception) {
+        } catch (\Throwable $exception) {
             //other system exception
             do_log("[" . get_class($exception) . "] " . $exception->getMessage() . "\n" . $exception->getTraceAsString(), 'error');
             $repDict = $this->generateFailedAnnounceResponse("system error, report to sysop please, hint: " . nexus()->getRequestId());
@@ -806,7 +806,7 @@ class TrackerRepository extends BaseRepository
             $repDict = $this->generateFailedAnnounceResponse($exception->getMessage());
         } catch (TrackerException $exception) {
             $repDict = $this->generateFailedAnnounceResponse($exception->getMessage());
-        } catch (\Exception $exception) {
+        } catch (\Throwable $exception) {
             //other system exception
             do_log("[" . get_class($exception) . "] " . $exception->getMessage() . "\n" . $exception->getTraceAsString(), 'error');
             $repDict = $this->generateFailedAnnounceResponse("system error, report to sysop please, hint: " . nexus()->getRequestId());