fix program filter

Richard Patel · Richard Patel · commit f3cf7e455e44 · 2022-02-28T09:56:32.000+01:00
diff --git a/Cargo.toml b/Cargo.toml
@@ -2,7 +2,7 @@
 name = "solana-accountsdb-plugin-kafka"
 description = "Solana AccountsDb plugin for Kafka"
 authors = ["Blockdaemon"]
-version = "0.1.1"
+version = "0.1.2"
 edition = "2021"
 repository = "https://github.com/Blockdaemon/solana-accountsdb-plugin-kafka"
 license = "Apache-2.0"
diff --git a/example-config.json b/example-config.json
diff --git a/src/plugin.rs b/src/plugin.rs
@@ -87,7 +87,7 @@ impl AccountsDbPlugin for KafkaPlugin {
         }
 
         let info = Self::unwrap_update_account(account);
-        if !self.unwrap_filter().wants_program(info.pubkey) {
+        if !self.unwrap_filter().wants_program(info.owner) {
             return Ok(());
         }
 

Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ impl AccountsDbPlugin for KafkaPlugin {`
`87`	`87`	`}`
`88`	`88`
`89`	`89`	`let info = Self::unwrap_update_account(account);`
`90`		`- if !self.unwrap_filter().wants_program(info.pubkey) {`
	`90`	`+ if !self.unwrap_filter().wants_program(info.owner) {`
`91`	`91`	`return Ok(());`
`92`	`92`	`}`
`93`	`93`