123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288 |
- <?php
- defined('GNUSOCIAL') || die();
- 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 $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' => 191, 'description' => 'universally unique identifier, usually a tag URI'),
- 'content' => array('type' => 'text', 'description' => 'update content', 'collate' => 'utf8mb4_general_ci'),
- 'rendered' => array('type' => 'text', 'description' => 'HTML version of the content'),
- 'url' => array('type' => 'varchar', 'length' => 191, 'description' => 'URL of any attachment (image, video, bookmark, whatever)'),
- 'created' => array('type' => 'datetime', 'not null' => true, 'default' => '0000-00-00 00:00:00', 'description' => 'date this record was created'),
- 'modified' => array('type' => 'datetime', 'not null' => true, 'default' => 'CURRENT_TIMESTAMP', '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' => 'the local numerical conversation id'),
- 'repeat_of' => array('type' => 'int', 'description' => 'notice this is a repeat of'),
- 'object_type' => array('type' => 'varchar', 'length' => 191, 'description' => 'URI representing activity streams object type', 'default' => null),
- 'verb' => array('type' => 'varchar', 'length' => 191, '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 = groups; 8 = followers; 16 = messages; 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_is_local_created_profile_id_idx' => array('is_local', 'created', 'profile_id'),
- 'notice_repeat_of_created_id_idx' => array('repeat_of', 'created', 'id'),
- 'notice_conversation_created_id_idx' => array('conversation', 'created', 'id'),
- 'notice_object_type_idx' => array('object_type'),
- 'notice_verb_idx' => array('verb'),
- 'notice_profile_id_verb_idx' => array('profile_id', 'verb'),
- 'notice_url_idx' => array('url'),
- '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;
- const MESSAGE_SCOPE = 16;
- 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;
- }
- public function deleteAs(Profile $actor, $delete_event=true)
- {
- if (!$this->getProfile()->sameAs($actor) && !$actor->hasRight(Right::DELETEOTHERSNOTICE)) {
- throw new AuthorizationException(_('You are not allowed to delete another user\'s notice.'));
- }
- $result = null;
- if (!$delete_event || Event::handle('DeleteNoticeAsProfile', array($this, $actor, &$result))) {
-
-
-
- $result = $this->delete();
- }
- return $result;
- }
- protected function deleteRelated()
- {
- if (Event::handle('NoticeDeleteRelated', array($this))) {
-
- $this->clearReplies();
- $this->clearLocation();
- $this->clearRepeats();
- $this->clearTags();
- $this->clearGroupInboxes();
- $this->clearFiles();
- $this->clearAttentions();
-
- }
- }
- public function delete($useWhere=false)
- {
- $this->deleteRelated();
- $result = parent::delete($useWhere);
- $this->blowOnDelete();
- return $result;
- }
- public function getUri()
- {
- return $this->uri;
- }
-
- public 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($imply=true)
- {
- $title = null;
- if (Event::handle('GetNoticeTitle', array($this, &$title)) && $imply) {
-
-
- $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 getRendered()
- {
-
- if (!empty($this->id) && (is_null($this->rendered) || $this->rendered === '')) {
-
- common_debug('Rendering notice '.$this->getID().' as it had no rendered HTML content.');
- $orig = clone($this);
- $this->rendered = common_render_content(
- $this->getContent(),
- $this->getProfile(),
- ($this->hasParent() ? $this->getParent() : null)
- );
- $this->update($orig);
- }
- return $this->rendered;
- }
- public function getCreated()
- {
- return $this->created;
- }
- public function getVerb($make_relative=false)
- {
- return ActivityUtils::resolveUri($this->verb, $make_relative);
- }
- public function isVerb(array $verbs)
- {
- return ActivityUtils::compareVerbs($this->getVerb(), $verbs);
- }
-
- public function getUrl($fallback=false)
- {
-
-
- switch (true) {
- case $this->isLocal():
- return common_local_url('shownotice', array('notice' => $this->getID()), null, null, false);
- case common_valid_http_url($this->url):
- return $this->url;
- case common_valid_http_url($this->uri):
- return $this->uri;
- case $fallback:
-
- return common_local_url('shownotice', array('notice' => $this->getID()), null, null, false);
- default:
- throw new InvalidUrlException($this->url);
- }
- }
- public function getSelfLink()
- {
- if ($this->isLocal()) {
- return common_local_url('ApiStatusesShow', array('id' => $this->getID(), 'format' => 'atom'));
- }
- $selfLink = $this->getPref('ostatus', 'self');
- if (!common_valid_http_url($selfLink)) {
- throw new InvalidUrlException($selfLink);
- }
- return $selfLink;
- }
- public function getObjectType($canonical = false)
- {
- if (is_null($this->object_type) || $this->object_type==='') {
- throw new NoObjectTypeException($this);
- }
- return ActivityUtils::resolveUri($this->object_type, $canonical);
- }
- public function isObjectType(array $types)
- {
- try {
- return ActivityUtils::compareTypes($this->getObjectType(), $types);
- } catch (NoObjectTypeException $e) {
- return false;
- }
- }
-
- public 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]);
- }
-
- public 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;
- }
-
- public 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);
- }
-
- public static function saveNew($profile_id, $content, $source, array $options = null)
- {
- $defaults = array('uri' => null,
- 'url' => null,
- 'self' => 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;
- if ($source && in_array($source, common_config('public', '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 (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 (!empty($options['repeat_of'])) {
-
- $repeat = Notice::getByID($options['repeat_of']);
- if ($profile->sameAs($repeat->getProfile())) {
-
- 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) a reply to unknown remote user. Activity creation time ('.$notice->created.') should maybe be compared to conversation creation time ('.$conv->created.').');
- } else {
-
- common_debug('Conversation URI not found, so we will create it with the URI given in the options to Notice::saveNew: '.$options['conversation']);
- $convctx = new ActivityContext();
- $convctx->conversation = $options['conversation'];
- if (array_key_exists('conversation_url', $options)) {
- $convctx->conversation_url = $options['conversation_url'];
- }
-
- $conv = Conversation::create($convctx, $notice->created);
- }
- $notice->conversation = $conv->getID();
- unset($conv);
- }
- }
-
- if (empty($notice->conversation)) {
- $conv = Conversation::create();
- $notice->conversation = $conv->getID();
- unset($conv);
- }
- $notloc = new Notice_location();
- if (!empty($lat) && !empty($lon)) {
- $notloc->lat = $lat;
- $notloc->lon = $lon;
- }
- if (!empty($location_ns) && !empty($location_id)) {
- $notloc->location_id = $location_id;
- $notloc->location_ns = $location_ns;
- }
- if (!empty($rendered)) {
- $notice->rendered = $rendered;
- } else {
- $notice->rendered = common_render_content(
- $final,
- $notice->getProfile(),
- ($notice->hasParent() ? $notice->getParent() : null)
- );
- }
- 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 (($notloc->lat && $notloc->lon) || ($notloc->location_id && $notloc->location_ns)) {
- $notloc->notice_id = $notice->getID();
- $notloc->insert();
- }
- } catch (Exception $e) {
-
-
-
- if (!empty($notice->id)) {
- $notice->delete();
- }
- throw $e;
- }
- }
- if ($self && common_valid_http_url($self)) {
- $notice->setPref('ostatus', 'self', $self);
- }
-
-
-
- if (ActivityUtils::compareVerbs($notice->verb, array(ActivityVerb::POST))) {
- 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;
- }
- public static function saveActivity(Activity $act, Profile $actor, array $options = [])
- {
-
- 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.'));
- }
-
- $actobj = null;
- if (!empty($act->id)) {
-
- $options['uri'] = $act->id;
- $options['url'] = $act->link;
- if ($act->selfLink) {
- $options['self'] = $act->selfLink;
- }
- } 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;
- }
- }
- if ($actobj->selfLink) {
- $options['self'] = $actobj->selfLink;
- }
- }
- $defaults = array(
- 'groups' => array(),
- 'is_local' => $actor->isLocal() ? self::LOCAL_PUBLIC : self::REMOTE,
- 'mentions' => array(),
- 'reply_to' => null,
- 'repeat_of' => null,
- 'scope' => null,
- 'self' => 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) && !ActivityUtils::compareVerbs($act->verb, array(ActivityVerb::DELETE))) {
- $stored->uri = $uri;
- if ($stored->find()) {
- common_debug('cannot create duplicate Notice URI: '.$stored->uri);
-
-
- throw new AlreadyFulfilledException('Notice URI already exists');
- }
- }
-
-
-
-
- if ($source && in_array($source, common_config('public', 'autosource'))) {
- $stored->is_local = Notice::LOCAL_NONPUBLIC;
- } else {
- $stored->is_local = intval($is_local);
- }
- if (!$stored->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.');
- }
- }
- $stored->profile_id = $actor->getID();
- $stored->source = $source;
- $stored->uri = $uri;
- $stored->url = $url;
- $stored->verb = $act->verb;
-
- $content = mb_strlen($act->content) ? $act->content : $act->summary;
- if (mb_strlen($content)===0 && !is_null($actobj)) {
- $content = mb_strlen($actobj->content) ? $actobj->content : $actobj->summary;
- }
-
- $stored->rendered = common_purify($content, ['URI.Base' => $stored->url ?: null]);
- $stored->content = common_strip_html($stored->getRendered(), true, true);
- if (trim($stored->content) === '') {
-
- throw new ClientException(_('Empty notice content, will not save this.'));
- }
- unset($content);
-
- if (!empty($act->time)) {
- $stored->created = common_sql_date($act->time);
- } else {
- $stored->created = common_sql_now();
- }
- $reply = null;
- $replyUris = [];
- if ($act->context instanceof ActivityContext && !empty($act->context->replyToID)) {
- $replyUris[] = $act->context->replyToID;
- }
- if ($act->target instanceof ActivityObject && !empty($act->target->id)) {
- $replyUris[] = $act->target->id;
- }
- foreach (array_unique($replyUris) as $replyUri) {
- $reply = self::getKV('uri', $replyUri);
-
- if (!common_config('site', 'private') && !$reply instanceof Notice) {
-
-
-
- Event::handle('FetchRemoteNotice', array($replyUri, $actor, &$reply));
- }
-
- if ($reply instanceof Notice) {
- break;
- }
-
- $reply = null;
- }
- unset($replyUris);
- 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)) {
- $replyGroups = $reply->getGroups();
- foreach ($replyGroups as $group) {
- if ($actor->isMember($group)) {
- $groups[] = $group->id;
- }
- }
- }
- if (is_null($scope)) {
- $scope = $reply->scope;
- }
- } else {
-
-
-
- if (empty($stored->conversation) and !empty($act->context->conversation)) {
- $conv = Conversation::getKV('uri', $act->context->conversation);
- if ($conv instanceof Conversation) {
- common_debug('Conversation stitched together from (probably) a reply activity to unknown remote user. Activity creation time ('.$stored->created.') should maybe be compared to conversation creation time ('.$conv->created.').');
- } else {
-
- common_debug('Conversation URI not found, so we will create it with the URI given in the context of the activity: '.$act->context->conversation);
-
- $conv = Conversation::create($act->context, $stored->created);
- }
- $stored->conversation = $conv->getID();
- unset($conv);
- }
- }
- unset($reply);
-
- if (empty($stored->conversation)) {
- $conv = Conversation::create();
- $stored->conversation = $conv->getID();
- unset($conv);
- }
- $notloc = null;
- if ($act->context instanceof ActivityContext) {
- if ($act->context->location instanceof Location) {
- $notloc = Notice_location::fromLocation($act->context->location);
- }
- } else {
- $act->context = new ActivityContext();
- }
- if (array_key_exists(ActivityContext::ATTN_PUBLIC, $act->context->attention)) {
- $stored->scope = Notice::PUBLIC_SCOPE;
-
- unset($act->context->attention[ActivityContext::ATTN_PUBLIC]);
- } else {
- $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 (ActivityUtils::compareVerbs($stored->verb, array(ActivityVerb::POST))) {
- if (empty($act->objects[0]->type)) {
-
-
- $stored->object_type = empty($stored->reply_to) ? ActivityObject::NOTE : ActivityObject::COMMENT;
- } else {
-
-
-
- $stored->object_type = ActivityUtils::resolveUri($act->objects[0]->type, true);
- }
- }
- if (Event::handle('StartNoticeSave', array(&$stored))) {
-
- try {
- $result = $stored->insert();
- if ($notloc instanceof Notice_location) {
- $notloc->notice_id = $stored->getID();
- $notloc->insert();
- }
- $orig = clone($stored);
- $object = null;
- Event::handle('StoreActivityObject', array($act, $stored, $options, &$object));
- if (empty($object)) {
- throw new NoticeSaveException('Unsuccessful call to StoreActivityObject '._ve($stored->getUri()) . ': '._ve($act->asString()));
- }
- unset($object);
-
- $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;
- }
- }
- unset($notloc);
- if (!$stored instanceof Notice) {
- throw new ServerException('StartNoticeSave did not give back a Notice.');
- } elseif (empty($stored->id)) {
- throw new ServerException('Supposedly saved Notice has no ID.');
- }
- if ($self && common_valid_http_url($self)) {
- $stored->setPref('ostatus', 'self', $self);
- }
- if ($self && common_valid_http_url($self)) {
- $stored->setPref('ostatus', 'self', $self);
- }
-
-
-
- if (ActivityUtils::compareVerbs($stored->verb, array(ActivityVerb::POST))) {
- if (!empty($tags)) {
- $stored->saveKnownTags($tags);
- } else {
- $stored->saveTags();
- }
-
-
- $stored->saveAttentions($act->context->attention);
- if (!empty($urls)) {
- $stored->saveKnownUrls($urls);
- } else {
- $stored->saveUrls();
- }
- }
- if ($distribute) {
-
- $stored->distribute();
- }
- return $stored;
- }
- public static function figureOutScope(Profile $actor, array $groups, $scope = null)
- {
- $scope = is_null($scope) ? self::defaultScope() : intval($scope);
-
- 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) {
- try {
- $group = User_group::getByID($group_id);
- if ($group->force_scope) {
- $scope |= Notice::GROUP_SCOPE;
- break;
- }
- } catch (Exception $e) {
- common_log(LOG_ERR, 'Notice figureOutScope threw exception: '.$e->getMessage());
- }
- }
- return $scope;
- }
- public function blowOnInsert($conversation = false)
- {
- $this->blowStream('profile:notice_ids:%d', $this->profile_id);
- if ($this->isPublic()) {
- $this->blowStream('public');
- $this->blowStream('networkpublic');
- }
- if ($this->conversation) {
- 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();
- }
- }
-
- public 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);
- }
- }
- public 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);
- }
- }
- }
-
- public function saveUrls()
- {
- if (common_config('attachments', 'process_links')) {
- common_replace_urls_callback($this->content, array($this, 'saveUrl'), $this);
- }
- }
-
- public function saveKnownUrls($urls)
- {
- if (common_config('attachments', 'process_links')) {
-
- foreach (array_unique($urls) as $url) {
- $this->saveUrl($url, $this);
- }
- }
- }
-
- public function saveUrl($url, Notice $notice)
- {
- try {
- File::processNew($url, $notice);
- } catch (ServerException $e) {
-
- }
- }
- public 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;
- } elseif ($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);
- }
- public 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 = [];
- public function attachments()
- {
- if (isset($this->_attachments[$this->id])) {
- return $this->_attachments[$this->id];
- }
- $f2ps = File_to_post::listGet('post_id', array($this->id));
- $ids = [];
- foreach ($f2ps[$this->id] as $f2p) {
- $ids[] = $f2p->file_id;
- }
- return $this->_setAttachments(File::multiGet('id', $ids)->fetchAll());
- }
- public function _setAttachments(array $attachments)
- {
- return $this->_attachments[$this->id] = $attachments;
- }
- public static function publicStream($offset = 0, $limit = 20, $since_id = null, $max_id = null)
- {
- $stream = new PublicNoticeStream();
- return $stream->getNotices($offset, $limit, $since_id, $max_id);
- }
- public static function conversationStream($id, $offset = 0, $limit = 20, $since_id = null, $max_id = null, Profile $scoped = null)
- {
- $stream = new ConversationNoticeStream($id, $scoped);
- return $stream->getNotices($offset, $limit, $since_id, $max_id);
- }
-
- public function hasConversation()
- {
- if (empty($this->conversation)) {
-
-
- return false;
- }
-
-
- $notice = self::conversationStream($this->conversation, 1, 1, null, null, Profile::current());
-
- return $notice->N > 0;
- }
-
- public 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(true);
- $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 (NoParentNoticeException $e) {
-
- } catch (NoResultException $e) {
-
-
-
- }
-
- $root = $last;
- break;
- }
- self::cacheSet($keypart, $root);
- return $root;
- }
-
- public 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;
- }
- public function getSubscribedUsers()
- {
- $user = new User();
- $user->query(sprintf(
- 'SELECT id FROM %1$s INNER JOIN subscription ' .
- 'ON %1$s.id = subscription.subscriber ' .
- 'WHERE subscription.subscribed = %2$d ',
- $user->escapedTableName(),
- $this->profile_id
- ));
- $ids = [];
- while ($user->fetch()) {
- $ids[] = $user->id;
- }
- $user->free();
- return $ids;
- }
- public function getProfileTags()
- {
- $ptags = array();
- try {
- $profile = $this->getProfile();
- $list = $profile->getOtherTags($profile);
- while ($list->fetch()) {
- $ptags[] = clone($list);
- }
- } catch (Exception $e) {
- common_log(LOG_ERR, "Error during Notice->getProfileTags() for id=={$this->getID()}: {$e->getMessage()}");
- }
- 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;
- }
-
- public function saveKnownGroups(array $group_ids)
- {
- $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')) {
-
- common_debug('Adding hashtag matching group nickname: '._ve($group->getNickname()));
- $tag = Notice_tag::pkeyGet(array('tag' => common_canonical_tag($group->getNickname()),
- 'notice_id' => $this->getID()));
- if (is_null($tag)) {
- $this->saveTag($group->getNickname());
- }
- }
- $groups[] = clone($group);
- } else {
- common_log(LOG_ERR, "Local delivery to group id $id skipped, doesn't exist");
- }
- }
- return $groups;
- }
- public 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;
- }
- public function saveAttentions(array $uris)
- {
- foreach ($uris as $uri=>$type) {
- try {
- $target = Profile::fromUri($uri);
- } catch (UnknownUriException $e) {
- common_log(LOG_WARNING, "Unable to determine profile for URI '$uri'");
- continue;
- }
- try {
- $this->saveAttention($target);
- } catch (AlreadyFulfilledException $e) {
- common_debug('Attention already exists: ' . var_export($e->getMessage(), true));
- } catch (Exception $e) {
- common_log(LOG_ERR, "Could not save notice id=={$this->getID()} attention for profile id=={$target->getID()}: {$e->getMessage()}");
- }
- }
- }
-
- public function saveAttention(Profile $target, $reason = null)
- {
- if ($target->isGroup()) {
-
-
- $this->addToGroupInbox($target->getGroup());
- } else {
- if ($target->hasBlocked($this->getProfile())) {
- common_log(LOG_INFO, "Not saving reply to profile {$target->id} ($uri) from sender {$sender->id} because of a block.");
- return false;
- }
- }
- if ($target->isLocal()) {
-
- $this->saveReply($target->getID());
- }
- $att = Attention::saveNew($this, $target, $reason);
- return true;
- }
-
- public function saveKnownReplies(array $uris)
- {
- if (empty($uris)) {
- return;
- }
- $sender = $this->getProfile();
- 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->getID());
- self::blow('reply:stream:%d', $profile->getID());
- }
- }
-
- public function saveReplies()
- {
- $sender = $this->getProfile();
- $replied = array();
-
- try {
- $parent = $this->getParent();
- $parentauthor = $parent->getProfile();
- $this->saveReply($parentauthor->getID());
- $replied[$parentauthor->getID()] = 1;
- self::blow('reply:stream:%d', $parentauthor->getID());
- } catch (NoParentNoticeException $e) {
-
- $parent = null;
- } catch (NoResultException $e) {
-
- $parent = null;
- }
-
-
- $mentions = common_find_mentions($this->content, $sender, $parent);
- foreach ($mentions as $mention) {
- foreach ($mention['mentioned'] as $mentioned) {
-
- if (array_key_exists($mentioned->id, $replied)) {
- continue;
- }
-
- if ($mentioned->hasBlocked($sender)) {
- continue;
- }
- $this->saveReply($mentioned->id);
- $replied[$mentioned->id] = 1;
- self::blow('reply:stream:%d', $mentioned->id);
- }
- }
- $recipientIds = array_keys($replied);
- return $recipientIds;
- }
- public function saveReply($profileId)
- {
- $reply = new Reply();
- $reply->notice_id = $this->id;
- $reply->profile_id = $profileId;
- $reply->modified = $this->created;
- $reply->insert();
- return $reply;
- }
- protected $_attentionids = array();
-
- public function getAttentionProfileIDs()
- {
- if (!isset($this->_attentionids[$this->getID()])) {
- $atts = Attention::multiGet('notice_id', array($this->getID()));
-
- $this->_attentionids[$this->getID()] = (array)$atts->fetchAll('profile_id');
- }
- return $this->_attentionids[$this->getID()];
- }
- protected $_replies = array();
-
- public function getReplies()
- {
- if (!isset($this->_replies[$this->getID()])) {
- $mentions = Reply::multiGet('notice_id', array($this->getID()));
- $this->_replies[$this->getID()] = $mentions->fetchAll('profile_id');
- }
- return $this->_replies[$this->getID()];
- }
- public function _setReplies($replies)
- {
- $this->_replies[$this->getID()] = $replies;
- }
-
- public function getAttentionProfiles()
- {
- $ids = array_unique(array_merge($this->getReplies(), $this->getGroupProfileIDs(), $this->getAttentionProfileIDs()));
- $profiles = Profile::multiGet('id', (array)$ids);
- return $profiles->fetchAll();
- }
-
- public function sendReplyNotifications()
- {
-
- if ($this->isRepeat()) {
- return array();
- }
- $recipientIds = $this->getReplies();
- if (Event::handle('StartNotifyMentioned', array($this, &$recipientIds))) {
- require_once INSTALLDIR . '/lib/util/mail.php';
- foreach ($recipientIds as $recipientId) {
- try {
- $user = User::getByID($recipientId);
- mail_notify_attn($user->getProfile(), $this);
- } catch (NoResultException $e) {
-
- }
- }
- Event::handle('EndNotifyMentioned', array($this, $recipientIds));
- }
- }
-
- public function getGroupProfileIDs()
- {
- $ids = array();
- foreach ($this->getGroups() as $group) {
- $ids[] = $group->profile_id;
- }
- return $ids;
- }
-
- protected $_groups = array();
- public 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 = [];
- 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];
- }
- public function _setGroups($groups)
- {
- $this->_groups[$this->id] = $groups;
- }
-
- public 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->getRendered());
- $profile = $this->getProfile();
- $act->actor = $profile->asActivityObject();
- $act->actor->extra[] = $profile->profileInfo($scoped);
- $act->verb = $this->verb;
- if (!$this->repeat_of) {
- $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->enclosures[] = $attachment->getEnclosure();
- }
- }
- $ctx = new ActivityContext();
- try {
- $reply = $this->getParent();
- $ctx->replyToID = $reply->getUri();
- $ctx->replyToUrl = $reply->getUrl(true);
- } catch (NoParentNoticeException $e) {
-
- } catch (NoResultException $e) {
-
- }
- try {
- $ctx->location = Notice_location::locFromStored($this);
- } catch (ServerException $e) {
- $ctx->location = null;
- }
- $conv = null;
- if (!empty($this->conversation)) {
- $conv = Conversation::getKV('id', $this->conversation);
- if ($conv instanceof Conversation) {
- $ctx->conversation = $conv->uri;
- $ctx->conversation_url = $conv->url;
- }
- }
-
-
- foreach ($this->getAttentionProfiles() as $target) {
-
- $ctx->attention[$target->getUri()] = $target->getObjectType();
- }
- 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');
- }
- }
- try {
- $act->selfLink = $this->getSelfLink();
- } catch (InvalidUrlException $e) {
- $act->selfLink = null;
- }
- if ($this->isLocal()) {
- $act->editLink = $act->selfLink;
- }
- Event::handle('EndNoticeAsActivity', array($this, $act, $scoped));
- }
- self::cacheSet(Cache::codeKey('notice:as-activity:'.$this->id), $act);
- return $act;
- }
-
-
- public 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);
- }
-
- public 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'] = $ns->name;
- }
- }
- }
-
- 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);
- }
-
- public 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->getRendered();
- $object->link = $this->getUrl();
- try {
- $object->selfLink = $this->getSelfLink();
- } catch (InvalidUrlException $e) {
- $object->selfLink = null;
- }
- $object->extra[] = array('statusnet:notice_id', null, $this->id);
- Event::handle('EndActivityObjectFromNotice', array($this, &$object));
- }
- if (!$object instanceof ActivityObject) {
- common_log(LOG_ERR, 'Notice asActivityObject created something else for uri=='._ve($this->getUri()).': '._ve($object));
- throw new ServerException('Notice asActivityObject created something else.');
- }
- return $object;
- }
-
- public 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;
- }
- public static function maxContent()
- {
- $contentlimit = common_config('notice', 'contentlimit');
-
- if (is_null($contentlimit)) {
- $contentlimit = common_config('site', 'textlimit');
- }
- return $contentlimit;
- }
- public static function contentTooLong($content)
- {
- $contentlimit = self::maxContent();
- return ($contentlimit > 0 && !empty($content) && (mb_strlen($content) > $contentlimit));
- }
-
- public 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,
- ['repeat_of' => $this->id, 'scope' => $this->scope]
- );
- }
-
- public 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 = explode(',', $idstr);
- } else {
- $ids = [];
- }
- } 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);
- }
- public 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');
- }
- public static 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;
- }
- } elseif (!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;
- }
- } elseif (!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;
- }
- public function clearAttentions()
- {
- $att = new Attention();
- $att->notice_id = $this->getID();
- if ($att->find()) {
- while ($att->fetch()) {
-
- $other = clone($att);
- $other->delete();
- }
- }
- }
- public 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();
- }
- public function clearLocation()
- {
- $loc = new Notice_location();
- $loc->notice_id = $this->id;
- if ($loc->find()) {
- $loc->delete();
- }
- }
- public function clearFiles()
- {
- $f2p = new File_to_post();
- $f2p->post_id = $this->id;
- if ($f2p->find()) {
- while ($f2p->fetch()) {
- $f2p->delete();
- }
- }
-
-
- }
- public 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);
- }
- }
- }
- public 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();
- }
- public 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();
- }
- public 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;
- }
- }
- public 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',
- ['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->getObjectType(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;
- }
-
- public 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()
- {
- $is_local = intval($this->is_local);
- return ($is_local === self::LOCAL_PUBLIC || $is_local === self::LOCAL_NONPUBLIC);
- }
- public function getScope()
- {
- return intval($this->scope);
- }
- public function isRepeat()
- {
- return !empty($this->repeat_of);
- }
- public function isRepeated()
- {
- $n = new Notice();
- $n->repeat_of = $this->getID();
- return $n->find() && $n->N > 0;
- }
-
- 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;
- }
- private static 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 (empty($id)) {
- throw new EmptyPkeyValueException('Notice', 'id');
- }
- $timestamp = null;
- if (Event::handle('GetNoticeSqlTimestamp', array($id, &$timestamp))) {
-
- $notice = Notice::getByID($id);
- $timestamp = $notice->created;
- }
- if (empty($timestamp)) {
- throw new ServerException('No timestamp found for Notice with id=='._ve($id));
- }
- return $timestamp;
- }
-
- public static function whereSinceId($id, $idField='id', $createdField='created')
- {
- try {
- $since = Notice::getAsTimestamp($id);
- } catch (Exception $e) {
- return false;
- }
- return sprintf("($createdField = '%s' and $idField > %d) or ($createdField > '%s')", $since, $id, $since);
- }
-
- 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')
- {
- try {
- $max = Notice::getAsTimestamp($id);
- } catch (Exception $e) {
- return false;
- }
- return sprintf("($createdField < '%s') or ($createdField = '%s' and $idField <= %d)", $max, $max, $id);
- }
-
- public static function addWhereMaxId(DB_DataObject $obj, $id, $idField='id', $createdField='created')
- {
- $max = self::whereMaxId($id, $idField, $createdField);
- if ($max) {
- $obj->whereAdd($max);
- }
- }
- public function isPublic()
- {
- $is_local = intval($this->is_local);
- return !($is_local === Notice::LOCAL_NONPUBLIC || $is_local === Notice::GATEWAY);
- }
-
- public 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)
- {
- $scope = is_null($this->scope) ? self::defaultScope() : $this->getScope();
- if ($scope === 0 && !$this->getProfile()->isPrivateStream()) {
- return !$this->isHiddenSpam($profile);
- }
-
- 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;
- }
- }
- if ($scope & Notice::FOLLOWER_SCOPE || $this->getProfile()->isPrivateStream()) {
- if (!Subscription::exists($profile, $this->getProfile())) {
- return false;
- }
- }
- return !$this->isHiddenSpam($profile);
- }
- public 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 hasParent()
- {
- try {
- $this->getParent();
- } catch (NoParentNoticeException $e) {
- return false;
- }
- return true;
- }
- public function getParent()
- {
- $reply_to_id = null;
- if (empty($this->reply_to)) {
- throw new NoParentNoticeException($this);
- }
-
-
-
-
- try {
- $reply_to_id = self::getByID($this->reply_to);
- } catch (Exception $e) {
- throw new NoParentNoticeException($this);
- }
- return $reply_to_id;
- }
-
- public function __sleep()
- {
- $vars = parent::__sleep();
- $skip = array('_profile', '_groups', '_attachments', '_faves', '_replies', '_repeats');
- return array_diff($vars, $skip);
- }
- public static function defaultScope()
- {
- $scope = common_config('notice', 'defaultscope');
- if (is_null($scope)) {
- if (common_config('site', 'private')) {
- $scope = 1;
- } else {
- $scope = 0;
- }
- }
- return $scope;
- }
- public 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);
- }
- public static function getProfiles(&$notices)
- {
- $ids = [];
- foreach ($notices as $notice) {
- $ids[] = $notice->profile_id;
- }
- $ids = array_unique($ids);
- return Profile::pivotGet('id', $ids);
- }
- public static function fillGroups(&$notices)
- {
- $ids = self::_idsOf($notices);
- $gis = Group_inbox::listGet('notice_id', $ids);
- $gids = [];
- 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 = [];
- $gi = $gis[$notice->id];
- foreach ($gi as $g) {
- $grps[] = $group[$g->group_id];
- }
- $notice->_setGroups($grps);
- }
- }
- public static function _idsOf(array &$notices)
- {
- $ids = [];
- foreach ($notices as $notice) {
- $ids[$notice->id] = true;
- }
- return array_keys($ids);
- }
- public static function fillAttachments(&$notices)
- {
- $ids = self::_idsOf($notices);
- $f2pMap = File_to_post::listGet('post_id', $ids);
- $fileIds = [];
- 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 = [];
- $f2ps = $f2pMap[$notice->id];
- foreach ($f2ps as $f2p) {
- if (!isset($fileMap[$f2p->file_id])) {
-
-
- continue;
- } elseif (is_null($fileMap[$f2p->file_id])) {
-
-
-
- common_debug('ATTACHMENT deleting f2p for post_id='.$f2p->post_id.' file_id='.$f2p->file_id);
- $f2p->delete();
- unset($fileMap[$f2p->file_id]);
- continue;
- }
- $files[] = $fileMap[$f2p->file_id];
- }
- $notice->_setAttachments($files);
- }
- }
- public 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);
- }
- }
- public static function beforeSchemaUpdate()
- {
- $table = strtolower(get_called_class());
- $schema = Schema::get();
- $schemadef = $schema->getTableDef($table);
-
-
- if (isset($schemadef['fields']['lat'])
- && isset($schemadef['fields']['lon'])
- && isset($schemadef['fields']['location_id'])
- && isset($schemadef['fields']['location_ns'])) {
-
- $schema->ensureTable('notice_location', Notice_location::schemaDef());
-
- echo "\nFound old $table table, moving location data to 'notice_location' table... (this will probably take a LONG time, but can be aborted and continued)";
- $notice = new Notice();
- $notice->query(sprintf(
- 'SELECT id, lat, lon, location_id, location_ns FROM %1$s ' .
- 'WHERE lat IS NOT NULL ' .
- 'OR lon IS NOT NULL ' .
- 'OR location_id IS NOT NULL ' .
- 'OR location_ns IS NOT NULL',
- common_database_tablename($table)
- ));
- print "\nFound {$notice->N} notices with location data, inserting";
- while ($notice->fetch()) {
- $notloc = Notice_location::getKV('notice_id', $notice->id);
- if ($notloc instanceof Notice_location) {
- print "-";
- continue;
- }
- $notloc = new Notice_location();
- $notloc->notice_id = $notice->id;
- $notloc->lat= $notice->lat;
- $notloc->lon= $notice->lon;
- $notloc->location_id= $notice->location_id;
- $notloc->location_ns= $notice->location_ns;
- $notloc->insert();
- print ".";
- }
- print "\n";
- }
-
- if (!isset($schemadef['foreign keys'])) {
- $newschemadef = self::schemaDef();
- printfnq("\nConstraint checking Notice table...\n");
-
- foreach (['reply_to', 'repeat_of'] as $field) {
- $notice = new Notice();
- $notice->query(sprintf('UPDATE %1$s SET %2$s=NULL WHERE %2$s=0', $notice->escapedTableName(), $field));
-
- unset($notice);
- }
-
- foreach (['reply_to' => 'reset', 'repeat_of' => 'delete', 'profile_id' => 'delete'] as $field=>$action) {
- $notice = new Notice();
- $fkeyname = $notice->tableName().'_'.$field.'_fkey';
- assert(isset($newschemadef['foreign keys'][$fkeyname]));
- assert($newschemadef['foreign keys'][$fkeyname]);
- $foreign_key = $newschemadef['foreign keys'][$fkeyname];
- $fkeytable = $foreign_key[0];
- assert(isset($foreign_key[1][$field]));
- $fkeycol = $foreign_key[1][$field];
- printfnq("* {$fkeyname} ({$field} => {$fkeytable}.{$fkeycol})\n");
-
- $notice->whereAdd(sprintf('%1$s NOT IN (SELECT %2$s FROM %3$s)', $field, $fkeycol, $fkeytable));
- if ($notice->find()) {
- printfnq("\tFound {$notice->N} notices with {$field} NOT IN notice.id, {$action}ing...");
- switch ($action) {
- case 'delete':
- while ($notice->fetch()) {
- $notice->delete();
- }
- break;
- case 'reset':
- $ids = [];
- foreach ($notice->fetchAll('id') as $id) {
- settype($id, 'int');
- $ids[] = $id;
- }
- unset($notice);
- $notice = new Notice();
- $notice->query(sprintf(
- 'UPDATE %1$s SET %2$s = NULL WHERE id IN (%3$s)',
- $notice->escapedTableName(),
- $field,
- implode(',', $ids)
- ));
- break;
- default:
- throw new ServerException('The programmer sucks, invalid action name when fixing table.');
- }
- printfnq("DONE.\n");
- }
- unset($notice);
- }
- }
- }
- public function delPref($namespace, $topic)
- {
- return Notice_prefs::setData($this, $namespace, $topic, null);
- }
- public function getPref($namespace, $topic, $default = null)
- {
-
- try {
- return Notice_prefs::getData($this, $namespace, $topic, $default);
- } catch (NoResultException $e) {
- return null;
- }
- }
-
- public function getConfigPref($namespace, $topic)
- {
- return Notice_prefs::getConfigData($this, $namespace, $topic);
- }
- public function setPref($namespace, $topic, $data)
- {
- return Notice_prefs::setData($this, $namespace, $topic, $data);
- }
- }
|