Merge pull request #3900 from didx-xyz/update-ruff-lint-rules

🔧 🎨 Revise lint rules

Author: swcurran

.github/workflows/format.yml

@@ -22,10 +22,10 @@ jobs:
       - name: Ruff Format Check
         uses: chartboost/ruff-action@e18ae971ccee1b2d7bbef113930f00c670b78da4 # v1.0.0
         with:
-          version: 0.12.10
+          version: 0.13.3
           args: "format --check"
       - name: Ruff Lint Check
         uses: chartboost/ruff-action@e18ae971ccee1b2d7bbef113930f00c670b78da4 # v1.0.0
         with:
-          version: 0.12.10
+          version: 0.13.3
           args: "check"

.pre-commit-config.yaml

@@ -8,7 +8,7 @@ repos:
         additional_dependencies: ['@commitlint/config-conventional']
   - repo: https://github.com/astral-sh/ruff-pre-commit
     # Ensure this is synced with pyproject.toml
-    rev: v0.12.10
+    rev: v0.13.3
     hooks:
       # Run the linter
       - id: ruff

acapy_agent/__main__.py

@@ -9,7 +9,6 @@
 
 def init_debug(args):
     """Initialize debugging environment."""
-
     ENABLE_PTVSD = os.getenv("ENABLE_PTVSD", "").lower()
     ENABLE_PTVSD = ENABLE_PTVSD and ENABLE_PTVSD not in ("false", "0")
 

acapy_agent/admin/server.py

