add pending check on group queries

4 files changed, 15 insertions, 11 deletions

diff --git a/include/follow.php b/include/follow.php
index 686282624..7b9405247 100644
--- a/include/follow.php
+++ b/include/follow.php
@@ -53,7 +53,7 @@ function new_contact($uid,$url,$channel,$interactive = false) {
 
 	// check service class limits
 
-	$r = q("select count(*) as total from abook where abook_channel = %d and not (abook_flags & %d)",
+	$r = q("select count(*) as total from abook where abook_channel = %d and not (abook_flags & %d) ",
 		intval($uid),
 		intval(ABOOK_FLAG_SELF)
 	);
diff --git a/include/group.php b/include/group.php
index dda432266..1019daa9c 100644
--- a/include/group.php
+++ b/include/group.php
@@ -159,11 +159,12 @@ function group_get_members($gid) {
 	if(intval($gid)) {
 		$r = q("SELECT abook.*,xchan.*,group_member.* FROM `group_member` 
 			LEFT JOIN abook ON abook_xchan = `group_member`.`xchan` left join xchan on xchan_hash = abook_xchan
-			WHERE `gid` = %d AND `group_member`.`uid` = %d and not ( abook_flags & %d) and not (abook_flags & %d) ORDER BY xchan_name ASC ",
+			WHERE `gid` = %d AND `group_member`.`uid` = %d and not ( abook_flags & %d ) and not ( abook_flags & %d ) and not ( abook_flags & %d ) ORDER BY xchan_name ASC ",
 			intval($gid),
 			intval(local_user()),
 			intval(ABOOK_FLAG_SELF),
-			intval(ABOOK_FLAG_BLOCKED)
+			intval(ABOOK_FLAG_BLOCKED),
+			intval(ABOOK_FLAG_PENDING)
 		);
 		if(count($r))
 			$ret = $r;
diff --git a/include/items.php b/include/items.php
index a0cc64fc2..493a4e2f2 100755
--- a/include/items.php
+++ b/include/items.php
@@ -22,9 +22,10 @@ function collect_recipients($item,&$private) {
 	}
 	else {
 		$recipients = array();
-		$r = q("select * from abook where abook_channel = %d and not (abook_flags & %d) ",
+		$r = q("select * from abook where abook_channel = %d and not (abook_flags & %d) and not (abook_flags & %d)",
 			intval($item['uid']),
-			intval(ABOOK_FLAG_SELF)
+			intval(ABOOK_FLAG_SELF),
+			intval(ABOOK_FLAG_PENDING)
 		);
 		if($r) {
 			foreach($r as $rr) {
diff --git a/include/zot.php b/include/zot.php
index 88568f09f..d098b1350 100644
--- a/include/zot.php
+++ b/include/zot.php
@@ -248,20 +248,22 @@ function zot_refresh($them,$channel = null) {
 					$their_perms = $their_perms | intval($global_perms[$k][1]);
 				}
 			}
-dbg(1);
-			$r = q("select * from abook where abook_xchan = '%s' and abook_channel = %d and not (abook_flags & %d) limit 1",
+
+			$r = q("select * from abook where abook_xchan = '%s' and abook_channel = %d and not (abook_flags & %d) and not ( abook_flags & %d) limit 1",
 				dbesc($x['hash']),
 				intval($channel['channel_id']),
-				intval(ABOOK_FLAG_SELF)
+				intval(ABOOK_FLAG_SELF),
+				intval(ABOOK_FLAG_PENDING)
 			);
 			if($r) {		
 				$y = q("update abook set abook_their_perms = %d 
 					where abook_xchan = '%s' and abook_channel = %d 
-					and not (abook_flags & %d) limit 1",
+					and not (abook_flags & %d) and not ( abook_flags & %d) limit 1",
 					intval($their_perms),
 					dbesc($x['hash']),
 					intval($channel['channel_id']),
-					intval(ABOOK_FLAG_SELF)
+					intval(ABOOK_FLAG_SELF),
+					intval(ABOOK_FLAG_PENDING)
 				);
 				if(! $y)
 					logger('abook update failed');
@@ -279,7 +281,7 @@ dbg(1);
 				if($y)
 					logger("New introduction received for {$channel['channel_name']}");
 			}
-dbg(0);	
+
 		}
 
 		return true;