X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FContact.php;h=b0f5ef9f244a3fde42ea33c4d565cc8b32eadd5c;hb=b958a0702f688cbec70064467dafa1754d04784c;hp=3708603ba33051cd5d2656e5b0f291843bff1ebf;hpb=a42595a30c6f6644674e3827c2867af37788b2d1;p=friendica.git

diff --git a/src/Model/Contact.php b/src/Model/Contact.php
index 3708603ba3..b0f5ef9f24 100644
--- a/src/Model/Contact.php
+++ b/src/Model/Contact.php
@@ -7,19 +7,22 @@
 namespace Friendica\Model;
 
 use Friendica\BaseObject;
+use Friendica\Core\Config;
 use Friendica\Core\PConfig;
 use Friendica\Core\System;
 use Friendica\Core\Worker;
 use Friendica\Database\DBM;
 use Friendica\Network\Probe;
-use Friendica\Object\Image;
+use Friendica\Model\Photo;
 use Friendica\Protocol\Diaspora;
 use Friendica\Protocol\DFRN;
 use Friendica\Protocol\OStatus;
+use Friendica\Protocol\PortableContact;
 use Friendica\Protocol\Salmon;
 use dba;
 
 require_once 'boot.php';
+require_once 'include/dba.php';
 require_once 'include/text.php';
 
 /**
@@ -27,6 +30,66 @@ require_once 'include/text.php';
  */
 class Contact extends BaseObject
 {
+	/**
+	 * @brief Returns a list of contacts belonging in a group
+	 *
+	 * @param int $gid
+	 * @return array
+	 */
+	public static function getByGroupId($gid)
+	{
+		$return = [];
+		if (intval($gid)) {
+			$stmt = dba::p('SELECT `group_member`.`contact-id`, `contact`.*
+				FROM `contact`
+				INNER JOIN `group_member`
+					ON `contact`.`id` = `group_member`.`contact-id`
+				WHERE `gid` = ?
+				AND `contact`.`uid` = ?
+				AND NOT `contact`.`self`
+				AND NOT `contact`.`blocked`
+				AND NOT `contact`.`pending`
+				ORDER BY `contact`.`name` ASC',
+				$gid,
+				local_user()
+			);
+			if (DBM::is_result($stmt)) {
+				$return = dba::inArray($stmt);
+			}
+		}
+
+		return $return;
+	}
+
+	/**
+	 * @brief Returns the count of OStatus contacts in a group
+	 *
+	 * @param int $gid
+	 * @return int
+	 */
+	public static function getOStatusCountByGroupId($gid)
+	{
+		$return = 0;
+		if (intval($gid)) {
+			$contacts = dba::fetch_first('SELECT COUNT(*) AS `count`
+				FROM `contact`
+				INNER JOIN `group_member`
+					ON `contact`.`id` = `group_member`.`contact-id`
+				WHERE `gid` = ?
+				AND `contact`.`uid` = ?
+				AND `contact`.`network` = ?
+				AND `contact`.`notify` != ""',
+				$gid,
+				local_user(),
+				NETWORK_OSTATUS
+			);
+			$return = $contacts['count'];
+		}
+
+		return $return;
+	}
+
+
 	/**
 	 * Creates the self-contact for the provided user id
 	 *
@@ -36,11 +99,11 @@ class Contact extends BaseObject
 	public static function createSelfFromUserId($uid)
 	{
 		// Only create the entry if it doesn't exist yet
-		if (dba::exists('contact', ['uid' => intval($uid), 'self'])) {
+		if (dba::exists('contact', ['uid' => $uid, 'self' => true])) {
 			return true;
 		}
 
-		$user = dba::select('user', ['uid', 'username', 'nickname'], ['uid' => intval($uid)], ['limit' => 1]);
+		$user = dba::select('user', ['uid', 'username', 'nickname'], ['uid' => $uid], ['limit' => 1]);
 		if (!DBM::is_result($user)) {
 			return false;
 		}
@@ -136,7 +199,7 @@ class Contact extends BaseObject
 	 * up or some other transient event and that there's a possibility we could recover from it.
 	 *
 	 * @param array $contact contact to mark for archival
-	 * @return type
+	 * @return null
 	 */
 	public static function markForArchival(array $contact)
 	{
@@ -545,7 +608,9 @@ class Contact extends BaseObject
 			AND NOT `pending`
 			AND `id` NOT IN (
 				SELECT DISTINCT(`contact-id`)
-				FROM `group_member` WHERE `uid` = %d
+				FROM `group_member`
+				INNER JOIN `group` ON `group`.`id` = `group_member`.`gid`
+				WHERE `group`.`uid` = %d
 			)
 			LIMIT %d, %d", intval($uid), intval($uid), intval($start), intval($count)
 		);
@@ -599,7 +664,7 @@ class Contact extends BaseObject
 		if (!DBM::is_result($contact)) {
 			// The link could be provided as http although we stored it as https
 			$ssl_url = str_replace('http://', 'https://', $url);
-			$r = dba::select('contact', array('id', 'avatar-date'), array('`alias` IN (?, ?, ?) AND `uid` = ?', $url, normalise_link($url), $ssl_url, $uid), array('limit' => 1));
+			$r = dba::select('contact', array('id', 'avatar', 'avatar-date'), array('`alias` IN (?, ?, ?) AND `uid` = ?', $url, normalise_link($url), $ssl_url, $uid), array('limit' => 1));
 			$contact = dba::fetch($r);
 			dba::close($r);
 		}
@@ -611,7 +676,7 @@ class Contact extends BaseObject
 			$update_contact = ($contact['avatar-date'] < datetime_convert('', '', 'now -7 days'));
 
 			// We force the update if the avatar is empty
-			if ($contact['avatar'] == '') {
+			if (!x($contact, 'avatar')) {
 				$update_contact = true;
 			}
 
@@ -812,11 +877,13 @@ class Contact extends BaseObject
 		$contact = ($r[0]["contact-type"] == ACCOUNT_TYPE_COMMUNITY ? 'owner-id' : 'author-id');
 
 		$r = q(item_query() . " AND `item`.`" . $contact . "` = %d AND " . $sql .
-			" ORDER BY `item`.`created` DESC LIMIT %d, %d", intval($author_id), intval(local_user()), intval($a->pager['start']), intval($a->pager['itemspage'])
+			" AND `item`.`verb` = '%s' ORDER BY `item`.`created` DESC LIMIT %d, %d",
+			intval($author_id), intval(local_user()), dbesc(ACTIVITY_POST),
+			intval($a->pager['start']), intval($a->pager['itemspage'])
 		);
 
 
-		$o = conversation($a, $r, 'community', false);
+		$o = conversation($a, $r, 'contact-posts', false);
 
 		$o .= alt_pager($a, count($r));
 
@@ -921,7 +988,7 @@ class Contact extends BaseObject
 		}
 
 		if (($r["avatar"] != $avatar) || $force) {
-			$photos = Image::importProfilePhoto($avatar, $uid, $cid, true);
+			$photos = Photo::importProfilePhoto($avatar, $uid, $cid, true);
 
 			if ($photos) {
 				dba::update(
@@ -944,4 +1011,283 @@ class Contact extends BaseObject
 
 		return $data;
 	}
+
+	/**
+	 * @param integer $id contact id
+	 * @return boolean
+	 */
+	public static function updateFromProbe($id)
+	{
+		/*
+		Warning: Never ever fetch the public key via Probe::uri and write it into the contacts.
+		This will reliably kill your communication with Friendica contacts.
+		*/
+
+		$r = dba::select('contact', ['url', 'nurl', 'addr', 'alias', 'batch', 'notify', 'poll', 'poco', 'network'], ['id' => $id], ['limit' => 1]);
+		if (!DBM::is_result($r)) {
+			return false;
+		}
+
+		$ret = Probe::uri($r["url"]);
+
+		// If Probe::uri fails the network code will be different
+		if ($ret["network"] != $r["network"]) {
+			return false;
+		}
+
+		$update = false;
+
+		// make sure to not overwrite existing values with blank entries
+		foreach ($ret as $key => $val) {
+			if (isset($r[$key]) && ($r[$key] != "") && ($val == ""))
+				$ret[$key] = $r[$key];
+
+			if (isset($r[$key]) && ($ret[$key] != $r[$key]))
+				$update = true;
+		}
+
+		if (!$update) {
+			return true;
+		}
+
+		dba::update(
+			'contact',
+			[
+				'url' => $ret['url'],
+				'nurl' => normalise_link($ret['url']),
+				'addr' => $ret['addr'],
+				'alias' => $ret['alias'],
+				'batch' => $ret['batch'],
+				'notify' => $ret['notify'],
+				'poll' => $ret['poll'],
+				'poco' => $ret['poco']
+			],
+			['id' => $id]
+		);
+
+		// Update the corresponding gcontact entry
+		PortableContact::lastUpdated($ret["url"]);
+
+		return true;
+	}
+
+	/**
+	 * Takes a $uid and a url/handle and adds a new contact
+	 * Currently if the contact is DFRN, interactive needs to be true, to redirect to the
+	 * dfrn_request page.
+	 *
+	 * Otherwise this can be used to bulk add statusnet contacts, twitter contacts, etc.
+	 *
+	 * Returns an array
+	 * $return['success'] boolean true if successful
+	 * $return['message'] error text if success is false.
+	 *
+	 * @brief Takes a $uid and a url/handle and adds a new contact
+	 * @param int    $uid
+	 * @param string $url
+	 * @param bool   $interactive
+	 * @param string $network
+	 * @return boolean|string
+	 */
+	public static function createFromProbe($uid, $url, $interactive = false, $network = '')
+	{
+		$result = array('cid' => -1, 'success' => false, 'message' => '');
+
+		$a = get_app();
+
+		// remove ajax junk, e.g. Twitter
+		$url = str_replace('/#!/', '/', $url);
+
+		if (!allowed_url($url)) {
+			$result['message'] = t('Disallowed profile URL.');
+			return $result;
+		}
+
+		if (blocked_url($url)) {
+			$result['message'] = t('Blocked domain');
+			return $result;
+		}
+
+		if (!$url) {
+			$result['message'] = t('Connect URL missing.');
+			return $result;
+		}
+
+		$arr = array('url' => $url, 'contact' => array());
+
+		call_hooks('follow', $arr);
+
+		if (x($arr['contact'], 'name')) {
+			$ret = $arr['contact'];
+		} else {
+			$ret = Probe::uri($url, $network, $uid, false);
+		}
+
+		if (($network != '') && ($ret['network'] != $network)) {
+			logger('Expected network ' . $network . ' does not match actual network ' . $ret['network']);
+			return result;
+		}
+
+		if ($ret['network'] === NETWORK_DFRN) {
+			if ($interactive) {
+				if (strlen($a->path)) {
+					$myaddr = bin2hex(System::baseUrl() . '/profile/' . $a->user['nickname']);
+				} else {
+					$myaddr = bin2hex($a->user['nickname'] . '@' . $a->get_hostname());
+				}
+
+				goaway($ret['request'] . "&addr=$myaddr");
+
+				// NOTREACHED
+			}
+		} elseif (Config::get('system', 'dfrn_only')) {
+			$result['message'] = t('This site is not configured to allow communications with other networks.') . EOL;
+			$result['message'] != t('No compatible communication protocols or feeds were discovered.') . EOL;
+			return $result;
+		}
+
+		// This extra param just confuses things, remove it
+		if ($ret['network'] === NETWORK_DIASPORA) {
+			$ret['url'] = str_replace('?absolute=true', '', $ret['url']);
+		}
+
+		// do we have enough information?
+
+		if (!((x($ret, 'name')) && (x($ret, 'poll')) && ((x($ret, 'url')) || (x($ret, 'addr'))))) {
+			$result['message'] .= t('The profile address specified does not provide adequate information.') . EOL;
+			if (!x($ret, 'poll')) {
+				$result['message'] .= t('No compatible communication protocols or feeds were discovered.') . EOL;
+			}
+			if (!x($ret, 'name')) {
+				$result['message'] .= t('An author or name was not found.') . EOL;
+			}
+			if (!x($ret, 'url')) {
+				$result['message'] .= t('No browser URL could be matched to this address.') . EOL;
+			}
+			if (strpos($url, '@') !== false) {
+				$result['message'] .= t('Unable to match @-style Identity Address with a known protocol or email contact.') . EOL;
+				$result['message'] .= t('Use mailto: in front of address to force email check.') . EOL;
+			}
+			return $result;
+		}
+
+		if ($ret['network'] === NETWORK_OSTATUS && Config::get('system', 'ostatus_disabled')) {
+			$result['message'] .= t('The profile address specified belongs to a network which has been disabled on this site.') . EOL;
+			$ret['notify'] = '';
+		}
+
+		if (!$ret['notify']) {
+			$result['message'] .= t('Limited profile. This person will be unable to receive direct/personal notifications from you.') . EOL;
+		}
+
+		$writeable = ((($ret['network'] === NETWORK_OSTATUS) && ($ret['notify'])) ? 1 : 0);
+
+		$subhub = (($ret['network'] === NETWORK_OSTATUS) ? true : false);
+
+		$hidden = (($ret['network'] === NETWORK_MAIL) ? 1 : 0);
+
+		if (in_array($ret['network'], array(NETWORK_MAIL, NETWORK_DIASPORA))) {
+			$writeable = 1;
+		}
+
+		// check if we already have a contact
+		// the poll url is more reliable than the profile url, as we may have
+		// indirect links or webfinger links
+
+		$r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `poll` IN ('%s', '%s') AND `network` = '%s' LIMIT 1",
+			intval($uid),
+			dbesc($ret['poll']),
+			dbesc(normalise_link($ret['poll'])),
+			dbesc($ret['network'])
+		);
+
+		if (!DBM::is_result($r)) {
+			$r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `nurl` = '%s' AND `network` = '%s' LIMIT 1",
+				intval($uid), dbesc(normalise_link($url)), dbesc($ret['network'])
+			);
+		}
+
+		if (DBM::is_result($r)) {
+			// update contact
+			$new_relation = (($r[0]['rel'] == CONTACT_IS_FOLLOWER) ? CONTACT_IS_FRIEND : CONTACT_IS_SHARING);
+
+			$fields = array('rel' => $new_relation, 'subhub' => $subhub, 'readonly' => false);
+			dba::update('contact', $fields, array('id' => $r[0]['id']));
+		} else {
+			$new_relation = ((in_array($ret['network'], array(NETWORK_MAIL))) ? CONTACT_IS_FRIEND : CONTACT_IS_SHARING);
+
+			// create contact record
+			dba::insert(
+				'contact',
+				[
+					'uid' => $uid,
+					'created' => datetime_convert(),
+					'url' => $ret['url'],
+					'nurl' => normalise_link($ret['url']),
+					'addr' => $ret['addr'],
+					'alias' => $ret['alias'],
+					'batch' => $ret['batch'],
+					`notify` => $ret['notify'],
+					`poll` => $ret['poll'],
+					`poco` => $ret['poco'],
+					`name` => $ret['name'],
+					`nick` => $ret['nick'],
+					`network` => $ret['network'],
+					`pubkey` => $ret['pubkey'],
+					`rel` => $new_relation,
+					`priority` => $ret['priority'],
+					`writable` => $writeable,
+					`hidden` => $hidden,
+					`blocked` => 0,
+					`readonly` => 0,
+					`pending` => 0,
+					`subhub` => $subhub
+				]
+			);
+		}
+
+		$r = dba::select('contact', ['url' => $ret['url'], 'network' => $ret['network'], 'uid' => $uid], ['limit' => 1]);
+
+		if (!DBM::is_result($r)) {
+			$result['message'] .= t('Unable to retrieve contact information.') . EOL;
+			return $result;
+		}
+
+		$contact = $r;
+		$contact_id = $r['id'];
+		$result['cid'] = $contact_id;
+
+		Group::addMember(User::getDefaultGroup($uid, $contact["network"]), $contact_id);
+
+		// Update the avatar
+		self::updateAvatar($ret['photo'], $uid, $contact_id);
+
+		// pull feed and consume it, which should subscribe to the hub.
+
+		Worker::add(PRIORITY_HIGH, "OnePoll", $contact_id, "force");
+
+		$r = q("SELECT `contact`.*, `user`.* FROM `contact` INNER JOIN `user` ON `contact`.`uid` = `user`.`uid`
+				WHERE `user`.`uid` = %d AND `contact`.`self` LIMIT 1",
+				intval($uid)
+		);
+
+		if (DBM::is_result($r)) {
+			if (($contact['network'] == NETWORK_OSTATUS) && (strlen($contact['notify']))) {
+				// create a follow slap
+				$item = array();
+				$item['verb'] = ACTIVITY_FOLLOW;
+				$item['follow'] = $contact["url"];
+				$slap = OStatus::salmon($item, $r[0]);
+				Salmon::slapper($r[0], $contact['notify'], $slap);
+			}
+
+			if ($contact['network'] == NETWORK_DIASPORA) {
+				$ret = Diaspora::sendShare($a->user, $contact);
+				logger('share returns: ' . $ret);
+			}
+		}
+
+		$result['success'] = true;
+		return $result;
+	}
 }