mirror of
https://github.com/zulip/zulip.git
synced 2025-11-03 13:33:24 +00:00
embedded bots: Move StateHandler query logic to separate file.
This commit is contained in:
@@ -7,8 +7,9 @@ import time
|
||||
import re
|
||||
import importlib
|
||||
from zerver.lib.actions import internal_send_message
|
||||
from zerver.models import UserProfile, \
|
||||
get_bot_state, set_bot_state, get_bot_state_size, is_key_in_bot_state, remove_bot_state
|
||||
from zerver.models import UserProfile
|
||||
from zerver.lib.bot_storage import get_bot_state, set_bot_state, \
|
||||
is_key_in_bot_state, get_bot_state_size, remove_bot_state
|
||||
from zerver.lib.integrations import EMBEDDED_BOTS
|
||||
|
||||
from six.moves import configparser
|
||||
|
||||
38
zerver/lib/bot_storage.py
Normal file
38
zerver/lib/bot_storage.py
Normal file
@@ -0,0 +1,38 @@
|
||||
from django.db.models import Sum
|
||||
from django.db.models.query import F
|
||||
from django.db.models.functions import Length
|
||||
from zerver.models import BotUserStateData, UserProfile, Length
|
||||
|
||||
from typing import Text, Optional
|
||||
|
||||
def get_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> Text
|
||||
return BotUserStateData.objects.get(bot_profile=bot_profile, key=key).value
|
||||
|
||||
def set_bot_state(bot_profile, key, value):
|
||||
# type: (UserProfile, Text, Text) -> None
|
||||
obj, created = BotUserStateData.objects.get_or_create(bot_profile=bot_profile, key=key,
|
||||
defaults={'value': value})
|
||||
if not created:
|
||||
obj.value = value
|
||||
obj.save()
|
||||
|
||||
def remove_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> None
|
||||
removed_ctr, removed_entries = BotUserStateData.objects.get(bot_profile=bot_profile, key=key).delete()
|
||||
|
||||
def is_key_in_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> bool
|
||||
return BotUserStateData.objects.filter(bot_profile=bot_profile, key=key).exists()
|
||||
|
||||
def get_bot_state_size(bot_profile, key=None):
|
||||
# type: (UserProfile, Optional[Text]) -> int
|
||||
if key is None:
|
||||
return BotUserStateData.objects.filter(bot_profile=bot_profile) \
|
||||
.annotate(key_size=Length('key'), value_size=Length('value')) \
|
||||
.aggregate(sum=Sum(F('key_size')+F('value_size')))['sum'] or 0
|
||||
else:
|
||||
try:
|
||||
return len(key) + len(BotUserStateData.objects.get(bot_profile=bot_profile, key=key).value)
|
||||
except BotUserStateData.DoesNotExist:
|
||||
return 0
|
||||
@@ -1983,35 +1983,3 @@ class BotUserStateData(models.Model):
|
||||
|
||||
class Meta(object):
|
||||
unique_together = ("bot_profile", "key")
|
||||
|
||||
def get_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> Text
|
||||
return BotUserStateData.objects.get(bot_profile=bot_profile, key=key).value
|
||||
|
||||
def set_bot_state(bot_profile, key, value):
|
||||
# type: (UserProfile, Text, Text) -> None
|
||||
obj, created = BotUserStateData.objects.get_or_create(bot_profile=bot_profile, key=key,
|
||||
defaults={'value': value})
|
||||
if not created:
|
||||
obj.value = value
|
||||
obj.save()
|
||||
|
||||
def remove_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> None
|
||||
removed_ctr, removed_entries = BotUserStateData.objects.get(bot_profile=bot_profile, key=key).delete()
|
||||
|
||||
def is_key_in_bot_state(bot_profile, key):
|
||||
# type: (UserProfile, Text) -> bool
|
||||
return BotUserStateData.objects.filter(bot_profile=bot_profile, key=key).exists()
|
||||
|
||||
def get_bot_state_size(bot_profile, key=None):
|
||||
# type: (UserProfile, Optional[Text]) -> int
|
||||
if key is None:
|
||||
return BotUserStateData.objects.filter(bot_profile=bot_profile) \
|
||||
.annotate(key_size=Length('key'), value_size=Length('value')) \
|
||||
.aggregate(sum=Sum(F('key_size')+F('value_size')))['sum'] or 0
|
||||
else:
|
||||
try:
|
||||
return len(key) + len(BotUserStateData.objects.get(bot_profile=bot_profile, key=key).value)
|
||||
except BotUserStateData.DoesNotExist:
|
||||
return 0
|
||||
|
||||
Reference in New Issue
Block a user