src/Model/Group.php

   1 <?php
   2 /**
   3  * @copyright Copyright (C) 2010-2023, the Friendica project
   4  *
   5  * @license GNU AGPL version 3 or any later version
   6  *
   7  * This program is free software: you can redistribute it and/or modify
   8  * it under the terms of the GNU Affero General Public License as
   9  * published by the Free Software Foundation, either version 3 of the
  10  * License, or (at your option) any later version.
  11  *
  12  * This program is distributed in the hope that it will be useful,
  13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15  * GNU Affero General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU Affero General Public License
  18  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
  19  *
  20  */
  21
  22 namespace Friendica\Model;
  23
  24 use Friendica\BaseModule;
  25 use Friendica\Core\Logger;
  26 use Friendica\Core\Protocol;
  27 use Friendica\Core\Renderer;
  28 use Friendica\Database\Database;
  29 use Friendica\Database\DBA;
  30 use Friendica\DI;
  31 use Friendica\Network\HTTPException;
  32 use Friendica\Protocol\ActivityPub;
  33
  34 /**
  35  * functions for interacting with the group database table
  36  */
  37 class Group
  38 {
  39         const FOLLOWERS = '~';
  40         const MUTUALS = '&';
  41
  42         /**
  43          * Fetches group record by user id and maybe includes deleted groups as well
  44          *
  45          * @param int  $uid User id to fetch group(s) for
  46          * @param bool $includesDeleted Whether deleted groups should be included
  47          * @return array|bool Array on success, bool on error
  48          */
  49         public static function getByUserId(int $uid, bool $includesDeleted = false)
  50         {
  51                 $conditions = ['uid' => $uid, 'cid' => null];
  52
  53                 if (!$includesDeleted) {
  54                         $conditions['deleted'] = false;
  55                 }
  56
  57                 return DBA::selectToArray('group', [], $conditions);
  58         }
  59
  60         /**
  61          * Checks whether given group id is found in database
  62          *
  63          * @param int $group_id Group id
  64          * @param int $uid Optional user id
  65          * @return bool
  66          * @throws \Exception
  67          */
  68         public static function exists(int $group_id, int $uid = null): bool
  69         {
  70                 $condition = ['id' => $group_id, 'deleted' => false];
  71
  72                 if (!is_null($uid)) {
  73                         $condition = [
  74                                 'uid' => $uid
  75                         ];
  76                 }
  77
  78                 return DBA::exists('group', $condition);
  79         }
  80
  81         /**
  82          * Create a new contact group
  83          *
  84          * Note: If we found a deleted group with the same name, we restore it
  85          *
  86          * @param int    $uid User id to create group for
  87          * @param string $name Name of group
  88          * @return int|boolean Id of newly created group or false on error
  89          * @throws \Exception
  90          */
  91         public static function create(int $uid, string $name)
  92         {
  93                 $return = false;
  94                 if (!empty($uid) && !empty($name)) {
  95                         $gid = self::getIdByName($uid, $name); // check for dupes
  96                         if ($gid !== false) {
  97                                 // This could be a problem.
  98                                 // Let's assume we've just created a group which we once deleted
  99                                 // all the old members are gone, but the group remains so we don't break any security
 100                                 // access lists. What we're doing here is reviving the dead group, but old content which
 101                                 // was restricted to this group may now be seen by the new group members.
 102                                 $group = DBA::selectFirst('group', ['deleted'], ['id' => $gid]);
 103                                 if (DBA::isResult($group) && $group['deleted']) {
 104                                         DBA::update('group', ['deleted' => 0], ['id' => $gid]);
 105                                         DI::sysmsg()->addNotice(DI::l10n()->t('A deleted group with this name was revived. Existing item permissions <strong>may</strong> apply to this group and any future members. If this is not what you intended, please create another group with a different name.'));
 106                                 }
 107                                 return true;
 108                         }
 109
 110                         $return = DBA::insert('group', ['uid' => $uid, 'name' => $name]);
 111                         if ($return) {
 112                                 $return = DBA::lastInsertId();
 113                         }
 114                 }
 115                 return $return;
 116         }
 117
 118         /**
 119          * Update group information.
 120          *
 121          * @param int    $id   Group ID
 122          * @param string $name Group name
 123          *
 124          * @return bool Was the update successful?
 125          * @throws \Exception
 126          */
 127         public static function update(int $id, string $name): bool
 128         {
 129                 return DBA::update('group', ['name' => $name], ['id' => $id]);
 130         }
 131
 132         /**
 133          * Get a list of group ids a contact belongs to
 134          *
 135          * @param int $cid Contact id
 136          * @return array Group ids
 137          * @throws \Exception
 138          */
 139         public static function getIdsByContactId(int $cid): array
 140         {
 141                 $contact = Contact::getById($cid, ['rel']);
 142                 if (!$contact) {
 143                         return [];
 144                 }
 145
 146                 $groupIds = [];
 147
 148                 $stmt = DBA::select('group_member', ['gid'], ['contact-id' => $cid]);
 149                 while ($group = DBA::fetch($stmt)) {
 150                         $groupIds[] = $group['gid'];
 151                 }
 152                 DBA::close($stmt);
 153
 154                 // Meta-groups
 155                 if ($contact['rel'] == Contact::FOLLOWER || $contact['rel'] == Contact::FRIEND) {
 156                         $groupIds[] = self::FOLLOWERS;
 157                 }
 158
 159                 if ($contact['rel'] == Contact::FRIEND) {
 160                         $groupIds[] = self::MUTUALS;
 161                 }
 162
 163                 return $groupIds;
 164         }
 165
 166         /**
 167          * count unread group items
 168          *
 169          * Count unread items of each groups of the local user
 170          *
 171          * @return array
 172          *    'id' => group id
 173          *    'name' => group name
 174          *    'count' => counted unseen group items
 175          * @throws \Exception
 176          */
 177         public static function countUnseen()
 178         {
 179                 $stmt = DBA::p("SELECT `group`.`id`, `group`.`name`,
 180                                 (SELECT COUNT(*) FROM `post-user`
 181                                         WHERE `uid` = ?
 182                                         AND `unseen`
 183                                         AND `contact-id` IN
 184                                                 (SELECT `contact-id`
 185                                                 FROM `group_member`
 186                                                 WHERE `group_member`.`gid` = `group`.`id`)
 187                                         ) AS `count`
 188                                 FROM `group`
 189                                 WHERE `group`.`uid` = ?;",
 190                         DI::userSession()->getLocalUserId(),
 191                         DI::userSession()->getLocalUserId()
 192                 );
 193
 194                 return DBA::toArray($stmt);
 195         }
 196
 197         /**
 198          * Get the group id for a user/name couple
 199          *
 200          * Returns false if no group has been found.
 201          *
 202          * @param int    $uid User id
 203          * @param string $name Group name
 204          * @return int|boolean Groups' id number or false on error
 205          * @throws \Exception
 206          */
 207         public static function getIdByName(int $uid, string $name)
 208         {
 209                 if (!$uid || !strlen($name)) {
 210                         return false;
 211                 }
 212
 213                 $group = DBA::selectFirst('group', ['id'], ['uid' => $uid, 'name' => $name]);
 214                 if (DBA::isResult($group)) {
 215                         return $group['id'];
 216                 }
 217
 218                 return false;
 219         }
 220
 221         /**
 222          * Mark a group as deleted
 223          *
 224          * @param int $gid
 225          * @return boolean
 226          * @throws \Exception
 227          */
 228         public static function remove(int $gid): bool
 229         {
 230                 if (!$gid) {
 231                         return false;
 232                 }
 233
 234                 $group = DBA::selectFirst('group', ['uid'], ['id' => $gid]);
 235                 if (!DBA::isResult($group)) {
 236                         return false;
 237                 }
 238
 239                 // remove group from default posting lists
 240                 $user = DBA::selectFirst('user', ['def_gid', 'allow_gid', 'deny_gid'], ['uid' => $group['uid']]);
 241                 if (DBA::isResult($user)) {
 242                         $change = false;
 243
 244                         if ($user['def_gid'] == $gid) {
 245                                 $user['def_gid'] = 0;
 246                                 $change = true;
 247                         }
 248                         if (strpos($user['allow_gid'], '<' . $gid . '>') !== false) {
 249                                 $user['allow_gid'] = str_replace('<' . $gid . '>', '', $user['allow_gid']);
 250                                 $change = true;
 251                         }
 252                         if (strpos($user['deny_gid'], '<' . $gid . '>') !== false) {
 253                                 $user['deny_gid'] = str_replace('<' . $gid . '>', '', $user['deny_gid']);
 254                                 $change = true;
 255                         }
 256
 257                         if ($change) {
 258                                 DBA::update('user', $user, ['uid' => $group['uid']]);
 259                         }
 260                 }
 261
 262                 // remove all members
 263                 DBA::delete('group_member', ['gid' => $gid]);
 264
 265                 // remove group
 266                 $return = DBA::update('group', ['deleted' => 1], ['id' => $gid]);
 267
 268                 return $return;
 269         }
 270
 271         /**
 272          * Adds a contact to a group
 273          *
 274          * @param int $gid
 275          * @param int $cid
 276          * @return boolean
 277          * @throws \Exception
 278          */
 279         public static function addMember(int $gid, int $cid): bool
 280         {
 281                 if (!$gid || !$cid) {
 282                         return false;
 283                 }
 284
 285                 // @TODO Backward compatibility with user contacts, remove by version 2022.03
 286                 $group = DBA::selectFirst('group', ['uid'], ['id' => $gid]);
 287                 if (empty($group)) {
 288                         throw new HTTPException\NotFoundException('Group not found.');
 289                 }
 290
 291                 $cdata = Contact::getPublicAndUserContactID($cid, $group['uid']);
 292                 if (empty($cdata['user'])) {
 293                         throw new HTTPException\NotFoundException('Invalid contact.');
 294                 }
 295
 296                 return DBA::insert('group_member', ['gid' => $gid, 'contact-id' => $cdata['user']], Database::INSERT_IGNORE);
 297         }
 298
 299         /**
 300          * Removes a contact from a group
 301          *
 302          * @param int $gid
 303          * @param int $cid
 304          * @return boolean
 305          * @throws \Exception
 306          */
 307         public static function removeMember(int $gid, int $cid): bool
 308         {
 309                 if (!$gid || !$cid) {
 310                         return false;
 311                 }
 312
 313                 // @TODO Backward compatibility with user contacts, remove by version 2022.03
 314                 $group = DBA::selectFirst('group', ['uid'], ['id' => $gid]);
 315                 if (empty($group)) {
 316                         throw new HTTPException\NotFoundException('Group not found.');
 317                 }
 318
 319                 $cdata = Contact::getPublicAndUserContactID($cid, $group['uid']);
 320                 if (empty($cdata['user'])) {
 321                         throw new HTTPException\NotFoundException('Invalid contact.');
 322                 }
 323
 324                 return DBA::delete('group_member', ['gid' => $gid, 'contact-id' => $cid]);
 325         }
 326
 327         /**
 328          * Adds contacts to a group
 329          *
 330          * @param int $gid
 331          * @param array $contacts Array with contact ids
 332          * @return void
 333          * @throws \Exception
 334          */
 335         public static function addMembers(int $gid, array $contacts)
 336         {
 337                 if (!$gid || !$contacts) {
 338                         return;
 339                 }
 340
 341                 // @TODO Backward compatibility with user contacts, remove by version 2022.03
 342                 $group = DBA::selectFirst('group', ['uid'], ['id' => $gid]);
 343                 if (empty($group)) {
 344                         throw new HTTPException\NotFoundException('Group not found.');
 345                 }
 346
 347                 foreach ($contacts as $cid) {
 348                         $cdata = Contact::getPublicAndUserContactID($cid, $group['uid']);
 349                         if (empty($cdata['user'])) {
 350                                 throw new HTTPException\NotFoundException('Invalid contact.');
 351                         }
 352
 353                         DBA::insert('group_member', ['gid' => $gid, 'contact-id' => $cdata['user']], Database::INSERT_IGNORE);
 354                 }
 355         }
 356
 357         /**
 358          * Removes contacts from a group
 359          *
 360          * @param int $gid Group id
 361          * @param array $contacts Contact ids
 362          * @return bool
 363          * @throws \Exception
 364          */
 365         public static function removeMembers(int $gid, array $contacts)
 366         {
 367                 if (!$gid || !$contacts) {
 368                         return false;
 369                 }
 370
 371                 // @TODO Backward compatibility with user contacts, remove by version 2022.03
 372                 $group = DBA::selectFirst('group', ['uid'], ['id' => $gid]);
 373                 if (empty($group)) {
 374                         throw new HTTPException\NotFoundException('Group not found.');
 375                 }
 376
 377                 $contactIds = [];
 378
 379                 foreach ($contacts as $cid) {
 380                         $cdata = Contact::getPublicAndUserContactID($cid, $group['uid']);
 381                         if (empty($cdata['user'])) {
 382                                 throw new HTTPException\NotFoundException('Invalid contact.');
 383                         }
 384
 385                         $contactIds[] = $cdata['user'];
 386                 }
 387
 388                 // Return status of deletion
 389                 return DBA::delete('group_member', ['gid' => $gid, 'contact-id' => $contactIds]);
 390         }
 391
 392         /**
 393          * Returns the combined list of contact ids from a group id list
 394          *
 395          * @param int     $uid              User id
 396          * @param array   $group_ids        Groups ids
 397          * @param boolean $check_dead       Whether check "dead" records (?)
 398          * @param boolean $expand_followers Expand the list of followers
 399          * @return array
 400          * @throws \Exception
 401          */
 402         public static function expand(int $uid, array $group_ids, bool $check_dead = false, bool $expand_followers = true): array
 403         {
 404                 if (!is_array($group_ids) || !count($group_ids)) {
 405                         return [];
 406                 }
 407
 408                 $return               = [];
 409                 $pubmail              = false;
 410                 $followers_collection = false;
 411                 $networks             = Protocol::SUPPORT_PRIVATE;
 412
 413                 $mailacct = DBA::selectFirst('mailacct', ['pubmail'], ['`uid` = ? AND `server` != ""', $uid]);
 414                 if (DBA::isResult($mailacct)) {
 415                         $pubmail = $mailacct['pubmail'];
 416                 }
 417
 418                 if (!$pubmail) {
 419                         $networks = array_diff($networks, [Protocol::MAIL]);
 420                 }
 421
 422                 $key = array_search(self::FOLLOWERS, $group_ids);
 423                 if ($key !== false) {
 424                         if ($expand_followers) {
 425                                 $followers = Contact::selectToArray(['id'], [
 426                                         'uid' => $uid,
 427                                         'rel' => [Contact::FOLLOWER, Contact::FRIEND],
 428                                         'network' => $networks,
 429                                         'contact-type' => [Contact::TYPE_UNKNOWN, Contact::TYPE_PERSON],
 430                                         'archive' => false,
 431                                         'pending' => false,
 432                                         'blocked' => false,
 433                                 ]);
 434
 435                                 foreach ($followers as $follower) {
 436                                         $return[] = $follower['id'];
 437                                 }
 438                         } else {
 439                                 $followers_collection = true;
 440                         }
 441                         unset($group_ids[$key]);
 442                 }
 443
 444                 $key = array_search(self::MUTUALS, $group_ids);
 445                 if ($key !== false) {
 446                         $mutuals = Contact::selectToArray(['id'], [
 447                                 'uid' => $uid,
 448                                 'rel' => [Contact::FRIEND],
 449                                 'network' => $networks,
 450                                 'contact-type' => [Contact::TYPE_UNKNOWN, Contact::TYPE_PERSON],
 451                                 'archive' => false,
 452                                 'pending' => false,
 453                                 'blocked' => false,
 454                         ]);
 455
 456                         foreach ($mutuals as $mutual) {
 457                                 $return[] = $mutual['id'];
 458                         }
 459
 460                         unset($group_ids[$key]);
 461                 }
 462
 463                 $stmt = DBA::select('group_member', ['contact-id'], ['gid' => $group_ids]);
 464                 while ($group_member = DBA::fetch($stmt)) {
 465                         $return[] = $group_member['contact-id'];
 466                 }
 467                 DBA::close($stmt);
 468
 469                 if ($check_dead) {
 470                         $return = Contact::pruneUnavailable($return);
 471                 }
 472
 473                 if ($followers_collection) {
 474                         $return[] = -1;
 475                 }
 476
 477                 return $return;
 478         }
 479
 480         /**
 481          * Returns a templated group selection list
 482          *
 483          * @param int    $uid User id
 484          * @param int    $gid   An optional pre-selected group
 485          * @param string $label An optional label of the list
 486          * @return string
 487          * @throws \Exception
 488          */
 489         public static function displayGroupSelection(int $uid, int $gid = 0, string $label = ''): string
 490         {
 491                 $display_groups = [
 492                         [
 493                                 'name' => '',
 494                                 'id' => '0',
 495                                 'selected' => ''
 496                         ]
 497                 ];
 498
 499                 $stmt = DBA::select('group', [], ['deleted' => false, 'uid' => $uid, 'cid' => null], ['order' => ['name']]);
 500                 while ($group = DBA::fetch($stmt)) {
 501                         $display_groups[] = [
 502                                 'name' => $group['name'],
 503                                 'id' => $group['id'],
 504                                 'selected' => $gid == $group['id'] ? 'true' : ''
 505                         ];
 506                 }
 507                 DBA::close($stmt);
 508
 509                 Logger::info('Got groups', $display_groups);
 510
 511                 if ($label == '') {
 512                         $label = DI::l10n()->t('Default privacy group for new contacts');
 513                 }
 514
 515                 $o = Renderer::replaceMacros(Renderer::getMarkupTemplate('group_selection.tpl'), [
 516                         '$label' => $label,
 517                         '$groups' => $display_groups
 518                 ]);
 519                 return $o;
 520         }
 521
 522         /**
 523          * Create group sidebar widget
 524          *
 525          * @param string $every
 526          * @param string $each
 527          * @param string $editmode
 528          *    'standard' => include link 'Edit groups'
 529          *    'extended' => include link 'Create new group'
 530          *    'full' => include link 'Create new group' and provide for each group a link to edit this group
 531          * @param string|int $group_id Distinct group id or 'everyone'
 532          * @param int    $cid Contact id
 533          * @return string Sidebar widget HTML code
 534          * @throws \Exception
 535          */
 536         public static function sidebarWidget(string $every = 'contact', string $each = 'group', string $editmode = 'standard', $group_id = '', int $cid = 0)
 537         {
 538                 if (!DI::userSession()->getLocalUserId()) {
 539                         return '';
 540                 }
 541
 542                 $display_groups = [
 543                         [
 544                                 'text' => DI::l10n()->t('Everybody'),
 545                                 'id' => 0,
 546                                 'selected' => (($group_id === 'everyone') ? 'group-selected' : ''),
 547                                 'href' => $every,
 548                         ]
 549                 ];
 550
 551                 $member_of = [];
 552                 if ($cid) {
 553                         $member_of = self::getIdsByContactId($cid);
 554                 }
 555
 556                 $stmt = DBA::select('group', [], ['deleted' => false, 'uid' => DI::userSession()->getLocalUserId(), 'cid' => null], ['order' => ['name']]);
 557                 while ($group = DBA::fetch($stmt)) {
 558                         $selected = (($group_id == $group['id']) ? ' group-selected' : '');
 559
 560                         if ($editmode == 'full') {
 561                                 $groupedit = [
 562                                         'href' => 'group/' . $group['id'],
 563                                         'title' => DI::l10n()->t('edit'),
 564                                 ];
 565                         } else {
 566                                 $groupedit = null;
 567                         }
 568
 569                         if ($each == 'group') {
 570                                 $count = DBA::count('group_member', ['gid' => $group['id']]);
 571                                 $group_name = sprintf('%s (%d)', $group['name'], $count);
 572                         } else {
 573                                 $group_name = $group['name'];
 574                         }
 575
 576                         $display_groups[] = [
 577                                 'id'   => $group['id'],
 578                                 'cid'  => $cid,
 579                                 'text' => $group_name,
 580                                 'href' => $each . '/' . $group['id'],
 581                                 'edit' => $groupedit,
 582                                 'selected' => $selected,
 583                                 'ismember' => in_array($group['id'], $member_of),
 584                         ];
 585                 }
 586                 DBA::close($stmt);
 587
 588                 // Don't show the groups on the network page when there is only one
 589                 if ((count($display_groups) <= 2) && ($each == 'network')) {
 590                         return '';
 591                 }
 592
 593                 $tpl = Renderer::getMarkupTemplate('group_side.tpl');
 594                 $o = Renderer::replaceMacros($tpl, [
 595                         '$add' => DI::l10n()->t('add'),
 596                         '$title' => DI::l10n()->t('Groups'),
 597                         '$groups' => $display_groups,
 598                         'newgroup' => $editmode == 'extended' || $editmode == 'full' ? 1 : '',
 599                         'grouppage' => 'group/',
 600                         '$edittext' => DI::l10n()->t('Edit group'),
 601                         '$ungrouped' => $every === 'contact' ? DI::l10n()->t('Contacts not in any group') : '',
 602                         '$ungrouped_selected' => (($group_id === 'none') ? 'group-selected' : ''),
 603                         '$createtext' => DI::l10n()->t('Create a new group'),
 604                         '$creategroup' => DI::l10n()->t('Group Name: '),
 605                         '$editgroupstext' => DI::l10n()->t('Edit groups'),
 606                         '$form_security_token' => BaseModule::getFormSecurityToken('group_edit'),
 607                 ]);
 608
 609                 return $o;
 610         }
 611
 612         /**
 613          * Fetch the group id for the given contact id
 614          *
 615          * @param integer $id Contact ID
 616          * @return integer Group IO
 617          */
 618         public static function getIdForForum(int $id): int
 619         {
 620                 Logger::info('Get id for forum id', ['id' => $id]);
 621                 $contact = Contact::getById($id, ['uid', 'name', 'contact-type', 'manually-approve']);
 622                 if (empty($contact) || ($contact['contact-type'] != Contact::TYPE_COMMUNITY) || !$contact['manually-approve']) {
 623                         return 0;
 624                 }
 625
 626                 $group = DBA::selectFirst('group', ['id'], ['uid' => $contact['uid'], 'cid' => $id]);
 627                 if (empty($group)) {
 628                         $fields = [
 629                                 'uid'  => $contact['uid'],
 630                                 'name' => $contact['name'],
 631                                 'cid'  => $id,
 632                         ];
 633                         DBA::insert('group', $fields);
 634                         $gid = DBA::lastInsertId();
 635                 } else {
 636                         $gid = $group['id'];
 637                 }
 638
 639                 return $gid;
 640         }
 641
 642         /**
 643          * Fetch the followers of a given contact id and store them as group members
 644          *
 645          * @param integer $id Contact ID
 646          * @return void
 647          */
 648         public static function updateMembersForForum(int $id)
 649         {
 650                 Logger::info('Update forum members', ['id' => $id]);
 651
 652                 $contact = Contact::getById($id, ['uid', 'url']);
 653                 if (empty($contact)) {
 654                         return;
 655                 }
 656
 657                 $apcontact = APContact::getByURL($contact['url']);
 658                 if (empty($apcontact['followers'])) {
 659                         return;
 660                 }
 661
 662                 $gid = self::getIdForForum($id);
 663                 if (empty($gid)) {
 664                         return;
 665                 }
 666
 667                 $group_members = DBA::selectToArray('group_member', ['contact-id'], ['gid' => $gid]);
 668                 if (!empty($group_members)) {
 669                         $current = array_unique(array_column($group_members, 'contact-id'));
 670                 } else {
 671                         $current = [];
 672                 }
 673
 674                 foreach (ActivityPub::fetchItems($apcontact['followers'], $contact['uid']) as $follower) {
 675                         $id = Contact::getIdForURL($follower);
 676                         if (!in_array($id, $current)) {
 677                                 DBA::insert('group_member', ['gid' => $gid, 'contact-id' => $id]);
 678                         } else {
 679                                 $key = array_search($id, $current);
 680                                 unset($current[$key]);
 681                         }
 682                 }
 683
 684                 DBA::delete('group_member', ['gid' => $gid, 'contact-id' => $current]);
 685                 Logger::info('Updated forum members', ['id' => $id, 'count' => DBA::count('group_member', ['gid' => $gid])]);
 686         }
 687 }