from src.connectors.neo4j import get_session

__all__ = ["get_identities"]


def get_identities(emails: list[str]):
    query = """
        UNWIND $emailList AS email
        OPTIONAL MATCH (i:Identity {email: email})
        RETURN email, COALESCE(i.id, NULL) AS identityId;
        """

    with get_session() as session:
        result = list(session.run(query, emailList=emails))
    return result