123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137 |
- <?php
- if (!defined('STATUSNET')) {
- exit(1);
- }
- class SearchSub extends Managed_DataObject
- {
- public $__table = 'searchsub';
- public $search;
- public $profile_id;
- public $created;
-
- public static function schemaDef()
- {
- return array(
- 'description' => 'SearchSubPlugin search subscription records',
- 'fields' => array(
- 'search' => array('type' => 'varchar', 'length' => 64, 'not null' => true, 'description' => 'hash search associated with this subscription'),
- 'profile_id' => array('type' => 'int', 'not null' => true, 'description' => 'profile ID of subscribing user'),
- 'created' => array('type' => 'datetime', 'not null' => true, 'description' => 'date this record was created'),
- ),
- 'primary key' => array('search', 'profile_id'),
- 'foreign keys' => array(
- 'searchsub_profile_id_fkey' => array('profile', array('profile_id' => 'id')),
- ),
- 'indexes' => array(
- 'searchsub_created_idx' => array('created'),
- 'searchsub_profile_id_tag_idx' => array('profile_id', 'search'),
- ),
- );
- }
-
- static function start(Profile $profile, $search)
- {
- $ts = new SearchSub();
- $ts->search = $search;
- $ts->profile_id = $profile->id;
- $ts->created = common_sql_now();
- $ts->insert();
- self::blow('searchsub:by_profile:%d', $profile->id);
- return $ts;
- }
-
- static function cancel(Profile $profile, $search)
- {
- $ts = SearchSub::pkeyGet(array('search' => $search,
- 'profile_id' => $profile->id));
- if ($ts) {
- $ts->delete();
- self::blow('searchsub:by_profile:%d', $profile->id);
- }
- }
- static function forProfile(Profile $profile)
- {
- $searches = array();
- $keypart = sprintf('searchsub:by_profile:%d', $profile->id);
- $searchstring = self::cacheGet($keypart);
-
- if ($searchstring !== false) {
- if (!empty($searchstring)) {
- $searches = explode(',', $searchstring);
- }
- } else {
- $searchsub = new SearchSub();
- $searchsub->profile_id = $profile->id;
- $searchsub->selectAdd();
- $searchsub->selectAdd('search');
- if ($searchsub->find()) {
- $searches = $searchsub->fetchAll('search');
- }
- self::cacheSet($keypart, implode(',', $searches));
- }
- return $searches;
- }
- }
|