swarm - added dataconnector

pkgs/core/swarmauri_core/ComponentBase.py

@@ -52,6 +52,7 @@ class ResourceTypes(Enum):
     VECTOR_STORE = "VectorStore"
     VECTOR = "Vector"
     VCM = "VCM"
+    DATA_CONNECTOR = "DataConnector"
 
 
 def generate_id() -> str:

pkgs/core/swarmauri_core/dataconnectors/IDataConnector.py

@@ -0,0 +1,70 @@
+from abc import ABC, abstractmethod
+
+
+class IDataConnector(ABC):
+    """
+    Abstract base class for data connectors.
+    Defines the interface for all concrete data connector implementations.
+    """
+
+    @abstractmethod
+    def authenticate(self, **kwargs):
+        """
+        Authenticate with the data source.
+        This method should handle any required authentication process.
+
+        :param kwargs: Authentication parameters such as API keys, tokens, etc.
+        """
+        pass
+
+    @abstractmethod
+    def fetch_data(self, query: str, **kwargs):
+        """
+        Fetch data from the data source based on a query.
+
+        :param query: Query string or parameters to fetch specific data.
+        :param kwargs: Additional parameters for fetching data.
+        :return: Data fetched from the source.
+        """
+        pass
+
+    @abstractmethod
+    def insert_data(self, data, **kwargs):
+        """
+        Insert data into the data source.
+
+        :param data: Data to be inserted.
+        :param kwargs: Additional parameters for inserting data.
+        """
+        pass
+
+    @abstractmethod
+    def update_data(self, identifier, data, **kwargs):
+        """
+        Update existing data in the data source.
+
+        :param identifier: Unique identifier of the data to update.
+        :param data: Updated data.
+        :param kwargs: Additional parameters for updating data.
+        """
+        pass
+
+    @abstractmethod
+    def delete_data(self, identifier, **kwargs):
+        """
+        Delete data from the data source.
+
+        :param identifier: Unique identifier of the data to delete.
+        :param kwargs: Additional parameters for deleting data.
+        """
+        pass
+
+    @abstractmethod
+    def test_connection(self, **kwargs):
+        """
+        Test the connection to the data source.
+
+        :param kwargs: Connection parameters.
+        :return: Boolean indicating whether the connection is successful.
+        """
+        pass

pkgs/swarmauri/swarmauri/dataconnectors/base/DataConnectorBase.py

@@ -0,0 +1,79 @@
+from swarmauri_core.dataconnectors.IDataConnector import IDataConnector
+
+
+class DataConnectorBase(IDataConnector):
+    """
+    Base implementation of IDataConnector that raises NotImplementedError
+    for all abstract methods, ensuring explicit implementation in child classes.
+    """
+
+    def authenticate(self, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param kwargs: Authentication parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Authenticate method must be implemented by child classes."
+        )
+
+    def fetch_data(self, query: str, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param query: Query string or parameters
+        :param kwargs: Additional parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Fetch data method must be implemented by child classes."
+        )
+
+    def insert_data(self, data, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param data: Data to be inserted
+        :param kwargs: Additional parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Insert data method must be implemented by child classes."
+        )
+
+    def update_data(self, identifier, data, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param identifier: Unique identifier of the data to update
+        :param data: Updated data
+        :param kwargs: Additional parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Update data method must be implemented by child classes."
+        )
+
+    def delete_data(self, identifier, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param identifier: Unique identifier of the data to delete
+        :param kwargs: Additional parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Delete data method must be implemented by child classes."
+        )
+
+    def test_connection(self, **kwargs):
+        """
+        Raises NotImplementedError to enforce implementation in child classes.
+
+        :param kwargs: Connection parameters
+        :raises NotImplementedError: Always raised to require specific implementation
+        """
+        raise NotImplementedError(
+            "Test connection method must be implemented by child classes."
+        )