X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=classes%2FFile_to_post.php;h=bf201756f493b8630a4a7f702bad96451f4339fe;hb=42c653a9d0a57d8b575614827a569badd054e5a7;hp=ea5751042649e4cc3a2f350d493ccab179549cf5;hpb=c5cf2c4c94794a1aeea32a427ddd50e157fa893d;p=quix0rs-gnu-social.git diff --git a/classes/File_to_post.php b/classes/File_to_post.php index ea57510426..bf201756f4 100644 --- a/classes/File_to_post.php +++ b/classes/File_to_post.php @@ -17,15 +17,13 @@ * along with this program. If not, see . */ -if (!defined('STATUSNET')) { exit(1); } - -require_once INSTALLDIR.'/classes/Memcached_DataObject.php'; +if (!defined('GNUSOCIAL')) { exit(1); } /** * Table Definition for file_to_post */ -class File_to_post extends Memcached_DataObject +class File_to_post extends Managed_DataObject { ###START_AUTOCODE /* the code below is auto generated do not remove the above tag */ @@ -35,36 +33,82 @@ class File_to_post extends Memcached_DataObject public $post_id; // int(4) primary_key not_null public $modified; // timestamp() not_null default_CURRENT_TIMESTAMP - /* Static get */ - function staticGet($k,$v=NULL) { return Memcached_DataObject::staticGet('File_to_post',$k,$v); } - /* the code above is auto generated do not remove the tag below */ ###END_AUTOCODE - function processNew($file_id, $notice_id) { + public static function schemaDef() + { + return array( + 'fields' => array( + 'file_id' => array('type' => 'int', 'not null' => true, 'description' => 'id of URL/file'), + 'post_id' => array('type' => 'int', 'not null' => true, 'description' => 'id of the notice it belongs to'), + 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date this record was modified'), + ), + 'primary key' => array('file_id', 'post_id'), + 'foreign keys' => array( + 'file_to_post_file_id_fkey' => array('file', array('file_id' => 'id')), + 'file_to_post_post_id_fkey' => array('notice', array('post_id' => 'id')), + ), + 'indexes' => array( + 'file_id_idx' => array('file_id'), + 'post_id_idx' => array('post_id'), + ), + ); + } + + static function processNew(File $file, Notice $notice) { static $seen = array(); - if (empty($seen[$notice_id]) || !in_array($file_id, $seen[$notice_id])) { - $f2p = File_to_post::pkeyGet(array('post_id' => $notice_id, - 'file_id' => $file_id)); - if (empty($f2p)) { + $file_id = $file->getID(); + $notice_id = $notice->getID(); + if (!array_key_exists($notice_id, $seen)) { + $seen[$notice_id] = array(); + } + + if (empty($seen[$notice_id]) || !in_array($file_id, $seen[$notice_id])) { + try { + $f2p = File_to_post::getByPK(array('post_id' => $notice_id, + 'file_id' => $file_id)); + } catch (NoResultException $e) { $f2p = new File_to_post; $f2p->file_id = $file_id; $f2p->post_id = $notice_id; $f2p->insert(); + + $file->blowCache(); } - if (empty($seen[$notice_id])) { - $seen[$notice_id] = array($file_id); - } else { - $seen[$notice_id][] = $file_id; - } + $seen[$notice_id][] = $file_id; + } + } + + static function getNoticeIDsByFile(File $file) + { + $f2p = new File_to_post(); + + $f2p->selectAdd(); + $f2p->selectAdd('post_id'); + + $f2p->file_id = $file->getID(); + + $ids = array(); + + if (!$f2p->find()) { + throw new NoResultException($f2p); } + + return $f2p->fetchAll('post_id'); } - function &pkeyGet($kv) + function delete($useWhere=false) { - return Memcached_DataObject::pkeyGet('File_to_post', $kv); + try { + $f = File::getByID($this->file_id); + $f->blowCache(); + } catch (NoResultException $e) { + // ...alright, that's weird, but no File to delete anyway. + } + + return parent::delete($useWhere); } } -