Merge branch 'master' into subtype

Dockerfile

@@ -3,7 +3,7 @@ FROM ubuntu:22.04 as builder
 SHELL ["bash", "-c"]
 
 ARG git_commit_id
-ARG rust_version=1.73.0
+ARG rust_version=1.75.0
 
 ENV GIT_COMMIT_ID=$git_commit_id
 ENV TZ=UTC

backend/canisters/community/impl/src/jobs/make_pending_payments.rs

@@ -94,6 +94,6 @@ async fn make_payment(ledger_canister: CanisterId, transfer_args: TransferArg) -
 
 fn memo(reason: PendingPaymentReason) -> Memo {
     match reason {
-        PendingPaymentReason::AccessGate => MEMO_JOINING_FEE.to_vec().try_into().unwrap(),
+        PendingPaymentReason::AccessGate => MEMO_JOINING_FEE.to_vec().into(),
     }
 }

backend/canisters/cycles_dispenser/api/src/lib.rs

@@ -1,7 +1,5 @@
 mod lifecycle;
-mod queries;
 mod updates;
 
 pub use lifecycle::*;
-pub use queries::*;
 pub use updates::*;

backend/canisters/escrow/api/src/lib.rs

@@ -4,11 +4,9 @@ use sha256::sha256;
 use types::UserId;
 
 mod lifecycle;
-mod queries;
 mod updates;
 
 pub use lifecycle::*;
-pub use queries::*;
 pub use updates::*;
 
 pub fn deposit_subaccount(user_id: UserId, offer_id: u32) -> Subaccount {

backend/canisters/group/impl/src/jobs/make_pending_payments.rs

@@ -94,6 +94,6 @@ async fn make_payment(ledger_canister: CanisterId, transfer_args: TransferArg) -
 
 fn memo(reason: PendingPaymentReason) -> Memo {
     match reason {
-        PendingPaymentReason::AccessGate => MEMO_JOINING_FEE.to_vec().try_into().unwrap(),
+        PendingPaymentReason::AccessGate => MEMO_JOINING_FEE.to_vec().into(),
     }
 }

backend/canisters/neuron_controller/api/src/lib.rs

@@ -1,7 +1,5 @@
 mod lifecycle;
-mod queries;
 mod updates;
 
 pub use lifecycle::*;
-pub use queries::*;
 pub use updates::*;

backend/canisters/proposals_bot/impl/src/lib.rs

@@ -160,7 +160,7 @@ fn generate_message_id(governance_canister_id: CanisterId, proposal_id: Proposal
     hash.update(b"proposals_bot");
     hash.update(governance_canister_id.as_slice());
     hash.update(proposal_id.to_ne_bytes());
-    let array32: [u8; 32] = hash.finalize().try_into().unwrap();
+    let array32: [u8; 32] = hash.finalize().into();
     let array16: [u8; 16] = array32[..16].try_into().unwrap();
     u128::from_ne_bytes(array16).into()
 }

backend/canisters/user/CHANGELOG.md

@@ -5,6 +5,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 ## [unreleased]
 
+### Changed
+
+- Add `local_user_index_canister_id` to `initial_state` response ([#5083](https://github.com/open-chat-labs/open-chat/pull/5083))
+
 ### Removed
 
 - Remove group summary cache ([#5067](https://github.com/open-chat-labs/open-chat/pull/5067))

backend/canisters/user/api/can.did

@@ -747,6 +747,7 @@ type InitialStateResponse = variant {
         avatar_id : opt nat;
         blocked_users : vec UserId;
         suspended : bool;
+        local_user_index_canister_id : CanisterId;
     };
 };
 

backend/canisters/user/api/src/queries/initial_state.rs

@@ -1,6 +1,6 @@
 use candid::CandidType;
 use serde::{Deserialize, Serialize};
-use types::{Chat, ChatId, DirectChatSummary, Empty, GroupChatSummary, TimestampMillis, UserId};
+use types::{CanisterId, Chat, ChatId, DirectChatSummary, Empty, GroupChatSummary, TimestampMillis, UserId};
 
 pub type Args = Empty;
 
@@ -19,6 +19,7 @@ pub struct SuccessResult {
     pub avatar_id: Option<u128>,
     pub blocked_users: Vec<UserId>,
     pub suspended: bool,
+    pub local_user_index_canister_id: CanisterId,
 }
 
 #[derive(CandidType, Serialize, Deserialize, Debug)]

backend/canisters/user/impl/src/queries/initial_state.rs

@@ -44,5 +44,6 @@ fn initial_state_impl(state: &RuntimeState) -> Response {
         avatar_id,
         blocked_users,
         suspended: state.data.suspended.value,
+        local_user_index_canister_id: state.data.local_user_index_canister_id,
     })
 }

backend/canisters/user_index/impl/src/jobs/make_pending_payments.rs

@@ -66,7 +66,7 @@ async fn make_payment(pending_payment: &PendingPayment) -> Result<BlockIndex, bo
         to: pending_payment.recipient_account,
         fee: None,
         created_at_time: Some(pending_payment.timestamp),
-        memo: Some(pending_payment.memo.to_vec().try_into().unwrap()),
+        memo: Some(pending_payment.memo.to_vec().into()),
         amount: pending_payment.amount.into(),
     };
 

backend/integration_tests/src/batched_summary_and_event_tests.rs

@@ -71,7 +71,7 @@ fn get_batched_events_succeeds() {
         },
     );
 
