Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-09-07 21:11:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

WIP building out mau reserved users

Browse Source
This commit is contained in:
Neil Johnson 2018-08-06 23:25:25 +01:00
parent fbe255f9a4
commit a74b25faaa
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
synapse/storage/monthly_active_users.py
View File

@ -19,16 +19,30 @@ from synapse.util.caches.descriptors import cached
from ._base import SQLBaseStore
# Number of msec of granularity to store the monthly_active_user timestamp
# This means it is not necessary to update the table on every request
LAST_SEEN_GRANULARITY = 60 * 60 * 1000
class MonthlyActiveUsersStore(SQLBaseStore):
@defer.inlineCallbacks
def __init__(self, dbconn, hs):
super(MonthlyActiveUsersStore, self).__init__(None, hs)
self._clock = hs.get_clock()
self.hs = hs
threepids = self.hs.config.mau_limits_reserved_threepids
self.reserved_user_ids = set()
for tp in threepids:
user_id = yield hs.get_datastore().get_user_id_by_threepid(
tp["medium"], tp["address"]
)
if user_id:
self.reserved_user_ids.add(user_id)
else:
logger.warning(
"mau limit reserved threepid %s not found in db" % tp
)
def reap_monthly_active_users(self):
"""
@ -78,7 +92,7 @@ class MonthlyActiveUsersStore(SQLBaseStore):
@cached(num_args=0)
def get_monthly_active_count(self):
"""Generates current count of monthly active users.abs
"""Generates current count of monthly active users
Returns:
Defered[int]: Number of current monthly active users