From 311e50eab403b45ffe1738a3e62c411ca91e54d1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bendeg=C3=BAz=20Csirmaz?= Date: Wed, 15 Apr 2026 11:25:20 +0200 Subject: [PATCH] fix(dir-sdk-python): fix formatting issues MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Bendegúz Csirmaz --- .../agntcy/dir_sdk/client/client.py | 178 +++++++++--------- .../agntcy/dir_sdk/client/config.py | 1 - 2 files changed, 89 insertions(+), 90 deletions(-) diff --git a/dir-sdk-python/agntcy/dir_sdk/client/client.py b/dir-sdk-python/agntcy/dir_sdk/client/client.py index ac77d1d..1848ad2 100644 --- a/dir-sdk-python/agntcy/dir_sdk/client/client.py +++ b/dir-sdk-python/agntcy/dir_sdk/client/client.py @@ -458,9 +458,9 @@ def _server_name_from_addr(self, addr: str) -> str: return addr.rsplit(":", 1)[0] def publish( - self, - req: routing_v1.PublishRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.PublishRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> None: """Publish objects to the Routing API matching the specified criteria. @@ -493,9 +493,9 @@ def publish( raise RuntimeError(msg) from e def list( - self, - req: routing_v1.ListRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.ListRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> list[routing_v1.ListResponse]: """List objects from the Routing API matching the specified criteria. @@ -536,9 +536,9 @@ def list( return results def search_cids( - self, - req: search_v1.SearchCIDsRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: search_v1.SearchCIDsRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[search_v1.SearchCIDsResponse]: """Search for record CIDs matching the specified queries. @@ -580,9 +580,9 @@ def search_cids( return results def search_records( - self, - req: search_v1.SearchRecordsRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: search_v1.SearchRecordsRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[search_v1.SearchRecordsResponse]: """Search for full records matching the specified queries. @@ -623,9 +623,9 @@ def search_records( return results def unpublish( - self, - req: routing_v1.UnpublishRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.UnpublishRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> None: """Unpublish objects from the Routing API matching the specified criteria. @@ -658,9 +658,9 @@ def unpublish( raise RuntimeError(msg) from e def push( - self, - records: builtins.list[core_v1.Record], - metadata: Sequence[tuple[str, str]] | None = None, + self, + records: builtins.list[core_v1.Record], + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[core_v1.RecordRef]: """Push records to the Store API. @@ -701,9 +701,9 @@ def push( return results def push_referrer( - self, - req: builtins.list[store_v1.PushReferrerRequest], - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: builtins.list[store_v1.PushReferrerRequest], + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[store_v1.PushReferrerResponse]: """Push records with referrer metadata to the Store API. @@ -744,9 +744,9 @@ def push_referrer( return results def pull( - self, - refs: builtins.list[core_v1.RecordRef], - metadata: Sequence[tuple[str, str]] | None = None, + self, + refs: builtins.list[core_v1.RecordRef], + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[core_v1.Record]: """Pull records from the Store API by their references. @@ -787,9 +787,9 @@ def pull( return results def pull_referrer( - self, - req: builtins.list[store_v1.PullReferrerRequest], - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: builtins.list[store_v1.PullReferrerRequest], + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[store_v1.PullReferrerResponse]: """Pull records with referrer metadata from the Store API. @@ -832,9 +832,9 @@ def pull_referrer( return results def lookup( - self, - refs: builtins.list[core_v1.RecordRef], - metadata: Sequence[tuple[str, str]] | None = None, + self, + refs: builtins.list[core_v1.RecordRef], + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[core_v1.RecordMeta]: """Look up metadata for records in the Store API. @@ -876,9 +876,9 @@ def lookup( return results def delete( - self, - refs: builtins.list[core_v1.RecordRef], - metadata: Sequence[tuple[str, str]] | None = None, + self, + refs: builtins.list[core_v1.RecordRef], + metadata: Sequence[tuple[str, str]] | None = None, ) -> None: """Delete records from the Store API. @@ -909,9 +909,9 @@ def delete( raise RuntimeError(msg) from e def create_sync( - self, - req: store_v1.CreateSyncRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: store_v1.CreateSyncRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> store_v1.CreateSyncResponse: """Create a new synchronization configuration. @@ -951,9 +951,9 @@ def create_sync( return response def list_syncs( - self, - req: store_v1.ListSyncsRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: store_v1.ListSyncsRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[store_v1.ListSyncsItem]: """List existing synchronization configurations. @@ -998,9 +998,9 @@ def list_syncs( return results def get_sync( - self, - req: store_v1.GetSyncRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: store_v1.GetSyncRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> store_v1.GetSyncResponse: """Retrieve detailed information about a specific synchronization configuration. @@ -1040,9 +1040,9 @@ def get_sync( return response def delete_sync( - self, - req: store_v1.DeleteSyncRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: store_v1.DeleteSyncRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> None: """Delete a synchronization configuration. @@ -1075,9 +1075,9 @@ def delete_sync( raise RuntimeError(msg) from e def listen( - self, - req: events_v1.ListenRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: events_v1.ListenRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> grpc.UnaryStreamMultiCallable: """ Listen establishes a streaming connection to receive events. @@ -1113,9 +1113,9 @@ def listen( return stream def create_publication( - self, - req: routing_v1.PublishRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.PublishRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> routing_v1.CreatePublicationResponse: """ Create publication creates a new publication request that will be processed by the PublicationWorker. @@ -1147,9 +1147,9 @@ def create_publication( return response def get_publication( - self, - req: routing_v1.GetPublicationRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.GetPublicationRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> routing_v1.GetPublicationResponse: """ GetPublication retrieves details of a specific publication request by its identifier. @@ -1180,9 +1180,9 @@ def get_publication( return response def list_publication( - self, - req: routing_v1.ListPublicationsRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: routing_v1.ListPublicationsRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> builtins.list[routing_v1.ListPublicationsItem]: """ ListPublications returns a stream of all publication requests in the system. @@ -1217,10 +1217,10 @@ def list_publication( return results def resolve( - self, - name: str, - version: str | None = None, - metadata: Sequence[tuple[str, str]] | None = None, + self, + name: str, + version: str | None = None, + metadata: Sequence[tuple[str, str]] | None = None, ) -> naming_v1.ResolveResponse: """Resolve a record name to CIDs. @@ -1264,11 +1264,11 @@ def resolve( return response def get_verification_info( - self, - cid: str | None = None, - name: str | None = None, - version: str | None = None, - metadata: Sequence[tuple[str, str]] | None = None, + self, + cid: str | None = None, + name: str | None = None, + version: str | None = None, + metadata: Sequence[tuple[str, str]] | None = None, ) -> naming_v1.GetVerificationInfoResponse: """Get verification info for a record. @@ -1319,9 +1319,9 @@ def get_verification_info( return response def verify( - self, - req: sign_v1.VerifyRequest, - metadata: Sequence[tuple[str, str]] | None = None, + self, + req: sign_v1.VerifyRequest, + metadata: Sequence[tuple[str, str]] | None = None, ) -> sign_v1.VerifyResponse: """Verify a cryptographic signature on a record. @@ -1411,10 +1411,10 @@ def verify( pass def _verify_with_key( - self, - record_ref: core_v1.RecordRef, - key_verifier: sign_v1.VerifyWithKey, - output_path: str, + self, + record_ref: core_v1.RecordRef, + key_verifier: sign_v1.VerifyWithKey, + output_path: str, ) -> None: """Verify a record using a public key. @@ -1462,10 +1462,10 @@ def _verify_with_key( raise RuntimeError(msg) from e def _verify_with_any( - self, - record_ref: core_v1.RecordRef, - any_verifier: sign_v1.VerifyWithAny | None, - output_path: str, + self, + record_ref: core_v1.RecordRef, + any_verifier: sign_v1.VerifyWithAny | None, + output_path: str, ) -> None: """Verify a record using any valid signature. @@ -1519,10 +1519,10 @@ def _verify_with_any( raise RuntimeError(msg) from e def _verify_with_oidc( - self, - record_ref: core_v1.RecordRef, - oidc_verifier: sign_v1.VerifyWithOIDC | None, - output_path: str, + self, + record_ref: core_v1.RecordRef, + oidc_verifier: sign_v1.VerifyWithOIDC | None, + output_path: str, ) -> None: """Verify a record using OIDC-based verification. @@ -1608,8 +1608,8 @@ def _parse_verify_response(self, output: bytes) -> sign_v1.VerifyResponse: raise RuntimeError(msg) from e def sign( - self, - req: sign_v1.SignRequest, + self, + req: sign_v1.SignRequest, ) -> None: """Sign a record with a cryptographic signature. @@ -1653,9 +1653,9 @@ def sign( raise RuntimeError(msg) from e def _sign_with_key( - self, - record_ref: core_v1.RecordRef, - key_signer: sign_v1.SignWithKey, + self, + record_ref: core_v1.RecordRef, + key_signer: sign_v1.SignWithKey, ) -> None: """Sign a record using a private key. @@ -1709,9 +1709,9 @@ def _sign_with_key( raise RuntimeError(msg) from e def _sign_with_oidc( - self, - record_ref: core_v1.RecordRef, - oidc_signer: sign_v1.SignWithOIDC, + self, + record_ref: core_v1.RecordRef, + oidc_signer: sign_v1.SignWithOIDC, ) -> None: """Sign a record using OIDC-based authentication. diff --git a/dir-sdk-python/agntcy/dir_sdk/client/config.py b/dir-sdk-python/agntcy/dir_sdk/client/config.py index b546c81..c6ef09e 100644 --- a/dir-sdk-python/agntcy/dir_sdk/client/config.py +++ b/dir-sdk-python/agntcy/dir_sdk/client/config.py @@ -129,7 +129,6 @@ def __init__( self.server_address = server_address self.dirctl_path = dirctl_path self.spiffe_socket_path = spiffe_socket_path - self.auth_mode = auth_mode # '', insecure, x509, jwt, tls, oidc resolved_auth_token = auth_token or oidc_access_token or "" self.auth_token = resolved_auth_token # Backward-compatible alias for older callers.