-    assert_is_message_with_text(responses.get(0).unwrap(), "User: 0");
+    assert_is_message_with_text(responses.first().unwrap(), "User: 0");
     assert_is_message_with_text(responses.get(1).unwrap(), "Group1: 1");
     assert_is_message_with_text(responses.get(2).unwrap(), "Group2: 2");
     assert_is_message_with_text(responses.get(3).unwrap(), "Channel: 3");
@@ -123,13 +123,13 @@ fn get_batched_summaries_succeeds() {
             },
         );
 
-    assert_is_summary_with_id(responses.get(0).unwrap(), group_id1.into(), false);
+    assert_is_summary_with_id(responses.first().unwrap(), group_id1.into(), false);
     assert_is_summary_with_id(responses.get(1).unwrap(), group_id2.into(), false);
     assert_is_summary_with_id(responses.get(2).unwrap(), community_id.into(), true);
 }
 
 fn assert_is_message_with_text(response: &EventsResponse, text: &str) {
-    if let local_user_index_canister::chat_events::EventsResponse::Success(result) = response {
+    if let EventsResponse::Success(result) = response {
         assert_eq!(result.events.len(), 1);
         if let ChatEvent::Message(message) = &result.events.first().unwrap().event {
             assert_eq!(message.content.text().unwrap(), text);

backend/libraries/candid_gen/src/lib.rs

@@ -61,7 +61,7 @@ pub fn generate_candid_method_no_args(input: TokenStream) -> TokenStream {
 }
 
 fn get_method_attribute(inputs: Vec<String>) -> MethodAttribute {
-    let first_arg = inputs.get(0).unwrap();
+    let first_arg = inputs.first().unwrap();
     let second_arg = inputs.get(1).unwrap();
     let third_arg = inputs.get(2).unwrap();
 

backend/libraries/canister_api_macros/src/lib.rs

@@ -180,7 +180,7 @@ fn get_arg_names(signature: &Signature) -> Vec<Ident> {
 }
 
 fn get_validation_method_attribute(inputs: Vec<String>) -> ValidationMethodAttribute {
-    let service_name = inputs.get(0).unwrap().to_string();
+    let service_name = inputs.first().unwrap().to_string();
     let function_name = inputs.get(1).unwrap().to_string();
 
     ValidationMethodAttribute {

frontend/app/src/i18n/cn.json

@@ -711,8 +711,8 @@
         "communities": "社区",
         "selectCommunity": "选择一个社区",
         "global": "全球的",
-        "block": "堵塞",
-        "unblock": "解锁"
+        "block": "屏蔽",
+        "unblock": "取消屏蔽"
     },
     "undeleteMessage": "取消删除",
     "undeletingMessage": "{username} 在 {timestamp} 上取消删除消息",
@@ -1208,4 +1208,4 @@
         "quoteTooLow": "所报的最佳费率是 {rate}  {tokenOut} / {tokenIn} @{dex}。这将从 {amountIn} {tokenIn} 兑换 {amountOut} {tokenOut} 。仅当报价金额超过 {minAmountOut} 时，您才可以进行交换。"
     },
     "messageBlocked": "消息已隐藏"
-}
+}

frontend/openchat-client/src/openchat.ts

@@ -2349,9 +2349,9 @@ export class OpenChat extends OpenChatAgentWorker {
             return Promise.resolve();
         }
 
-        const context = this._liveState.selectedMessageContext;
+        const context = { chatId, threadRootMessageIndex };
 
-        if (context?.threadRootMessageIndex === undefined) return;
+        if (!messageContextsEqual(context, this._liveState.selectedMessageContext)) return;
 
         const eventsResponse = await this.sendRequest({
             kind: "chatEvents",

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "1.73.0"
+channel = "1.75.0"
 targets = ["wasm32-unknown-unknown"]