pki_ca/ca_core/group_member.py

34 lines
734 B
Python

from db_logging import log_change
from entity import ensure_entity_active
def add_group_member(cursor, group_id, member_id, role):
ensure_entity_active(cursor, group_id)
ensure_entity_active(cursor, member_id)
cursor.execute(
"""
INSERT INTO group_member (group_id, member_id, role)
VALUES (%s, %s, %s)
""",
(group_id, member_id, role)
)
log_change(
cursor,
f"Added member {member_id} to group {group_id} as {role}"
)
def get_members_of_group(cursor, group_id):
cursor.execute(
"""
SELECT member_id, role
FROM group_member
WHERE group_id = %s
""",
(group_id,)
)
return cursor.fetchall()