context = DatabaseConnection::i()->getContext(); $this->comments = $this->context->table("comments"); } private function toComment(?ActiveRow $ar): ?Comment { return is_null($ar) ? NULL : new Comment($ar); } function get(int $id): ?Comment { return $this->toComment($this->comments->get($id)); } function getCommentsByTarget(Postable $target, int $page, ?int $perPage = NULL): \Traversable { $comments = $this->comments->where([ "model" => get_class($target), "target" => $target->getId(), "deleted" => false, ])->page($page, $perPage ?? OPENVK_DEFAULT_PER_PAGE); foreach($comments as $comment) yield $this->toComment($comment); } function getLastCommentsByTarget(Postable $target, ?int $count = NULL): \Traversable { $comments = $this->comments->where([ "model" => get_class($target), "target" => $target->getId(), "deleted" => false, ])->page(1, $count ?? OPENVK_DEFAULT_PER_PAGE)->order("created DESC"); $comments = array_reverse(iterator_to_array($comments)); foreach($comments as $comment) yield $this->toComment($comment); } function getCommentsCountByTarget(Postable $target): int { return sizeof($this->comments->where([ "model" => get_class($target), "target" => $target->getId(), "deleted" => false, ])); } function getCountOfAllComments(): int { return sizeof($this->comments->where(["deleted" => false])); } }