Skip to content

Commit

Permalink
Add watched users
Browse files Browse the repository at this point in the history
  • Loading branch information
@RikudouSage
RikudouSage committed Mar 4, 2024
1 parent f4c91a1 commit 38f6070
Show file tree
Hide file tree
Showing 10 changed files with 387 additions and 26 deletions.
129 changes: 129 additions & 0 deletions migrations/Version20240304152809.php
View file
@@ -0,0 +1,129 @@
<?php

declare(strict_types=1);

namespace DoctrineMigrations;

use Doctrine\DBAL\Schema\Schema;
use Doctrine\Migrations\AbstractMigration;

/**
* Auto-generated Migration: Please modify to your needs!
*/
final class Version20240304152809 extends AbstractMigration
{
public function getDescription(): string
{
return '';
}

public function up(Schema $schema): void
{
// this up() migration is auto-generated, please modify it to your needs
$this->addSql('CREATE TABLE watched_user (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) DEFAULT NULL, instance VARCHAR(180) DEFAULT NULL, user_id INTEGER DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('CREATE TEMPORARY TABLE __temp__auto_approval_regexes AS SELECT id, regex, enabled FROM auto_approval_regexes');
$this->addSql('DROP TABLE auto_approval_regexes');
$this->addSql('CREATE TABLE auto_approval_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO auto_approval_regexes (id, regex, enabled) SELECT id, regex, enabled FROM __temp__auto_approval_regexes');
$this->addSql('DROP TABLE __temp__auto_approval_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_emails AS SELECT id, regex, reason, enabled FROM banned_emails');
$this->addSql('DROP TABLE banned_emails');
$this->addSql('CREATE TABLE banned_emails (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex VARCHAR(180) NOT NULL, reason CLOB DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO banned_emails (id, regex, reason, enabled) SELECT id, regex, reason, enabled FROM __temp__banned_emails');
$this->addSql('DROP TABLE __temp__banned_emails');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_images AS SELECT id, image_hash, similarity_percent, remove_all, reason, description, enabled FROM banned_images');
$this->addSql('DROP TABLE banned_images');
$this->addSql('CREATE TABLE banned_images (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, image_hash VARCHAR(180) NOT NULL, similarity_percent DOUBLE PRECISION DEFAULT \'100\' NOT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, reason CLOB DEFAULT NULL, description CLOB DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO banned_images (id, image_hash, similarity_percent, remove_all, reason, description, enabled) SELECT id, image_hash, similarity_percent, remove_all, reason, description, enabled FROM __temp__banned_images');
$this->addSql('DROP TABLE __temp__banned_images');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_usernames AS SELECT id, username, reason, remove_all, enabled FROM banned_usernames');
$this->addSql('DROP TABLE banned_usernames');
$this->addSql('CREATE TABLE banned_usernames (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) NOT NULL, reason VARCHAR(180) DEFAULT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO banned_usernames (id, username, reason, remove_all, enabled) SELECT id, username, reason, remove_all, enabled FROM __temp__banned_usernames');
$this->addSql('DROP TABLE __temp__banned_usernames');
$this->addSql('CREATE TEMPORARY TABLE __temp__ignored_users AS SELECT id, username, instance, user_id, enabled FROM ignored_users');
$this->addSql('DROP TABLE ignored_users');
$this->addSql('CREATE TABLE ignored_users (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) DEFAULT NULL, instance VARCHAR(180) DEFAULT NULL, user_id INTEGER DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO ignored_users (id, username, instance, user_id, enabled) SELECT id, username, instance, user_id, enabled FROM __temp__ignored_users');
$this->addSql('DROP TABLE __temp__ignored_users');
$this->addSql('CREATE UNIQUE INDEX UNIQ_EE4834DCF85E06774230B1DE ON ignored_users (username, instance)');
$this->addSql('CREATE UNIQUE INDEX UNIQ_EE4834DCA76ED395 ON ignored_users (user_id)');
$this->addSql('CREATE TEMPORARY TABLE __temp__instance_ban_regexes AS SELECT id, regex, reason, remove_all, enabled FROM instance_ban_regexes');
$this->addSql('DROP TABLE instance_ban_regexes');
$this->addSql('CREATE TABLE instance_ban_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, reason VARCHAR(255) DEFAULT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO instance_ban_regexes (id, regex, reason, remove_all, enabled) SELECT id, regex, reason, remove_all, enabled FROM __temp__instance_ban_regexes');
$this->addSql('DROP TABLE __temp__instance_ban_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__instance_defederation_rules AS SELECT id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled FROM instance_defederation_rules');
$this->addSql('DROP TABLE instance_defederation_rules');
$this->addSql('CREATE TABLE instance_defederation_rules (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, software VARCHAR(180) DEFAULT NULL, allow_open_registrations BOOLEAN DEFAULT NULL, allow_open_registrations_with_captcha BOOLEAN DEFAULT NULL, allow_open_registrations_with_email_verification BOOLEAN DEFAULT NULL, allow_open_registrations_with_application BOOLEAN DEFAULT NULL, treat_missing_data_as BOOLEAN DEFAULT NULL, minimum_version VARCHAR(180) DEFAULT NULL, reason CLOB DEFAULT NULL, evidence CLOB DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO instance_defederation_rules (id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled) SELECT id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled FROM __temp__instance_defederation_rules');
$this->addSql('DROP TABLE __temp__instance_defederation_rules');
$this->addSql('CREATE TEMPORARY TABLE __temp__report_regexes AS SELECT id, regex, message, enabled FROM report_regexes');
$this->addSql('DROP TABLE report_regexes');
$this->addSql('CREATE TABLE report_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, message CLOB NOT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO report_regexes (id, regex, message, enabled) SELECT id, regex, message, enabled FROM __temp__report_regexes');
$this->addSql('DROP TABLE __temp__report_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__trusted_users AS SELECT id, username, instance, user_id, enabled FROM trusted_users');
$this->addSql('DROP TABLE trusted_users');
$this->addSql('CREATE TABLE trusted_users (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) DEFAULT NULL, instance VARCHAR(180) DEFAULT NULL, user_id INTEGER DEFAULT NULL, enabled BOOLEAN NOT NULL)');
$this->addSql('INSERT INTO trusted_users (id, username, instance, user_id, enabled) SELECT id, username, instance, user_id, enabled FROM __temp__trusted_users');
$this->addSql('DROP TABLE __temp__trusted_users');
$this->addSql('CREATE UNIQUE INDEX UNIQ_4A8733F7F85E06774230B1DE ON trusted_users (username, instance)');
$this->addSql('CREATE UNIQUE INDEX UNIQ_4A8733F7A76ED395 ON trusted_users (user_id)');
}

public function down(Schema $schema): void
{
// this down() migration is auto-generated, please modify it to your needs
$this->addSql('DROP TABLE watched_user');
$this->addSql('CREATE TEMPORARY TABLE __temp__auto_approval_regexes AS SELECT id, regex, enabled FROM auto_approval_regexes');
$this->addSql('DROP TABLE auto_approval_regexes');
$this->addSql('CREATE TABLE auto_approval_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO auto_approval_regexes (id, regex, enabled) SELECT id, regex, enabled FROM __temp__auto_approval_regexes');
$this->addSql('DROP TABLE __temp__auto_approval_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_emails AS SELECT id, regex, reason, enabled FROM banned_emails');
$this->addSql('DROP TABLE banned_emails');
$this->addSql('CREATE TABLE banned_emails (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex VARCHAR(180) NOT NULL, reason CLOB DEFAULT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO banned_emails (id, regex, reason, enabled) SELECT id, regex, reason, enabled FROM __temp__banned_emails');
$this->addSql('DROP TABLE __temp__banned_emails');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_images AS SELECT id, image_hash, similarity_percent, remove_all, reason, description, enabled FROM banned_images');
$this->addSql('DROP TABLE banned_images');
$this->addSql('CREATE TABLE banned_images (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, image_hash VARCHAR(180) NOT NULL, similarity_percent DOUBLE PRECISION DEFAULT \'100\' NOT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, reason CLOB DEFAULT NULL, description CLOB DEFAULT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO banned_images (id, image_hash, similarity_percent, remove_all, reason, description, enabled) SELECT id, image_hash, similarity_percent, remove_all, reason, description, enabled FROM __temp__banned_images');
$this->addSql('DROP TABLE __temp__banned_images');
$this->addSql('CREATE TEMPORARY TABLE __temp__banned_usernames AS SELECT id, username, reason, remove_all, enabled FROM banned_usernames');
$this->addSql('DROP TABLE banned_usernames');
$this->addSql('CREATE TABLE banned_usernames (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) NOT NULL, reason VARCHAR(180) DEFAULT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO banned_usernames (id, username, reason, remove_all, enabled) SELECT id, username, reason, remove_all, enabled FROM __temp__banned_usernames');
$this->addSql('DROP TABLE __temp__banned_usernames');
$this->addSql('CREATE TEMPORARY TABLE __temp__ignored_users AS SELECT id, username, instance, user_id, enabled FROM ignored_users');
$this->addSql('DROP TABLE ignored_users');
$this->addSql('CREATE TABLE ignored_users (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) DEFAULT NULL, instance VARCHAR(180) DEFAULT NULL, user_id INTEGER DEFAULT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO ignored_users (id, username, instance, user_id, enabled) SELECT id, username, instance, user_id, enabled FROM __temp__ignored_users');
$this->addSql('DROP TABLE __temp__ignored_users');
$this->addSql('CREATE UNIQUE INDEX UNIQ_EE4834DCA76ED395 ON ignored_users (user_id)');
$this->addSql('CREATE UNIQUE INDEX UNIQ_EE4834DCF85E06774230B1DE ON ignored_users (username, instance)');
$this->addSql('CREATE TEMPORARY TABLE __temp__instance_ban_regexes AS SELECT id, regex, reason, remove_all, enabled FROM instance_ban_regexes');
$this->addSql('DROP TABLE instance_ban_regexes');
$this->addSql('CREATE TABLE instance_ban_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, reason VARCHAR(255) DEFAULT NULL, remove_all BOOLEAN DEFAULT 0 NOT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO instance_ban_regexes (id, regex, reason, remove_all, enabled) SELECT id, regex, reason, remove_all, enabled FROM __temp__instance_ban_regexes');
$this->addSql('DROP TABLE __temp__instance_ban_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__instance_defederation_rules AS SELECT id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled FROM instance_defederation_rules');
$this->addSql('DROP TABLE instance_defederation_rules');
$this->addSql('CREATE TABLE instance_defederation_rules (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, software VARCHAR(180) DEFAULT NULL, allow_open_registrations BOOLEAN DEFAULT NULL, allow_open_registrations_with_captcha BOOLEAN DEFAULT NULL, allow_open_registrations_with_email_verification BOOLEAN DEFAULT NULL, allow_open_registrations_with_application BOOLEAN DEFAULT NULL, treat_missing_data_as BOOLEAN DEFAULT NULL, minimum_version VARCHAR(180) DEFAULT NULL, reason CLOB DEFAULT NULL, evidence CLOB DEFAULT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO instance_defederation_rules (id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled) SELECT id, software, allow_open_registrations, allow_open_registrations_with_captcha, allow_open_registrations_with_email_verification, allow_open_registrations_with_application, treat_missing_data_as, minimum_version, reason, evidence, enabled FROM __temp__instance_defederation_rules');
$this->addSql('DROP TABLE __temp__instance_defederation_rules');
$this->addSql('CREATE TEMPORARY TABLE __temp__report_regexes AS SELECT id, regex, message, enabled FROM report_regexes');
$this->addSql('DROP TABLE report_regexes');
$this->addSql('CREATE TABLE report_regexes (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, regex CLOB NOT NULL, message CLOB NOT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO report_regexes (id, regex, message, enabled) SELECT id, regex, message, enabled FROM __temp__report_regexes');
$this->addSql('DROP TABLE __temp__report_regexes');
$this->addSql('CREATE TEMPORARY TABLE __temp__trusted_users AS SELECT id, username, instance, user_id, enabled FROM trusted_users');
$this->addSql('DROP TABLE trusted_users');
$this->addSql('CREATE TABLE trusted_users (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(180) DEFAULT NULL, instance VARCHAR(180) DEFAULT NULL, user_id INTEGER DEFAULT NULL, enabled BOOLEAN DEFAULT true NOT NULL)');
$this->addSql('INSERT INTO trusted_users (id, username, instance, user_id, enabled) SELECT id, username, instance, user_id, enabled FROM __temp__trusted_users');
$this->addSql('DROP TABLE __temp__trusted_users');
$this->addSql('CREATE UNIQUE INDEX UNIQ_4A8733F7A76ED395 ON trusted_users (user_id)');
$this->addSql('CREATE UNIQUE INDEX UNIQ_4A8733F7F85E06774230B1DE ON trusted_users (username, instance)');
}
}
112 changes: 112 additions & 0 deletions src/Automod/ModAction/Notification/NotifyAboutWatchedUserAction.php
View file
@@ -0,0 +1,112 @@
<?php

namespace App\Automod\ModAction\Notification;

use App\Automod\ModAction\AbstractModAction;
use App\Context\Context;
use App\Entity\WatchedUser;
use App\Enum\FurtherAction;
use App\Repository\WatchedUserRepository;
use App\Service\InstanceLinkConverter;
use App\Service\Notification\NotificationSender;
use App\Service\UserEntityResolver;
use LogicException;
use Override;
use Rikudou\LemmyApi\Response\Model\Person;
use Rikudou\LemmyApi\Response\View\CommentReportView;
use Rikudou\LemmyApi\Response\View\CommentView;
use Rikudou\LemmyApi\Response\View\PostReportView;
use Rikudou\LemmyApi\Response\View\PostView;
use Rikudou\LemmyApi\Response\View\PrivateMessageReportView;
use Symfony\Component\DependencyInjection\Attribute\Autowire;

/**
* @extends AbstractModAction<PostView|CommentView|CommentReportView|PostReportView|PrivateMessageReportView>
*/
final readonly class NotifyAboutWatchedUserAction extends AbstractModAction
{
public function __construct(
private WatchedUserRepository $watchedUserRepository,
private UserEntityResolver $userEntityResolver,
private NotificationSender $notificationSender,
#[Autowire('%app.lemmy.instance%')]
private string $instance,
private InstanceLinkConverter $linkConverter,
) {
}

#[Override]
public function shouldRun(object $object): bool
{
if (
!$object instanceof PostView
&& !$object instanceof CommentView
&& !$object instanceof CommentReportView
&& !$object instanceof PostReportView
&& !$object instanceof PrivateMessageReportView
) {
return false;
}

$watchedUsers = $this->watchedUserRepository->findBy(['enabled' => true]);
if (!count($watchedUsers)) {
return false;
}
$this->userEntityResolver->resolve(...$watchedUsers);

$person = $this->getPerson($object);
if (!count(array_filter($watchedUsers, fn (WatchedUser $user) => $user->getUserId() === $person->id))) {
return false;
}

return true;
}

#[Override]
public function takeAction(object $object, Context $context = new Context()): FurtherAction
{
$person = $this->getPerson($object);
$username = "{$person->name}@" . parse_url($person->actorId, PHP_URL_HOST);

$message = "New action by a watched user ([{$username}](https://{$this->instance}/u/{$username})): ";
if ($object instanceof PostView) {
$message .= "They've created a new post: " . $this->linkConverter->convertPostLink($object->post);
} else if ($object instanceof CommentView) {
$message .= "They've created a new comment: " . $this->linkConverter->convertCommentLink($object->comment);
} else if ($object instanceof CommentReportView) {
$message .= "Their comment has been reported: " . $this->linkConverter->convertCommentLink($object->comment);
} else if ($object instanceof PostReportView) {
$message .= "Their post has been reported: " . $this->linkConverter->convertPostLink($object->post);
} else if ($object instanceof PrivateMessageReportView) {
$message .= "Their private message has been reported.";
} else {
throw new LogicException('Unsupported object: ' . get_class($object));
}

$this->notificationSender->sendNotificationAsync($message);

return FurtherAction::CanContinue;
}

private function getPerson(PostView|CommentView|CommentReportView|PostReportView|PrivateMessageReportView $object): Person
{
if (
$object instanceof PostView
|| $object instanceof CommentView
) {
return $object->creator;
}

if ($object instanceof CommentReportView) {
return $object->commentCreator;
}
if ($object instanceof PostReportView) {
return $object->postCreator;
}
if ($object instanceof PrivateMessageReportView) {
return $object->privateMessageCreator;
}

throw new LogicException('Unhandled case: ' . get_class($object));
}
}

0 comments on commit 38f6070

Please sign in to comment.