From 915965edbb100308d77d2e3a03620da0f62214c9 Mon Sep 17 00:00:00 2001 From: Nithin Date: Tue, 5 Mar 2024 13:51:27 +0530 Subject: [PATCH] feat (core) : adding MinIOAppUserAdapter --- .../storage/minio_app_user_adapter.py | 44 +++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 src/infra/adapters/storage/minio_app_user_adapter.py diff --git a/src/infra/adapters/storage/minio_app_user_adapter.py b/src/infra/adapters/storage/minio_app_user_adapter.py new file mode 100644 index 0000000..bba85b8 --- /dev/null +++ b/src/infra/adapters/storage/minio_app_user_adapter.py @@ -0,0 +1,44 @@ +from logging import Logger + +from infra.adapters.storage.base_storage_adapter import BaseStorageAdapter +from minio.api import Minio + + +class MinIOAppUserAdapter(BaseStorageAdapter): + def __init__( + self, + logger: Logger, + host: str, + access_key: str, + secret_key: str, + secure: bool, + ) -> None: + super().__init__(logger) + self._client = Minio( + endpoint=host, access_key=access_key, secret_key=secret_key, secure=secure + ) + + @property + def client(self) -> Minio: + return self._client + + # def bucket_exists(self, bucket_name: str) -> bool: + # return self.client.bucket_exists(bucket_name=bucket_name) + + # def create_bucket(self, bucket_name: str) -> None: + # return self.client.make_bucket(bucket_name=bucket_name) + + # def get_bucket_lifecycle(self, bucket_name: str) -> Optional[LifecycleConfig]: + # return self.client.get_bucket_lifecycle(bucket_name=bucket_name) + + # def get_bucket_policy(self, bucket_name: str) -> str: + # return self.client.get_bucket_policy(bucket_name=bucket_name) + + # def list_buckets(self) -> List[Bucket]: + # return self.client.list_buckets() + + # def delete_bucket(self, bucket_name: str) -> None: + # return self.client.remove_bucket(bucket_name=bucket_name) + + # def create_object(self, bucket_name: str, object_name: str, data: str): + # return self.client.put_object()