123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976 |
- <?php
- if (!defined('GNUSOCIAL')) { exit(1); }
- define('NOTICE_CACHE_WINDOW', CachingNoticeStream::CACHE_WINDOW);
- define('MAX_BOXCARS', 128);
- class Notice extends Managed_DataObject
- {
-
-
- public $__table = 'notice';
- public $id;
- public $profile_id;
- public $uri;
- public $content;
- public $rendered;
- public $url;
- public $created;
- public $modified;
- public $reply_to;
- public $is_local;
- public $source;
- public $conversation;
- public $lat;
- public $lon;
- public $location_id;
- public $location_ns;
- public $repeat_of;
- public $verb;
- public $object_type;
- public $scope;
-
-
- public static function schemaDef()
- {
- $def = array(
- 'fields' => array(
- 'id' => array('type' => 'serial', 'not null' => true, 'description' => 'unique identifier'),
- 'profile_id' => array('type' => 'int', 'not null' => true, 'description' => 'who made the update'),
- 'uri' => array('type' => 'varchar', 'length' => 255, 'description' => 'universally unique identifier, usually a tag URI'),
- 'content' => array('type' => 'text', 'description' => 'update content', 'collate' => 'utf8_general_ci'),
- 'rendered' => array('type' => 'text', 'description' => 'HTML version of the content'),
- 'url' => array('type' => 'varchar', 'length' => 255, 'description' => 'URL of any attachment (image, video, bookmark, whatever)'),
- 'created' => array('type' => 'datetime', 'not null' => true, 'description' => 'date this record was created'),
- 'modified' => array('type' => 'timestamp', 'not null' => true, 'description' => 'date this record was modified'),
- 'reply_to' => array('type' => 'int', 'description' => 'notice replied to (usually a guess)'),
- 'is_local' => array('type' => 'int', 'size' => 'tiny', 'default' => 0, 'description' => 'notice was generated by a user'),
- 'source' => array('type' => 'varchar', 'length' => 32, 'description' => 'source of comment, like "web", "im", or "clientname"'),
- 'conversation' => array('type' => 'int', 'description' => 'id of root notice in this conversation'),
- 'lat' => array('type' => 'numeric', 'precision' => 10, 'scale' => 7, 'description' => 'latitude'),
- 'lon' => array('type' => 'numeric', 'precision' => 10, 'scale' => 7, 'description' => 'longitude'),
- 'location_id' => array('type' => 'int', 'description' => 'location id if possible'),
- 'location_ns' => array('type' => 'int', 'description' => 'namespace for location'),
- 'repeat_of' => array('type' => 'int', 'description' => 'notice this is a repeat of'),
- 'object_type' => array('type' => 'varchar', 'length' => 255, 'description' => 'URI representing activity streams object type', 'default' => 'http://activitystrea.ms/schema/1.0/note'),
- 'verb' => array('type' => 'varchar', 'length' => 255, 'description' => 'URI representing activity streams verb', 'default' => 'http://activitystrea.ms/schema/1.0/post'),
- 'scope' => array('type' => 'int',
- 'description' => 'bit map for distribution scope; 0 = everywhere; 1 = this server only; 2 = addressees; 4 = followers; null = default'),
- ),
- 'primary key' => array('id'),
- 'unique keys' => array(
- 'notice_uri_key' => array('uri'),
- ),
- 'foreign keys' => array(
- 'notice_profile_id_fkey' => array('profile', array('profile_id' => 'id')),
- 'notice_reply_to_fkey' => array('notice', array('reply_to' => 'id')),
- 'notice_conversation_fkey' => array('conversation', array('conversation' => 'id')),
- 'notice_repeat_of_fkey' => array('notice', array('repeat_of' => 'id')),
- ),
- 'indexes' => array(
- 'notice_created_id_is_local_idx' => array('created', 'id', 'is_local'),
- 'notice_profile_id_idx' => array('profile_id', 'created', 'id'),
- 'notice_repeat_of_created_id_idx' => array('repeat_of', 'created', 'id'),
- 'notice_conversation_created_id_idx' => array('conversation', 'created', 'id'),
- 'notice_replyto_idx' => array('reply_to')
- )
- );
- if (common_config('search', 'type') == 'fulltext') {
- $def['fulltext indexes'] = array('content' => array('content'));
- }
- return $def;
- }
-
-
- const LOCAL_PUBLIC = 1;
- const REMOTE = 0;
- const LOCAL_NONPUBLIC = -1;
- const GATEWAY = -2;
- const PUBLIC_SCOPE = 0;
- const SITE_SCOPE = 1;
- const ADDRESSEE_SCOPE = 2;
- const GROUP_SCOPE = 4;
- const FOLLOWER_SCOPE = 8;
- protected $_profile = array();
-
-
- public function getProfile()
- {
- if (!isset($this->_profile[$this->profile_id])) {
-
-
- $profile = Profile::getKV('id', $this->profile_id);
- $this->_setProfile($profile instanceof Profile ? $profile : null);
- }
- return $this->_profile[$this->profile_id];
- }
-
- public function _setProfile(Profile $profile=null)
- {
- if (!$profile instanceof Profile) {
- throw new NoProfileException($this->profile_id);
- }
- $this->_profile[$this->profile_id] = $profile;
- }
- function delete($useWhere=false)
- {
-
-
-
-
- $deleted = Deleted_notice::getKV('id', $this->id);
- if (!$deleted instanceof Deleted_notice) {
- $deleted = Deleted_notice::getKV('uri', $this->uri);
- }
- if (!$deleted instanceof Deleted_notice) {
- $deleted = new Deleted_notice();
- $deleted->id = $this->id;
- $deleted->profile_id = $this->profile_id;
- $deleted->uri = $this->uri;
- $deleted->created = $this->created;
- $deleted->deleted = common_sql_now();
- $deleted->insert();
- }
- if (Event::handle('NoticeDeleteRelated', array($this))) {
-
- $this->clearReplies();
- $this->clearRepeats();
- $this->clearTags();
- $this->clearGroupInboxes();
- $this->clearFiles();
- $this->clearAttentions();
-
- }
- $result = parent::delete($useWhere);
- $this->blowOnDelete();
- return $result;
- }
- public function getUri()
- {
- return $this->uri;
- }
-
- static function fromUri($uri)
- {
- $notice = null;
- if (Event::handle('StartGetNoticeFromUri', array($uri, &$notice))) {
- $notice = Notice::getKV('uri', $uri);
- Event::handle('EndGetNoticeFromUri', array($uri, $notice));
- }
- if (!$notice instanceof Notice) {
- throw new UnknownUriException($uri);
- }
- return $notice;
- }
-
- public function getConversationUrl($anchor=true)
- {
- return Conversation::getUrlFromNotice($this, $anchor);
- }
-
- public function getLocalUrl()
- {
- return common_local_url('shownotice', array('notice' => $this->id), null, null, false);
- }
- public function getTitle()
- {
- $title = null;
- if (Event::handle('GetNoticeTitle', array($this, &$title))) {
-
-
- $title = sprintf(_('%1$s\'s status on %2$s'),
- $this->getProfile()->getFancyName(),
- common_exact_date($this->created));
- }
- return $title;
- }
-
- public function getContent()
- {
- return $this->content;
- }
-
- public function getUrl($fallback=false)
- {
-
-
- switch (true) {
- case common_valid_http_url($this->url):
- return $this->url;
- case !$this->isLocal() && common_valid_http_url($this->uri):
- return $this->uri;
- case $this->isLocal() || $fallback:
-
- return common_local_url('shownotice', array('notice' => $this->id), null, null, false);
- default:
- common_debug('No URL available for notice: id='.$this->id);
- throw new InvalidUrlException($this->url);
- }
- }
- public function get_object_type($canonical=false) {
- return $canonical
- ? ActivityObject::canonicalType($this->object_type)
- : $this->object_type;
- }
- public static function getByUri($uri)
- {
- $notice = new Notice();
- $notice->uri = $uri;
- if (!$notice->find(true)) {
- throw new NoResultException($notice);
- }
- return $notice;
- }
-
- function saveTags()
- {
-
- $count = preg_match_all('/(?:^|\s)#([\pL\pN_\-\.]{1,64})/u', strtolower($this->content), $match);
- if (!$count) {
- return true;
- }
-
- return $this->saveKnownTags($match[1]);
- }
-
- function saveKnownTags($hashtags)
- {
-
-
- for($i=0; $i<count($hashtags); $i++) {
-
- $hashtags[$i] = common_canonical_tag($hashtags[$i]);
- }
- foreach(array_unique($hashtags) as $hashtag) {
- $this->saveTag($hashtag);
- self::blow('profile:notice_ids_tagged:%d:%s', $this->profile_id, $hashtag);
- }
- return true;
- }
-
- function saveTag($hashtag)
- {
- $tag = new Notice_tag();
- $tag->notice_id = $this->id;
- $tag->tag = $hashtag;
- $tag->created = $this->created;
- $id = $tag->insert();
- if (!$id) {
-
- throw new ServerException(sprintf(_('Database error inserting hashtag: %s.'),
- $last_error->message));
- return;
- }
-
- $tag->blowCache(false);
- }
-
- static function saveNew($profile_id, $content, $source, array $options=null) {
- $defaults = array('uri' => null,
- 'url' => null,
- 'conversation' => null,
- 'reply_to' => null,
- 'repeat_of' => null,
- 'scope' => null,
- 'distribute' => true,
- 'object_type' => null,
- 'verb' => null);
- if (!empty($options) && is_array($options)) {
- $options = array_merge($defaults, $options);
- extract($options);
- } else {
- extract($defaults);
- }
- if (!isset($is_local)) {
- $is_local = Notice::LOCAL_PUBLIC;
- }
- $profile = Profile::getKV('id', $profile_id);
- if (!$profile instanceof Profile) {
-
- throw new ClientException(_('Problem saving notice. Unknown user.'));
- }
- $user = User::getKV('id', $profile_id);
- if ($user instanceof User) {
-
- $final = $user->shortenLinks($content);
- } else {
- $final = common_shorten_links($content);
- }
- if (Notice::contentTooLong($final)) {
-
- throw new ClientException(_('Problem saving notice. Too long.'));
- }
- if (common_config('throttle', 'enabled') && !Notice::checkEditThrottle($profile_id)) {
- common_log(LOG_WARNING, 'Excessive posting by profile #' . $profile_id . '; throttled.');
-
- throw new ClientException(_('Too many notices too fast; take a breather '.
- 'and post again in a few minutes.'));
- }
- if (common_config('site', 'dupelimit') > 0 && !Notice::checkDupes($profile_id, $final)) {
- common_log(LOG_WARNING, 'Dupe posting by profile #' . $profile_id . '; throttled.');
-
- throw new ClientException(_('Too many duplicate messages too quickly;'.
- ' take a breather and post again in a few minutes.'));
- }
- if (!$profile->hasRight(Right::NEWNOTICE)) {
- common_log(LOG_WARNING, "Attempted post from user disallowed to post: " . $profile->nickname);
-
- throw new ClientException(_('You are banned from posting notices on this site.'), 403);
- }
- $notice = new Notice();
- $notice->profile_id = $profile_id;
- $autosource = common_config('public', 'autosource');
-
- if (!$profile->hasRight(Right::PUBLICNOTICE) ||
- ($source && $autosource && in_array($source, $autosource))) {
- $notice->is_local = Notice::LOCAL_NONPUBLIC;
- } else {
- $notice->is_local = $is_local;
- }
- if (!empty($created)) {
- $notice->created = $created;
- } else {
- $notice->created = common_sql_now();
- }
- if (!$notice->isLocal()) {
-
- if (!common_valid_http_url($url)) {
- common_debug('Bad notice URL: ['.$url.'], URI: ['.$uri.']. Cannot link back to original! This is normal for shared notices etc.');
- }
- if (empty($uri)) {
- throw new ServerException('No URI for remote notice. Cannot accept that.');
- }
- }
- $notice->content = $final;
- $notice->source = $source;
- $notice->uri = $uri;
- $notice->url = $url;
-
- if (!isset($groups)) {
- $groups = User_group::idsFromText($notice->content, $profile);
- }
- $reply = null;
-
- if (isset($repeat_of)) {
-
- $repeat = Notice::getKV('id', $repeat_of);
- if (!($repeat instanceof Notice)) {
-
- throw new ClientException(_('Cannot repeat; original notice is missing or deleted.'));
- }
- if ($profile->id == $repeat->profile_id) {
-
- throw new ClientException(_('You cannot repeat your own notice.'));
- }
- if ($repeat->scope != Notice::SITE_SCOPE &&
- $repeat->scope != Notice::PUBLIC_SCOPE) {
-
- throw new ClientException(_('Cannot repeat a private notice.'), 403);
- }
- if (!$repeat->inScope($profile)) {
-
-
- throw new ClientException(_('Cannot repeat a notice you cannot read.'), 403);
- }
- if ($profile->hasRepeated($repeat)) {
-
- throw new ClientException(_('You already repeated that notice.'));
- }
- $notice->repeat_of = $repeat->id;
- $notice->conversation = $repeat->conversation;
- } else {
- $reply = null;
-
-
- if (!empty($reply_to)) {
- $reply = Notice::getKV('id', $reply_to);
- } elseif (in_array($source, array('xmpp', 'mail', 'sms'))) {
-
-
- $reply = self::getInlineReplyTo($profile, $final);
- }
- if ($reply instanceof Notice) {
- if (!$reply->inScope($profile)) {
-
-
- throw new ClientException(sprintf(_('%1$s has no access to notice %2$d.'),
- $profile->nickname, $reply->id), 403);
- }
-
- if ($reply->isRepeat()) {
- $notice->reply_to = $reply->repeat_of;
- } else {
- $notice->reply_to = $reply->id;
- }
-
- $notice->conversation = $reply->conversation;
-
-
- if (empty($groups) && ($reply->scope & Notice::GROUP_SCOPE)) {
- $groups = array();
- $replyGroups = $reply->getGroups();
- foreach ($replyGroups as $group) {
- if ($profile->isMember($group)) {
- $groups[] = $group->id;
- }
- }
- }
-
- }
-
-
-
- if (empty($notice->conversation) and !empty($options['conversation'])) {
- $conv = Conversation::getKV('uri', $options['conversation']);
- if ($conv instanceof Conversation) {
- common_debug('Conversation stitched together from (probably) reply to unknown remote user. Activity creation time ('.$notice->created.') should maybe be compared to conversation creation time ('.$conv->created.').');
- $notice->conversation = $conv->id;
- } else {
-
-
- $notice->tmp_conv_uri = $options['conversation'];
- }
- } else {
-
-
-
- $options['conversation'] = null;
- }
- }
- if (!empty($lat) && !empty($lon)) {
- $notice->lat = $lat;
- $notice->lon = $lon;
- }
- if (!empty($location_ns) && !empty($location_id)) {
- $notice->location_id = $location_id;
- $notice->location_ns = $location_ns;
- }
- if (!empty($rendered)) {
- $notice->rendered = $rendered;
- } else {
- $notice->rendered = common_render_content($final, $notice);
- }
- if (empty($verb)) {
- if ($notice->isRepeat()) {
- $notice->verb = ActivityVerb::SHARE;
- $notice->object_type = ActivityObject::ACTIVITY;
- } else {
- $notice->verb = ActivityVerb::POST;
- }
- } else {
- $notice->verb = $verb;
- }
- if (empty($object_type)) {
- $notice->object_type = (empty($notice->reply_to)) ? ActivityObject::NOTE : ActivityObject::COMMENT;
- } else {
- $notice->object_type = $object_type;
- }
- if (is_null($scope) && $reply instanceof Notice) {
- $notice->scope = $reply->scope;
- } else {
- $notice->scope = $scope;
- }
- $notice->scope = self::figureOutScope($profile, $groups, $notice->scope);
- if (Event::handle('StartNoticeSave', array(&$notice))) {
-
- try {
- $notice->insert();
-
-
- if (empty($notice->conversation)) {
- $orig = clone($notice);
-
- $conv = Conversation::create($notice, $options['conversation']);
- $notice->conversation = $conv->id;
- $notice->update($orig);
- }
- } catch (Exception $e) {
-
-
-
- if (!empty($notice->id)) {
- $notice->delete();
- }
- throw $e;
- }
- }
-
-
-
- if (isset($replies)) {
- $notice->saveKnownReplies($replies);
- } else {
- $notice->saveReplies();
- }
- if (isset($tags)) {
- $notice->saveKnownTags($tags);
- } else {
- $notice->saveTags();
- }
-
-
-
- $notice->saveKnownGroups($groups);
- if (isset($urls)) {
- $notice->saveKnownUrls($urls);
- } else {
- $notice->saveUrls();
- }
- if ($distribute) {
-
- $notice->distribute();
- }
- return $notice;
- }
- static function saveActivity(Activity $act, Profile $actor, array $options=array())
- {
-
- if (!$actor->hasRight(Right::NEWNOTICE)) {
- common_log(LOG_WARNING, "Attempted post from user disallowed to post: " . $actor->getNickname());
-
- throw new ClientException(_m('You are banned from posting notices on this site.'), 403);
- }
- if (common_config('throttle', 'enabled') && !self::checkEditThrottle($actor->id)) {
- common_log(LOG_WARNING, 'Excessive posting by profile #' . $actor->id . '; throttled.');
-
- throw new ClientException(_m('Too many notices too fast; take a breather '.
- 'and post again in a few minutes.'));
- }
-
- if (!empty($act->id)) {
-
- $options['uri'] = $act->id;
- $options['url'] = $act->link;
- } else {
- $actobj = count($act->objects)==1 ? $act->objects[0] : null;
- if (!is_null($actobj) && !empty($actobj->id)) {
- $options['uri'] = $actobj->id;
- if ($actobj->link) {
- $options['url'] = $actobj->link;
- } elseif (preg_match('!^https?://!', $actobj->id)) {
- $options['url'] = $actobj->id;
- }
- }
- }
- $defaults = array(
- 'groups' => array(),
- 'is_local' => self::LOCAL_PUBLIC,
- 'mentions' => array(),
- 'reply_to' => null,
- 'repeat_of' => null,
- 'scope' => null,
- 'source' => 'unknown',
- 'tags' => array(),
- 'uri' => null,
- 'url' => null,
- 'urls' => array(),
- 'distribute' => true);
-
- $options = array_merge($defaults, $options);
- foreach (array_keys($defaults) as $key) {
-
- $$key = $options[$key];
- }
- extract($options, EXTR_SKIP);
- $stored = new Notice();
- if (!empty($uri)) {
- $stored->uri = $uri;
- if ($stored->find()) {
- common_debug('cannot create duplicate Notice URI: '.$stored->uri);
- throw new Exception('Notice URI already exists');
- }
- }
- $stored->profile_id = $actor->id;
- $stored->source = $source;
- $stored->uri = $uri;
- $stored->url = $url;
- $stored->verb = $act->verb;
-
- $stored->rendered = $actor->isLocal()
- ? $actor->shortenLinks($act->content)
- : $act->content;
- $stored->content = common_strip_html($stored->rendered);
- $autosource = common_config('public', 'autosource');
-
- if (!$actor->hasRight(Right::PUBLICNOTICE) ||
- ($source && $autosource && in_array($source, $autosource))) {
- $stored->is_local = Notice::LOCAL_NONPUBLIC;
- }
-
- if (!empty($act->time)) {
- $stored->created = common_sql_date($act->time);
- } else {
- $stored->created = common_sql_now();
- }
- $reply = null;
- if ($act->context instanceof ActivityContext && !empty($act->context->replyToID)) {
- $reply = self::getKV('uri', $act->context->replyToID);
- }
- if (!$reply instanceof Notice && $act->target instanceof ActivityObject) {
- $reply = self::getKV('uri', $act->target->id);
- }
- if ($reply instanceof Notice) {
- if (!$reply->inScope($actor)) {
-
-
- throw new ClientException(sprintf(_m('%1$s has no right to reply to notice %2$d.'), $actor->getNickname(), $reply->id), 403);
- }
- $stored->reply_to = $reply->id;
- $stored->conversation = $reply->conversation;
-
-
- if (empty($groups) && ($reply->scope & Notice::GROUP_SCOPE)) {
- $groups = array();
- $replyGroups = $reply->getGroups();
- foreach ($replyGroups as $group) {
- if ($actor->isMember($group)) {
- $groups[] = $group->id;
- }
- }
- }
- if (is_null($scope)) {
- $scope = $reply->scope;
- }
- }
- if ($act->context instanceof ActivityContext) {
- $location = $act->context->location;
- if ($location) {
- $stored->lat = $location->lat;
- $stored->lon = $location->lon;
- if ($location->location_id) {
- $stored->location_ns = $location->location_ns;
- $stored->location_id = $location->location_id;
- }
- }
- } else {
- $act->context = new ActivityContext();
- }
- $stored->scope = self::figureOutScope($actor, $groups, $scope);
- foreach ($act->categories as $cat) {
- if ($cat->term) {
- $term = common_canonical_tag($cat->term);
- if (!empty($term)) {
- $tags[] = $term;
- }
- }
- }
- foreach ($act->enclosures as $href) {
-
- $urls[] = $href;
- }
- if (Event::handle('StartNoticeSave', array(&$stored))) {
-
- try {
- $stored->insert();
- $orig = clone($stored);
-
-
- if (empty($stored->conversation)) {
-
- $conv = Conversation::create($stored, $act->context->conversation);
- $stored->conversation = $conv->id;
- }
- $object = null;
- Event::handle('StoreActivityObject', array($act, $stored, $options, &$object));
- if (empty($object)) {
- throw new ServerException('No object from StoreActivityObject '.$stored->uri . ': '.$act->asString());
- }
- $stored->object_type = ActivityUtils::resolveUri($object->getObjectType(), true);
- $stored->update($orig);
- } catch (Exception $e) {
- if (empty($stored->id)) {
- common_debug('Failed to save stored object entry in database ('.$e->getMessage().')');
- } else {
- common_debug('Failed to store activity object in database ('.$e->getMessage().'), deleting notice id '.$stored->id);
- $stored->delete();
- }
- throw $e;
- }
- }
- if (!$stored instanceof Notice) {
- throw new ServerException('StartNoticeSave did not give back a Notice');
- }
-
- $mentions = array();
- $groups = array();
-
-
- Event::handle('GetLocalAttentions', array($actor, $act->context->attention, &$mentions, &$groups));
- if (!empty($mentions)) {
- $stored->saveKnownReplies($mentions);
- } else {
- $stored->saveReplies();
- }
- if (!empty($tags)) {
- $stored->saveKnownTags($tags);
- } else {
- $stored->saveTags();
- }
-
-
-
- $stored->saveKnownGroups($groups);
- if (!empty($urls)) {
- $stored->saveKnownUrls($urls);
- } else {
- $stored->saveUrls();
- }
- if ($distribute) {
-
- $stored->distribute();
- }
-
- return $stored;
- }
- static public function figureOutScope(Profile $actor, array $groups, $scope=null) {
- if (is_null($scope)) {
- $scope = self::defaultScope();
- }
-
- try {
- $user = $actor->getUser();
-
- if ($user->private_stream && ($scope == Notice::PUBLIC_SCOPE || $scope == Notice::SITE_SCOPE)) {
- $scope |= Notice::FOLLOWER_SCOPE;
- }
- } catch (NoSuchUserException $e) {
-
- }
-
- foreach ($groups as $group_id) {
- $group = User_group::staticGet('id', $group_id);
- if ($group instanceof User_group) {
- if ($group->force_scope) {
- $scope |= Notice::GROUP_SCOPE;
- break;
- }
- }
- }
- return $scope;
- }
- function blowOnInsert($conversation = false)
- {
- $this->blowStream('profile:notice_ids:%d', $this->profile_id);
- if ($this->isPublic()) {
- $this->blowStream('public');
- $this->blowStream('networkpublic');
- }
- self::blow('notice:list-ids:conversation:%s', $this->conversation);
- self::blow('conversation:notice_count:%d', $this->conversation);
- if ($this->isRepeat()) {
-
- $this->blowStream('notice:repeats:%d', $this->repeat_of);
- self::blow('notice:list-ids:repeat_of:%d', $this->repeat_of);
- }
- $original = Notice::getKV('id', $this->repeat_of);
- if ($original instanceof Notice) {
- $originalUser = User::getKV('id', $original->profile_id);
- if ($originalUser instanceof User) {
- $this->blowStream('user:repeats_of_me:%d', $originalUser->id);
- }
- }
- $profile = Profile::getKV($this->profile_id);
- if ($profile instanceof Profile) {
- $profile->blowNoticeCount();
- }
- $ptags = $this->getProfileTags();
- foreach ($ptags as $ptag) {
- $ptag->blowNoticeStreamCache();
- }
- }
-
- function blowOnDelete()
- {
- $this->blowOnInsert();
- self::blow('profile:notice_ids:%d;last', $this->profile_id);
- if ($this->isPublic()) {
- self::blow('public;last');
- self::blow('networkpublic;last');
- }
- self::blow('fave:by_notice', $this->id);
- if ($this->conversation) {
-
- self::blow('notice:conversation_root:%d', $this->conversation);
- }
- $ptags = $this->getProfileTags();
- foreach ($ptags as $ptag) {
- $ptag->blowNoticeStreamCache(true);
- }
- }
- function blowStream()
- {
- $c = self::memcache();
- if (empty($c)) {
- return false;
- }
- $args = func_get_args();
- $format = array_shift($args);
- $keyPart = vsprintf($format, $args);
- $cacheKey = Cache::key($keyPart);
-
- $c->delete($cacheKey);
-
-
- $lastKey = $cacheKey.';last';
- $lastStr = $c->get($lastKey);
- if ($lastStr !== false) {
- $window = explode(',', $lastStr);
- $lastID = $window[0];
- $lastNotice = Notice::getKV('id', $lastID);
- if (!$lastNotice instanceof Notice
- || strtotime($lastNotice->created) >= strtotime($this->created)) {
- $c->delete($lastKey);
- }
- }
- }
-
- function saveUrls() {
- if (common_config('attachments', 'process_links')) {
- common_replace_urls_callback($this->content, array($this, 'saveUrl'), $this->id);
- }
- }
-
- function saveKnownUrls($urls)
- {
- if (common_config('attachments', 'process_links')) {
-
- foreach (array_unique($urls) as $url) {
- try {
- File::processNew($url, $this->id);
- } catch (ServerException $e) {
-
- }
- }
- }
- }
-
- function saveUrl($url, $notice_id) {
- try {
- File::processNew($url, $notice_id);
- } catch (ServerException $e) {
-
- }
- }
- static function checkDupes($profile_id, $content) {
- $profile = Profile::getKV($profile_id);
- if (!$profile instanceof Profile) {
- return false;
- }
- $notice = $profile->getNotices(0, CachingNoticeStream::CACHE_WINDOW);
- if (!empty($notice)) {
- $last = 0;
- while ($notice->fetch()) {
- if (time() - strtotime($notice->created) >= common_config('site', 'dupelimit')) {
- return true;
- } else if ($notice->content == $content) {
- return false;
- }
- }
- }
-
-
- $notice = new Notice();
- $notice->profile_id = $profile_id;
- $notice->content = $content;
- $threshold = common_sql_date(time() - common_config('site', 'dupelimit'));
- $notice->whereAdd(sprintf("created > '%s'", $notice->escape($threshold)));
- $cnt = $notice->count();
- return ($cnt == 0);
- }
- static function checkEditThrottle($profile_id) {
- $profile = Profile::getKV($profile_id);
- if (!$profile instanceof Profile) {
- return false;
- }
-
- $notice = $profile->getNotices(common_config('throttle', 'count') - 1, 1);
- if ($notice && $notice->fetch()) {
-
- if (time() - strtotime($notice->created) <= common_config('throttle', 'timespan')) {
-
- return false;
- }
- }
-
- return true;
- }
- protected $_attachments = array();
-
- function attachments() {
- if (isset($this->_attachments[$this->id])) {
- return $this->_attachments[$this->id];
- }
-
- $f2ps = File_to_post::listGet('post_id', array($this->id));
-
- $ids = array();
-
- foreach ($f2ps[$this->id] as $f2p) {
- $ids[] = $f2p->file_id;
- }
-
- $files = File::multiGet('id', $ids);
- $this->_attachments[$this->id] = $files->fetchAll();
-
- return $this->_attachments[$this->id];
- }
- function _setAttachments($attachments)
- {
- $this->_attachments[$this->id] = $attachments;
- }
- function publicStream($offset=0, $limit=20, $since_id=0, $max_id=0)
- {
- $stream = new PublicNoticeStream();
- return $stream->getNotices($offset, $limit, $since_id, $max_id);
- }
- function conversationStream($id, $offset=0, $limit=20, $since_id=0, $max_id=0)
- {
- $stream = new ConversationNoticeStream($id);
- return $stream->getNotices($offset, $limit, $since_id, $max_id);
- }
-
- function hasConversation()
- {
- if (!empty($this->conversation)) {
- $conversation = Notice::conversationStream(
- $this->conversation,
- 1,
- 1
- );
- if ($conversation->N > 0) {
- return true;
- }
- }
- return false;
- }
-
- function conversationRoot($profile=-1)
- {
-
- if (empty($this->conversation)) {
- return null;
- }
-
- if (is_int($profile) && $profile == -1) {
- $profile = Profile::current();
- }
-
- if (!$this->inScope($profile)) {
- return null;
- }
-
-
- if (empty($this->reply_to)) {
- $root = new Notice;
- $root->conversation = $this->conversation;
- $root->orderBy('notice.created ASC');
- $root->find();
- $root->fetch();
- $root->free();
- return $root;
- }
-
- if (is_null($profile)) {
- $keypart = sprintf('notice:conversation_root:%d:null', $this->id);
- } else {
- $keypart = sprintf('notice:conversation_root:%d:%d',
- $this->id,
- $profile->id);
- }
-
- $root = self::cacheGet($keypart);
- if ($root !== false && $root->inScope($profile)) {
- return $root;
- }
- $last = $this;
- while (true) {
- try {
- $parent = $last->getParent();
- if ($parent->inScope($profile)) {
- $last = $parent;
- continue;
- }
- } catch (Exception $e) {
-
- }
-
- $root = $last;
- break;
- }
- self::cacheSet($keypart, $root);
- return $root;
- }
-
- function whoGets(array $groups=null, array $recipients=null)
- {
- $c = self::memcache();
- if (!empty($c)) {
- $ni = $c->get(Cache::key('notice:who_gets:'.$this->id));
- if ($ni !== false) {
- return $ni;
- }
- }
- if (is_null($recipients)) {
- $recipients = $this->getReplies();
- }
- $ni = array();
-
- if (Event::handle('StartNoticeWhoGets', array($this, &$ni))) {
- $users = $this->getSubscribedUsers();
- foreach ($users as $id) {
- $ni[$id] = NOTICE_INBOX_SOURCE_SUB;
- }
- if (is_null($groups)) {
- $groups = $this->getGroups();
- }
- foreach ($groups as $group) {
- $users = $group->getUserMembers();
- foreach ($users as $id) {
- if (!array_key_exists($id, $ni)) {
- $ni[$id] = NOTICE_INBOX_SOURCE_GROUP;
- }
- }
- }
- $ptAtts = $this->getAttentionsFromProfileTags();
- foreach ($ptAtts as $key=>$val) {
- if (!array_key_exists($key, $ni)) {
- $ni[$key] = $val;
- }
- }
- foreach ($recipients as $recipient) {
- if (!array_key_exists($recipient, $ni)) {
- $ni[$recipient] = NOTICE_INBOX_SOURCE_REPLY;
- }
- }
-
- $profile = $this->getProfile();
- $originalProfile = null;
- if ($this->isRepeat()) {
-
- $original = Notice::getKV('id', $this->repeat_of);
- if ($original instanceof Notice) {
- $originalProfile = $original->getProfile();
- }
- }
- foreach ($ni as $id => $source) {
- try {
- $user = User::getKV('id', $id);
- if (!$user instanceof User ||
- $user->hasBlocked($profile) ||
- ($originalProfile && $user->hasBlocked($originalProfile))) {
- unset($ni[$id]);
- }
- } catch (UserNoProfileException $e) {
-
- unset($ni[$id]);
- }
- }
-
- Event::handle('EndNoticeWhoGets', array($this, &$ni));
- }
- if (!empty($c)) {
-
- $c->set(Cache::key('notice:who_gets:'.$this->id), $ni);
- }
- return $ni;
- }
- function getSubscribedUsers()
- {
- $user = new User();
- if(common_config('db','quote_identifiers'))
- $user_table = '"user"';
- else $user_table = 'user';
- $qry =
- 'SELECT id ' .
- 'FROM '. $user_table .' JOIN subscription '.
- 'ON '. $user_table .'.id = subscription.subscriber ' .
- 'WHERE subscription.subscribed = %d ';
- $user->query(sprintf($qry, $this->profile_id));
- $ids = array();
- while ($user->fetch()) {
- $ids[] = $user->id;
- }
- $user->free();
- return $ids;
- }
- function getProfileTags()
- {
- $profile = $this->getProfile();
- $list = $profile->getOtherTags($profile);
- $ptags = array();
- while($list->fetch()) {
- $ptags[] = clone($list);
- }
- return $ptags;
- }
- public function getAttentionsFromProfileTags()
- {
- $ni = array();
- $ptags = $this->getProfileTags();
- foreach ($ptags as $ptag) {
- $users = $ptag->getUserSubscribers();
- foreach ($users as $id) {
- $ni[$id] = NOTICE_INBOX_SOURCE_PROFILE_TAG;
- }
- }
- return $ni;
- }
-
- function saveKnownGroups($group_ids)
- {
- if (!is_array($group_ids)) {
-
- throw new ServerException(_('Bad type provided to saveKnownGroups.'));
- }
- $groups = array();
- foreach (array_unique($group_ids) as $id) {
- $group = User_group::getKV('id', $id);
- if ($group instanceof User_group) {
- common_log(LOG_DEBUG, "Local delivery to group id $id, $group->nickname");
- $result = $this->addToGroupInbox($group);
- if (!$result) {
- common_log_db_error($gi, 'INSERT', __FILE__);
- }
- if (common_config('group', 'addtag')) {
-
- $tag = Notice_tag::pkeyGet(array('tag' => common_canonical_tag($group->nickname),
- 'notice_id' => $this->id));
- if (is_null($tag)) {
- $this->saveTag($group->nickname);
- }
- }
- $groups[] = clone($group);
- } else {
- common_log(LOG_ERR, "Local delivery to group id $id skipped, doesn't exist");
- }
- }
- return $groups;
- }
- function addToGroupInbox(User_group $group)
- {
- $gi = Group_inbox::pkeyGet(array('group_id' => $group->id,
- 'notice_id' => $this->id));
- if (!$gi instanceof Group_inbox) {
- $gi = new Group_inbox();
- $gi->group_id = $group->id;
- $gi->notice_id = $this->id;
- $gi->created = $this->created;
- $result = $gi->insert();
- if (!$result) {
- common_log_db_error($gi, 'INSERT', __FILE__);
-
- throw new ServerException(_('Problem saving group inbox.'));
- }
- self::blow('user_group:notice_ids:%d', $gi->group_id);
- }
- return true;
- }
-
- function saveKnownReplies(array $uris)
- {
- if (empty($uris)) {
- return;
- }
- $sender = Profile::getKV($this->profile_id);
- foreach (array_unique($uris) as $uri) {
- try {
- $profile = Profile::fromUri($uri);
- } catch (UnknownUriException $e) {
- common_log(LOG_WARNING, "Unable to determine profile for URI '$uri'");
- continue;
- }
- if ($profile->hasBlocked($sender)) {
- common_log(LOG_INFO, "Not saving reply to profile {$profile->id} ($uri) from sender {$sender->id} because of a block.");
- continue;
- }
- $this->saveReply($profile->id);
- self::blow('reply:stream:%d', $profile->id);
- }
- return;
- }
-
- function saveReplies()
- {
-
- if ($this->isRepeat()) {
- return array();
- }
- $sender = $this->getProfile();
- $replied = array();
-
- try {
- $parent = $this->getParent();
- $parentauthor = $parent->getProfile();
- $this->saveReply($parentauthor->id);
- $replied[$parentauthor->id] = 1;
- self::blow('reply:stream:%d', $parentauthor->id);
- } catch (Exception $e) {
-
- }
-
-
- $mentions = common_find_mentions($this->content, $this);
-
-
- foreach ($mentions as $mention) {
- foreach ($mention['mentioned'] as $mentioned) {
-
- if (!empty($replied[$mentioned->id])) {
- continue;
- }
-
- $mentioned_user = User::getKV('id', $mentioned->id);
- if ($mentioned_user instanceof User && $mentioned_user->hasBlocked($sender)) {
- continue;
- }
- $this->saveReply($mentioned->id);
- $replied[$mentioned->id] = 1;
- self::blow('reply:stream:%d', $mentioned->id);
- }
- }
- $recipientIds = array_keys($replied);
- return $recipientIds;
- }
- function saveReply($profileId)
- {
- $reply = new Reply();
- $reply->notice_id = $this->id;
- $reply->profile_id = $profileId;
- $reply->modified = $this->created;
- $reply->insert();
- return $reply;
- }
- protected $_replies = array();
-
- function getReplies()
- {
- if (isset($this->_replies[$this->id])) {
- return $this->_replies[$this->id];
- }
- $replyMap = Reply::listGet('notice_id', array($this->id));
- $ids = array();
- foreach ($replyMap[$this->id] as $reply) {
- $ids[] = $reply->profile_id;
- }
- $this->_replies[$this->id] = $ids;
- return $ids;
- }
- function _setReplies($replies)
- {
- $this->_replies[$this->id] = $replies;
- }
-
- function getReplyProfiles()
- {
- $ids = $this->getReplies();
-
- $profiles = Profile::multiGet('id', $ids);
-
- return $profiles->fetchAll();
- }
-
- function sendReplyNotifications()
- {
-
- if ($this->isRepeat()) {
- return array();
- }
- $recipientIds = $this->getReplies();
- if (Event::handle('StartNotifyMentioned', array($this, &$recipientIds))) {
- require_once INSTALLDIR.'/lib/mail.php';
- foreach ($recipientIds as $recipientId) {
- $user = User::getKV('id', $recipientId);
- if ($user instanceof User) {
- mail_notify_attn($user, $this);
- }
- }
- Event::handle('EndNotifyMentioned', array($this, $recipientIds));
- }
- }
-
-
- protected $_groups = array();
-
- function getGroups()
- {
-
- if (!empty($this->repeat_of)) {
- return array();
- }
-
- if (isset($this->_groups[$this->id])) {
- return $this->_groups[$this->id];
- }
-
- $gis = Group_inbox::listGet('notice_id', array($this->id));
- $ids = array();
- foreach ($gis[$this->id] as $gi)
- {
- $ids[] = $gi->group_id;
- }
-
- $groups = User_group::multiGet('id', $ids);
-
- $this->_groups[$this->id] = $groups->fetchAll();
-
- return $this->_groups[$this->id];
- }
-
- function _setGroups($groups)
- {
- $this->_groups[$this->id] = $groups;
- }
-
- function asActivity(Profile $scoped=null)
- {
- $act = self::cacheGet(Cache::codeKey('notice:as-activity:'.$this->id));
- if ($act instanceof Activity) {
- return $act;
- }
- $act = new Activity();
- if (Event::handle('StartNoticeAsActivity', array($this, $act, $scoped))) {
- $act->id = $this->uri;
- $act->time = strtotime($this->created);
- try {
- $act->link = $this->getUrl();
- } catch (InvalidUrlException $e) {
-
-
- }
- $act->content = common_xml_safe_str($this->rendered);
- $profile = $this->getProfile();
- $act->actor = $profile->asActivityObject();
- $act->actor->extra[] = $profile->profileInfo($scoped);
- $act->verb = $this->verb;
- if ($this->repeat_of) {
- $repeated = Notice::getKV('id', $this->repeat_of);
- if ($repeated instanceof Notice) {
-
-
- $act->title = sprintf(_('%1$s repeated a notice by %2$s'),
- $this->getProfile()->getNickname(),
- $repeated->getProfile()->getNickname());
- $act->objects[] = $repeated->asActivity($scoped);
- }
- } else {
- $act->objects[] = $this->asActivityObject();
- }
-
-
- $tags = $this->getTags();
- foreach ($tags as $tag) {
- $cat = new AtomCategory();
- $cat->term = $tag;
- $act->categories[] = $cat;
- }
-
-
- $attachments = $this->attachments();
- foreach ($attachments as $attachment) {
-
- if (!empty($attachment->filename)) {
- $act->attachments[] = ActivityObject::fromFile($attachment);
- }
- }
- $ctx = new ActivityContext();
- try {
- $reply = $this->getParent();
- $ctx->replyToID = $reply->getUri();
- $ctx->replyToUrl = $reply->getUrl();
- } catch (Exception $e) {
-
- }
- $ctx->location = $this->getLocation();
- $conv = null;
- if (!empty($this->conversation)) {
- $conv = Conversation::getKV('id', $this->conversation);
- if ($conv instanceof Conversation) {
- $ctx->conversation = $conv->uri;
- }
- }
- $reply_ids = $this->getReplies();
- foreach ($reply_ids as $id) {
- $rprofile = Profile::getKV('id', $id);
- if ($rprofile instanceof Profile) {
- $ctx->attention[$rprofile->getUri()] = ActivityObject::PERSON;
- }
- }
- $groups = $this->getGroups();
- foreach ($groups as $group) {
- $ctx->attention[$group->getUri()] = ActivityObject::GROUP;
- }
- switch ($this->scope) {
- case Notice::PUBLIC_SCOPE:
- $ctx->attention[ActivityContext::ATTN_PUBLIC] = ActivityObject::COLLECTION;
- break;
- case Notice::FOLLOWER_SCOPE:
- $surl = common_local_url("subscribers", array('nickname' => $profile->nickname));
- $ctx->attention[$surl] = ActivityObject::COLLECTION;
- break;
- }
- $act->context = $ctx;
- $source = $this->getSource();
- if ($source instanceof Notice_source) {
- $act->generator = ActivityObject::fromNoticeSource($source);
- }
-
- $atom_feed = $profile->getAtomFeed();
- if (!empty($atom_feed)) {
- $act->source = new ActivitySource();
-
- $act->source->id = $atom_feed;
-
- $act->source->title = $profile->getBestName();
- $act->source->links['alternate'] = $profile->profileurl;
- $act->source->links['self'] = $atom_feed;
- $act->source->icon = $profile->avatarUrl(AVATAR_PROFILE_SIZE);
- $notice = $profile->getCurrentNotice();
- if ($notice instanceof Notice) {
- $act->source->updated = self::utcDate($notice->created);
- }
- $user = User::getKV('id', $profile->id);
- if ($user instanceof User) {
- $act->source->links['license'] = common_config('license', 'url');
- }
- }
- if ($this->isLocal()) {
- $act->selfLink = common_local_url('ApiStatusesShow', array('id' => $this->id,
- 'format' => 'atom'));
- $act->editLink = $act->selfLink;
- }
- Event::handle('EndNoticeAsActivity', array($this, $act, $scoped));
- }
- self::cacheSet(Cache::codeKey('notice:as-activity:'.$this->id), $act);
- return $act;
- }
-
-
- function asAtomEntry($namespace=false,
- $source=false,
- $author=true,
- Profile $scoped=null)
- {
- $act = $this->asActivity($scoped);
- $act->extra[] = $this->noticeInfo($scoped);
- return $act->asString($namespace, $author, $source);
- }
-
- function noticeInfo(Profile $scoped=null)
- {
-
- $noticeInfoAttr = array('local_id' => $this->id);
-
- $ns = $this->getSource();
- if ($ns instanceof Notice_source) {
- $noticeInfoAttr['source'] = $ns->code;
- if (!empty($ns->url)) {
- $noticeInfoAttr['source_link'] = $ns->url;
- if (!empty($ns->name)) {
- $noticeInfoAttr['source'] = '<a href="'
- . htmlspecialchars($ns->url)
- . '" rel="nofollow">'
- . htmlspecialchars($ns->name)
- . '</a>';
- }
- }
- }
-
- if ($scoped instanceof Profile) {
- $noticeInfoAttr['repeated'] = ($scoped->hasRepeated($this)) ? "true" : "false";
- }
- if (!empty($this->repeat_of)) {
- $noticeInfoAttr['repeat_of'] = $this->repeat_of;
- }
- Event::handle('StatusNetApiNoticeInfo', array($this, &$noticeInfoAttr, $scoped));
- return array('statusnet:notice_info', $noticeInfoAttr, null);
- }
-
- function asActivityNoun($element)
- {
- $noun = $this->asActivityObject();
- return $noun->asString('activity:' . $element);
- }
- public function asActivityObject()
- {
- $object = new ActivityObject();
- if (Event::handle('StartActivityObjectFromNotice', array($this, &$object))) {
- $object->type = $this->object_type ?: ActivityObject::NOTE;
- $object->id = $this->getUri();
- $object->title = sprintf('New %1$s by %2$s', ActivityObject::canonicalType($object->type), $this->getProfile()->getNickname());
- $object->content = $this->rendered;
- $object->link = $this->getUrl();
- $object->extra[] = array('status_net', array('notice_id' => $this->id));
- Event::handle('EndActivityObjectFromNotice', array($this, &$object));
- }
- return $object;
- }
-
- static function getInlineReplyTo(Profile $sender, $content)
- {
-
- if (preg_match('/^T ([A-Z0-9]{1,64}) /', $content, $match)
- || preg_match('/^@([a-z0-9]{1,64})\s+/', $content, $match)) {
- $nickname = common_canonical_nickname($match[1]);
- } else {
- return null;
- }
-
- $recipient = common_relative_profile($sender, $nickname, common_sql_now());
- if ($recipient instanceof Profile) {
-
- $last = $recipient->getCurrentNotice();
- if ($last instanceof Notice) {
- return $last;
- }
-
-
- }
- return null;
- }
- static function maxContent()
- {
- $contentlimit = common_config('notice', 'contentlimit');
-
- if (is_null($contentlimit)) {
- $contentlimit = common_config('site', 'textlimit');
- }
- return $contentlimit;
- }
- static function contentTooLong($content)
- {
- $contentlimit = self::maxContent();
- return ($contentlimit > 0 && !empty($content) && (mb_strlen($content) > $contentlimit));
- }
- function getLocation()
- {
- $location = null;
- if (!empty($this->location_id) && !empty($this->location_ns)) {
- $location = Location::fromId($this->location_id, $this->location_ns);
- }
- if (is_null($location)) {
- if (!empty($this->lat) && !empty($this->lon)) {
- $location = Location::fromLatLon($this->lat, $this->lon);
- }
- }
- return $location;
- }
-
- function repeat(Profile $repeater, $source)
- {
- $author = $this->getProfile();
-
-
- $content = sprintf(_('RT @%1$s %2$s'),
- $author->getNickname(),
- $this->content);
- $maxlen = self::maxContent();
- if ($maxlen > 0 && mb_strlen($content) > $maxlen) {
-
-
-
-
-
-
- $content = mb_substr($content, 0, $maxlen - 4) . ' ...';
- }
-
- return self::saveNew($repeater->id,
- $content,
- $source,
- array('repeat_of' => $this->id,
- 'scope' => $this->scope));
- }
-
- function repeatStream($limit=100)
- {
- $cache = Cache::instance();
- if (empty($cache)) {
- $ids = $this->_repeatStreamDirect($limit);
- } else {
- $idstr = $cache->get(Cache::key('notice:repeats:'.$this->id));
- if ($idstr !== false) {
- if (empty($idstr)) {
- $ids = array();
- } else {
- $ids = explode(',', $idstr);
- }
- } else {
- $ids = $this->_repeatStreamDirect(100);
- $cache->set(Cache::key('notice:repeats:'.$this->id), implode(',', $ids));
- }
- if ($limit < 100) {
-
- $ids = array_slice($ids, 0, $limit);
- }
- }
- return NoticeStream::getStreamByIds($ids);
- }
- function _repeatStreamDirect($limit)
- {
- $notice = new Notice();
- $notice->selectAdd();
- $notice->selectAdd('id');
- $notice->repeat_of = $this->id;
- $notice->orderBy('created, id');
- if (!is_null($limit)) {
- $notice->limit(0, $limit);
- }
- return $notice->fetchAll('id');
- }
- function locationOptions($lat, $lon, $location_id, $location_ns, $profile = null)
- {
- $options = array();
- if (!empty($location_id) && !empty($location_ns)) {
- $options['location_id'] = $location_id;
- $options['location_ns'] = $location_ns;
- $location = Location::fromId($location_id, $location_ns);
- if ($location instanceof Location) {
- $options['lat'] = $location->lat;
- $options['lon'] = $location->lon;
- }
- } else if (!empty($lat) && !empty($lon)) {
- $options['lat'] = $lat;
- $options['lon'] = $lon;
- $location = Location::fromLatLon($lat, $lon);
- if ($location instanceof Location) {
- $options['location_id'] = $location->location_id;
- $options['location_ns'] = $location->location_ns;
- }
- } else if (!empty($profile)) {
- if (isset($profile->lat) && isset($profile->lon)) {
- $options['lat'] = $profile->lat;
- $options['lon'] = $profile->lon;
- }
- if (isset($profile->location_id) && isset($profile->location_ns)) {
- $options['location_id'] = $profile->location_id;
- $options['location_ns'] = $profile->location_ns;
- }
- }
- return $options;
- }
- function clearAttentions()
- {
- $att = new Attention();
- $att->notice_id = $this->getID();
- if ($att->find()) {
- while ($att->fetch()) {
-
- $other = clone($att);
- $other->delete();
- }
- }
- }
- function clearReplies()
- {
- $replyNotice = new Notice();
- $replyNotice->reply_to = $this->id;
-
- if ($replyNotice->find()) {
- while ($replyNotice->fetch()) {
- $orig = clone($replyNotice);
- $replyNotice->reply_to = null;
- $replyNotice->update($orig);
- }
- }
-
- $reply = new Reply();
- $reply->notice_id = $this->id;
- if ($reply->find()) {
- while($reply->fetch()) {
- self::blow('reply:stream:%d', $reply->profile_id);
- $reply->delete();
- }
- }
- $reply->free();
- }
- function clearFiles()
- {
- $f2p = new File_to_post();
- $f2p->post_id = $this->id;
- if ($f2p->find()) {
- while ($f2p->fetch()) {
- $f2p->delete();
- }
- }
-
-
- }
- function clearRepeats()
- {
- $repeatNotice = new Notice();
- $repeatNotice->repeat_of = $this->id;
-
- if ($repeatNotice->find()) {
- while ($repeatNotice->fetch()) {
- $orig = clone($repeatNotice);
- $repeatNotice->repeat_of = null;
- $repeatNotice->update($orig);
- }
- }
- }
- function clearTags()
- {
- $tag = new Notice_tag();
- $tag->notice_id = $this->id;
- if ($tag->find()) {
- while ($tag->fetch()) {
- self::blow('profile:notice_ids_tagged:%d:%s', $this->profile_id, Cache::keyize($tag->tag));
- self::blow('profile:notice_ids_tagged:%d:%s;last', $this->profile_id, Cache::keyize($tag->tag));
- self::blow('notice_tag:notice_ids:%s', Cache::keyize($tag->tag));
- self::blow('notice_tag:notice_ids:%s;last', Cache::keyize($tag->tag));
- $tag->delete();
- }
- }
- $tag->free();
- }
- function clearGroupInboxes()
- {
- $gi = new Group_inbox();
- $gi->notice_id = $this->id;
- if ($gi->find()) {
- while ($gi->fetch()) {
- self::blow('user_group:notice_ids:%d', $gi->group_id);
- $gi->delete();
- }
- }
- $gi->free();
- }
- function distribute()
- {
-
-
- Event::handle('StartNoticeDistribute', array($this));
-
-
- try {
- $qm = QueueManager::get();
- $qm->enqueue($this, 'distrib');
- } catch (Exception $e) {
-
-
-
- try {
- $handler = new DistribQueueHandler();
- $handler->handle($this);
- } catch (Exception $e) {
- common_log(LOG_ERR, "emergency redistribution resulted in " . $e->getMessage());
- }
-
- throw $e;
- }
- }
- function insert()
- {
- $result = parent::insert();
- if ($result === false) {
- common_log_db_error($this, 'INSERT', __FILE__);
-
- throw new ServerException('Could not save Notice');
- }
-
-
- if (!empty($this->repeat_of)) {
- $c = self::memcache();
- if (!empty($c)) {
- $ck = self::multicacheKey('Notice',
- array('profile_id' => $this->profile_id,
- 'repeat_of' => $this->repeat_of));
- $c->delete($ck);
- }
- }
-
-
- $orig = clone($this);
- $changed = false;
-
-
- if (empty($this->uri)) {
- $this->uri = sprintf('%s%s=%d:%s=%s',
- TagURI::mint(),
- 'noticeId', $this->id,
- 'objectType', $this->get_object_type(true));
- $changed = true;
- }
- if ($changed && $this->update($orig) === false) {
- common_log_db_error($notice, 'UPDATE', __FILE__);
-
- throw new ServerException(_('Problem saving notice.'));
- }
- $this->blowOnInsert();
- return $result;
- }
-
- function getSource()
- {
- if (empty($this->source)) {
- return false;
- }
- $ns = new Notice_source();
- switch ($this->source) {
- case 'web':
- case 'xmpp':
- case 'mail':
- case 'omb':
- case 'system':
- case 'api':
- $ns->code = $this->source;
- break;
- default:
- $ns = Notice_source::getKV($this->source);
- if (!$ns) {
- $ns = new Notice_source();
- $ns->code = $this->source;
- $app = Oauth_application::getKV('name', $this->source);
- if ($app) {
- $ns->name = $app->name;
- $ns->url = $app->source_url;
- }
- }
- break;
- }
- return $ns;
- }
-
- public function isLocal()
- {
- return ($this->is_local == Notice::LOCAL_PUBLIC ||
- $this->is_local == Notice::LOCAL_NONPUBLIC);
- }
- public function isRepeat()
- {
- return !empty($this->repeat_of);
- }
-
- public function getTags()
- {
- $tags = array();
- $keypart = sprintf('notice:tags:%d', $this->id);
- $tagstr = self::cacheGet($keypart);
- if ($tagstr !== false) {
- $tags = explode(',', $tagstr);
- } else {
- $tag = new Notice_tag();
- $tag->notice_id = $this->id;
- if ($tag->find()) {
- while ($tag->fetch()) {
- $tags[] = $tag->tag;
- }
- }
- self::cacheSet($keypart, implode(',', $tags));
- }
- return $tags;
- }
- static private function utcDate($dt)
- {
- $dateStr = date('d F Y H:i:s', strtotime($dt));
- $d = new DateTime($dateStr, new DateTimeZone('UTC'));
- return $d->format(DATE_W3C);
- }
-
- public static function getAsTimestamp($id)
- {
- if (!$id) {
- return false;
- }
- $notice = Notice::getKV('id', $id);
- if ($notice) {
- return $notice->created;
- }
- $deleted = Deleted_notice::getKV('id', $id);
- if ($deleted) {
- return $deleted->created;
- }
- return false;
- }
-
- public static function whereSinceId($id, $idField='id', $createdField='created')
- {
- $since = Notice::getAsTimestamp($id);
- if ($since) {
- return sprintf("($createdField = '%s' and $idField > %d) or ($createdField > '%s')", $since, $id, $since);
- }
- return false;
- }
-
- public static function addWhereSinceId(DB_DataObject $obj, $id, $idField='id', $createdField='created')
- {
- $since = self::whereSinceId($id, $idField, $createdField);
- if ($since) {
- $obj->whereAdd($since);
- }
- }
-
- public static function whereMaxId($id, $idField='id', $createdField='created')
- {
- $max = Notice::getAsTimestamp($id);
- if ($max) {
- return sprintf("($createdField < '%s') or ($createdField = '%s' and $idField <= %d)", $max, $max, $id);
- }
- return false;
- }
-
- public static function addWhereMaxId(DB_DataObject $obj, $id, $idField='id', $createdField='created')
- {
- $max = self::whereMaxId($id, $idField, $createdField);
- if ($max) {
- $obj->whereAdd($max);
- }
- }
- function isPublic()
- {
- return (($this->is_local != Notice::LOCAL_NONPUBLIC) &&
- ($this->is_local != Notice::GATEWAY));
- }
-
- function inScope($profile)
- {
- if (is_null($profile)) {
- $keypart = sprintf('notice:in-scope-for:%d:null', $this->id);
- } else {
- $keypart = sprintf('notice:in-scope-for:%d:%d', $this->id, $profile->id);
- }
- $result = self::cacheGet($keypart);
- if ($result === false) {
- $bResult = false;
- if (Event::handle('StartNoticeInScope', array($this, $profile, &$bResult))) {
- $bResult = $this->_inScope($profile);
- Event::handle('EndNoticeInScope', array($this, $profile, &$bResult));
- }
- $result = ($bResult) ? 1 : 0;
- self::cacheSet($keypart, $result, 0, 300);
- }
- return ($result == 1) ? true : false;
- }
- protected function _inScope($profile)
- {
- if (!is_null($this->scope)) {
- $scope = $this->scope;
- } else {
- $scope = self::defaultScope();
- }
-
- if ($scope == 0) {
- return !$this->isHiddenSpam($profile);
- } else {
-
- if (empty($profile)) {
- return false;
- }
-
- if ($this->profile_id == $profile->id) {
- return true;
- }
-
- if (($scope & Notice::SITE_SCOPE) && !$profile->isLocal()) {
- return false;
- }
-
- if ($scope & Notice::ADDRESSEE_SCOPE) {
- $reply = Reply::pkeyGet(array('notice_id' => $this->id,
- 'profile_id' => $profile->id));
-
- if (!$reply instanceof Reply) {
- return false;
- }
- }
-
- if ($scope & Notice::GROUP_SCOPE) {
-
- $groups = $this->getGroups();
- $foundOne = false;
- foreach ($groups as $group) {
- if ($profile->isMember($group)) {
- $foundOne = true;
- break;
- }
- }
- if (!$foundOne) {
- return false;
- }
- }
-
- $author = null;
- if ($scope & Notice::FOLLOWER_SCOPE) {
- try {
- $author = $this->getProfile();
- } catch (Exception $e) {
- return false;
- }
-
- if (!Subscription::exists($profile, $author)) {
- return false;
- }
- }
- return !$this->isHiddenSpam($profile);
- }
- }
- function isHiddenSpam($profile) {
-
-
- if (common_config('notice', 'hidespam')) {
- try {
- $author = $this->getProfile();
- } catch(Exception $e) {
-
-
- return true;
- }
- if ($author->hasRole(Profile_role::SILENCED)) {
- if (!$profile instanceof Profile || (($profile->id !== $author->id) && (!$profile->hasRight(Right::REVIEWSPAM)))) {
- return true;
- }
- }
- }
- return false;
- }
- public function getParent()
- {
- $parent = Notice::getKV('id', $this->reply_to);
- if (!$parent instanceof Notice) {
- throw new ServerException('Notice has no parent');
- }
- return $parent;
- }
-
- function __sleep()
- {
- $vars = parent::__sleep();
- $skip = array('_profile', '_groups', '_attachments', '_faves', '_replies', '_repeats');
- return array_diff($vars, $skip);
- }
-
- static function defaultScope()
- {
- $scope = common_config('notice', 'defaultscope');
- if (is_null($scope)) {
- if (common_config('site', 'private')) {
- $scope = 1;
- } else {
- $scope = 0;
- }
- }
- return $scope;
- }
- static function fillProfiles($notices)
- {
- $map = self::getProfiles($notices);
-
- foreach ($notices as $entry=>$notice) {
- try {
- if (array_key_exists($notice->profile_id, $map)) {
- $notice->_setProfile($map[$notice->profile_id]);
- }
- } catch (NoProfileException $e) {
- common_log(LOG_WARNING, "Failed to fill profile in Notice with non-existing entry for profile_id: {$e->profile_id}");
- unset($notices[$entry]);
- }
- }
-
- return array_values($map);
- }
-
- static function getProfiles(&$notices)
- {
- $ids = array();
- foreach ($notices as $notice) {
- $ids[] = $notice->profile_id;
- }
-
- $ids = array_unique($ids);
-
- return Profile::pivotGet('id', $ids);
- }
-
- static function fillGroups(&$notices)
- {
- $ids = self::_idsOf($notices);
-
- $gis = Group_inbox::listGet('notice_id', $ids);
-
- $gids = array();
- foreach ($gis as $id => $gi)
- {
- foreach ($gi as $g)
- {
- $gids[] = $g->group_id;
- }
- }
-
- $gids = array_unique($gids);
-
- $group = User_group::pivotGet('id', $gids);
-
- foreach ($notices as $notice)
- {
- $grps = array();
- $gi = $gis[$notice->id];
- foreach ($gi as $g) {
- $grps[] = $group[$g->group_id];
- }
- $notice->_setGroups($grps);
- }
- }
- static function _idsOf(array &$notices)
- {
- $ids = array();
- foreach ($notices as $notice) {
- $ids[$notice->id] = true;
- }
- return array_keys($ids);
- }
- static function fillAttachments(&$notices)
- {
- $ids = self::_idsOf($notices);
- $f2pMap = File_to_post::listGet('post_id', $ids);
-
- $fileIds = array();
-
- foreach ($f2pMap as $noticeId => $f2ps) {
- foreach ($f2ps as $f2p) {
- $fileIds[] = $f2p->file_id;
- }
- }
- $fileIds = array_unique($fileIds);
- $fileMap = File::pivotGet('id', $fileIds);
- foreach ($notices as $notice)
- {
- $files = array();
- $f2ps = $f2pMap[$notice->id];
- foreach ($f2ps as $f2p) {
- $files[] = $fileMap[$f2p->file_id];
- }
- $notice->_setAttachments($files);
- }
- }
- static function fillReplies(&$notices)
- {
- $ids = self::_idsOf($notices);
- $replyMap = Reply::listGet('notice_id', $ids);
- foreach ($notices as $notice) {
- $replies = $replyMap[$notice->id];
- $ids = array();
- foreach ($replies as $reply) {
- $ids[] = $reply->profile_id;
- }
- $notice->_setReplies($ids);
- }
- }
- protected $_repeats = array();
- function getRepeats()
- {
- if (isset($this->_repeats[$this->id])) {
- return $this->_repeats[$this->id];
- }
- $repeatMap = Notice::listGet('repeat_of', array($this->id));
- $this->_repeats[$this->id] = $repeatMap[$this->id];
- return $this->_repeats[$this->id];
- }
- function _setRepeats($repeats)
- {
- $this->_repeats[$this->id] = $repeats;
- }
- static function fillRepeats(&$notices)
- {
- $ids = self::_idsOf($notices);
- $repeatMap = Notice::listGet('repeat_of', $ids);
- foreach ($notices as $notice) {
- $repeats = $repeatMap[$notice->id];
- $notice->_setRepeats($repeats);
- }
- }
- }
|