openvk/Web/Models/Entities/Club.php

<?php declare(strict_types=1);
namespace openvk\Web\Models\Entities;
use openvk\Web\Util\DateTime;
use openvk\Web\Models\RowModel;
use openvk\Web\Models\Entities\{User, Manager};
use openvk\Web\Models\Repositories\{Users, Clubs, Albums, Managers};
use Nette\Database\Table\{ActiveRow, GroupedSelection};
use Chandler\Database\DatabaseConnection as DB;
use Chandler\Security\User as ChandlerUser;

class Club extends RowModel
{
    protected $tableName = "groups";
    
    const TYPE_GROUP  = 1;
    const TYPE_PUBLIC = 1;
    const TYPE_EVENT  = 2;
    
    const OPEN    = 0;
    const CLOSED  = 1;
    const PRIVATE = 2;
    
    const NOT_RELATED  = 0;
    const SUBSCRIBED   = 1;
    const REQUEST_SENT = 2;
    
    function getId(): int
    {
        return $this->getRecord()->id;
    }
    
    function getAvatarPhoto(): ?Photo
    {
        $avAlbum  = (new Albums)->getClubAvatarAlbum($this);
        $avCount  = $avAlbum->getPhotosCount();
        $avPhotos = $avAlbum->getPhotos($avCount, 1);
        
        return iterator_to_array($avPhotos)[0] ?? NULL;
    }
    
    function getAvatarUrl(): string
    {
        $serverUrl = ovk_scheme(true) . $_SERVER["SERVER_NAME"];
        $avPhoto   = $this->getAvatarPhoto();
        
        return is_null($avPhoto) ? "$serverUrl/assets/packages/static/openvk/img/camera_200.png" : $avPhoto->getURL();
    }
    
    function getAvatarLink(): string
    {
        $avPhoto = $this->getAvatarPhoto();
        if(!$avPhoto) return "javascript:void(0)";
        
        $pid = $avPhoto->getPrettyId();
        $aid = (new Albums)->getClubAvatarAlbum($this)->getId();
        
        return "/photo$pid?from=album$aid";
    }
    
    function getURL(): string
    {
        if(!is_null($this->getShortCode()))
            return "/" . $this->getShortCode();
        else
            return "/club" . $this->getId();
    }
    /* 
    function getAvatarUrl(): string
    {
        $avAlbum  = (new Albums)->getUserAvatarAlbum($this);
        $avCount  = $avAlbum->getPhotosCount();
        $avPhotos = $avAlbum->getPhotos($avCount, 1);
        $avPhoto  = iterator_to_array($avPhotos)[0] ?? NULL;
        
        return is_null($avPhoto) ? "/assets/packages/static/openvk/img/camera_200.png" : $avPhoto->getURL();
    } */
    
    function getName(): string
    {
        return ovk_proc_strtr($this->getRecord()->name, 32);
    }
    
    function getCanonicalName(): string
    {
        return $this->getName();
    }
    
    function getOwner(): ?User
    {
        return (new Users)->get($this->getRecord()->owner);
    }
    
    function getDescription(): ?string
    {
        return $this->getRecord()->about;
    }
    
    function getShortCode(): ?string
    {
        return $this->getRecord()->shortcode;
    }
    
    function getBanReason(): ?string
    {
        return $this->getRecord()->block_reason;
    }
    
    function getOpennesStatus(): int
    {
        return $this->getRecord()->closed;
    }
    
    function getType(): int
    {
        return $this->getRecord()->type;
    }
    
    function isVerified(): bool
    {
        return (bool) $this->getRecord()->verified;
    }
    
    function isBanned(): bool
    {
        return !is_null($this->getBanReason());
    }

    function canPost(): bool
    {
	return (bool) $this->getRecord()->wall;
    }

    
    function setShortCode(?string $code = NULL): ?bool
    {
        if(!is_null($code)) {
            if(!preg_match("%^[a-z][a-z0-9\\.\\_]{0,30}[a-z0-9]$%", $code))
                return false;
            if(in_array($code, OPENVK_ROOT_CONF["openvk"]["preferences"]["shortcodes"]["forbiddenNames"]))
                return false;
            if(\Chandler\MVC\Routing\Router::i()->getMatchingRoute("/$code")[0]->presenter !== "UnknownTextRouteStrategy")
                return false;
            
            $pUser = DB::i()->getContext()->table("profiles")->where("shortcode", $code)->fetch();
            if(!is_null($pUser))
                return false;
        }
        
        $this->stateChanges("shortcode", $code);
        return true;
    }
    
    function isSubscriptionAccepted(User $user): bool
    {
        return !is_null($this->getRecord()->related("subscriptions.follower")->where([
            "follower" => $this->getId(),
            "target"   => $user->getId(),
        ])->fetch());;
    }
    
