Fix ACL data

[friendica.git] / src / Worker / TagUpdate.php

diff --git a/src/Worker/TagUpdate.php b/src/Worker/TagUpdate.php
index 1e97135c5b05fa6a038b3b6f001f3471be175bee..fa3079731c7eb5d88907b4046263b2ba244a4a7e 100644 (file)
--- a/src/Worker/TagUpdate.php
+++ b/src/Worker/TagUpdate.php
@@ -1,6 +1,41 @@
 <?php
-require_once("include/tags.php");
 
-function tagupdate_run(&$argv, &$argc){
-       update_items();
+namespace Friendica\Worker;
+
+class TagUpdate
+{
+       public static function execute()
+       {
+               $messages = dba::p("SELECT `oid`,`item`.`guid`, `item`.`created`, `item`.`received` FROM `term` INNER JOIN `item` ON `item`.`id`=`term`.`oid` WHERE `term`.`otype` = 1 AND `term`.`guid` = ''");
+
+               logger('fetched messages: ' . dba::num_rows($messages));
+               while ($message = dba::fetch($messages)) {
+                       if ($message['uid'] == 0) {
+                               $global = true;
+
+                               q("UPDATE `term` SET `global` = 1 WHERE `otype` = %d AND `guid` = '%s'",
+                                       intval(TERM_OBJ_POST), dbesc($message['guid']));
+                       } else {
+                               $isglobal = q("SELECT `global` FROM `term` WHERE `uid` = 0 AND `otype` = %d AND `guid` = '%s'",
+                                       intval(TERM_OBJ_POST), dbesc($message['guid']));
+
+                               $global = (count($isglobal) > 0);
+                       }
+
+                       q("UPDATE `term` SET `guid` = '%s', `created` = '%s', `received` = '%s', `global` = %d WHERE `otype` = %d AND `oid` = %d",
+                               dbesc($message['guid']), dbesc($message['created']), dbesc($message['received']),
+                               intval($global), intval(TERM_OBJ_POST), intval($message['oid']));
+               }
+
+               dba::close($messages);
+
+               $messages = dba::p("SELECT `guid` FROM `item` WHERE `uid` = 0");
+
+               logger('fetched messages: ' . dba::num_rows($messages));
+               while ($message = dba::fetch(messages)) {
+                       q("UPDATE `item` SET `global` = 1 WHERE `guid` = '%s'", dbesc($message['guid']));
+               }
+
+               dba::close($messages);
+       }
 }