agent0.chainsync.db.hyperdrive.convert_data
===========================================

.. py:module:: agent0.chainsync.db.hyperdrive.convert_data

.. autoapi-nested-parse::

   Utilities to convert hyperdrive related things to database schema objects.

   ..
       !! processed by numpydoc !!


Functions
---------

.. autoapisummary::

   agent0.chainsync.db.hyperdrive.convert_data.convert_checkpoint_events
   agent0.chainsync.db.hyperdrive.convert_data.convert_trade_events
   agent0.chainsync.db.hyperdrive.convert_data.convert_pool_config
   agent0.chainsync.db.hyperdrive.convert_data.convert_pool_info


Module Contents
---------------

.. py:function:: convert_checkpoint_events(events: list[dict[str, Any]]) -> pandas.DataFrame

   
   Convert hyperdrive trade events to database schema objects.

   :param events: A list of event dictionary objects from `get_logs` to insert into postgres.
   :type events: list[dict[str, Any]]

   :returns: A DataFrame that matches the db schema of checkpoint events.
   :rtype: DataFrame















   ..
       !! processed by numpydoc !!

.. py:function:: convert_trade_events(events: list[dict[str, Any]], wallet_addr: str | None) -> pandas.DataFrame

   
   Convert hyperdrive trade events to database schema objects.

   :param events: A list of event dictionary objects from `get_logs` to insert into postgres.
   :type events: list[dict[str, Any]]
   :param wallet_addr: The wallet address that events are associated with for transfer events.
                       If None, will assume we want all events to the database.
   :type wallet_addr: str | None

   :returns: A DataFrame that matches the db schema of trade events.
   :rtype: DataFrame















   ..
       !! processed by numpydoc !!

.. py:function:: convert_pool_config(pool_config_dict: dict[str, Any]) -> agent0.chainsync.db.hyperdrive.schema.DBPoolConfig

   
   Converts a pool_config_dict from a call in hyperdrive_interface to the postgres data type

   :param pool_config_dict: A dicitonary containing the required pool_config keys.
   :type pool_config_dict: dict[str, Any]

   :returns: The db object for pool config
   :rtype: PoolConfig















   ..
       !! processed by numpydoc !!

.. py:function:: convert_pool_info(pool_info_dict: dict[str, Any]) -> agent0.chainsync.db.hyperdrive.schema.DBPoolInfo

   
   Converts a pool_info_dict from a call in hyperdrive interface to the postgres data type

   :param pool_info_dict: The dictionary returned from hyperdrive_instance.get_hyperdrive_pool_info
   :type pool_info_dict: dict[str, Any]

   :returns: The db object for pool info
   :rtype: PoolInfo















   ..
       !! processed by numpydoc !!