From 56b54da6fc6e97d5d6dac70f2393dcc98d93991c Mon Sep 17 00:00:00 2001 From: Frederick Muriuki Muriithi Date: Mon, 12 Dec 2022 13:29:45 +0300 Subject: auth: pass cursor object to `user_group` function --- gn3/auth/authorisation/groups.py | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) (limited to 'gn3/auth/authorisation') diff --git a/gn3/auth/authorisation/groups.py b/gn3/auth/authorisation/groups.py index cda11b3..dbc9f7d 100644 --- a/gn3/auth/authorisation/groups.py +++ b/gn3/auth/authorisation/groups.py @@ -108,15 +108,14 @@ def authenticated_user_group(conn) -> Maybe: return Nothing -def user_group(conn: db.DbConnection, user: User) -> Maybe: +def user_group(cursor: db.DbCursor, user: User) -> Maybe: """Returns the given user's group""" - with db.cursor(conn) as cursor: - cursor.execute( - ("SELECT groups.group_id, groups.group_name FROM group_users " - "INNER JOIN groups ON group_users.group_id=groups.group_id " - "WHERE group_users.user_id = ?"), - (str(user.user_id),)) - groups = tuple(Group(UUID(row[0]), row[1]) for row in cursor.fetchall()) + cursor.execute( + ("SELECT groups.group_id, groups.group_name FROM group_users " + "INNER JOIN groups ON group_users.group_id=groups.group_id " + "WHERE group_users.user_id = ?"), + (str(user.user_id),)) + groups = tuple(Group(UUID(row[0]), row[1]) for row in cursor.fetchall()) if len(groups) > 1: raise MembershipError(user, groups) -- cgit v1.2.3