]> git.mxchange.org Git - quix0rs-gnu-social.git/blobdiff - lib/util.php
many jabber queue management changes
[quix0rs-gnu-social.git] / lib / util.php
index 9ebb487a13026040f2624fb7ca75ee7b514d939e..c6cdfbcb949ab0d447802ce55461f9b53cbd5fb3 100644 (file)
@@ -131,16 +131,29 @@ function common_end_xml() {
        $xw->flush();
 }
 
+function common_init_language() {
+       mb_internal_encoding('UTF-8');
+       $language = common_language();
+       # So we don't have to make people install the gettext locales
+       putenv('LANGUAGE='.$language);
+       putenv('LANG='.$language);      
+       $locale_set = setlocale(LC_ALL, $language . ".utf8",
+                                                       $language . ".UTF8",
+                                                       $language . ".utf-8",
+                                                       $language . ".UTF-8",
+                                                       $language);
+       bindtextdomain("laconica", common_config('site','locale_path'));
+       bind_textdomain_codeset("laconica", "UTF-8");
+       textdomain("laconica");
+       setlocale(LC_CTYPE, 'C');
+}
+
 define('PAGE_TYPE_PREFS', 'text/html,application/xhtml+xml,application/xml;q=0.3,text/xml;q=0.2');
 
 function common_show_header($pagetitle, $callable=NULL, $data=NULL, $headercall=NULL) {
        global $config, $xw;
 
        $httpaccept = isset($_SERVER['HTTP_ACCEPT']) ? $_SERVER['HTTP_ACCEPT'] : NULL;
-        $language = common_language();
-        setlocale(LC_ALL, $language);
-        bindtextdomain("laconica", $config['site']['locale_path']);
-        textdomain("laconica");
 
        # XXX: allow content negotiation for RDF, RSS, or XRDS
 
@@ -160,6 +173,8 @@ function common_show_header($pagetitle, $callable=NULL, $data=NULL, $headercall=
 
        # FIXME: correct language for interface
 
+       $language = common_language();
+       
        common_element_start('html', array('xmlns' => 'http://www.w3.org/1999/xhtml',
                                                                           'xml:lang' => $language,
                                                                           'lang' => $language));
@@ -186,7 +201,12 @@ function common_show_header($pagetitle, $callable=NULL, $data=NULL, $headercall=
                                                                   'src' => common_path('js/util.js')),
                                   ' ');
        common_element('link', array('rel' => 'search', 'type' => 'application/opensearchdescription+xml',
-                                        'href' =>  common_local_url('opensearch'), 'title' => common_config('site', 'name').' Search'));
+                                        'href' =>  common_local_url('opensearch', array('type' => 'people')),
+                                        'title' => common_config('site', 'name').' People Search'));
+
+       common_element('link', array('rel' => 'search', 'type' => 'application/opensearchdescription+xml',
+                                        'href' =>  common_local_url('opensearch', array('type' => 'notice')),
+                                        'title' => common_config('site', 'name').' Notice Search'));
 
        if ($callable) {
                if ($data) {
@@ -279,11 +299,8 @@ function common_nav_menu() {
                common_menu_item(common_local_url('all', array('nickname' => $user->nickname)),
                                                 _('Home'));
        }
-       common_menu_item(common_local_url('public'), _('Public'));
        common_menu_item(common_local_url('peoplesearch'), _('Search'));
        common_menu_item(common_local_url('tags'), _('Tags'));
-       common_menu_item(common_local_url('doc', array('title' => 'help')),
-                                        _('Help'));
        if ($user) {
                common_menu_item(common_local_url('profilesettings'),
                                                 _('Settings'));
@@ -301,6 +318,8 @@ function common_nav_menu() {
 
 function common_foot_menu() {
        common_element_start('ul', array('id' => 'nav_sub'));
+       common_menu_item(common_local_url('doc', array('title' => 'help')),
+                                        _('Help'));
        common_menu_item(common_local_url('doc', array('title' => 'about')),
                                         _('About'));
        common_menu_item(common_local_url('doc', array('title' => 'faq')),
@@ -435,6 +454,18 @@ function common_textarea($id, $label, $content=NULL, $instructions=NULL) {
        common_element_end('p');
 }
 
+function common_timezone() {
+       if (common_logged_in()) {
+               $user = common_current_user();
+               if ($user->timezone) {
+                       return $user->timezone;
+               }
+       }
+
+       global $config;
+       return $config['site']['timezone'];
+}
+
 function common_language() {
        $httplang = isset($_SERVER['HTTP_ACCEPT_LANGUAGE']) ? $_SERVER['HTTP_ACCEPT_LANGUAGE'] : NULL;
         $language = array();
@@ -464,6 +495,10 @@ function common_munge_password($password, $id) {
 
 # check if a username exists and has matching password
 function common_check_user($nickname, $password) {
+       # NEVER allow blank passwords, even if they match the DB
+       if (mb_strlen($password) == 0) {
+               return false;
+       }
        $user = User::staticGet('nickname', $nickname);
        if (is_null($user)) {
                return false;
@@ -647,6 +682,8 @@ define('URL_REGEX', '^|[ \t\r\n])((ftp|http|https|gopher|mailto|news|nntp|telnet
 
 function common_render_content($text, $notice) {
        $r = htmlspecialchars($text);
+
+       $r = preg_replace('/[\x{0}-\x{8}\x{b}-\x{c}\x{e}-\x{19}]/', '', $r);
        $id = $notice->profile_id;
        $r = preg_replace('@https?://[^)\]>\s]+@', '<a href="\0" class="extlink">\0</a>', $r);
        $r = preg_replace('/(^|\s+)@([a-z0-9]{1,64})/e', "'\\1@'.common_at_link($id, '\\2')", $r);
@@ -657,7 +694,7 @@ function common_render_content($text, $notice) {
 }
 
 function common_tag_link($tag) {
-       return '<a href="' . htmlspecialchars(common_path('tag/' . $tag)) . '" class="hashlink">' . $tag . '</a>';
+       return '<a href="' . htmlspecialchars(common_path('tag/' . $tag)) . '" rel="tag" class="hashlink">' . htmlspecialchars($tag) . '</a>';
 }
 
 function common_at_link($sender_id, $nickname) {
@@ -764,7 +801,11 @@ function common_fancy_url($action, $args=NULL) {
         case 'publicxrds':
                return common_path('xrds');
         case 'opensearch':
-               return common_path('opensearch');
+                if ($args && $args['type']) {
+                        return common_path('opensearch/'.$args['type']);
+                } else {
+                        return common_path('opensearch/people');
+                }
         case 'doc':
                return common_path('doc/'.$args['title']);
         case 'login':
@@ -802,9 +843,9 @@ function common_fancy_url($action, $args=NULL) {
                return common_path('notice/'.$args['notice']);
         case 'deletenotice':
                 if ($args && $args['notice']) {
-                        return common_path('deletenotice/'.$args['notice']);
+                        return common_path('notice/delete/'.$args['notice']);
                 } else {
-                        return common_path('deletenotice/');
+                        return common_path('notice/delete');
                 }
         case 'xrds':
         case 'foaf':
@@ -918,23 +959,43 @@ function common_date_string($dt) {
 }
 
 function common_exact_date($dt) {
-       $t = strtotime($dt);
-       return date(DATE_RFC850, $t);
+    static $_utc;
+    static $_siteTz;
+
+    if (!$_utc) {
+        $_utc = new DateTimeZone('UTC');
+        $_siteTz = new DateTimeZone(common_timezone());
+    }
+
+       $dateStr = date('d F Y H:i:s', strtotime($dt));
+       $d = new DateTime($dateStr, $_utc);
+       $d->setTimezone($_siteTz);
+       return $d->format(DATE_RFC850);
 }
 
 function common_date_w3dtf($dt) {
-       $t = strtotime($dt);
-       return date(DATE_W3C, $t);
+       $dateStr = date('d F Y H:i:s', strtotime($dt));
+       $d = new DateTime($dateStr, new DateTimeZone('UTC'));
+       $d->setTimezone(new DateTimeZone(common_timezone()));
+       return $d->format(DATE_W3C);
 }
 
 function common_date_rfc2822($dt) {
-       $t = strtotime($dt);
-       return date("r", $t);
+       $dateStr = date('d F Y H:i:s', strtotime($dt));
+       $d = new DateTime($dateStr, new DateTimeZone('UTC'));
+       $d->setTimezone(new DateTimeZone(common_timezone()));
+       return $d->format('r');
 }
 
 function common_date_iso8601($dt) {
-       $t = strtotime($dt);
-       return date("c", $t);
+       $dateStr = date('d F Y H:i:s', strtotime($dt));
+       $d = new DateTime($dateStr, new DateTimeZone('UTC'));
+       $d->setTimezone(new DateTimeZone(common_timezone()));
+       return $d->format('c');
+}
+
+function common_sql_now() {
+       return strftime('%Y-%m-%d %H:%M:%S', time());
 }
 
 function common_redirect($url, $code=307) {
@@ -978,9 +1039,11 @@ function common_save_replies($notice) {
                if ($i == 0 && ($recipient->id != $sender->id)) { # Don't save reply to self
                        $reply_for = $recipient;
                        $recipient_notice = $reply_for->getCurrentNotice();
-                       $orig = clone($notice);
-                       $notice->reply_to = $recipient_notice->id;
-                       $notice->update($orig);
+                       if ($recipient_notice) {
+                               $orig = clone($notice);
+                               $notice->reply_to = $recipient_notice->id;
+                               $notice->update($orig);
+                       }
                }
                $reply = new Reply();
                $reply->notice_id = $notice->id;
@@ -1007,26 +1070,29 @@ function common_broadcast_notice($notice, $remote=false) {
 # Stick the notice on the queue
 
 function common_enqueue_notice($notice) {
-       $qi = new Queue_item();
-       $qi->notice_id = $notice->id;
-       $qi->created = $notice->created;
+       foreach (array('jabber', 'omb', 'sms', 'public') as $transport) {
+               $qi = new Queue_item();
+               $qi->notice_id = $notice->id;
+               $qi->transport = $transport;
+               $qi->created = $notice->created;
         $result = $qi->insert();
-       if (!$result) {
-           $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
-           common_log(LOG_ERR, 'DB error inserting queue item: ' . $last_error->message);
-           return false;
+               if (!$result) {
+                       $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
+                       common_log(LOG_ERR, 'DB error inserting queue item: ' . $last_error->message);
+                       return false;
+               }
+               common_log(LOG_DEBUG, 'complete queueing notice ID = ' . $notice->id . ' for ' . $transport);
        }
-       common_log(LOG_DEBUG, 'complete queueing notice ID = ' . $notice->id);
        return $result;
 }
 
 function common_dequeue_notice($notice) {
-        $qi = Queue_Item::staticGet($notice->id);
+        $qi = Queue_item::staticGet($notice->id);
         if ($qi) {
                 $result = $qi->delete();
                if (!$result) {
                    $last_error = &PEAR::getStaticProperty('DB_DataObject','lastError');
-                    common_log(LOG_ERROR, 'DB error deleting queue item: ' . $last_error->message);
+                    common_log(LOG_ERR, 'DB error deleting queue item: ' . $last_error->message);
                     return false;
                 }
                 common_log(LOG_DEBUG, 'complete dequeueing notice ID = ' . $notice->id);
@@ -1060,6 +1126,12 @@ function common_real_broadcast($notice, $remote=false) {
                        common_log(LOG_ERR, 'Error in sms broadcast for notice ' . $notice->id);
                }
        }
+       if ($success) {
+               $success = jabber_public_notice($notice);
+               if (!$success) {
+                       common_log(LOG_ERR, 'Error in public broadcast for notice ' . $notice->id);
+               }
+       }
        // XXX: broadcast notices to other IM
        return $success;
 }
@@ -1336,7 +1408,7 @@ function common_negotiate_type($cprefs, $sprefs) {
 
 function common_config($main, $sub) {
        global $config;
-       return $config[$main][$sub];
+       return isset($config[$main][$sub]) ? $config[$main][$sub] : false;
 }
 
 function common_copy_args($from) {
@@ -1413,4 +1485,35 @@ function common_canonical_sms($sms) {
        # strip non-digits
        preg_replace('/\D/', '', $sms);
        return $sms;
-}
\ No newline at end of file
+}
+
+function common_error_handler($errno, $errstr, $errfile, $errline, $errcontext) {
+    switch ($errno) {
+     case E_USER_ERROR:
+               echo "ERROR: [$errno] $errstr ($errfile:$errline)\n";
+               echo "  Fatal error on line $errline in file $errfile";
+               echo ", PHP " . PHP_VERSION . " (" . PHP_OS . ")\n";
+               echo "Aborting...\n";
+               exit(1);
+               break;
+
+        case E_USER_WARNING:
+               echo "WARNING [$errno] $errstr ($errfile:$errline)\n";
+               break;
+
+     case E_USER_NOTICE:
+               echo "NOTICE [$errno] $errstr ($errfile:$errline)\n";
+               break;
+    }
+
+    /* Don't execute PHP internal error handler */
+    return true;
+}
+
+function common_session_token() {
+       common_ensure_session();
+       if (!array_key_exists('token', $_SESSION)) {
+               $_SESSION['token'] = common_good_rand(64);
+       }
+       return $_SESSION['token'];
+}