Convert to asyncio

.code-workspace

@@ -8,6 +8,10 @@
             "name": "Bulletin Board Gem",
             "path": "bulletin_board/ruby-client"
         },
+        {
+            "name": "Bulletin Board JS Client",
+            "path": "bulletin_board/js-client"
+        },
         {
             "name": "Documentation",
             "path": "docs"
@@ -20,13 +24,30 @@
             "name": "Dummy JS Adapter",
             "path": "voting_schemes/dummy/js-adapter"
         },
+        {
+            "name": "ElectionGuard Wrapper",
+            "path": "voting_schemes/electionguard/python-wrapper"
+        },
         {
             "name": "ElectionGuard JS Adapter",
             "path": "voting_schemes/electionguard/js-adapter"
         },
         {
-            "name": "ElectionGuard Wrapper",
-            "path": "voting_schemes/electionguard/python-wrapper"
+            "name": "ElectionGuard Ruby Adapter",
+            "path": "voting_schemes/electionguard/ruby-adapter"
+        },
+        {
+            "name": "ElectionGuard Python2JS",
+            "path": "voting_schemes/electionguard/python-to-js"
+        },
+        {
+            "name": "ElectionGuard Pyodide Base Packages",
+            "path": "voting_schemes/electionguard/pyodide-base-packages"
+        },
+        {
+            "name": "ElectionGuard Pyodide Verifier",
+            "path": "voting_schemes/electionguard/verifier"
         }
-    ]
+    ],
+    "settings": {}
 }

voting_schemes/electionguard/python-wrapper/Pipfile

@@ -6,6 +6,7 @@ verify_ssl = true
 [dev-packages]
 flake8 = ">=3.8.3"
 pytest = "*"
+pytest-asyncio = "*"
 black = "*"
 
 [packages]

voting_schemes/electionguard/python-wrapper/src/bulletin_board/electionguard/bulletin_board.py

@@ -15,7 +15,7 @@
 from electionguard.types import GUARDIAN_ID
 from electionguard.utils import get_optional
 
-from .common import Content, Context, ElectionStep, Wrapper
+from .common import Content, Context, ElectionStep, Wrapper, async_wrap
 from .dummy_scheduler import DummyScheduler
 from .messages import (
     Compensation,
@@ -292,6 +292,7 @@ def __init__(self, recorder=None) -> None:
             BulletinBoardContext(), ProcessCreateElection(), recorder=recorder
         )
 
+    @async_wrap
     def add_ballots(self, ballots: List[str]):
         submitted_ballots: List[Tuple[None, SubmittedBallot]] = []
         for ballot in ballots:
@@ -302,6 +303,7 @@ def add_ballots(self, ballots: List[str]):
 
         self.context.tally.batch_append(submitted_ballots, DummyScheduler())  # type: ignore
 
+    @async_wrap
     def add_ballot(self, ballot: str):
         ciphertext_ballot = deserialize(ballot, CiphertextBallot)
         submitted_ballot = from_ciphertext_ballot(
@@ -312,6 +314,7 @@ def add_ballot(self, ballot: str):
             DummyScheduler(),  # type: ignore
         )
 
+    @async_wrap
     def get_tally_cast(self) -> Dict:
         return {
             "message_type": "tally.cast",

voting_schemes/electionguard/python-wrapper/src/bulletin_board/electionguard/common.py

@@ -1,5 +1,7 @@
 from __future__ import annotations
 
+import asyncio
+from functools import partial, wraps
 import json
 import logging as log
 from pathlib import Path
@@ -9,8 +11,8 @@
 from electionguard.election_builder import ElectionBuilder
 from electionguard.manifest import InternalManifest, Manifest
 
-from .utils import InvalidElectionDescription
 from .election import parse_description
+from .utils import InvalidElectionDescription
 
 try:
     import cPickle as pickle  # type: ignore
@@ -27,6 +29,17 @@ def unwrap(x: Optional[X], message="You messed up") -> X:
     return x
 
 
+
+def async_wrap(func):
+    @wraps(func)
+    async def run(*args, loop=None, executor=None, **kwargs):
+        if loop is None:
+            loop = asyncio.get_event_loop()
+        pfunc = partial(func, *args, **kwargs)
+        return await loop.run_in_executor(executor, pfunc)
+    return run 
+
+
 class Context:
     election: Manifest
     election_builder: ElectionBuilder
@@ -123,6 +136,7 @@ def __init__(
     def skip_message(self, message_type: str) -> bool:
         return self.step.skip_message(message_type)
 
+    @async_wrap
     def process_message(
         self, message_type: str, message: Optional[Message] | dict
     ) -> List[Message]:
@@ -156,9 +170,12 @@ def is_key_ceremony_done(self) -> bool:
     def is_tally_done(self) -> bool:
         raise NotImplementedError
 
+
+    @async_wrap
     def backup(self) -> bytes:
         return pickle.dumps(self)
 
     @classmethod
+    @async_wrap
     def restore(cls: Type[T], backup: bytes) -> T:
         return pickle.loads(backup)

voting_schemes/electionguard/python-wrapper/src/bulletin_board/electionguard/trustee.py

@@ -24,7 +24,7 @@
 from electionguard.types import CONTEST_ID, GUARDIAN_ID, SELECTION_ID
 from electionguard.utils import get_optional
 
-from .common import Content, Context, ElectionStep, Wrapper, unwrap
+from .common import Content, Context, ElectionStep, Wrapper, async_wrap, unwrap
 from .messages import (
     Compensation,
     KeyCeremonyResults,
@@ -416,12 +416,14 @@ def __init__(self, guardian_id: GUARDIAN_ID, recorder=None) -> None:
             TrusteeContext(guardian_id), self.starting_step(), recorder=recorder
         )
 
+    @async_wrap
     def is_key_ceremony_done(self) -> bool:
         return self.step.__class__ in [
             ProcessTallyCast,
             ProcessEndTally,
             ProcessPublishResults,
         ]
 
+    @async_wrap
     def is_tally_done(self) -> bool:
         return self.step.__class__ in [ProcessPublishResults]

voting_schemes/electionguard/python-wrapper/src/bulletin_board/electionguard/voter.py

@@ -10,7 +10,7 @@
 from electionguard.key_ceremony import ElectionJointKey
 from electionguard.utils import get_optional
 
-from .common import Content, Context, ElectionStep, Wrapper, unwrap
+from .common import Content, Context, ElectionStep, Wrapper, async_wrap, unwrap
 from .messages import KeyCeremonyResults
 from .utils import MissingJointKey, deserialize, remove_nonces, serialize
 
@@ -66,6 +66,7 @@ def __init__(self, ballot_id: str, recorder=None) -> None:
         super().__init__(VoterContext(), ProcessCreateElection(), recorder=recorder)
         self.ballot_id = ballot_id
 
+    @async_wrap
     def encrypt(
         self, ballot: dict, ballot_style: Optional[str] = None, master_nonce: int = None
     ) -> Tuple[str, str]: