clones/friendica
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Bugfix for better mail import

This commit is contained in:
Michael 2017-09-23 22:53:44 +00:00
parent 7360945d8a
commit d72e6b2c82
4 changed files with 41 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/Contact.php
View File

@ -584,10 +584,10 @@ function get_contact($url, $uid = 0, $no_update = false) {
return 0; return 0;
} }
$data = Probe::uri($url); $data = Probe::uri($url, "", $uid);
// Last try in gcontact for unsupported networks // Last try in gcontact for unsupported networks
if (!in_array($data["network"], array(NETWORK_DFRN, NETWORK_OSTATUS, NETWORK_DIASPORA, NETWORK_PUMPIO))) { if (!in_array($data["network"], array(NETWORK_DFRN, NETWORK_OSTATUS, NETWORK_DIASPORA, NETWORK_PUMPIO, NETWORK_MAIL))) {
if ($uid != 0) { if ($uid != 0) {
return 0; return 0;
} }

21
include/email.php
View File

@ -18,22 +18,27 @@ function email_poll($mbox,$email_addr) {
return array(); return array();
$search1 = @imap_search($mbox,'FROM "' . $email_addr . '"', SE_UID); $search1 = @imap_search($mbox,'FROM "' . $email_addr . '"', SE_UID);
if (! $search1) if (!$search1) {
$search1 = array(); $search1 = array();
} else {
logger("Found mails from ".$email_addr, LOGGER_DEBUG);
}
$search2 = @imap_search($mbox,'TO "' . $email_addr . '"', SE_UID); $search2 = @imap_search($mbox,'TO "' . $email_addr . '"', SE_UID);
if (! $search2) if (!$search2) {
$search2 = array(); $search2 = array();
} else {
logger("Found mails to ".$email_addr, LOGGER_DEBUG);
}
$search3 = @imap_search($mbox,'CC "' . $email_addr . '"', SE_UID); $search3 = @imap_search($mbox,'CC "' . $email_addr . '"', SE_UID);
if (! $search3) if (!$search3) {
$search3 = array(); $search3 = array();
} else {
logger("Found mails cc ".$email_addr, LOGGER_DEBUG);
}
$search4 = @imap_search($mbox,'BCC "' . $email_addr . '"', SE_UID); $res = array_unique(array_merge($search1, $search2, $search3));
if (! $search4)
$search4 = array();
$res = array_unique(array_merge($search1,$search2,$search3,$search4));
return $res; return $res;
} }

6
include/onepoll.php
View File

@ -328,7 +328,7 @@ function onepoll_run(&$argv, &$argc){
unlink($cookiejar); unlink($cookiejar);
} elseif ($contact['network'] === NETWORK_MAIL || $contact['network'] === NETWORK_MAIL2) { } elseif ($contact['network'] === NETWORK_MAIL || $contact['network'] === NETWORK_MAIL2) {
logger("Mail: Fetching", LOGGER_DEBUG); logger("Mail: Fetching for ".$contact['addr'], LOGGER_DEBUG);
$mail_disabled = ((function_exists('imap_open') && (! get_config('system','imap_disabled'))) ? 0 : 1); $mail_disabled = ((function_exists('imap_open') && (! get_config('system','imap_disabled'))) ? 0 : 1);
if ($mail_disabled) if ($mail_disabled)
@ -363,10 +363,10 @@ function onepoll_run(&$argv, &$argc){
} }
if ($mbox) { if ($mbox) {
$msgs = email_poll($mbox,$contact['addr']); $msgs = email_poll($mbox, $contact['addr']);
if (count($msgs)) { if (count($msgs)) {
logger("Mail: Parsing ".count($msgs)." mails for ".$mailconf[0]['user'], LOGGER_DEBUG); logger("Mail: Parsing ".count($msgs)." mails from ".$contact['addr']." for ".$mailconf[0]['user'], LOGGER_DEBUG);
$metas = email_msg_meta($mbox,implode(',',$msgs)); $metas = email_msg_meta($mbox,implode(',',$msgs));
if (count($metas) != count($msgs)) { if (count($metas) != count($msgs)) {

10
src/Network/Probe.php
View File

@ -306,7 +306,7 @@ class Probe {
* *
* @return array uri data * @return array uri data
*/ */
public static function uri($uri, $network = "", $uid = 0, $cache = true) { public static function uri($uri, $network = "", $uid = -1, $cache = true) {
if ($cache) { if ($cache) {
$result = Cache::get("probe_url:".$network.":".$uri); $result = Cache::get("probe_url:".$network.":".$uri);
@ -315,7 +315,7 @@ class Probe {
} }
} }
if ($uid == 0) { if ($uid == -1) {
$uid = local_user(); $uid = local_user();
} }
@ -1483,6 +1483,7 @@ class Probe {
return false; return false;
} }
if ($uid != 0) {
$x = q("SELECT `prvkey` FROM `user` WHERE `uid` = %d LIMIT 1", intval($uid)); $x = q("SELECT `prvkey` FROM `user` WHERE `uid` = %d LIMIT 1", intval($uid));
$r = q("SELECT * FROM `mailacct` WHERE `uid` = %d AND `server` != '' LIMIT 1", intval($uid)); $r = q("SELECT * FROM `mailacct` WHERE `uid` = %d AND `server` != '' LIMIT 1", intval($uid));
@ -1503,6 +1504,7 @@ class Probe {
if (!count($msgs)) { if (!count($msgs)) {
return false; return false;
} }
}
$phost = substr($uri, strpos($uri, '@') + 1); $phost = substr($uri, strpos($uri, '@') + 1);
@ -1512,7 +1514,7 @@ class Probe {
$data["name"] = substr($uri, 0, strpos($uri, '@')); $data["name"] = substr($uri, 0, strpos($uri, '@'));
$data["nick"] = $data["name"]; $data["nick"] = $data["name"];
$data["photo"] = avatar_img($uri); $data["photo"] = avatar_img($uri);
$data["url"] = 'http://'.$phost."/".$data["nick"]; $data["url"] = 'mailto:'.$uri;
$data["notify"] = 'smtp '.random_string(); $data["notify"] = 'smtp '.random_string();
$data["poll"] = 'email '.random_string(); $data["poll"] = 'email '.random_string();
@ -1542,7 +1544,9 @@ class Probe {
} }
} }
} }
if (!empty($mbox)) {
imap_close($mbox); imap_close($mbox);
}
return $data; return $data;
} }