    function getPostViewStats(bool $unique = false): ?array
    {
        $edb = eventdb();
        if(!$edb)
            return NULL;
        
        $subs  = [];
        $viral = [];
        $total = [];
        for($i = 1; $i < 8; $i++) {
            $begin = strtotime("-" . $i . "day midnight");
            $end   = $i === 1 ? time() + 10 : strtotime("-" . ($i - 1) . "day midnight");
            
            $query  = "SELECT COUNT(" . ($unique ? "DISTINCT profile" : "*") . ") AS cnt FROM postViews";
            $query .= " WHERE `group`=1 AND owner=" . $this->getId();
            $query .= " AND timestamp > $begin AND timestamp < $end";
            
            $sub = $edb->getConnection()->query("$query AND NOT subscribed=0")->fetch()->cnt;
            $vir = $edb->getConnection()->query("$query AND subscribed=0")->fetch()->cnt;
            $subs[]  = $sub;
            $viral[] = $vir;
            $total[] = $sub + $vir;
        }
        
        return [
            "total" => [
                "x" => array_reverse(range(1, 7)),
                "y" => $total,
                "type" => "scatter",
                "line" => [
                    "shape" => "spline",
                    "color" => "#597da3",
                ],
                "name" => $unique ? "Полный охват" : "Все просмотры",
            ],
            "subs"  => [
                "x" => array_reverse(range(1, 7)),
                "y" => $subs,
                "type" => "scatter",
                "line" => [
                    "shape" => "spline",
                    "color" => "#b05c91",
                ],
                "fill" => "tozeroy",
                "name" => $unique ? "Охват подписчиков" : "Просмотры подписчиков",
            ],
            "viral" => [
                "x" => array_reverse(range(1, 7)),
                "y" => $viral,
                "type" => "scatter",
                "line" => [
                    "shape" => "spline",
                    "color" => "#4d9fab",
                ],
                "fill" => "tozeroy",
                "name" => $unique ? "Виральный охват" : "Виральные просмотры",
            ],
        ];
    }
    
    function getSubscriptionStatus(User $user): bool
    {
        $subbed = !is_null($this->getRecord()->related("subscriptions.target")->where([
            "target"   => $this->getId(),
            "model"    => static::class,
            "follower" => $user->getId(),
        ])->fetch());
        
        return $subbed && ($this->getOpennesStatus() === static::CLOSED ? $this->isSubscriptionAccepted($user) : true);
    }
    
    function getFollowersQuery(): GroupedSelection
    {
        $query = $this->getRecord()->related("subscriptions.target");
        
        if($this->getOpennesStatus() === static::OPEN) {
            $query = $query->where("model", "openvk\\Web\\Models\\Entities\\Club");
        } else {
            return false;
        }
        
        return $query;
    }
    
    function getFollowersCount(): int
    {
        return sizeof($this->getFollowersQuery());
    }
    
    function getFollowers(int $page = 1): \Traversable
    {
        $rels = $this->getFollowersQuery()->page($page, 6);
        
        foreach($rels as $rel) {
            $rel = (new Users)->get($rel->follower);
            if(!$rel) continue;
            
            yield $rel;
        }
    }
    
    function getManagers(int $page = 1): \Traversable
    {
        $rels = $this->getRecord()->related("group_coadmins.club")->page($page, 6);
        
        foreach($rels as $rel) {
            $rel = (new Users)->get($rel->user);
            if(!$rel) continue;

            yield $rel;
        }
    }

    function getManagersWithComment(int $page = 1): \Traversable
    {
        $rels = $this->getRecord()->related("group_coadmins.club")->where("comment IS NOT NULL")->page($page, 10);
        
        foreach($rels as $rel) {
            $rel = (new Managers)->get($rel->id);
            if(!$rel) continue;

            yield $rel;
        }
    }
    
    function getManagersCount(): int
    {
        return sizeof($this->getRecord()->related("group_coadmins.club")) + 1;
    }

    function getManagersCountWithComment(): int
    {
        return sizeof($this->getRecord()->related("group_coadmins.club")->where("comment IS NOT NULL")) + 1;
    }
    
    function addManager(User $user, ?string $comment = NULL): void
    {
        DB::i()->getContext()->table("group_coadmins")->insert([
            "club" => $this->getId(),
            "user" => $user->getId(),
            "comment" => $comment,
        ]);
    }
    
    function removeManager(User $user): void
    {
        DB::i()->getContext()->table("group_coadmins")->where([
            "club" => $this->getId(),
            "user" => $user->getId(),
        ])->delete();
    }
    
    function canBeModifiedBy(User $user): bool
    {
        $id = $user->getId();
        if($this->getOwner()->getId() === $id)
            return true;
        
        return !is_null($this->getRecord()->related("group_coadmins.club")->where("user", $id)->fetch());
    }
    
    use Traits\TSubscribable;
}