Fix starting group upgrade job when concurrency updated (#6963)

open-chat-labs · Dec 3, 2024 · 7d93fc2 · 7d93fc2
1 parent d0f9572
commit 7d93fc2
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 1 deletion.
diff --git a/backend/canisters/community/api/src/lifecycle/init.rs b/backend/canisters/community/api/src/lifecycle/init.rs
@@ -25,6 +25,7 @@ pub struct Args {
     pub group_index_canister_id: CanisterId,
     pub local_group_index_canister_id: CanisterId,
     pub notifications_canister_id: CanisterId,
+    pub bot_api_gateway_canister_id: CanisterId,
     pub proposals_bot_user_id: UserId,
     pub escrow_canister_id: CanisterId,
     pub internet_identity_canister_id: CanisterId,

diff --git a/backend/canisters/group/api/src/lifecycle/init.rs b/backend/canisters/group/api/src/lifecycle/init.rs
@@ -26,6 +26,7 @@ pub struct Args {
     pub group_index_canister_id: CanisterId,
     pub local_group_index_canister_id: CanisterId,
     pub notifications_canister_id: CanisterId,
+    pub bot_api_gateway_canister_id: CanisterId,
     pub proposals_bot_user_id: UserId,
     pub escrow_canister_id: CanisterId,
     pub internet_identity_canister_id: CanisterId,

diff --git a/backend/canisters/local_group_index/CHANGELOG.md b/backend/canisters/local_group_index/CHANGELOG.md
@@ -10,6 +10,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 - Remove references to bot_api_gateway ([#6944](https://github.com/open-chat-labs/open-chat/pull/6944))
 
+### Fixed
+
+- Fix starting group upgrade job when concurrency updated ([#6963](https://github.com/open-chat-labs/open-chat/pull/6963))
+
 ## [[2.0.1482](https://github.com/open-chat-labs/open-chat/releases/tag/v2.0.1482-local_group_index)] - 2024-11-29
 
 ### Changed

diff --git a/backend/canisters/local_group_index/impl/src/updates/c2c_create_community.rs b/backend/canisters/local_group_index/impl/src/updates/c2c_create_community.rs
@@ -108,6 +108,7 @@ fn prepare(args: Args, state: &mut RuntimeState) -> Result<PrepareOk, Response>
         user_index_canister_id: state.data.user_index_canister_id,
         local_user_index_canister_id,
         notifications_canister_id: state.data.notifications_canister_id,
+        bot_api_gateway_canister_id: CanisterId::anonymous(),
         proposals_bot_user_id: state.data.proposals_bot_user_id,
         escrow_canister_id: state.data.escrow_canister_id,
         internet_identity_canister_id: state.data.internet_identity_canister_id,

diff --git a/backend/canisters/local_group_index/impl/src/updates/c2c_create_group.rs b/backend/canisters/local_group_index/impl/src/updates/c2c_create_group.rs
@@ -115,6 +115,7 @@ fn prepare(args: Args, state: &mut RuntimeState) -> Result<PrepareOk, Response>
         user_index_canister_id: state.data.user_index_canister_id,
         local_user_index_canister_id,
         notifications_canister_id: state.data.notifications_canister_id,
+        bot_api_gateway_canister_id: CanisterId::anonymous(),
         proposals_bot_user_id: state.data.proposals_bot_user_id,
         escrow_canister_id: state.data.escrow_canister_id,
         internet_identity_canister_id: state.data.internet_identity_canister_id,

diff --git a/backend/canisters/local_group_index/impl/src/updates/c2c_set_group_upgrade_concurrency.rs b/backend/canisters/local_group_index/impl/src/updates/c2c_set_group_upgrade_concurrency.rs
@@ -13,7 +13,7 @@ fn c2c_set_group_upgrade_concurrency(args: Args) -> Response {
         let max = state.data.max_concurrent_group_upgrades;
         state.data.group_upgrade_concurrency = min(args.value, max);
         if state.data.group_upgrade_concurrency > 0 {
-            crate::jobs::upgrade_communities::start_job_if_required(state);
+            crate::jobs::upgrade_groups::start_job_if_required(state);
         }
         info!(state.data.group_upgrade_concurrency, "Group upgrade concurrency set");
         if args.value > max {