Separate per-user and per-room flood limits

This commit is contained in:
Tulir Asokan 2019-06-23 14:20:25 +03:00
parent 85a7967888
commit b26f9cf6eb
3 changed files with 28 additions and 10 deletions

View File

@ -30,8 +30,12 @@ default_flags:
- ignorecase
antispam:
max: 2
delay: 60
room:
max: 1
delay: 60
user:
max: 2
delay: 60
rules:
twim_cookies:

View File

@ -29,16 +29,17 @@ from .config import Config, ConfigError
@dataclass
class FloodInfo:
rb: 'ReactBot'
max: int
delay: int
count: int
last_message: int
def bump(self) -> bool:
now = int(time.time())
if self.last_message + self.rb.config["antispam.delay"] < now:
if self.last_message + self.delay < now:
self.count = 0
self.count += 1
if self.count > self.rb.config["antispam.max"]:
if self.count > self.max:
return True
self.last_message = now
return False
@ -66,10 +67,21 @@ class ReactBot(Plugin):
except ConfigError:
self.log.exception("Failed to load config")
def _make_flood_info(self, for_type: str) -> 'FloodInfo':
return FloodInfo(max=self.config[f"antispam.{for_type}.max"],
delay=self.config[f"antispam.{for_type}.delay"],
count=0, last_message=0)
def _get_flood_info(self, flood_map: dict, key: str, for_type: str) -> 'FloodInfo':
try:
return flood_map[key]
except KeyError:
fi = flood_map[key] = self._make_flood_info(for_type)
return fi
def is_flood(self, evt: MessageEvent) -> bool:
uf = self.user_flood.setdefault(evt.sender, FloodInfo(rb=self, count=0, last_message=0))
rf = self.room_flood.setdefault(evt.room_id, FloodInfo(rb=self, count=0, last_message=0))
return uf.bump() or rf.bump()
return (self._get_flood_info(self.user_flood, evt.sender, "user").bump()
or self._get_flood_info(self.room_flood, evt.room_id, "room").bump())
@event.on(EventType.ROOM_MESSAGE)
async def event_handler(self, evt: MessageEvent) -> None:

View File

@ -37,8 +37,10 @@ class Config(BaseProxyConfig):
helper.copy("rules")
helper.copy("templates")
helper.copy("default_flags")
helper.copy("antispam.max")
helper.copy("antispam.delay")
helper.copy("antispam.user.max")
helper.copy("antispam.user.delay")
helper.copy("antispam.room.max")
helper.copy("antispam.room.delay")
def parse_data(self) -> None:
self.default_flags = re.RegexFlag(0)