@@ -105,6 +105,7 @@ async def send_outbound(
         Args:
             message: The `OutboundMessage` to be sent
             **kwargs: Additional keyword arguments
+
         """
         profile = self._profile()
         if not profile:
@@ -117,6 +118,7 @@ async def send_webhook(self, topic: str, payload: dict):
         Args:
             topic: the webhook topic identifier
             payload: the webhook payload value
+
         """
         warnings.warn(
             "responder.send_webhook is deprecated; please use the event bus instead.",
@@ -136,7 +138,6 @@ def send_fn(self) -> Coroutine:
 @web.middleware
 async def ready_middleware(request: web.BaseRequest, handler: Coroutine):
     """Only continue if application is ready to take work."""
-
     is_status_check = str(request.rel_url).rstrip("/") in status_paths
     is_app_ready = request.app._state.get("ready")
 
@@ -241,7 +242,6 @@ async def upgrade_middleware(request: web.BaseRequest, handler: Coroutine):
 @web.middleware
 async def debug_middleware(request: web.BaseRequest, handler: Coroutine):
     """Show request detail in debug log."""
-
     if LOGGER.isEnabledFor(logging.DEBUG):  # Skipped if DEBUG is not enabled
         LOGGER.debug("Incoming request: %s %s", request.method, request.path_qs)
         is_status_check = str(request.rel_url).startswith("/status/")
@@ -282,6 +282,7 @@ def __init__(
             conductor_stop (Coroutine): Conductor (graceful) stop for shutdown API call.
             task_queue (TaskQueue, optional): An optional task queue for handlers.
             conductor_stats (Coroutine, optional): Conductor statistics API call.
+
         """
         self.app = None
         self.admin_api_key = context.settings.get("admin.admin_api_key")
@@ -302,7 +303,6 @@ def __init__(
 
     async def make_application(self) -> web.Application:
         """Get the aiohttp application instance."""
-
         middlewares = [ready_middleware, debug_middleware]
 
         # admin-token and admin-token are mutually exclusive and required.
@@ -566,7 +566,6 @@ def notify_fatal_error(self):
 
     async def websocket_handler(self, request):
         """Send notifications to admin client over websocket."""
-
         ws = web.WebSocketResponse()
         await ws.prepare(request)
         socket_id = str(uuid4())

acapy_agent/anoncreds/base.py

@@ -59,6 +59,7 @@ def __init__(
             obj (T, optional): The generic object associated with the instance.
             *args: Variable length argument list.
             **kwargs: Arbitrary keyword arguments.
+
         """
         super().__init__(message, obj_id, obj, *args, **kwargs)
         self._message = message

acapy_agent/anoncreds/default/legacy_indy/recover.py

@@ -52,7 +52,6 @@ async def fetch_txns(
     set[int],
 ]:
     """Fetch tails file and revocation registry information."""
-
     LOGGER.debug(f"Fetch revocation registry def {registry_id} from ledger")
     revoc_reg_delta_request = indy_vdr.ledger.build_get_revoc_reg_def_request(
         None, registry_id
@@ -92,7 +91,6 @@ async def fetch_txns(
 
 async def generate_ledger_rrrecovery_txn(genesis_txns: str, rev_list: RevList) -> dict:
     """Generate a new ledger accum entry, using the wallet value if revocations ahead of ledger."""  # noqa: E501
-
     registry_from_ledger, prev_revoked = await fetch_txns(
         genesis_txns, rev_list.rev_reg_def_id, rev_list.issuer_id
     )

acapy_agent/anoncreds/default/legacy_indy/registry.py

@@ -175,7 +175,6 @@ def make_rev_reg_def_id(rev_reg_def: RevRegDef) -> str:
 
     async def get_schema(self, profile: Profile, schema_id: str) -> GetSchemaResult:
         """Get a schema from the registry."""
-
         multitenant_mgr = profile.inject_or(BaseMultitenantManager)
         if multitenant_mgr:
             ledger_exec_inst = IndyLedgerRequestsExecutor(profile)
@@ -333,7 +332,6 @@ async def get_credential_definition(
         self, profile: Profile, cred_def_id: str
     ) -> GetCredDefResult:
         """Get a credential definition from the registry."""
-
         async with profile.session() as session:
             multitenant_mgr = session.inject_or(BaseMultitenantManager)
             if multitenant_mgr:
@@ -1211,7 +1209,6 @@ async def txn_submit(
         write_ledger: bool = True,
     ) -> str:
         """Submit a transaction to the ledger."""
-
         try:
             async with ledger:
                 return await shield(

acapy_agent/anoncreds/events.py

@@ -37,6 +37,7 @@ def __init__(
 
         Args:
             payload: CredDefFinishedPayload
+
         """
         self._topic = CRED_DEF_FINISHED_EVENT
         self._payload = payload
@@ -84,6 +85,7 @@ def __init__(self, payload: RevRegDefFinishedPayload):
 
         Args:
             payload: RevRegDefFinishedPayload
+
         """
         self._topic = REV_REG_DEF_FINISHED_EVENT
         self._payload = payload
@@ -121,6 +123,7 @@ def __init__(self, payload: RevListFinishedPayload):
 
         Args:
             payload: RevListFinishedPayload
+
         """
         self._topic = REV_LIST_FINISHED_EVENT
         self._payload = payload

acapy_agent/anoncreds/holder.py

@@ -87,7 +87,6 @@ def profile(self) -> AskarAnonCredsProfile:
 
     async def get_master_secret(self) -> str:
         """Get or create the default master secret."""
-
         while True:
             async with self.profile.session() as session:
                 try:
@@ -381,7 +380,6 @@ async def get_credentials(self, *, offset: int, limit: int, wql: dict) -> list[d
             wql: wql query dict
 
         """
-
         result = []
 
         try:
@@ -526,6 +524,7 @@ async def credential_revoked(
 
         Returns:
             bool: True if the credential is revoked, False otherwise.
+
         """
         cred = await self._get_credential(credential_id)
         rev_reg_id = cred.rev_reg_id
@@ -604,7 +603,6 @@ async def create_presentation(
             rev_states: AnonCreds format revocation states JSON
 
         """
-
         creds: Dict[str, Credential] = {}
 
         def get_rev_state(cred_id: str, detail: dict):
@@ -750,7 +748,6 @@ async def create_revocation_state(
             the revocation state
 
         """
-
         try:
             rev_state = await asyncio.get_event_loop().run_in_executor(
                 None,

acapy_agent/anoncreds/issuer.py

@@ -272,6 +272,7 @@ async def credential_definition_in_wallet(
 
         Args:
             credential_definition_id: The credential definition ID to check
+
         """
         try:
             async with self.profile.session() as session: