This commit is contained in:
retoor 2025-04-14 22:41:14 +02:00
parent a3abd854bb
commit 9fb6e64655

View File

@ -7,15 +7,15 @@ class UserPropertyService(BaseService):
mapper_name = "user_property"
async def set(self, user_uid, name, value):
prop = await super().get(user_uid=user_uid, name=name)
if not prop:
prop = await self.new()
prop["user_uid"] = user_uid
prop["name"] = name
prop["value"] = json.dumps(value, default=str)
return await self.save(prop)
self.mapper.db["user_property"].upsert(
{
"user_uid": user_uid,
"name": name,
"value": json.dumps(value, default=str)
},
["user_uid", "name"]
)
async def get(self, user_uid, name):
try:
return json.loads((await super().get(user_uid=user_uid, name=name))["value"])