Paulo/upstream changes 1.9.1 (#4)

* chore: bump Pallas to v0.30.1 (txpipe#811)

* Release v1.9.1

* chore: bump version

* fix: pubsub emulator again

---------

Co-authored-by: Santiago Carmuega <[email protected]>

Author: 2 people

Cargo.lock

@@ -1,7 +1,7 @@
 [package]
 name = "oura"
 description = "The tail of Cardano"
-version = "1.10.0"
+version = "1.10.1"
 edition = "2021"
 repository = "https://github.com/txpipe/oura"
 homepage = "https://github.com/txpipe/oura"

Cargo.toml

@@ -57,16 +57,7 @@ pub fn writer_loop(
         .build()?;
 
     let publisher: Publisher = rt.block_on(async {
-        let client_config = if emulator {
-            ClientConfig {
-                project_id: Some(emulator_project_id.clone().unwrap_or_default()),
-                environment: Environment::Emulator(emulator_endpoint.clone().unwrap_or_default()),
-                ..Default::default()
-            }
-        } else {
-            ClientConfig::default()
-        };
-        let client = Client::new(client_config).await?;
+        let client = Client::new(ClientConfig::default().with_auth().await?).await?;
         let topic = client.topic(topic_name);
         Result::<_, crate::Error>::Ok(topic.new_publisher(None))
     })?;

src/sinks/gcp_pubsub/run.rs

@@ -16,10 +16,6 @@ pub struct Config {
     pub retry_policy: Option<retry::Policy>,
     pub ordering_key: Option<String>,
     pub attributes: Option<GenericKV>,
-    pub emulator: Option<bool>,
-    pub emulator_endpoint: Option<String>,
-    pub emulator_project_id: Option<String>,
-
     #[warn(deprecated)]
     pub credentials: Option<String>,
 }