replynoticestream.php 3.6 KB

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