from pymongo.database import Database

from electionguard_gui.models.key_ceremony_dto import KeyCeremonyDto
from electionguard_gui.services.key_ceremony_service import get_guardian_number
from electionguard_gui.services.key_ceremony_stages.key_ceremony_stage_base import (
    KeyCeremonyStageBase,
)
from electionguard_gui.services.guardian_service import make_guardian


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    """Responsible for stage 1 of the key ceremony where guardians join"""

    def run(self, db: Database, key_ceremony: KeyCeremonyDto) -> None:
        key_ceremony_id = key_ceremony.id
        user_id = self._auth_service.get_required_user_id()
        self._key_ceremony_service.append_guardian_joined(db, key_ceremony_id, user_id)
        # refresh key ceremony to get the list of guardians with the authoritative order they joined in
        key_ceremony = self._key_ceremony_service.get(db, key_ceremony_id)
        guardian_number = get_guardian_number(key_ceremony, user_id)
        self.log.debug(
            f"user {user_id} about to join key ceremony {key_ceremony_id} as guardian #{guardian_number}"
        )
        guardian = make_guardian(user_id, guardian_number, key_ceremony)
        self._guardian_service.save_guardian(guardian, key_ceremony)
        public_key = guardian.share_key()
        self._key_ceremony_service.append_key(db, key_ceremony_id, public_key)
        self.log.debug(
            f"{user_id} joined key ceremony {key_ceremony_id} as guardian #{guardian_number}"
        )
        self._key_ceremony_service.notify_changed(db, key_ceremony_id)

dc794e29f466a68d2b2e4904acd9c653c1b9247e
<mask token>


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    <mask token>
    <mask token>

<mask token>


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    <mask token>

    def run(self, db: Database, key_ceremony: KeyCeremonyDto) ->None:
        key_ceremony_id = key_ceremony.id
        user_id = self._auth_service.get_required_user_id()
        self._key_ceremony_service.append_guardian_joined(db,
            key_ceremony_id, user_id)
        key_ceremony = self._key_ceremony_service.get(db, key_ceremony_id)
        guardian_number = get_guardian_number(key_ceremony, user_id)
        self.log.debug(
            f'user {user_id} about to join key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        guardian = make_guardian(user_id, guardian_number, key_ceremony)
        self._guardian_service.save_guardian(guardian, key_ceremony)
        public_key = guardian.share_key()
        self._key_ceremony_service.append_key(db, key_ceremony_id, public_key)
        self.log.debug(
            f'{user_id} joined key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        self._key_ceremony_service.notify_changed(db, key_ceremony_id)

<mask token>


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    """Responsible for stage 1 of the key ceremony where guardians join"""

    def run(self, db: Database, key_ceremony: KeyCeremonyDto) ->None:
        key_ceremony_id = key_ceremony.id
        user_id = self._auth_service.get_required_user_id()
        self._key_ceremony_service.append_guardian_joined(db,
            key_ceremony_id, user_id)
        key_ceremony = self._key_ceremony_service.get(db, key_ceremony_id)
        guardian_number = get_guardian_number(key_ceremony, user_id)
        self.log.debug(
            f'user {user_id} about to join key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        guardian = make_guardian(user_id, guardian_number, key_ceremony)
        self._guardian_service.save_guardian(guardian, key_ceremony)
        public_key = guardian.share_key()
        self._key_ceremony_service.append_key(db, key_ceremony_id, public_key)
        self.log.debug(
            f'{user_id} joined key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        self._key_ceremony_service.notify_changed(db, key_ceremony_id)

from pymongo.database import Database
from electionguard_gui.models.key_ceremony_dto import KeyCeremonyDto
from electionguard_gui.services.key_ceremony_service import get_guardian_number
from electionguard_gui.services.key_ceremony_stages.key_ceremony_stage_base import KeyCeremonyStageBase
from electionguard_gui.services.guardian_service import make_guardian


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    """Responsible for stage 1 of the key ceremony where guardians join"""

    def run(self, db: Database, key_ceremony: KeyCeremonyDto) ->None:
        key_ceremony_id = key_ceremony.id
        user_id = self._auth_service.get_required_user_id()
        self._key_ceremony_service.append_guardian_joined(db,
            key_ceremony_id, user_id)
        key_ceremony = self._key_ceremony_service.get(db, key_ceremony_id)
        guardian_number = get_guardian_number(key_ceremony, user_id)
        self.log.debug(
            f'user {user_id} about to join key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        guardian = make_guardian(user_id, guardian_number, key_ceremony)
        self._guardian_service.save_guardian(guardian, key_ceremony)
        public_key = guardian.share_key()
        self._key_ceremony_service.append_key(db, key_ceremony_id, public_key)
        self.log.debug(
            f'{user_id} joined key ceremony {key_ceremony_id} as guardian #{guardian_number}'
            )
        self._key_ceremony_service.notify_changed(db, key_ceremony_id)

from pymongo.database import Database

from electionguard_gui.models.key_ceremony_dto import KeyCeremonyDto
from electionguard_gui.services.key_ceremony_service import get_guardian_number
from electionguard_gui.services.key_ceremony_stages.key_ceremony_stage_base import (
    KeyCeremonyStageBase,
)
from electionguard_gui.services.guardian_service import make_guardian


class KeyCeremonyS1JoinService(KeyCeremonyStageBase):
    """Responsible for stage 1 of the key ceremony where guardians join"""

    def run(self, db: Database, key_ceremony: KeyCeremonyDto) -> None:
        key_ceremony_id = key_ceremony.id
        user_id = self._auth_service.get_required_user_id()
        self._key_ceremony_service.append_guardian_joined(db, key_ceremony_id, user_id)
        # refresh key ceremony to get the list of guardians with the authoritative order they joined in
        key_ceremony = self._key_ceremony_service.get(db, key_ceremony_id)
        guardian_number = get_guardian_number(key_ceremony, user_id)
        self.log.debug(
            f"user {user_id} about to join key ceremony {key_ceremony_id} as guardian #{guardian_number}"
        )
        guardian = make_guardian(user_id, guardian_number, key_ceremony)
        self._guardian_service.save_guardian(guardian, key_ceremony)
        public_key = guardian.share_key()
        self._key_ceremony_service.append_key(db, key_ceremony_id, public_key)
        self.log.debug(
            f"{user_id} joined key ceremony {key_ceremony_id} as guardian #{guardian_number}"
        )
        self._key_ceremony_service.notify_changed(db, key_ceremony_id)
