Fix notifications index canisterId in already running job (#7089)

open-chat-labs · Dec 19, 2024 · 6819115 · 6819115
1 parent 9704903
commit 6819115
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/backend/canisters/registry/CHANGELOG.md b/backend/canisters/registry/CHANGELOG.md
@@ -6,6 +6,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 ## [unreleased]
 
+## [[2.0.1535](https://github.com/open-chat-labs/open-chat/releases/tag/v2.0.1535-registry)] - 2024-12-19
+
 ### Fixed
 
 - Fix notifications index canisterId ([#7088](https://github.com/open-chat-labs/open-chat/pull/7088))

diff --git a/backend/canisters/registry/impl/src/lifecycle/post_upgrade.rs b/backend/canisters/registry/impl/src/lifecycle/post_upgrade.rs
@@ -7,7 +7,6 @@ use ic_cdk::post_upgrade;
 use registry_canister::post_upgrade::Args;
 use stable_memory::get_reader;
 use tracing::info;
-use types::CanisterId;
 use utils::cycles::init_cycles_dispenser_client;
 
 #[post_upgrade]
@@ -16,15 +15,9 @@ fn post_upgrade(args: Args) {
     let memory = get_upgrades_memory();
     let reader = get_reader(&memory);
 
-    let (mut data, errors, logs, traces): (Data, Vec<LogEntry>, Vec<LogEntry>, Vec<LogEntry>) =
+    let (data, errors, logs, traces): (Data, Vec<LogEntry>, Vec<LogEntry>, Vec<LogEntry>) =
         msgpack::deserialize(reader).unwrap();
 
-    if data.test_mode {
-        data.notifications_index_canister_id = CanisterId::from_text("7ekiy-aiaaa-aaaaf-ab2dq-cai").unwrap();
-    } else {
-        data.notifications_index_canister_id = CanisterId::from_text("4glvk-ryaaa-aaaaf-aaaia-cai").unwrap();
-    }
-
     canister_logger::init_with_logs(data.test_mode, errors, logs, traces);
 
     let env = init_env(data.rng_seed);

diff --git a/backend/canisters/registry/impl/src/timer_job_types.rs b/backend/canisters/registry/impl/src/timer_job_types.rs
@@ -23,6 +23,7 @@ pub struct ExpandOntoSubnetJob {
     pub this_canister_id: CanisterId,
     pub user_index: CanisterId,
     pub group_index: CanisterId,
+    #[serde(skip_deserializing, default = "notifications_index")]
     pub notifications_index: CanisterId,
     pub event_relay: CanisterId,
     pub cycles_dispenser: CanisterId,
@@ -31,6 +32,10 @@ pub struct ExpandOntoSubnetJob {
     pub create_canister_block_index: Option<u64>,
 }
 
+fn notifications_index() -> CanisterId {
+    CanisterId::from_text("4glvk-ryaaa-aaaaf-aaaia-cai").unwrap()
+}
+
 impl Job for TimerJob {
     fn execute(self) {
         match self {