tagnoticestream.php 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. <?php
  2. // This file is part of GNU social - https://www.gnu.org/software/social
  3. //
  4. // GNU social is free software: you can redistribute it and/or modify
  5. // it under the terms of the GNU Affero General Public License as published by
  6. // the Free Software Foundation, either version 3 of the License, or
  7. // (at your option) any later version.
  8. //
  9. // GNU social is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. // GNU Affero General Public License for more details.
  13. //
  14. // You should have received a copy of the GNU Affero General Public License
  15. // along with GNU social. If not, see <http://www.gnu.org/licenses/>.
  16. /**
  17. * Stream of notices with a given tag
  18. *
  19. * @category Stream
  20. * @package GNUsocial
  21. * @author Evan Prodromou <evan@status.net>
  22. * @copyright 2011 StatusNet, Inc.
  23. * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
  24. */
  25. defined('GNUSOCIAL') || die();
  26. /**
  27. * Stream of notices with a given tag
  28. *
  29. * @category Stream
  30. * @package GNUsocial
  31. * @author Evan Prodromou <evan@status.net>
  32. * @copyright 2011 StatusNet, Inc.
  33. * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
  34. */
  35. class TagNoticeStream extends ScopingNoticeStream
  36. {
  37. public function __construct($tag, Profile $scoped=null)
  38. {
  39. parent::__construct(
  40. new CachingNoticeStream(
  41. new RawTagNoticeStream($tag),
  42. 'notice_tag:notice_ids:' . Cache::keyize($tag)
  43. ),
  44. $scoped
  45. );
  46. }
  47. }
  48. /**
  49. * Raw stream of notices with a given tag
  50. *
  51. * @category Stream
  52. * @package GNUsocial
  53. * @author Evan Prodromou <evan@status.net>
  54. * @copyright 2011 StatusNet, Inc.
  55. * @license https://www.gnu.org/licenses/agpl.html GNU AGPL v3 or later
  56. */
  57. class RawTagNoticeStream extends NoticeStream
  58. {
  59. protected $tag;
  60. public function __construct($tag)
  61. {
  62. $this->tag = $tag;
  63. }
  64. public function getNoticeIds($offset, $limit, $since_id, $max_id)
  65. {
  66. $nt = new Notice_tag();
  67. $nt->tag = $this->tag;
  68. $nt->selectAdd();
  69. $nt->selectAdd('notice_id');
  70. Notice::addWhereSinceId($nt, $since_id, 'notice_id', 'notice_tag.created');
  71. Notice::addWhereMaxId($nt, $max_id, 'notice_id', 'notice_tag.created');
  72. if (!empty($this->selectVerbs)) {
  73. $nt->joinAdd(array('notice_id', 'notice:id'));
  74. $filter = array_keys(array_filter($this->selectVerbs));
  75. if (!empty($filter)) {
  76. // include verbs in selectVerbs with values that equate to true
  77. $nt->whereAddIn('notice.verb', $filter, 'string');
  78. }
  79. $filter = array_keys(array_filter($this->selectVerbs, function ($v) {
  80. return !$v;
  81. }));
  82. if (!empty($filter)) {
  83. // exclude verbs in selectVerbs with values that equate to false
  84. $nt->whereAddIn('!notice.verb', $filter, 'string');
  85. }
  86. }
  87. $nt->orderBy('notice_tag.created DESC, notice_id DESC');
  88. if (!is_null($offset)) {
  89. $nt->limit($offset, $limit);
  90. }
  91. $ids = array();
  92. if ($nt->find()) {
  93. while ($nt->fetch()) {
  94. $ids[] = $nt->notice_id;
  95. }
  96. }
  97. return $ids;
  98. }
  99. }