fix(general): improvements

Author: dineshpinto

src/flare_ai_kit/ecosystem/protocols/ftsov2.py

@@ -38,7 +38,7 @@ async def create(cls, settings: EcosystemSettings) -> Self:
 
         """
         instance = cls(settings)
-        logger.debug("Initializing FtsoV2...")
+        logger.info("Initializing FtsoV2...")
         # Await the async method from the base class
         ftsov2_address = await instance.get_protocol_contract_address("FtsoV2")
         instance.ftsov2 = instance.w3.eth.contract(
@@ -193,6 +193,7 @@ async def get_latest_prices(
         logger.debug(
             "get_latest_prices",
             feed_names=feed_names,
+            feed_ids=feed_ids,
             value=values,
             decimals=decimals,
             timestamp=timestamp,

src/flare_ai_kit/ingestion/__init__.py

@@ -1,5 +1,6 @@
 """Module providing tools for data ingestion pipelines."""
 
 from .github_ingestor import GithubIngestor
+from .pdf_processor import PDFProcessor
 
-__all__ = ["GithubIngestor"]
+__all__ = ["GithubIngestor", "PDFProcessor"]

src/flare_ai_kit/main.py

@@ -1,5 +1,9 @@
 """Entry point for Flare AI Kit SDK."""
 
+import asyncio
+
+import structlog
+
 from .a2a import A2AClient
 from .config import AppSettings
 from .ecosystem import BlockExplorer, FAssets, Flare, FtsoV2
@@ -9,6 +13,8 @@
 from .rag.vector import VectorRAGPipeline, create_vector_rag_pipeline
 from .social import TelegramClient, XClient
 
+logger = structlog.get_logger(__name__)
+
 
 class FlareAIKit:
     """The main entry point for the Flare AI Kit SDK."""
@@ -29,16 +35,16 @@ def __init__(self, config: AppSettings | None) -> None:
         self.settings = config or AppSettings()
 
         # Lazy-loaded properties
-        self._flare = None
-        self._block_explorer = None
-        self._ftso = None
-        self._fassets = None
-        self._vector_rag = None
-        self._telegram = None
-        self._github_ingestor = None
-        self._x_client = None
-        self._pdf_processor = None
-        self._a2a_client = None
+        self._flare: Flare | None = None
+        self._block_explorer: BlockExplorer | None = None
+        self._ftso: FtsoV2 | None = None
+        self._fassets: FAssets | None = None
+        self._vector_rag: VectorRAGPipeline | None = None
+        self._telegram: TelegramClient | None = None
+        self._github_ingestor: GithubIngestor | None = None
+        self._x_client: XClient | None = None
+        self._pdf_processor: PDFProcessor | None = None
+        self._a2a_client: A2AClient | None = None
 
     # Ecosystem Interaction Methods
     @property
@@ -122,8 +128,21 @@ def pdf_processor(self) -> PDFProcessor:
         return self._pdf_processor
 
     # A2A methods
-    def a2a_client(self, sqlite_db_path: str) -> A2AClient:
+    @property
+    def a2a_client(self) -> A2AClient:
         """Access the A2A client with optional db path."""
         if self._a2a_client is None:
-            self._a2a_client = A2AClient(sqlite_db_path)
+            self._a2a_client = A2AClient(settings=self.settings.a2a)
         return self._a2a_client
+
+
+async def core() -> None:
+    """Core function to run the Flare AI Kit SDK."""
+    logger.info("Starting Flare AI Kit core...")
+    # Your core logic
+    logger.info("Ending Flare AI Kit core...")
+
+
+def start() -> None:
+    """Main entry point for the Flare AI Kit SDK."""
+    asyncio.run(core())