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          * @return array
 399          * @throws \Exception
 400          */
 401         public static function expand(int $uid, array $group_ids, bool $check_dead = false): array
 402         {
 403                 if (!is_array($group_ids) || !count($group_ids)) {
 404                         return [];
 405                 }
 406
 407                 $return = [];
 408                 $pubmail = false;
 409                 $networks = Protocol::SUPPORT_PRIVATE;
 410
 411                 $mailacct = DBA::selectFirst('mailacct', ['pubmail'], ['`uid` = ? AND `server` != ""', $uid]);
 412                 if (DBA::isResult($mailacct)) {
 413                         $pubmail = $mailacct['pubmail'];
 414                 }
 415
 416                 if (!$pubmail) {
 417                         $networks = array_diff($networks, [Protocol::MAIL]);
 418                 }
 419
 420                 $key = array_search(self::FOLLOWERS, $group_ids);
 421                 if ($key !== false) {
 422                         $followers = Contact::selectToArray(['id'], [
 423                                 'uid' => $uid,
 424                                 'rel' => [Contact::FOLLOWER, Contact::FRIEND],
 425                                 'network' => $networks,
 426                                 'contact-type' => [Contact::TYPE_UNKNOWN, Contact::TYPE_PERSON],
 427                                 'archive' => false,
 428                                 'pending' => false,
 429                                 'blocked' => false,
 430                         ]);
 431
 432                         foreach ($followers as $follower) {
 433                                 $return[] = $follower['id'];
 434                         }
 435
 436                         unset($group_ids[$key]);
 437                 }
 438
 439                 $key = array_search(self::MUTUALS, $group_ids);
 440                 if ($key !== false) {
 441                         $mutuals = Contact::selectToArray(['id'], [
 442                                 'uid' => $uid,
 443                                 'rel' => [Contact::FRIEND],
 444                                 'network' => $networks,
 445                                 'contact-type' => [Contact::TYPE_UNKNOWN, Contact::TYPE_PERSON],
 446                                 'archive' => false,
 447                                 'pending' => false,
 448                                 'blocked' => false,
 449                         ]);
 450
 451                         foreach ($mutuals as $mutual) {
 452                                 $return[] = $mutual['id'];
 453                         }
 454
 455                         unset($group_ids[$key]);
 456                 }
 457
 458                 $stmt = DBA::select('group_member', ['contact-id'], ['gid' => $group_ids]);
 459                 while ($group_member = DBA::fetch($stmt)) {
 460                         $return[] = $group_member['contact-id'];
 461                 }
 462                 DBA::close($stmt);
 463
 464                 if ($check_dead) {
 465                         $return = Contact::pruneUnavailable($return);
 466                 }
 467
 468                 return $return;
 469         }
 470
 471         /**
 472          * Returns a templated group selection list
 473          *
 474          * @param int    $uid User id
 475          * @param int    $gid   An optional pre-selected group
 476          * @param string $label An optional label of the list
 477          * @return string
 478          * @throws \Exception
 479          */
 480         public static function displayGroupSelection(int $uid, int $gid = 0, string $label = ''): string
 481         {
 482                 $display_groups = [
 483                         [
 484                                 'name' => '',
 485                                 'id' => '0',
 486                                 'selected' => ''
 487                         ]
 488                 ];
 489
 490                 $stmt = DBA::select('group', [], ['deleted' => false, 'uid' => $uid, 'cid' => null], ['order' => ['name']]);
 491                 while ($group = DBA::fetch($stmt)) {
 492                         $display_groups[] = [
 493                                 'name' => $group['name'],
 494                                 'id' => $group['id'],
 495                                 'selected' => $gid == $group['id'] ? 'true' : ''
 496                         ];
 497                 }
 498                 DBA::close($stmt);
 499
 500                 Logger::info('Got groups', $display_groups);
 501
 502                 if ($label == '') {
 503                         $label = DI::l10n()->t('Default privacy group for new contacts');
 504                 }
 505
 506                 $o = Renderer::replaceMacros(Renderer::getMarkupTemplate('group_selection.tpl'), [
 507                         '$label' => $label,
 508                         '$groups' => $display_groups
 509                 ]);
 510                 return $o;
 511         }
 512
 513         /**
 514          * Create group sidebar widget
 515          *
 516          * @param string $every
 517          * @param string $each
 518          * @param string $editmode
 519          *    'standard' => include link 'Edit groups'
 520          *    'extended' => include link 'Create new group'
 521          *    'full' => include link 'Create new group' and provide for each group a link to edit this group
 522          * @param string|int $group_id Distinct group id or 'everyone'
 523          * @param int    $cid Contact id
 524          * @return string Sidebar widget HTML code
 525          * @throws \Exception
 526          */
 527         public static function sidebarWidget(string $every = 'contact', string $each = 'group', string $editmode = 'standard', $group_id = '', int $cid = 0)
 528         {
 529                 if (!DI::userSession()->getLocalUserId()) {
 530                         return '';
 531                 }
 532
 533                 $display_groups = [
 534                         [
 535                                 'text' => DI::l10n()->t('Everybody'),
 536                                 'id' => 0,
 537                                 'selected' => (($group_id === 'everyone') ? 'group-selected' : ''),
 538                                 'href' => $every,
 539                         ]
 540                 ];
 541
 542                 $member_of = [];
 543                 if ($cid) {
 544                         $member_of = self::getIdsByContactId($cid);
 545                 }
 546
 547                 $stmt = DBA::select('group', [], ['deleted' => false, 'uid' => DI::userSession()->getLocalUserId(), 'cid' => null], ['order' => ['name']]);
 548                 while ($group = DBA::fetch($stmt)) {
 549                         $selected = (($group_id == $group['id']) ? ' group-selected' : '');
 550
 551                         if ($editmode == 'full') {
 552                                 $groupedit = [
 553                                         'href' => 'group/' . $group['id'],
 554                                         'title' => DI::l10n()->t('edit'),
 555                                 ];
 556                         } else {
 557                                 $groupedit = null;
 558                         }
 559
 560                         if ($each == 'group') {
 561                                 $count = DBA::count('group_member', ['gid' => $group['id']]);
 562                                 $group_name = sprintf('%s (%d)', $group['name'], $count);
 563                         } else {
 564                                 $group_name = $group['name'];
 565                         }
 566
 567                         $display_groups[] = [
 568                                 'id'   => $group['id'],
 569                                 'cid'  => $cid,
 570                                 'text' => $group_name,
 571                                 'href' => $each . '/' . $group['id'],
 572                                 'edit' => $groupedit,
 573                                 'selected' => $selected,
 574                                 'ismember' => in_array($group['id'], $member_of),
 575                         ];
 576                 }
 577                 DBA::close($stmt);
 578
 579                 // Don't show the groups on the network page when there is only one
 580                 if ((count($display_groups) <= 2) && ($each == 'network')) {
 581                         return '';
 582                 }
 583
 584                 $tpl = Renderer::getMarkupTemplate('group_side.tpl');
 585                 $o = Renderer::replaceMacros($tpl, [
 586                         '$add' => DI::l10n()->t('add'),
 587                         '$title' => DI::l10n()->t('Groups'),
 588                         '$groups' => $display_groups,
 589                         'newgroup' => $editmode == 'extended' || $editmode == 'full' ? 1 : '',
 590                         'grouppage' => 'group/',
 591                         '$edittext' => DI::l10n()->t('Edit group'),
 592                         '$ungrouped' => $every === 'contact' ? DI::l10n()->t('Contacts not in any group') : '',
 593                         '$ungrouped_selected' => (($group_id === 'none') ? 'group-selected' : ''),
 594                         '$createtext' => DI::l10n()->t('Create a new group'),
 595                         '$creategroup' => DI::l10n()->t('Group Name: '),
 596                         '$editgroupstext' => DI::l10n()->t('Edit groups'),
 597                         '$form_security_token' => BaseModule::getFormSecurityToken('group_edit'),
 598                 ]);
 599
 600                 return $o;
 601         }
 602
 603         /**
 604          * Fetch the group id for the given contact id
 605          *
 606          * @param integer $id Contact ID
 607          * @return integer Group IO
 608          */
 609         public static function getIdForForum(int $id): int
 610         {
 611                 Logger::info('Get id for forum id', ['id' => $id]);
 612                 $contact = Contact::getById($id, ['uid', 'name', 'contact-type', 'manually-approve']);
 613                 if (empty($contact) || ($contact['contact-type'] != Contact::TYPE_COMMUNITY) || !$contact['manually-approve']) {
 614                         return 0;
 615                 }
 616
 617                 $group = DBA::selectFirst('group', ['id'], ['uid' => $contact['uid'], 'cid' => $id]);
 618                 if (empty($group)) {
 619                         $fields = [
 620                                 'uid'  => $contact['uid'],
 621                                 'name' => $contact['name'],
 622                                 'cid'  => $id,
 623                         ];
 624                         DBA::insert('group', $fields);
 625                         $gid = DBA::lastInsertId();
 626                 } else {
 627                         $gid = $group['id'];
 628                 }
 629
 630                 return $gid;
 631         }
 632
 633         /**
 634          * Fetch the followers of a given contact id and store them as group members
 635          *
 636          * @param integer $id Contact ID
 637          * @return void
 638          */
 639         public static function updateMembersForForum(int $id)
 640         {
 641                 Logger::info('Update forum members', ['id' => $id]);
 642
 643                 $contact = Contact::getById($id, ['uid', 'url']);
 644                 if (empty($contact)) {
 645                         return;
 646                 }
 647
 648                 $apcontact = APContact::getByURL($contact['url']);
 649                 if (empty($apcontact['followers'])) {
 650                         return;
 651                 }
 652
 653                 $gid = self::getIdForForum($id);
 654                 if (empty($gid)) {
 655                         return;
 656                 }
 657
 658                 $group_members = DBA::selectToArray('group_member', ['contact-id'], ['gid' => $gid]);
 659                 if (!empty($group_members)) {
 660                         $current = array_unique(array_column($group_members, 'contact-id'));
 661                 } else {
 662                         $current = [];
 663                 }
 664
 665                 foreach (ActivityPub::fetchItems($apcontact['followers'], $contact['uid']) as $follower) {
 666                         $id = Contact::getIdForURL($follower);
 667                         if (!in_array($id, $current)) {
 668                                 DBA::insert('group_member', ['gid' => $gid, 'contact-id' => $id]);
 669                         } else {
 670                                 $key = array_search($id, $current);
 671                                 unset($current[$key]);
 672                         }
 673                 }
 674
 675                 DBA::delete('group_member', ['gid' => $gid, 'contact-id' => $current]);
 676                 Logger::info('Updated forum members', ['id' => $id, 'count' => DBA::count('group_member', ['gid' => $gid])]);
 677         }
 678 }