]> git.mxchange.org Git - friendica.git/blobdiff - mod/dfrn_notify.php
Merge branch 'master', remote-tracking branch 'remotes/upstream/master'
[friendica.git] / mod / dfrn_notify.php
old mode 100644 (file)
new mode 100755 (executable)
index 6ca3f9f..3dbdc5b
@@ -1,6 +1,6 @@
 <?php
 
-require_once('simplepie/simplepie.inc');
+require_once('library/simplepie/simplepie.inc');
 require_once('include/items.php');
 require_once('include/event.php');
 
@@ -14,6 +14,7 @@ function dfrn_notify_post(&$a) {
        $key          = ((x($_POST,'key'))          ? $_POST['key']                     : '');
        $dissolve     = ((x($_POST,'dissolve'))     ? intval($_POST['dissolve'])        :  0);
        $perm         = ((x($_POST,'perm'))         ? notags(trim($_POST['perm']))      : 'r');
+       $ssl_policy   = ((x($_POST,'ssl_policy'))   ? notags(trim($_POST['ssl_policy'])): 'none');
 
        $writable = (-1);
        if($dfrn_version >= 2.21) {
@@ -58,6 +59,9 @@ function dfrn_notify_post(&$a) {
                        break; // NOTREACHED
        }
                 
+       // be careful - $importer will contain both the contact information for the contact
+       // sending us the post, and also the user information for the person receiving it.
+       // since they are mixed together, it is easy to get them confused.
 
        $r = q("SELECT  `contact`.*, `contact`.`uid` AS `importer_uid`, 
                                        `contact`.`pubkey` AS `cpubkey`, 
@@ -69,7 +73,7 @@ function dfrn_notify_post(&$a) {
                        FROM `contact` 
                        LEFT JOIN `user` ON `contact`.`uid` = `user`.`uid` 
                        WHERE `contact`.`blocked` = 0 AND `contact`.`pending` = 0 
-                               AND `user`.`nickname` = '%s' $sql_extra LIMIT 1",
+                               AND `user`.`nickname` = '%s' AND `user`.`account_expired` = 0 $sql_extra LIMIT 1",
                dbesc($a->argv[1])
        );
 
@@ -91,6 +95,65 @@ function dfrn_notify_post(&$a) {
                $importer['writable'] = $writable;
        }
 
+       // if contact's ssl policy changed, update our links
+
+       $ssl_changed = false;
+
+       if($ssl_policy == 'self' && strstr($importer['url'],'https:')) {
+               $ssl_changed = true;
+               $importer['url']     =  str_replace('https:','http:',$importer['url']);
+               $importer['nurl']    = normalise_link($importer['url']);
+               $importer['photo']   =  str_replace('https:','http:',$importer['photo']);
+               $importer['thumb']   =  str_replace('https:','http:',$importer['thumb']);
+               $importer['micro']   =  str_replace('https:','http:',$importer['micro']);
+               $importer['request'] =  str_replace('https:','http:',$importer['request']);
+               $importer['notify']  =  str_replace('https:','http:',$importer['notify']);
+               $importer['poll']    =  str_replace('https:','http:',$importer['poll']);
+               $importer['confirm'] =  str_replace('https:','http:',$importer['confirm']);
+               $importer['poco']    =  str_replace('https:','http:',$importer['poco']);
+       }
+
+       if($ssl_policy == 'full' && strstr($importer['url'],'http:')) {
+               $ssl_changed = true;
+               $importer['url']     =  str_replace('http:','https:',$importer['url']);
+               $importer['nurl']    = normalise_link($importer['url']);
+               $importer['photo']   =  str_replace('http:','https:',$importer['photo']);
+               $importer['thumb']   =  str_replace('http:','https:',$importer['thumb']);
+               $importer['micro']   =  str_replace('http:','https:',$importer['micro']);
+               $importer['request'] =  str_replace('http:','https:',$importer['request']);
+               $importer['notify']  =  str_replace('http:','https:',$importer['notify']);
+               $importer['poll']    =  str_replace('http:','https:',$importer['poll']);
+               $importer['confirm'] =  str_replace('http:','https:',$importer['confirm']);
+               $importer['poco']    =  str_replace('http:','https:',$importer['poco']);
+       }
+
+       if($ssl_changed) {
+               q("update contact set 
+                       url = '%s', 
+                       nurl = '%s',
+                       photo = '%s',
+                       thumb = '%s',
+                       micro = '%s',
+                       request = '%s',
+                       notify = '%s',
+                       poll = '%s',
+                       confirm = '%s',
+                       poco = '%s'
+                       where id = %d limit 1",
+                       dbesc($importer['url']),
+                       dbesc($importer['nurl']),
+                       dbesc($importer['photo']),
+                       dbesc($importer['thumb']),
+                       dbesc($importer['micro']),
+                       dbesc($importer['request']),
+                       dbesc($importer['notify']),
+                       dbesc($importer['poll']),
+                       dbesc($importer['confirm']),
+                       dbesc($importer['poco']),
+                       intval($importer['id'])
+               );
+       }
+                       
        logger('dfrn_notify: received notify from ' . $importer['name'] . ' for ' . $importer['username']);
        logger('dfrn_notify: data: ' . $data, LOGGER_DATA);
 
@@ -135,525 +198,10 @@ function dfrn_notify_post(&$a) {
        }
 
 
-       if($importer['readonly']) {
-               // We aren't receiving stuff from this person. But we will quietly ignore them
-               // rather than a blatant "go away" message.
-               logger('dfrn_notify: ignoring');
-               xml_status(0);
-               //NOTREACHED
-       }
-
-       // Consume notification feed. This may differ from consuming a public feed in several ways
-       // - might contain email
-       // - might contain remote followup to our message
-       //              - in which case we need to accept it and then notify other conversants
-       // - we may need to send various email notifications
-
-       $feed = new SimplePie();
-       $feed->set_raw_data($data);
-       $feed->enable_order_by_date(false);
-       $feed->init();
-
-       $ismail = false;
-
-       $rawmail = $feed->get_feed_tags( NAMESPACE_DFRN, 'mail' );
-       if(isset($rawmail[0]['child'][NAMESPACE_DFRN])) {
-
-               logger('dfrn_notify: private message received');
-
-               $ismail = true;
-               $base = $rawmail[0]['child'][NAMESPACE_DFRN];
-
-               $msg = array();
-               $msg['uid'] = $importer['importer_uid'];
-               $msg['from-name'] = notags(unxmlify($base['sender'][0]['child'][NAMESPACE_DFRN]['name'][0]['data']));
-               $msg['from-photo'] = notags(unxmlify($base['sender'][0]['child'][NAMESPACE_DFRN]['avatar'][0]['data']));
-               $msg['from-url'] = notags(unxmlify($base['sender'][0]['child'][NAMESPACE_DFRN]['uri'][0]['data']));
-               $msg['contact-id'] = $importer['id'];
-               $msg['title'] = notags(unxmlify($base['subject'][0]['data']));
-               $msg['body'] = escape_tags(unxmlify($base['content'][0]['data']));
-               $msg['seen'] = 0;
-               $msg['replied'] = 0;
-               $msg['uri'] = notags(unxmlify($base['id'][0]['data']));
-               $msg['parent-uri'] = notags(unxmlify($base['in-reply-to'][0]['data']));
-               $msg['created'] = datetime_convert(notags(unxmlify('UTC','UTC',$base['sentdate'][0]['data'])));
-               
-               dbesc_array($msg);
-
-               $r = dbq("INSERT INTO `mail` (`" . implode("`, `", array_keys($msg)) 
-                       . "`) VALUES ('" . implode("', '", array_values($msg)) . "')" );
-
-               // send email notification if requested.
-
-               require_once('bbcode.php');
-               if($importer['notify-flags'] & NOTIFY_MAIL) {
-
-                       push_lang($importer['language']);
-
-                       // name of the automated email sender
-                       $msg['notificationfromname']    = t('Administrator');
-                       // noreply address to send from
-                       $msg['notificationfromemail']   = t('noreply') . '@' . $a->get_hostname();                              
-
-                       // text version
-                       // process the message body to display properly in text mode
-                       //              1) substitute a \n character for the "\" then "n", so it behaves properly (it doesn't come in as a \n character)
-                       //              2) remove escape slashes
-                       //              3) decode any bbcode from the message editor
-                       //              4) decode any encoded html tags
-                       //              5) remove html tags
-                       $msg['textversion']
-                               = strip_tags(html_entity_decode(bbcode(stripslashes(str_replace(array("\\r\\n", "\\r", "\\n"), "\n",$msg['body']))),ENT_QUOTES,'UTF-8'));
-                               
-                       // html version
-                       // process the message body to display properly in text mode
-                       //              1) substitute a <br /> tag for the "\" then "n", so it behaves properly (it doesn't come in as a \n character)
-                       //              2) remove escape slashes
-                       //              3) decode any bbcode from the message editor
-                       //              4) decode any encoded html tags
-                       $msg['htmlversion']     
-                               = html_entity_decode(bbcode(stripslashes(str_replace(array("\\r\\n", "\\r","\\n\\n" ,"\\n"), "<br />\n",$msg['body']))));
-
-                       // load the template for private message notifications
-                       $tpl = get_intltext_template('mail_received_html_body_eml.tpl');
-                       $email_html_body_tpl = replace_macros($tpl,array(
-                               '$siteName'             => $a->config['sitename'],                      // name of this site
-                               '$siteurl'              => $a->get_baseurl(),                           // descriptive url of this site
-                               '$thumb'                => $importer['thumb'],                          // thumbnail url for sender icon
-                               '$email'                => $importer['email'],                          // email address to send to
-                               '$url'                  => $importer['url'],                            // full url for the site
-                               '$from'                 => $msg['from-name'],                           // name of the person sending the message
-                               '$title'                => stripslashes($msg['title']),                 // subject of the message
-                               '$htmlversion'  => $msg['htmlversion'],                                 // html version of the message
-                               '$mimeboundary' => $msg['mimeboundary'],                                // mime message divider
-                               '$hostname'             => $a->get_hostname()                           // name of this host
-                       ));
-                       
-                       // load the template for private message notifications
-                       $tpl = get_intltext_template('mail_received_text_body_eml.tpl');
-                       $email_text_body_tpl = replace_macros($tpl,array(
-                               '$siteName'             => $a->config['sitename'],                      // name of this site
-                               '$siteurl'              => $a->get_baseurl(),                           // descriptive url of this site
-                               '$thumb'                => $importer['thumb'],                          // thumbnail url for sender icon
-                               '$email'                => $importer['email'],                          // email address to send to
-                               '$url'                  => $importer['url'],                            // full url for the site
-                               '$from'                 => $msg['from-name'],                           // name of the person sending the message
-                               '$title'                => stripslashes($msg['title']),                 // subject of the message
-                               '$textversion'  => $msg['textversion'],                                 // text version of the message
-                               '$mimeboundary' => $msg['mimeboundary'],                                // mime message divider
-                               '$hostname'             => $a->get_hostname()                           // name of this host
-                       ));
-
-                       // use the EmailNotification library to send the message
-                       require_once("include/EmailNotification.php");
-                       EmailNotification::sendTextHtmlEmail(
-                               $msg['notificationfromname'],
-                               $msg['notificationfromemail'],
-                               $msg['notificationfromemail'],
-                               $importer['email'],
-                               t('New mail received at ') . $a->config['sitename'],
-                               $email_html_body_tpl,
-                               $email_text_body_tpl
-                       );
-
-                       pop_lang();
-               }
-               xml_status(0);
-               // NOTREACHED
-       }       
-       
-       logger('dfrn_notify: feed item count = ' . $feed->get_item_quantity());
-
-       // process any deleted entries
-
-       $del_entries = $feed->get_feed_tags(NAMESPACE_TOMB, 'deleted-entry');
-       if(is_array($del_entries) && count($del_entries)) {
-               foreach($del_entries as $dentry) {
-                       $deleted = false;
-                       if(isset($dentry['attribs']['']['ref'])) {
-                               $uri = $dentry['attribs']['']['ref'];
-                               $deleted = true;
-                               if(isset($dentry['attribs']['']['when'])) {
-                                       $when = $dentry['attribs']['']['when'];
-                                       $when = datetime_convert('UTC','UTC', $when, 'Y-m-d H:i:s');
-                               }
-                               else
-                                       $when = datetime_convert('UTC','UTC','now','Y-m-d H:i:s');
-                       }
-                       if($deleted) {
-
-                               $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d AND `contact-id` = %d LIMIT 1",
-                                       dbesc($uri),
-                                       intval($importer['importer_uid']),
-                                       intval($importer['id'])
-                               );
-
-                               if(count($r)) {
-                                       $item = $r[0];
-
-                                       if(! $item['deleted'])
-                                               logger('dfrn_notify: deleting item ' . $item['id'] . ' uri=' . $item['uri'], LOGGER_DEBUG);
-
-                                       if($item['uri'] == $item['parent-uri']) {
-                                               $r = q("UPDATE `item` SET `deleted` = 1, `edited` = '%s', `changed` = '%s'
-                                                       WHERE `parent-uri` = '%s' AND `uid` = %d",
-                                                       dbesc($when),
-                                                       dbesc(datetime_convert()),
-                                                       dbesc($item['uri']),
-                                                       intval($importer['importer_uid'])
-                                               );
-                                       }
-                                       else {
-                                               $r = q("UPDATE `item` SET `deleted` = 1, `edited` = '%s', `changed` = '%s' 
-                                                       WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                                       dbesc($when),
-                                                       dbesc(datetime_convert()),
-                                                       dbesc($uri),
-                                                       intval($importer['importer_uid'])
-                                               );
-                                               if($item['last-child']) {
-                                                       // ensure that last-child is set in case the comment that had it just got wiped.
-                                                       q("UPDATE `item` SET `last-child` = 0, `changed` = '%s' WHERE `parent-uri` = '%s' AND `uid` = %d ",
-                                                               dbesc(datetime_convert()),
-                                                               dbesc($item['parent-uri']),
-                                                               intval($item['uid'])
-                                                       );
-                                                       // who is the last child now? 
-                                                       $r = q("SELECT `id` FROM `item` WHERE `parent-uri` = '%s' AND `type` != 'activity' AND `deleted` = 0 AND `uid` = %d
-                                                               ORDER BY `created` DESC LIMIT 1",
-                                                                       dbesc($item['parent-uri']),
-                                                                       intval($importer['importer_uid'])
-                                                       );
-                                                       if(count($r)) {
-                                                               q("UPDATE `item` SET `last-child` = 1 WHERE `id` = %d LIMIT 1",
-                                                                       intval($r[0]['id'])
-                                                               );
-                                                       }       
-                                               }
-                                       }       
-                               }
-                       }
-               }
-       }
-
-
-       foreach($feed->get_items() as $item) {
-
-               $is_reply = false;              
-               $item_id = $item->get_id();
-               $rawthread = $item->get_item_tags( NAMESPACE_THREAD, 'in-reply-to');
-               if(isset($rawthread[0]['attribs']['']['ref'])) {
-                       $is_reply = true;
-                       $parent_uri = $rawthread[0]['attribs']['']['ref'];
-               }
-
-               if($is_reply) {
-                       if($feed->get_item_quantity() == 1) {
-                               logger('dfrn_notify: received remote comment');
-                               $is_like = false;
-                               // remote reply to our post. Import and then notify everybody else.
-                               $datarray = get_atom_elements($feed,$item);
-                               $datarray['type'] = 'remote-comment';
-                               $datarray['wall'] = 1;
-                               $datarray['parent-uri'] = $parent_uri;
-                               $datarray['uid'] = $importer['importer_uid'];
-                               $datarray['contact-id'] = $importer['id'];
-                               if(($datarray['verb'] == ACTIVITY_LIKE) || ($datarray['verb'] == ACTIVITY_DISLIKE)) {
-                                       $is_like = true;
-                                       $datarray['type'] = 'activity';
-                                       $datarray['gravity'] = GRAVITY_LIKE;
-                                       $datarray['last-child'] = 0;
-                               }
-                               $posted_id = item_store($datarray);
-                               $parent = 0;
-
-                               if($posted_id) {
-                                       $r = q("SELECT `parent` FROM `item` WHERE `id` = %d AND `uid` = %d LIMIT 1",
-                                               intval($posted_id),
-                                               intval($importer['importer_uid'])
-                                       );
-                                       if(count($r))
-                                               $parent = $r[0]['parent'];
-                       
-                                       if(! $is_like) {
-                                               $r1 = q("UPDATE `item` SET `last-child` = 0, `changed` = '%s' WHERE `uid` = %d AND `parent` = %d",
-                                                       dbesc(datetime_convert()),
-                                                       intval($importer['importer_uid']),
-                                                       intval($r[0]['parent'])
-                                               );
-
-                                               $r2 = q("UPDATE `item` SET `last-child` = 1, `changed` = '%s' WHERE `uid` = %d AND `id` = %d LIMIT 1",
-                                                       dbesc(datetime_convert()),
-                                                       intval($importer['importer_uid']),
-                                                       intval($posted_id)
-                                               );
-                                       }
-
-                                       if($posted_id && $parent) {
-                               
-                                               proc_run('php',"include/notifier.php","comment-import","$posted_id");
-                                       
-                                               if((! $is_like) && ($importer['notify-flags'] & NOTIFY_COMMENT) && (! $importer['self'])) {
-                                                       push_lang($importer['language']);
-                                                       require_once('bbcode.php');
-                                                       $from = stripslashes($datarray['author-name']);
-
-                                                       // name of the automated email sender
-                                                       $msg['notificationfromname']    = stripslashes($datarray['author-name']);;
-                                                       // noreply address to send from
-                                                       $msg['notificationfromemail']   = t('noreply') . '@' . $a->get_hostname();                              
-
-                                                       // text version
-                                                       // process the message body to display properly in text mode
-                                                       $msg['textversion']
-                                                               = html_entity_decode(strip_tags(bbcode(stripslashes($datarray['body']))), ENT_QUOTES, 'UTF-8');
-                               
-                                                       // html version
-                                                       // process the message body to display properly in text mode
-                                                       $msg['htmlversion']     
-                                                               = html_entity_decode(bbcode(stripslashes(str_replace(array("\\r\\n", "\\r","\\n\\n" ,"\\n"), "<br />\n",$datarray['body']))));
-
-                                                       // load the template for private message notifications
-                                                       $tpl = get_intltext_template('cmnt_received_html_body_eml.tpl');
-                                                       $email_html_body_tpl = replace_macros($tpl,array(
-                                                               '$sitename'             => $a->config['sitename'],                      // name of this site
-                                                               '$siteurl'              => $a->get_baseurl(),                           // descriptive url of this site
-                                                               '$thumb'                => $datarray['author-avatar'],                  // thumbnail url for sender icon
-                                                               '$email'                => $importer['email'],                          // email address to send to
-                                                               '$url'                  => $datarray['author-link'],                    // full url for the site
-                                                               '$from'                 => $from,                                       // name of the person sending the message
-                                                               '$body'                 => $msg['htmlversion'],                 // html version of the message
-                                                               '$display'              => $a->get_baseurl() . '/display/' . $importer['nickname'] . '/' . $posted_id,
-                                                       ));
-                       
-                                                       // load the template for private message notifications
-                                                       $tpl = get_intltext_template('cmnt_received_text_body_eml.tpl');
-                                                       $email_text_body_tpl = replace_macros($tpl,array(
-                                                               '$sitename'             => $a->config['sitename'],                      // name of this site
-                                                               '$siteurl'              => $a->get_baseurl(),                           // descriptive url of this site
-                                                               '$thumb'                => $datarray['author-avatar'],                  // thumbnail url for sender icon
-                                                               '$email'                => $importer['email'],                          // email address to send to
-                                                               '$url'                  => $datarray['author-link'],                    // full url for the site
-                                                               '$from'                 => $from,                                       // name of the person sending the message
-                                                               '$body'                 => $msg['textversion'],                         // text version of the message
-                                                               '$display'              => $a->get_baseurl() . '/display/' . $importer['nickname'] . '/' . $posted_id,
-                                                       ));
-
-                                                       // use the EmailNotification library to send the message
-                                                       require_once("include/EmailNotification.php");
-                                                       EmailNotification::sendTextHtmlEmail(
-                                                               $msg['notificationfromname'],
-                                                               t("Administrator") . '@' . $a->get_hostname(),
-                                                               t("noreply") . '@' . $a->get_hostname(),
-                                                               $importer['email'],
-                                                               sprintf( t('%s commented on an item at %s'), $from , $a->config['sitename']),
-                                                               $email_html_body_tpl,
-                                                               $email_text_body_tpl
-                                                       );
-                                                       pop_lang();
-                                               }
-                                       }
-                                       xml_status(0);
-                                       // NOTREACHED
-                               }
-                       }
-                       else {
-
-                               // regular comment that is part of this total conversation. Have we seen it? If not, import it.
-
-                               $item_id  = $item->get_id();
-                               $datarray = get_atom_elements($feed,$item);
-
-                               $r = q("SELECT `uid`, `last-child`, `edited`, `body` FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                       dbesc($item_id),
-                                       intval($importer['importer_uid'])
-                               );
-
-                               // Update content if 'updated' changes
-
-                               if(count($r)) {
-                                       if((x($datarray,'edited') !== false) && (datetime_convert('UTC','UTC',$datarray['edited']) !== $r[0]['edited'])) {  
-                                               $r = q("UPDATE `item` SET `body` = '%s', `edited` = '%s' WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                                       dbesc($datarray['body']),
-                                                       dbesc(datetime_convert('UTC','UTC',$datarray['edited'])),
-                                                       dbesc($item_id),
-                                                       intval($importer['importer_uid'])
-                                               );
-                                       }
-
-                                       // update last-child if it changes
-
-                                       $allow = $item->get_item_tags( NAMESPACE_DFRN, 'comment-allow');
-                                       if(($allow) && ($allow[0]['data'] != $r[0]['last-child'])) {
-                                               $r = q("UPDATE `item` SET `last-child` = 0, `changed` = '%s' WHERE `parent-uri` = '%s' AND `uid` = %d",
-                                                       dbesc(datetime_convert()),
-                                                       dbesc($parent_uri),
-                                                       intval($importer['importer_uid'])
-                                               );
-                                               $r = q("UPDATE `item` SET `last-child` = %d , `changed` = '%s'  WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                                       intval($allow[0]['data']),
-                                                       dbesc(datetime_convert()),
-                                                       dbesc($item_id),
-                                                       intval($importer['importer_uid'])
-                                               );
-                                       }
-                                       continue;
-                               }
-
-                               $datarray['parent-uri'] = $parent_uri;
-                               $datarray['uid'] = $importer['importer_uid'];
-                               $datarray['contact-id'] = $importer['id'];
-                               if(($datarray['verb'] == ACTIVITY_LIKE) || ($datarray['verb'] == ACTIVITY_DISLIKE)) {
-                                       $datarray['type'] = 'activity';
-                                       $datarray['gravity'] = GRAVITY_LIKE;
-                               }
-                               $posted_id = item_store($datarray);
-
-                               // find out if our user is involved in this conversation and wants to be notified.
-                       
-                               if(($datarray['type'] != 'activity') && ($importer['notify-flags'] & NOTIFY_COMMENT)) {
-
-                                       $myconv = q("SELECT `author-link`, `author-avatar` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 ",
-                                               dbesc($parent_uri),
-                                               intval($importer['importer_uid'])
-                                       );
-                                       if(count($myconv)) {
-                                               $importer_url = $a->get_baseurl() . '/profile/' . $importer['nickname'];
-                                               foreach($myconv as $conv) {
-                                                       if(! link_compare($conv['author-link'],$importer_url))
-                                                               continue;
-
-                                                       push_lang($importer['language']);
-                                                       require_once('bbcode.php');
-                                                       $from = stripslashes($datarray['author-name']);
-                                                       
-                                                       // name of the automated email sender
-                                                       $msg['notificationfromname']    = stripslashes($datarray['author-name']);;
-                                                       // noreply address to send from
-                                                       $msg['notificationfromemail']   = t('noreply') . '@' . $a->get_hostname();                              
-
-                                                       // text version
-                                                       // process the message body to display properly in text mode
-                                                       $msg['textversion']
-                                                               = html_entity_decode(strip_tags(bbcode(stripslashes($datarray['body']))), ENT_QUOTES, 'UTF-8');
-                               
-                                                       // html version
-                                                       // process the message body to display properly in text mode
-                                                       $msg['htmlversion']     
-                                                               = html_entity_decode(bbcode(stripslashes(str_replace(array("\\r\\n", "\\r","\\n\\n" ,"\\n"), "<br />\n",$datarray['body']))));
-
-                                                       // load the template for private message notifications
-                                                       $tpl = get_intltext_template('cmnt_received_html_body_eml.tpl');
-                                                       $email_html_body_tpl = replace_macros($tpl,array(
-                                                               '$sitename'             => $a->config['sitename'],                              // name of this site
-                                                               '$siteurl'              => $a->get_baseurl(),                                   // descriptive url of this site
-                                                               '$thumb'                => $datarray['author-avatar'],                          // thumbnail url for sender icon
-                                                               '$url'                  => $datarray['author-link'],                            // full url for the site
-                                                               '$from'                 => $from,                                               // name of the person sending the message
-                                                               '$body'                 => $msg['htmlversion'],                                 // html version of the message
-                                                               '$display'              => $a->get_baseurl() . '/display/' . $importer['nickname'] . '/' . $posted_id,
-                                                       ));
-                       
-                                                       // load the template for private message notifications
-                                                       $tpl = get_intltext_template('cmnt_received_text_body_eml.tpl');
-                                                       $email_text_body_tpl = replace_macros($tpl,array(
-                                                               '$sitename'             => $a->config['sitename'],                              // name of this site
-                                                               '$siteurl'              => $a->get_baseurl(),                                   // descriptive url of this site
-                                                               '$thumb'                => $datarray['author-avatar'],                          // thumbnail url for sender icon
-                                                               '$url'                  => $datarray['author-link'],                            // full url for the site
-                                                               '$from'                 => $from,                                               // name of the person sending the message
-                                                               '$body'                 => $msg['textversion'],                                 // text version of the message
-                                                               '$display'              => $a->get_baseurl() . '/display/' . $importer['nickname'] . '/' . $posted_id,
-                                                       ));
-
-                                                       // use the EmailNotification library to send the message
-                                                       require_once("include/EmailNotification.php");
-                                                       EmailNotification::sendTextHtmlEmail(
-                                                               $msg['notificationfromname'],
-                                                               t("Administrator@") . $a->get_hostname(),
-                                                               t("noreply") . '@' . $a->get_hostname(),
-                                                               $importer['email'],
-                                                               sprintf( t('%s commented on an item at %s'), $from , $a->config['sitename']),
-                                                               $email_html_body_tpl,
-                                                               $email_text_body_tpl
-                                                       );
-                                                       pop_lang();
-                                                       break;
-                                               }
-                                       }
-                               }
-                               continue;
-                       }
-               }
-
-               else {
-
-                       // Head post of a conversation. Have we seen it? If not, import it.
-
-
-                       $item_id  = $item->get_id();
-                       $datarray = get_atom_elements($feed,$item);
+       $ret = local_delivery($importer,$data);
+       xml_status($ret);
 
-                       if((x($datarray,'object-type')) && ($datarray['object-type'] === ACTIVITY_OBJ_EVENT)) {
-                               $ev = bbtoevent($datarray['body']);
-                               if(x($ev,'desc') && x($ev,'start')) {
-                                       $ev['cid'] = $importer['id'];
-                                       $ev['uid'] = $importer['uid'];
-                                       $ev['uri'] = $item_id;
-
-                                       $r = q("SELECT * FROM `event` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                               dbesc($item_id),
-                                               intval($importer['uid'])
-                                       );
-                                       if(count($r))
-                                               $ev['id'] = $r[0]['id'];
-                                       $xyz = event_store($ev);
-                                       continue;
-                               }
-                       }
-
-                       $r = q("SELECT `uid`, `last-child`, `edited`, `body` FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                               dbesc($item_id),
-                               intval($importer['importer_uid'])
-                       );
-
-                       // Update content if 'updated' changes
-
-                       if(count($r)) {
-                               if((x($datarray,'edited') !== false) && (datetime_convert('UTC','UTC',$datarray['edited']) !== $r[0]['edited'])) {  
-                                       $r = q("UPDATE `item` SET `body` = '%s', `edited` = '%s' WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                               dbesc($datarray['body']),
-                                               dbesc(datetime_convert('UTC','UTC',$datarray['edited'])),
-                                               dbesc($item_id),
-                                               intval($importer['importer_uid'])
-                                       );
-                               }
-
-                               // update last-child if it changes
-
-                               $allow = $item->get_item_tags( NAMESPACE_DFRN, 'comment-allow');
-                               if($allow && $allow[0]['data'] != $r[0]['last-child']) {
-                                       $r = q("UPDATE `item` SET `last-child` = %d , `changed` = '%s' WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
-                                               intval($allow[0]['data']),
-                                               dbesc(datetime_convert()),
-                                               dbesc($item_id),
-                                               intval($importer['importer_uid'])
-                                       );
-                               }
-                               continue;
-                       }
-
-                       $datarray['parent-uri'] = $item_id;
-                       $datarray['uid'] = $importer['importer_uid'];
-                       $datarray['contact-id'] = $importer['id'];
-                       $r = item_store($datarray);
-                       continue;
-               }
-       }
-
-       xml_status(0);
        // NOTREACHED
-
 }
 
 
@@ -688,7 +236,7 @@ function dfrn_notify_content(&$a) {
                        intval(time() + 90 )
                );
 
-               logger('dfrn_notify: challenge=' . $hash );
+               logger('dfrn_notify: challenge=' . $hash, LOGGER_DEBUG );
 
                $sql_extra = '';
                switch($direction) {
@@ -710,7 +258,8 @@ function dfrn_notify_content(&$a) {
                }
 
                $r = q("SELECT `contact`.*, `user`.`nickname` FROM `contact` LEFT JOIN `user` ON `user`.`uid` = `contact`.`uid` 
-                               WHERE `contact`.`blocked` = 0 AND `contact`.`pending` = 0 AND `user`.`nickname` = '%s' $sql_extra LIMIT 1",
+                               WHERE `contact`.`blocked` = 0 AND `contact`.`pending` = 0 AND `user`.`nickname` = '%s' 
+                               AND `user`.`account_expired` = 0 $sql_extra LIMIT 1",
                                dbesc($a->argv[1])
                );
 
@@ -721,14 +270,20 @@ function dfrn_notify_content(&$a) {
                $encrypted_id = '';
                $id_str = $my_id . '.' . mt_rand(1000,9999);
 
-               if((($r[0]['duplex']) && strlen($r[0]['prvkey'])) || (! strlen($r[0]['pubkey']))) {
-                       openssl_private_encrypt($hash,$challenge,$r[0]['prvkey']);
-                       openssl_private_encrypt($id_str,$encrypted_id,$r[0]['prvkey']);
+               $prv_key = trim($r[0]['prvkey']);
+               $pub_key = trim($r[0]['pubkey']);
+               $dplx = intval($r[0]['duplex']);
+
+               if((($dplx) && (strlen($prv_key))) || ((strlen($prv_key)) && (!(strlen($pub_key))))) {
+                       openssl_private_encrypt($hash,$challenge,$prv_key);
+                       openssl_private_encrypt($id_str,$encrypted_id,$prv_key);
                }
-               else {
-                       openssl_public_encrypt($hash,$challenge,$r[0]['pubkey']);
-                       openssl_public_encrypt($id_str,$encrypted_id,$r[0]['pubkey']);
+               elseif(strlen($pub_key)) {
+                       openssl_public_encrypt($hash,$challenge,$pub_key);
+                       openssl_public_encrypt($id_str,$encrypted_id,$pub_key);
                }
+               else
+                       $status = 1;
 
                $challenge    = bin2hex($challenge);
                $encrypted_id = bin2hex($encrypted_id);