remove RedisSessionManager

Author: rafaelpierre-abn

src/agents/memory/providers/redis.py

@@ -243,127 +243,3 @@ async def __aenter__(self):
     async def __aexit__(self, exc_type, exc_val, exc_tb):
         """Async context manager exit."""
         await self.close()
-
-
-class RedisSessionManager:
-    """Manager class for Redis sessions with connection pooling."""
-
-    def __init__(
-        self,
-        redis_url: str = "redis://localhost:6379",
-        db: int = 0,
-        session_prefix: str = "agent_session",
-        messages_prefix: str = "agent_messages",
-        default_ttl: int | None = None,
-        max_connections: int = 10,
-    ):
-        """Initialize the Redis session manager.
-
-        Args:
-            redis_url: Redis connection URL
-            db: Redis database number
-            session_prefix: Prefix for session metadata keys
-            messages_prefix: Prefix for message list keys
-            default_ttl: Default TTL for sessions in seconds
-            max_connections: Maximum number of Redis connections in the pool
-        """
-        self.redis_url = redis_url
-        self.db = db
-        self.session_prefix = session_prefix
-        self.messages_prefix = messages_prefix
-        self.default_ttl = default_ttl
-
-        self._redis_pool = redis.ConnectionPool.from_url(
-            redis_url,
-            db=db,
-            max_connections=max_connections,
-            decode_responses=True,
-        )
-
-    def get_session(
-        self,
-        session_id: str,
-        ttl: int | None = None,
-    ) -> RedisSession:
-        """Get a Redis session instance.
-
-        Args:
-            session_id: Unique identifier for the session
-            ttl: TTL for this session. If None, uses default_ttl
-
-        Returns:
-            RedisSession instance
-        """
-        session = RedisSession(
-            session_id=session_id,
-            redis_url=self.redis_url,
-            db=self.db,
-            session_prefix=self.session_prefix,
-            messages_prefix=self.messages_prefix,
-            ttl=ttl or self.default_ttl,
-        )
-
-        # Share the connection pool
-        session._redis_client = redis.Redis(connection_pool=self._redis_pool)
-
-        return session
-
-    async def list_sessions(self, pattern: str | None = None) -> list[str]:
-        """List all session IDs.
-
-        Args:
-            pattern: Optional pattern to filter session IDs
-
-        Returns:
-            List of session IDs
-        """
-        client = redis.Redis(connection_pool=self._redis_pool)
-
-        if pattern:
-            search_pattern = f"{self.session_prefix}:{pattern}"
-        else:
-            search_pattern = f"{self.session_prefix}:*"
-
-        keys = await client.keys(search_pattern)
-
-        # Extract session IDs from keys
-        session_ids = []
-        prefix_len = len(self.session_prefix) + 1  # +1 for the colon
-
-        for key in keys:
-            session_id = key[prefix_len:]
-            session_ids.append(session_id)
-
-        await client.aclose()
-        return session_ids
-
-    async def delete_session(self, session_id: str) -> bool:
-        """Delete a session and all its data.
-
-        Args:
-            session_id: Session ID to delete
-
-        Returns:
-            True if session was deleted, False if it didn't exist
-        """
-        client = redis.Redis(connection_pool=self._redis_pool)
-
-        session_key = f"{self.session_prefix}:{session_id}"
-        messages_key = f"{self.messages_prefix}:{session_id}"
-
-        deleted_count: int = await client.delete(session_key, messages_key)
-        await client.aclose()
-
-        return deleted_count > 0
-
-    async def close(self) -> None:
-        """Close the connection pool."""
-        await self._redis_pool.aclose()
-
-    async def __aenter__(self):
-        """Async context manager entry."""
-        return self
-
-    async def __aexit__(self, exc_type, exc_val, exc_tb):
-        """Async context manager exit."""
-        await self.close()