fix: use a different redis stream depending on the project (#9725)

After openfoodfacts/search-a-licious#81
openfoodfacts · Feb 1, 2024 · cdcdf05 · cdcdf05
1 parent dc04d18
commit cdcdf05
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 1 deletion.
diff --git a/lib/ProductOpener/Config_obf.pm b/lib/ProductOpener/Config_obf.pm
@@ -418,4 +418,7 @@ $options{other_servers} = {
 
 $options{no_nutrition_table} = 1;
 
+# Name of the Redis stream to which product updates are published
+$options{redis_stream_name} = "product_updates_obf";
+
 1;
diff --git a/lib/ProductOpener/Config_off.pm b/lib/ProductOpener/Config_off.pm
@@ -1027,6 +1027,9 @@ $options{other_servers} = {
 	}
 };
 
+# Name of the Redis stream to which product updates are published
+$options{redis_stream_name} = "product_updates_off";
+
 # used to rename texts and to redirect to the new name
 $options{redirect_texts} = {
 	"en/nova-groups-for-food-processing" => "nova",

diff --git a/lib/ProductOpener/Config_opf.pm b/lib/ProductOpener/Config_opf.pm
@@ -391,4 +391,7 @@ $options{other_servers} = {
 
 $options{no_nutrition_table} = 1;
 
+# Name of the Redis stream to which product updates are published
+$options{redis_stream_name} = "product_updates_opf";
+
 1;
diff --git a/lib/ProductOpener/Config_opff.pm b/lib/ProductOpener/Config_opff.pm
@@ -430,4 +430,7 @@ $options{other_servers} = {
 	}
 };
 
+# Name of the Redis stream to which product updates are published
+$options{redis_stream_name} = "product_updates_opff";
+
 1;
diff --git a/lib/ProductOpener/Redis.pm b/lib/ProductOpener/Redis.pm
@@ -112,7 +112,7 @@ sub push_to_redis_stream ($user_id, $product_ref, $action, $comment, $diffs) {
 		eval {
 			$redis_client->xadd(
 				# name of the Redis stream
-				'product_update',
+				$options{redis_stream_name},
 				# We do not add a MAXLEN
 				'MAXLEN', '~', '10000000',
 				# We let Redis generate the id
-Original file line number
+Diff line change
@@ Expand Up / @@ -430,4 +430,7 @@ $options{other_servers} = { @@
     	}
     };
+    # Name of the Redis stream to which product updates are published
+    $options{redis_stream_name} = "product_updates_opff";
 ;