refactor(Torrent): Add TorrentFactory

CHANGELOG.md

@@ -32,6 +32,7 @@
 ### Perf
 - **Component:** View Become a component to perf load time (660c1f1)
 - **Tracker:** Reduce Redis Calls for get User and Torrent Info in Tracker (e813435)
+- **User:** Sort class User and create UserFactory (8fced36)
 - **User:** Add `Entity\User\AbstractUserInterface` (1d8e9e4)
 - **User:** Simple sql to get user real_transfer from table `snatched` (547c772)
 

application/Components/Site.php

@@ -27,11 +27,13 @@ class Site extends Component
     const LOG_LEVEL_LEADER = 'leader';
 
     protected Entity\User\UserFactory $user_factory;
+    protected Entity\Torrent\TorrentFactory $torrent_factory;
 
     public function __construct($config = [])
     {
         parent::__construct($config);
         $this->user_factory = new Entity\User\UserFactory();
+        $this->torrent_factory = new Entity\Torrent\TorrentFactory();
     }
 
     public function onRequestBefore()
@@ -49,20 +51,22 @@ public function getUserFactory(): Entity\User\UserFactory
         return $this->user_factory;
     }
 
+    /**
+     * @return Entity\Torrent\TorrentFactory
+     */
+    public function getTorrentFactory(): Entity\Torrent\TorrentFactory
+    {
+        return $this->torrent_factory;
+    }
+
     protected function getCacheNameSpace(): string
     {
         return 'Site:hash:runtime_value';
     }
 
     public function getTorrent($tid)
     {
-        if (array_key_exists($tid, $this->torrents)) {
-            $torrent = $this->torrents[$tid];
-        } else {
-            $torrent = new Entity\Torrent($tid);  // TODO Handing if this torrent id does not exist
-            $this->torrents[$tid] = $torrent;
-        }
-        return $torrent;
+        return $this->torrent_factory->getTorrentById($tid);
     }
 
     /**

application/Entity/Torrent.php → application/Entity/Torrent/Torrent.php

@@ -6,73 +6,59 @@
  * Time: 10:10
  */
 
-namespace App\Entity;
+namespace App\Entity\Torrent;
 
-use App\Entity\Torrent\AbstractTorrent;
 use App\Entity\User\User;
 use App\Libraries\Constant;
 
 use Rid\Utils;
-use Rid\Exceptions\NotFoundException;
+use Rid\Base\BaseObject;
 
-class Torrent extends AbstractTorrent
+class Torrent extends BaseObject
 {
     use Utils\ClassValueCacheUtils;
 
-    protected $id = null;
-
-    protected $owner_id;
-    protected $info_hash;
-
-    protected $status;
-
-    protected $added_at;
-
-    protected $complete;
-    protected $incomplete;
-    protected $downloaded;
-    protected $comments;
+    //-- Torrent Base Info --//
+    protected int $id;
+    protected int $owner_id;
+    protected string $info_hash;
+    protected string $status = TorrentStatus::PENDING;
+    protected string $added_at;
+
+    protected int $complete = 0;
+    protected int $incomplete = 0;
+    protected int $downloaded = 0;
+    protected int $comments = 0;
+
+    protected string $title = '';
+    protected string $subtitle = '';
+    protected int $category = 0;
+    protected string $descr = '';
+    protected bool $uplver = false;
+    protected bool $hr = false;
+    protected $tags;
 
-    protected $title;
-    protected $subtitle;
-    protected $category;
-    protected $descr;
-    protected $uplver;
-    protected $hr;
+    protected int $team = 0;
+    protected int $quality_audio = 0;
+    protected int $quality_codec = 0;
+    protected int $quality_medium = 0;
+    protected int $quality_resolution = 0;
 
-    protected $nfo;
+    protected int $torrent_size;
 
-    protected $tags;
-    protected $pinned_tags;
+    //-- Torrent Extend Info --//
+    protected string $torrent_name;
+    protected string $torrent_type;
+    protected ?string $nfo;
+    protected ?string $torrent_structure;
 
-    protected $torrent_name;
-    protected $torrent_type;
-    protected $torrent_size;
-    protected $torrent_structure;
-
-    protected $team;
 
     protected $comment_perpage = 10;  // FIXME
 
-    public function __construct($id = null)
+    /** @noinspection PhpMissingParentConstructorInspection */
+    public function __construct($config)
     {
-        $this->loadTorrentContentById($id);
-        if ($this->id == null) {
-            throw new NotFoundException('Not Found');  // FIXME
-        }
-    }
-
-    public function loadTorrentContentById($id)
-    {
-        $self = app()->redis->hGetAll(Constant::torrentContent($id));
-        if (empty($self)) {
-            $self = app()->pdo->createCommand("SELECT * FROM `torrents` WHERE id=:id LIMIT 1;")->bindParams([
-                    "id" => $id
-                ])->queryOne() ?? [];
-            app()->redis->hMSet(Constant::torrentContent($id), $self);
-            app()->redis->expire(Constant::torrentContent($id), 1800);
-        }
-        $this->importAttributes($self);
+        $this->importAttributes($config);
     }
 
     protected function getCacheNameSpace(): string
@@ -95,9 +81,9 @@ public function getOwner(): User
         return app()->site->getUser($this->owner_id);
     }
 
