aboutsummaryrefslogtreecommitdiffstats
path: root/packages/meshbay-node/src/meshbay_node/roster.py
diff options
context:
space:
mode:
Diffstat (limited to 'packages/meshbay-node/src/meshbay_node/roster.py')
-rw-r--r--packages/meshbay-node/src/meshbay_node/roster.py15
1 files changed, 15 insertions, 0 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/roster.py b/packages/meshbay-node/src/meshbay_node/roster.py
index 9478a32..9533f25 100644
--- a/packages/meshbay-node/src/meshbay_node/roster.py
+++ b/packages/meshbay-node/src/meshbay_node/roster.py
@@ -1081,6 +1081,21 @@ class Roster:
await self._db.commit()
return code
+ async def drop_invites(self, group_id: str, user_id: str) -> int:
+ """
+ Cancel any code this person has not redeemed yet for this group.
+
+ A code already used is left alone: `used_at` is the record that the join
+ happened, and it is the only thing that makes a second attempt fail.
+ """
+ assert self._db
+ cur = await self._db.execute(
+ "DELETE FROM invites WHERE group_id = ? AND user_id = ? AND used_at IS NULL",
+ (group_id, user_id),
+ )
+ await self._db.commit()
+ return cur.rowcount
+
async def consume_invite(self, code: str, user_id: str) -> dict | None:
"""
Redeem a code for `user_id`, or return None.