code cleanup

Author: yulistremovsky-dot

databunkerpro/api.py

@@ -9,22 +9,6 @@
 
 
 # Type definitions for better type safety and documentation
-class ConnectorOptions(TypedDict, total=False):
-    """Options for connector operations."""
-
-    connectorid: Optional[Union[str, int]]
-    connectorname: Optional[str]
-    connectortype: Optional[str]
-    apikey: Optional[str]
-    username: Optional[str]
-    connectordesc: Optional[str]
-    dbhost: Optional[str]
-    dbport: Optional[int]
-    dbname: Optional[str]
-    tablename: Optional[str]
-    status: Optional[str]
-
-
 class UserOptions(TypedDict, total=False):
     """Options for user operations."""
 
@@ -960,169 +944,6 @@ def unlink_processing_activity_from_legal_basis(
             "ProcessingActivityUnlinkLegalBasis", data, request_metadata
         )
 
-    # Connector Management
-    def list_supported_connectors(
-        self, request_metadata: Optional[Dict[str, Any]] = None
-    ) -> Dict[str, Any]:
-        """List all supported connector types."""
-        return self._make_request(
-            "ConnectorListSupportedConnectors", None, request_metadata
-        )
-
-    def list_connectors(
-        self,
-        offset: int = 0,
-        limit: int = 10,
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """List connectors with pagination."""
-        data = {"offset": offset, "limit": limit}
-        return self._make_request("ConnectorListConnectors", data, request_metadata)
-
-    def create_connector(
-        self,
-        options: ConnectorOptions,
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Creates a new database connector with the specified configuration."""
-        data = {
-            "connectorname": options.get("connectorname"),
-            "connectortype": options.get("connectortype"),
-            "connectordesc": options.get("connectordesc"),
-            "username": options.get("username"),
-            "apikey": options.get("apikey"),
-            "dbhost": options.get("dbhost"),
-            "dbport": options.get("dbport"),
-            "dbname": options.get("dbname"),
-            "tablename": options.get("tablename"),
-            "status": options.get("status"),
-        }
-        return self._make_request("ConnectorCreate", data, request_metadata)
-
-    def update_connector(
-        self,
-        connector_ref: Union[str, int],
-        options: ConnectorOptions,
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Update an existing connector."""
-        data = {**options}
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorUpdate", data, request_metadata)
-
-    def validate_connector_connectivity(
-        self,
-        connector_ref: Union[str, int],
-        options: ConnectorOptions,
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Validate connector connectivity."""
-        data = {
-            "connectortype": options.get("connectortype"),
-            "connectordesc": options.get("connectordesc"),
-            "username": options.get("username"),
-            "apikey": options.get("apikey"),
-            "dbhost": options.get("dbhost"),
-            "dbport": options.get("dbport"),
-            "dbname": options.get("dbname"),
-            "tablename": options.get("tablename"),
-            "status": options.get("status"),
-        }
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-            data["connectorname"] = options.get("connectorname")
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request(
-            "ConnectorValidateConnectivity", data, request_metadata
-        )
-
-    def delete_connector(
-        self,
-        connector_ref: Union[str, int],
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Delete a connector."""
-        data: Dict[str, Any] = {}
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorDelete", data, request_metadata)
-
-    def get_table_metadata(
-        self,
-        connector_ref: Union[str, int],
-        options: ConnectorOptions,
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Get table metadata for a connector."""
-        data = {
-            "connectortype": options.get("connectortype"),
-            "connectordesc": options.get("connectordesc"),
-            "username": options.get("username"),
-            "apikey": options.get("apikey"),
-            "dbhost": options.get("dbhost"),
-            "dbport": options.get("dbport"),
-            "dbname": options.get("dbname"),
-            "tablename": options.get("tablename"),
-            "status": options.get("status"),
-        }
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-            data["connectorname"] = options.get("connectorname")
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorGetTableMetaData", data, request_metadata)
-
-    def connector_get_user_data(
-        self,
-        mode: str,
-        identity: str,
-        connector_ref: Union[str, int],
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Get user data from a connector."""
-        data: Dict[str, Any] = {"mode": mode, "identity": identity}
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorGetUserData", data, request_metadata)
-
-    def connector_get_user_extra_data(
-        self,
-        mode: str,
-        identity: str,
-        connector_ref: Union[str, int],
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Get user extra data from a connector."""
-        data: Dict[str, Any] = {"mode": mode, "identity": identity}
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorGetUserExtraData", data, request_metadata)
-
-    def connector_delete_user(
-        self,
-        mode: str,
-        identity: str,
-        connector_ref: Union[str, int],
-        request_metadata: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """Delete user data from a connector."""
-        data: Dict[str, Any] = {"mode": mode, "identity": identity}
-        if isinstance(connector_ref, int) or str(connector_ref).isdigit():
-            data["connectorid"] = int(connector_ref)
-        else:
-            data["connectorname"] = str(connector_ref)
-        return self._make_request("ConnectorDeleteUser", data, request_metadata)
-
     # Group Management
     def create_group(
         self,