Merge pull request #398 from theeldermillenial/feat/ogmios-path

Add path to Ogmios v6 backend

Author: theeldermillenial

pycardano/backend/ogmios_v6.py

@@ -57,6 +57,7 @@ def __init__(
         self,
         host: str = "localhost",
         port: int = 1337,
+        path: str = "",
         secure: bool = False,
         refetch_chain_tip_interval: Optional[float] = None,
         utxo_cache_size: int = 10000,
@@ -65,6 +66,7 @@ def __init__(
     ):
         self.host = host
         self.port = port
+        self.path = path
         self.secure = secure
         self._network = network
         self._service_name = "ogmios"
@@ -84,26 +86,26 @@ def __init__(
         self._datum_cache = LRUCache(maxsize=datum_cache_size)
 
     def _query_current_era(self) -> OgmiosEra:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             return get_current_era(client)
 
     def _query_current_epoch(self) -> int:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             epoch, _ = client.query_epoch.execute()
             return epoch
 
     def _query_chain_tip(self) -> OgmiosTip:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             tip, _ = client.query_network_tip.execute()
             return tip
 
     def _query_utxos_by_address(self, address: Address) -> List[OgmiosUtxo]:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             utxos, _ = client.query_utxo.execute([address])
             return utxos
 
     def _query_utxos_by_tx_id(self, tx_id: str, index: int) -> List[OgmiosUtxo]:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             utxos, _ = client.query_utxo.execute(
                 [OgmiosTxOutputReference(tx_id, index)]
             )
@@ -133,7 +135,7 @@ def protocol_param(self) -> ProtocolParameters:
         return self._protocol_param
 
     def _fetch_protocol_param(self) -> ProtocolParameters:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             protocol_parameters, _ = client.query_protocol_parameters.execute()
             pyc_protocol_params = ProtocolParameters(
                 min_fee_constant=protocol_parameters.min_fee_constant.lovelace,
@@ -203,7 +205,7 @@ def genesis_param(self) -> GenesisParameters:
         return self._genesis_param  # type: ignore[return-value]
 
     def _fetch_genesis_param(self) -> OgmiosGenesisParameters:
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             return OgmiosGenesisParameters(client, self._query_current_era())
 
     @property
@@ -308,13 +310,13 @@ def utxo_by_tx_id(self, tx_id: str, index: int) -> Optional[UTxO]:
     def submit_tx_cbor(self, cbor: Union[bytes, str]):
         if isinstance(cbor, bytes):
             cbor = cbor.hex()
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             client.submit_transaction.execute(cbor)
 
     def evaluate_tx_cbor(self, cbor: Union[bytes, str]) -> Dict[str, ExecutionUnits]:
         if isinstance(cbor, bytes):
             cbor = cbor.hex()
-        with OgmiosClient(self.host, self.port, self.secure) as client:
+        with OgmiosClient(self.host, self.port, self.path, self.secure) as client:
             result, _ = client.evaluate_transaction.execute(cbor)
             result_dict = {}
             for res in result:
@@ -363,6 +365,7 @@ class OgmiosChainContext(OgmiosV6ChainContext):
 def KupoOgmiosV6ChainContext(
     host: str,
     port: int,
+    path: str,
     secure: bool,
     refetch_chain_tip_interval: Optional[float] = None,
     utxo_cache_size: int = 10000,
@@ -374,6 +377,7 @@ def KupoOgmiosV6ChainContext(
         OgmiosV6ChainContext(
             host,
             port,
+            path,
             secure,
             refetch_chain_tip_interval,
             utxo_cache_size,