-    public function getInfoHash(): string
+    public function getInfoHash($hex = true): string
     {
-        return bin2hex($this->info_hash);
+        return $hex ? bin2hex($this->info_hash) : $this->info_hash;
     }
 
     public function getStatus(): string
@@ -150,26 +136,11 @@ public function getCategory()
         return app()->site->CategoryDetail($this->category);
     }
 
-    public function getTorrentName(): string
-    {
-        return $this->torrent_name;
-    }
-
-    public function getTorrentType(): string
-    {
-        return $this->torrent_type;
-    }
-
     public function getTorrentSize(): int
     {
         return $this->torrent_size;
     }
 
-    public function getTorrentStructure(): array
-    {
-        return json_decode($this->torrent_structure, true);
-    }
-
     public function getTeamId()
     {
         return $this->team;
@@ -238,6 +209,21 @@ public function getHr(): bool
         return (boolean)$this->hr;
     }
 
+    public function getTorrentName(): string
+    {
+        return $this->torrent_name;
+    }
+
+    public function getTorrentType(): string
+    {
+        return $this->torrent_type;
+    }
+
+    public function getTorrentStructure(): array
+    {
+        return json_decode($this->torrent_structure, true);
+    }
+
     public function hasNfo(): bool
     {
         return (boolean)$this->nfo;

application/Entity/Torrent/TorrentFactory.php

@@ -0,0 +1,43 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Rhilip
+ * Date: 1/27/2020
+ * Time: 2020
+ */
+
+declare(strict_types=1);
+
+namespace App\Entity\Torrent;
+
+use Rid\Exceptions\NotFoundException;
+
+class TorrentFactory
+{
+    public function getTorrentById($tid): Torrent
+    {
+        $self = app()->pdo->createCommand('SELECT * FROM `torrents` WHERE id=:id LIMIT 1;')->bindParams([
+            'id' => $tid
+        ])->queryOne();
+
+        if (false === $self) {
+            throw new NotFoundException('Not Found');  // FIXME
+        }
+
+        return new Torrent($self);
+    }
+
+    public function getTorrentBySearch(array $search_field, int $offset = 0, int $limit = 50): array
+    {
+        $fetch = app()->pdo->createCommand([
+            ['SELECT `id`, `owner_id`,`info_hash`,`status`,`added_at`,`complete`,`incomplete`,`downloaded`,`comments`,`title`,`subtitle`,`category`,`torrent_size`,`team`,`quality_audio`,`quality_codec`,`quality_medium`,`quality_resolution`,`tags`,`uplver`,`hr` FROM `torrents` WHERE 1=1 '],
+            ...$search_field,
+            ['ORDER BY `added_at` DESC '],
+            ['LIMIT :offset, :rows', 'params' => ['offset' => $offset, 'rows' => $limit]]
+        ])->queryAll();
+
+        return array_map(function ($self) {
+            return new Torrent($self);
+        }, $fetch);
+    }
+}

application/Repository/Torrent/TorrentStatus.php → application/Entity/Torrent/TorrentStatus.php

@@ -2,13 +2,13 @@
 /**
  * Created by PhpStorm.
  * User: Rhilip
- * Date: 1/11/2020
+ * Date: 1/27/2020
  * Time: 2020
  */
 
 declare(strict_types=1);
 
-namespace App\Repository\Torrent;
+namespace App\Entity\Torrent;
 
 class TorrentStatus
 {

application/Repository/Torrent/TorrentType.php → application/Entity/Torrent/TorrentType.php

@@ -8,7 +8,7 @@
 
 declare(strict_types=1);
 
-namespace App\Repository\Torrent;
+namespace App\Entity\Torrent;
 
 class TorrentType
 {

application/Entity/User/User.php

@@ -66,6 +66,7 @@ protected function getCacheNameSpace(): string
         return $this->cache_key_extra;
     }
 
+    /** @noinspection PhpMissingParentConstructorInspection */
     public function __construct($id = 0)
     {
         $this->id = $id;
@@ -79,8 +80,7 @@ public function __construct($id = 0)
         if (false === $self) {
             return; // It means this user id is invalid
         }
-
-        parent::__construct($self);
+        $this->importAttributes($self);
     }
 
     public function getId(): int
@@ -201,7 +201,8 @@ public function getTimeRatio()
         return $this->ratioHelper($this->seedtime, $this->leechtime);
     }
 
-    private function loadExtendProp() {
+    private function loadExtendProp()
+    {
         if (false === $this->extended_info_hit) {
             if (false === $self = app()->redis->get($this->cache_key_extended)) {
                 $self = app()->pdo->createCommand('SELECT `create_at`,`register_ip`,`last_login_at`,`last_access_at`,`last_upload_at`,`last_download_at`,`last_connect_at`,`last_login_ip`,`last_access_ip`,`last_tracker_ip` FROM `users` WHERE id = :uid')->bindParams([
@@ -372,10 +373,10 @@ public function getTempInvitesSum(): int
     public function getTempInviteDetails(): array
     {
         return $this->getCacheValue('temp_invites_details', function () {
-                return app()->pdo->createCommand('SELECT * FROM `user_invitations` WHERE `user_id` = :uid AND (`total`-`used`) > 0 AND `expire_at` > NOW() ORDER BY `expire_at` ASC')->bindParams([
+            return app()->pdo->createCommand('SELECT * FROM `user_invitations` WHERE `user_id` = :uid AND (`total`-`used`) > 0 AND `expire_at` > NOW() ORDER BY `expire_at` ASC')->bindParams([
                     "uid" => app()->auth->getCurUser()->getId()
                 ])->queryAll() ?: [];
-            }) ?? [];
+        }) ?? [];
     }
 
     public function getPendingInvites()

application/Entity/User/UserFactory.php

@@ -10,7 +10,6 @@
 
 namespace App\Entity\User;
 
-
 class UserFactory
 {
     protected array $user_instances = [];

application/Models/Form/Torrent/EditForm.php

@@ -10,9 +10,9 @@
 
 use App\Libraries\Constant;
 use App\Models\Form\Traits\isValidTorrentTrait;
-use App\Entity\Torrent;
+use App\Entity\Torrent\Torrent;
 
-use App\Repository\Torrent\TorrentStatus;
+use App\Entity\Torrent\TorrentStatus;
 use Rid\Http\UploadFile;
 use Rid\Validators\Validator;