WIP: remove maybe_update_sending_transport

2026-10-03 19:50:33 +03:00 · 2026-09-19 17:56:54 +00:00
81 changed files with 1518 additions and 1884 deletions
@@ -1,112 +1,5 @@
 # Changelog

-## [2.62.0] - 2026-09-22
-
-### API-Changes
-
- Remove unused ImapMessageMoved event.
- [**breaking**] get rid of `Qr::FprWithoutAddr` and `Qr::FprMismatch` variants.
-  - removed `DC_QR_FPR_WITHOUT_ADDR` and `DC_QR_FPR_MISMATCH` constants from CFFI
-  - removed FprWithoutAddr and FprMismatch variants from JSON-RPC QrObject returned by `check_qr`
-
-### Features / Changes
-
- Don't show "member added" messages in channels ([#8730](https://github.com/chatmail/core/pull/8730)).
-
-### Fixes
-
- Don't notify about a reaction sent by a blocked contact ([#8729](https://github.com/chatmail/core/pull/8729)).
- keep a message read status if a failure arrives later.
- prefer login errors over connection errors in the log message ([#8727](https://github.com/chatmail/core/pull/8727)).
- blocked or email contacts contacts are never recently seen or old ([#8733](https://github.com/chatmail/core/pull/8733)).
-
-### Refactor
-
- Remove code that moves messages between IMAP folders.
-
-## [2.61.0] - 2026-09-21
-
-### API-Changes
-
- add `init_transports()` for multi-relay onboarding.
- add JSON-RPC API `is_sending_finished()`.
- [**breaking**] remove verification methods from the FFI and JSON-RPC APIs.
-  - `dc_contact_is_verified()` and `dc_contact_get_verifier_id()` are removed.
-  - the JSON-RPC Contact object loses the `isVerified` and `verifierId` fields. A bot reading `snapshot.is_verified` now gets an `AttributeError` at runtime.
-  - the Python bindings lose `Contact.is_verified()` and `Contact.get_verifier()`.
-  - `DC_STR_CONTACT_VERIFIED` (35) is removed, so UIs should stop registering a translation for it. A stock id core does not know is logged and otherwise ignored, so an un-updated client keeps working.
- [**breaking**] remove default value for "addr" config.
- [**breaking**] remove `addr` field from Account objects in JSON-RPC APIs.
-  - `list_transports()` should be used instead.
- [**breaking**] remove `is_chatmail` and the XCHATMAIL capability.
-  - `is_chatmail` is no longer a known config key.
- [**breaking**] remove `Contact.get_name_n_addr()` and related APIs.
-  - `dc_contact_get_name_n_addr()` CFFI is removed
-  - JSON-RPC contact objects don't have nameAndAddr field anymore
- [**breaking**] replace `was_seen_recently` by `freshness` in contact object.
-  - use contact's `freshness` instead of `seen_recently`
-
-### Fixes
-
- always emit `AccountsBackgroundFetchDone`.
- make `background_fetch` not wait on or trigger SMTP connections.
- do not send a sync message when changing `configured_addr`.
- emit `SmtpMessageSent` event after deleting the message from SMTP queue.
- don't use extra STUN nine server for fallback.
- use `max_smtp_rcpt_to` chunking for the actual transport we are sending from.
- use correct `From` address when sending MDNs.
- use correct address for Bcc-self in unencrypted mails.
- don't emit configure progress events during background relay additions.
-
-### Features / Changes
-
- better quality of image recoding ([#8682](https://github.com/chatmail/core/pull/8682)).
- perform background fetch from all transports.
- queue messages for SMTP before encryption.
- [**breaking**] stop tracking contact verification.
-  - the statistics JSON sent to the self-reporting-bot on Android changes: Contacts have `encrypted` instead of `verified` and lose `transitive_chain` properties and message stats have `encrypted` instead of `verified` and `unverified_encrypted`, and securejoin invites lose `already_verified`. The collecting bot stores incoming reports verbatim but analysis will have to make sense of older and newer reports.
- remove last usage of XDELTAPUSH capability.
- base server-side message deletion on `force_encryption`.
- do not restart I/O when setting `configured_addr`.
- do not use ConfiguredAddr when connecting to SMTP.
- mark autorelays for relay operators ([#8701](https://github.com/chatmail/core/pull/8701)).
- try fasted relays to attempt first configure on.
- do not mark message as failed for which we got a read receipt before.
- a single NDN does not mark a group message as failed.
-
-### Documentation
-
- update `sys.msgsize_max_recommended` documentation.
- add hint about how to reset an invitation ([#8160](https://github.com/chatmail/core/pull/8160)).
- mention `get_app_version()` API in the changelog for 2.59.0.
- remove `protect_autocrypt` setting.
-
-### Miscellaneous Tasks
-
- cleanup "primary" wording in comments.
- update rustls to 0.23.45.
- fix nightly "cargo" warnings.
- fix some types in `deltachat_rpc_client`.
-
-### Refactor
-
- add `Encryption.is_encrypted()`.
- separate QueuedEncryption.
- sql: disable double-quoted string literals.
- add smtp::queue module.
- substitute configure progress macro with simple function call.
-
-### Tests
-
- cleanup `get_smtp_rows_for_msg()`.
- cross-core securejoin invites for every chat type.
- explicitly empty url in appversion updates ([#8702](https://github.com/chatmail/core/pull/8702)).
- do not talk about "inconsistent key state" in `test_securejoin_after_contact_resetup`.
- rename `test_aeap_transition_{0,1}` to `test_aeap_transition_{single,group}`.
- do not fetch all messages when `direct_imap` is created.
- `direct_imap`: always pass `mark_seen=False` to fetch().
- add pseudo transport explicitly rather than by setting ConfiguredAddr.
-
 ## [2.60.0] - 2026-09-11

 ### API-Changes
@@ -8901,5 +8794,3 @@ https://github.com/chatmail/core/pulls?q=is%3Apr+is%3Aclosed
 [2.58.0]: https://github.com/chatmail/core/compare/v2.57.0..v2.58.0
 [2.59.0]: https://github.com/chatmail/core/compare/v2.58.0..v2.59.0
 [2.60.0]: https://github.com/chatmail/core/compare/v2.59.0..v2.60.0
-[2.61.0]: https://github.com/chatmail/core/compare/v2.60.0..v2.61.0
-[2.62.0]: https://github.com/chatmail/core/compare/v2.61.0..v2.62.0
@@ -1327,7 +1327,7 @@ dependencies = [

 [[package]]
 name = "deltachat"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "anyhow",
 "astral-tokio-tar",
@@ -1435,7 +1435,7 @@ dependencies = [

 [[package]]
 name = "deltachat-jsonrpc"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "anyhow",
 "async-channel 2.5.0",
@@ -1456,14 +1456,14 @@ dependencies = [

 [[package]]
 name = "deltachat-jsonrpc-bindings"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "deltachat-jsonrpc",
 ]

 [[package]]
 name = "deltachat-repl"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "anyhow",
 "deltachat",
@@ -1479,7 +1479,7 @@ dependencies = [

 [[package]]
 name = "deltachat-rpc-server"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "anyhow",
 "deltachat",
@@ -1508,7 +1508,7 @@ dependencies = [

 [[package]]
 name = "deltachat_ffi"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 dependencies = [
 "anyhow",
 "deltachat",
@@ -2091,12 +2091,6 @@ version = "0.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d9c4f5dac5e15c24eb999c26181a6ca40b39fe946cbe4c263c7209467bc83af2"

-[[package]]
-name = "foldhash"
-version = "0.2.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "77ce24cb58228fbb8aa041425bb1050850ac19177686ea6e0f41a70416f56fdb"
-
 [[package]]
 name = "foreign-types"
 version = "0.3.2"
@@ -2417,34 +2411,16 @@ checksum = "5971ac85611da7067dbfcabef3c70ebb5606018acd9e2a3903a0da507521e0d5"
 dependencies = [
 "allocator-api2",
 "equivalent",
- "foldhash 0.1.5",
-]
-
-[[package]]
-name = "hashbrown"
-version = "0.16.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "841d1cc9bed7f9236f321df977030373f4a4163ae1a7dbfe1a51a2c1a51d9100"
-dependencies = [
- "foldhash 0.2.0",
-]
-
-[[package]]
-name = "hashbrown"
-version = "0.17.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ed5909b6e89a2db4456e54cd5f673791d7eca6732202bbf2a9cc504fe2f9b84a"
-dependencies = [
- "foldhash 0.2.0",
+ "foldhash",
 ]

 [[package]]
 name = "hashlink"
-version = "0.12.2"
+version = "0.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a596f1b20ed2cc5ecac41a164aaebc7258057060f06c0cf7a2ba3991ee7990fb"
+checksum = "7382cf6263419f2d8df38c55d7da83da5c18aef87fc7a7fc1fb1e344edfe14c1"
 dependencies = [
- "hashbrown 0.17.1",
+ "hashbrown",
 ]

 [[package]]
@@ -2978,7 +2954,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "4b0f83760fb341a774ed326568e19f5a863af4a952def8c39f9ab92fd95b88e5"
 dependencies = [
 "equivalent",
- "hashbrown 0.15.4",
+ "hashbrown",
 ]

 [[package]]
@@ -3285,12 +3261,11 @@ checksum = "b1a46d1a171d865aa5f83f92695765caa047a9b4cbae2cbf37dbd613a793fd4c"

 [[package]]
 name = "js-sys"
-version = "0.3.105"
+version = "0.3.77"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ce57d20d1ea864ce2ac172ab472d409214f4fd359f0b2a2775abdf522e2af99e"
+checksum = "1cfaf33c695fc6e08064efbc1f72ec937429614f25eef83af942d0e227c3a28f"
 dependencies = [
- "cfg-if",
- "futures-util",
+ "once_cell",
 "wasm-bindgen",
 ]

@@ -3369,11 +3344,12 @@ dependencies = [

 [[package]]
 name = "libsqlite3-sys"
-version = "0.38.2"
+version = "0.35.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f1d20bef17f513b9b3004532233187769cd072d790971f4e4da0e346eb6401e8"
+checksum = "133c182a6a2c87864fe97778797e46c7e999672690dc9fa3ee8e241aa4a9c13f"
 dependencies = [
 "cc",
+ "openssl-sys",
 "pkg-config",
 "vcpkg",
 ]
@@ -3445,7 +3421,7 @@ version = "0.12.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "234cf4f4a04dc1f57e24b96cc0cd600cf2af460d4161ac5ecdd0af8e1f3b2a38"
 dependencies = [
- "hashbrown 0.15.4",
+ "hashbrown",
 ]

 [[package]]
@@ -5234,21 +5210,11 @@ dependencies = [
 "zeroize",
 ]

-[[package]]
-name = "rsqlite-vfs"
-version = "0.1.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c51c9ae4df8a7fba42103df5c621fa3c37eccf3a3c650879e90fc48b11cc192c"
-dependencies = [
- "hashbrown 0.16.1",
- "thiserror 2.0.20",
-]
-
 [[package]]
 name = "rusqlite"
-version = "0.40.2"
+version = "0.37.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "23f2a97da3e3873c73cb2a2e71b35c40ff95e0b1eefa8d72d8499a6928c3b5b3"
+checksum = "165ca6e57b20e1351573e3729b958bc62f0e48025386970b6e4d29e7a7e71f3f"
 dependencies = [
 "bitflags 2.11.0",
 "fallible-iterator",
@@ -5256,7 +5222,6 @@ dependencies = [
 "hashlink",
 "libsqlite3-sys",
 "smallvec",
- "sqlite-wasm-rs",
 ]

 [[package]]
@@ -5961,18 +5926,6 @@ dependencies = [
 "der",
 ]

-[[package]]
-name = "sqlite-wasm-rs"
-version = "0.5.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "dc3efc0da82635d7e1ced0053bbbfa8c7ab9645d0bf36ceb4f7127bb85315d75"
-dependencies = [
- "cc",
- "js-sys",
- "rsqlite-vfs",
- "wasm-bindgen",
-]
-
 [[package]]
 name = "stable_deref_trait"
 version = "1.2.0"
@@ -6880,32 +6833,48 @@ checksum = "b8dad83b4f25e74f184f64c43b150b91efe7647395b42289f38e50566d82855b"

 [[package]]
 name = "wasm-bindgen"
-version = "0.2.128"
+version = "0.2.100"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "aecb87a33d3b0c5e3b7aa46336eaf486cffafbd281b195e4c8b80d50df2351bf"
+checksum = "1edc8929d7499fc4e8f0be2262a241556cfc54a0bea223790e71446f2aab1ef5"
 dependencies = [
 "cfg-if",
 "once_cell",
 "rustversion",
 "wasm-bindgen-macro",
+]
+
+[[package]]
+name = "wasm-bindgen-backend"
+version = "0.2.100"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2f0a0651a5c2bc21487bde11ee802ccaf4c51935d0d3d42a6101f98161700bc6"
+dependencies = [
+ "bumpalo",
+ "log",
+ "proc-macro2",
+ "quote",
+ "syn 2.0.118",
 "wasm-bindgen-shared",
 ]

 [[package]]
 name = "wasm-bindgen-futures"
-version = "0.4.78"
+version = "0.4.50"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6ef4c5d3d2cdf5c54f4231181768f5510842e350db025faf1f7163b1030ed928"
+checksum = "555d470ec0bc3bb57890405e5d4322cc9ea83cebb085523ced7be4144dac1e61"
 dependencies = [
+ "cfg-if",
 "js-sys",
+ "once_cell",
 "wasm-bindgen",
+ "web-sys",
 ]

 [[package]]
 name = "wasm-bindgen-macro"
-version = "0.2.128"
+version = "0.2.100"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a690d511e3c1a8b3a55e33511e3c2c00c78415cd23650f32b808627f5696b9ed"
+checksum = "7fe63fc6d09ed3792bd0897b314f53de8e16568c2b3f7982f468c0bf9bd0b407"
 dependencies = [
 "quote",
 "wasm-bindgen-macro-support",
@@ -6913,22 +6882,22 @@ dependencies = [

 [[package]]
 name = "wasm-bindgen-macro-support"
-version = "0.2.128"
+version = "0.2.100"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "411e4887f0071ef2d2164a9d5fdf2d20efbef78fccd3a78b0c10a1dc5295e48a"
+checksum = "8ae87ea40c9f689fc23f209965b6fb8a99ad69aeeb0231408be24920604395de"
 dependencies = [
- "bumpalo",
 "proc-macro2",
 "quote",
- "syn 3.0.4",
+ "syn 2.0.118",
+ "wasm-bindgen-backend",
 "wasm-bindgen-shared",
 ]

 [[package]]
 name = "wasm-bindgen-shared"
-version = "0.2.128"
+version = "0.2.100"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "81941cd78d0c92026c33e5e01312845a4cb1e9af3407f9134b100dd03144103e"
+checksum = "1a05d73b933a847d6cccdda8f838a22ff101ad9bf93e33684f39c1f5f0eece3d"
 dependencies = [
 "unicode-ident",
 ]
@@ -6948,9 +6917,9 @@ dependencies = [

 [[package]]
 name = "web-sys"
-version = "0.3.105"
+version = "0.3.77"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9fbddc4a036f00ec4f18c83445bd3115cb306a91da554919a099d9222fe4a7f8"
+checksum = "33b6dd2ef9186f1f2072e409e99cd22a975331a6b3591b12c764e0e55c60d5d2"
 dependencies = [
 "js-sys",
 "wasm-bindgen",
@@ -1,6 +1,6 @@
 [package]
 name = "deltachat"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 edition = "2024"
 license = "MPL-2.0"
 rust-version = "1.89"
@@ -85,7 +85,7 @@ quick-xml = { version = "0.41", features = ["escape-html"] }
 rand-old = { package = "rand", version = "0.8" }
 rand = { workspace = true }
 regex = { workspace = true }
-rusqlite = { workspace = true, features = ["backup"] }
+rusqlite = { workspace = true, features = ["sqlcipher"] }
 sanitize-filename = { workspace = true }
 sdp = "0.17.1"
 serde_json = { workspace = true }
@@ -194,7 +194,7 @@ nu-ansi-term = "0.50"
 num-traits = "0.2"
 rand = "0.9"
 regex = "1.12"
-rusqlite = "0.40.2"
+rusqlite = "0.37"
 sanitize-filename = "0.6"
 serde = "1.0"
 serde_json = "1"
@@ -209,7 +209,7 @@ yerpc = "0.7"
 default = ["vendored"]
 internals = []
 vendored = [
-  "rusqlite/bundled",
+  "rusqlite/bundled-sqlcipher-vendored-openssl",
  "async-native-tls/vendored"
 ]

@@ -1,6 +1,6 @@
 [package]
 name = "deltachat_ffi"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 description = "Deltachat FFI"
 edition = "2024"
 license = "MPL-2.0"
@@ -304,6 +304,21 @@ dc_context_t*   dc_context_new_closed        (const char* dbfile);
 int             dc_context_open              (dc_context_t *context, const char* passphrase);


+/**
+ * Changes the passphrase on the open database.
+ * Deprecated 2025-11, see `dc_context_open()` for reasoning.
+ *
+ * Existing database must already be encrypted and the passphrase cannot be NULL or empty.
+ * It is impossible to encrypt unencrypted database with this method and vice versa.
+ *
+ * @memberof dc_context_t
+ * @param context The context object.
+ * @param passphrase The new passphrase.
+ * @return 1 on success, 0 on error.
+ */
+int             dc_context_change_passphrase (dc_context_t* context, const char* passphrase);
+
+
 /**
 * Returns 1 if database is open.
 *
@@ -2440,6 +2455,8 @@ void            dc_stop_ongoing_process      (dc_context_t* context);
 #define         DC_QR_ASK_VERIFYGROUP        202 // text1=groupname
 #define         DC_QR_ASK_VERIFYBROADCAST    204 // text1=broadcast name
 #define         DC_QR_FPR_OK                 210 // id=contact
+#define         DC_QR_FPR_MISMATCH           220 // id=contact
+#define         DC_QR_FPR_WITHOUT_ADDR       230 // test1=formatted fingerprint
 #define         DC_QR_ACCOUNT                250 // text1=domain
 #define         DC_QR_BACKUP2                252
 #define         DC_QR_BACKUP_TOO_NEW         255
@@ -2480,6 +2497,13 @@ void            dc_stop_ongoing_process      (dc_context_t* context);
 *   ask the user if they want to start chatting;
 *   if so, call dc_create_chat_by_contact_id().
 *
+ * - DC_QR_FPR_MISMATCH with dc_lot_t::id=Contact ID:
+ *   scanned fingerprint does not match last seen fingerprint.
+ *
+ * - DC_QR_FPR_WITHOUT_ADDR with dc_lot_t::text1=Formatted fingerprint
+ *   the scanned QR code contains a fingerprint but no e-mail address;
+ *   suggest the user to establish an encrypted connection first.
+ *
 * - DC_QR_ACCOUNT dc_lot_t::text1=domain:
 *   ask the user if they want to create an account on the given domain,
 *   if so, call dc_set_config_from_qr() and then dc_configure().
@@ -4888,38 +4912,6 @@ uint32_t        dc_msg_get_saved_msg_id     (const dc_msg_t* msg);
 int             dc_msg_is_pinned           (const dc_msg_t* msg);


-/**
- * @defgroup DC_FRESHNESS DC_FRESHNESS
- *
- * These constants describe the freshness of a contact,
- * as returned by dc_contact_get_freshness().
- *
- * @addtogroup DC_FRESHNESS
- * @{
- */
-
-/**
- * Contact shall not be highlighted, e.g. neither shown with a "seen recently" dot
- * nor with a "not seen for a long time" hint.
- */
-#define DC_FRESHNESS_NORMAL         0
-
-/**
- * Contact was seen recently, the UI shall highlight it e.g. with a little green dot on the avatar.
- */
-#define DC_FRESHNESS_RECENTLY_SEEN  1
-
-/**
- * Contact was not seen for a long time, the UI shall highlight it e.g. with a string
- * below the contact name (e.g. "Seen 2 months ago").
- */
-#define DC_FRESHNESS_OLD            2
-
-/**
- * @}
- */
-
-
 /**
 * @class dc_contact_t
 *
@@ -5092,18 +5084,18 @@ int64_t         dc_contact_get_last_seen     (const dc_contact_t* contact);


 /**
- * Get the contact's freshness.
- *
- * The UI shall hightlight contacts that are recently seen by a little green dot on the avatar
- * and contacts that were not seen for a long time by a string below the contact name (e.g. "Seen 2 months ago")
+ * Check if the contact was seen recently.
 *
+ * The UI may highlight these contacts,
+ * eg. draw a little green dot on the avatars of the users recently seen.
+ * DC_CONTACT_ID_SELF and other special contact IDs are defined as never seen recently (they should not get a dot).
 * To get the time a contact was seen, use dc_contact_get_last_seen().
 *
 * @memberof dc_contact_t
 * @param contact The contact object.
- * @return One of the @ref DC_FRESHNESS constants.
+ * @return 1=contact seen recently, 0=contact not seen recently.
 */
-int             dc_contact_get_freshness (const dc_contact_t* contact);
+int             dc_contact_was_seen_recently (const dc_contact_t* contact);


 /**
@@ -5915,6 +5907,14 @@ void dc_event_unref(dc_event_t* event);
 */
 #define DC_EVENT_IMAP_MESSAGE_DELETED   104

+/**
+ * Emitted when a message was successfully moved on IMAP.
+ *
+ * @param data1 0
+ * @param data2 (char*) Info string in English language.
+ */
+#define DC_EVENT_IMAP_MESSAGE_MOVED   105
+
 /**
 * Emitted before going into IDLE on the Inbox folder.
 *
@@ -6163,17 +6163,6 @@ void dc_event_unref(dc_event_t* event);
 #define DC_EVENT_CHAT_DELETED             2023


-/**
- * The list of pinned messages for the chat has changed.
- *
- * Some message got pinned, or pinned message is unpinned or deleted.
- *
- * @param data1 (int) chat_id
- * @param data2 (int) 0
- */
-#define DC_EVENT_PINNED_MESSAGES_CHANGED 2024
-
-
 /**
 * Contact(s) created, renamed, blocked or deleted.
 *
@@ -160,6 +160,24 @@ pub unsafe extern "C" fn dc_context_open(
        .unwrap_or(0)
 }

+#[unsafe(no_mangle)]
+pub unsafe extern "C" fn dc_context_change_passphrase(
+    context: *mut dc_context_t,
+    passphrase: *const libc::c_char,
+) -> libc::c_int {
+    if context.is_null() {
+        eprintln!("ignoring careless call to dc_context_change_passphrase()");
+        return 0;
+    }
+
+    let ctx = unsafe { &*context };
+    let passphrase = to_string_lossy(passphrase);
+    block_on(ctx.change_passphrase(passphrase))
+        .context("dc_context_change_passphrase() failed")
+        .log_err(ctx)
+        .is_ok() as libc::c_int
+}
+
 #[unsafe(no_mangle)]
 pub unsafe extern "C" fn dc_context_is_open(context: *mut dc_context_t) -> libc::c_int {
    if context.is_null() {
@@ -475,6 +493,7 @@ pub unsafe extern "C" fn dc_event_get_id(event: *mut dc_event_t) -> libc::c_int
        EventType::ImapConnected(_) => 102,
        EventType::SmtpMessageSent(_) => 103,
        EventType::ImapMessageDeleted(_) => 104,
+        EventType::ImapMessageMoved(_) => 105,
        EventType::ImapInboxIdle => 106,
        EventType::NewBlobFile(_) => 150,
        EventType::DeletedBlobFile(_) => 151,
@@ -496,7 +515,6 @@ pub unsafe extern "C" fn dc_event_get_id(event: *mut dc_event_t) -> libc::c_int
        EventType::ChatModified(_) => 2020,
        EventType::ChatEphemeralTimerModified { .. } => 2021,
        EventType::ChatDeleted { .. } => 2023,
-        EventType::PinnedMessagesChanged { .. } => 2024,
        EventType::ContactsChanged(_) => 2030,
        EventType::LocationChanged(_) => 2035,
        EventType::ConfigureProgress { .. } => 2041,
@@ -542,6 +560,7 @@ pub unsafe extern "C" fn dc_event_get_data1_int(event: *mut dc_event_t) -> libc:
        | EventType::ImapConnected(_)
        | EventType::SmtpMessageSent(_)
        | EventType::ImapMessageDeleted(_)
+        | EventType::ImapMessageMoved(_)
        | EventType::ImapInboxIdle
        | EventType::NewBlobFile(_)
        | EventType::DeletedBlobFile(_)
@@ -570,8 +589,7 @@ pub unsafe extern "C" fn dc_event_get_data1_int(event: *mut dc_event_t) -> libc:
        | EventType::MsgReadCountChanged { chat_id, .. }
        | EventType::ChatModified(chat_id)
        | EventType::ChatEphemeralTimerModified { chat_id, .. }
-        | EventType::ChatDeleted { chat_id }
-        | EventType::PinnedMessagesChanged { chat_id } => chat_id.to_u32() as libc::c_int,
+        | EventType::ChatDeleted { chat_id } => chat_id.to_u32() as libc::c_int,
        EventType::ContactsChanged(id) | EventType::LocationChanged(id) => {
            let id = id.unwrap_or_default();
            id.to_u32() as libc::c_int
@@ -617,6 +635,7 @@ pub unsafe extern "C" fn dc_event_get_data2_int(event: *mut dc_event_t) -> libc:
        | EventType::ImapConnected(_)
        | EventType::SmtpMessageSent(_)
        | EventType::ImapMessageDeleted(_)
+        | EventType::ImapMessageMoved(_)
        | EventType::ImapInboxIdle
        | EventType::NewBlobFile(_)
        | EventType::DeletedBlobFile(_)
@@ -645,8 +664,7 @@ pub unsafe extern "C" fn dc_event_get_data2_int(event: *mut dc_event_t) -> libc:
        | EventType::OutgoingCallAccepted { .. }
        | EventType::CallEnded { .. }
        | EventType::EventChannelOverflow { .. }
-        | EventType::TransportsModified
-        | EventType::PinnedMessagesChanged { .. } => 0,
+        | EventType::TransportsModified => 0,
        EventType::MsgsChanged { msg_id, .. }
        | EventType::ReactionsChanged { msg_id, .. }
        | EventType::IncomingReaction { msg_id, .. }
@@ -712,6 +730,7 @@ pub unsafe extern "C" fn dc_event_get_data2_str(event: *mut dc_event_t) -> *mut
        | EventType::ImapConnected(msg)
        | EventType::SmtpMessageSent(msg)
        | EventType::ImapMessageDeleted(msg)
+        | EventType::ImapMessageMoved(msg)
        | EventType::NewBlobFile(msg)
        | EventType::DeletedBlobFile(msg)
        | EventType::Warning(msg)
@@ -747,8 +766,7 @@ pub unsafe extern "C" fn dc_event_get_data2_str(event: *mut dc_event_t) -> *mut
        | EventType::AccountsItemChanged
        | EventType::IncomingCallAccepted { .. }
        | EventType::WebxdcRealtimeAdvertisementReceived { .. }
-        | EventType::TransportsModified
-        | EventType::PinnedMessagesChanged { .. } => ptr::null_mut(),
+        | EventType::TransportsModified => ptr::null_mut(),
        EventType::IncomingCall {
            place_call_info, ..
        } => place_call_info.strdup(),
@@ -4016,13 +4034,13 @@ pub unsafe extern "C" fn dc_contact_get_last_seen(contact: *mut dc_contact_t) ->
 }

 #[unsafe(no_mangle)]
-pub unsafe extern "C" fn dc_contact_get_freshness(contact: *mut dc_contact_t) -> libc::c_int {
+pub unsafe extern "C" fn dc_contact_was_seen_recently(contact: *mut dc_contact_t) -> libc::c_int {
    if contact.is_null() {
-        eprintln!("ignoring careless call to dc_contact_get_freshness()");
+        eprintln!("ignoring careless call to dc_contact_was_seen_recently()");
        return 0;
    }
    let ffi_contact = unsafe { &*contact };
-    u32::from(ffi_contact.contact.get_freshness()) as libc::c_int
+    ffi_contact.contact.was_seen_recently() as libc::c_int
 }

 #[unsafe(no_mangle)]
@@ -47,6 +47,8 @@ impl Lot {
                Qr::AskVerifyGroup { grpname, .. } => Some(Cow::Borrowed(grpname)),
                Qr::AskJoinBroadcast { name, .. } => Some(Cow::Borrowed(name)),
                Qr::FprOk { .. } => None,
+                Qr::FprMismatch { .. } => None,
+                Qr::FprWithoutAddr { fingerprint, .. } => Some(Cow::Borrowed(fingerprint)),
                Qr::Account { domain } => Some(Cow::Borrowed(domain)),
                Qr::Backup2 { .. } => None,
                Qr::BackupTooNew { .. } => None,
@@ -101,6 +103,8 @@ impl Lot {
                Qr::AskVerifyGroup { .. } => LotState::QrAskVerifyGroup,
                Qr::AskJoinBroadcast { .. } => LotState::QrAskJoinBroadcast,
                Qr::FprOk { .. } => LotState::QrFprOk,
+                Qr::FprMismatch { .. } => LotState::QrFprMismatch,
+                Qr::FprWithoutAddr { .. } => LotState::QrFprWithoutAddr,
                Qr::Account { .. } => LotState::QrAccount,
                Qr::Backup2 { .. } => LotState::QrBackup2,
                Qr::BackupTooNew { .. } => LotState::QrBackupTooNew,
@@ -128,6 +132,8 @@ impl Lot {
                Qr::AskVerifyGroup { .. } => Default::default(),
                Qr::AskJoinBroadcast { .. } => Default::default(),
                Qr::FprOk { contact_id } => contact_id.to_u32(),
+                Qr::FprMismatch { contact_id } => contact_id.unwrap_or_default().to_u32(),
+                Qr::FprWithoutAddr { .. } => Default::default(),
                Qr::Account { .. } => Default::default(),
                Qr::Backup2 { .. } => Default::default(),
                Qr::BackupTooNew { .. } => Default::default(),
@@ -175,6 +181,12 @@ pub enum LotState {
    /// id=contact
    QrFprOk = 210,

+    /// id=contact
+    QrFprMismatch = 220,
+
+    /// text1=formatted fingerprint
+    QrFprWithoutAddr = 230,
+
    /// text1=domain
    QrAccount = 250,

@@ -1,6 +1,6 @@
 [package]
 name = "deltachat-jsonrpc-bindings"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 description = "Autogenerate DeltaChat JSON-RPC API bindings at build time"
 edition = "2024"
 license = "MPL-2.0"
@@ -54,5 +54,5 @@
  },
  "type": "module",
  "types": "dist/deltachat.d.ts",
-  "version": "2.63.0-dev"
+  "version": "2.61.0-dev"
 }
@@ -1,6 +1,6 @@
 [package]
 name = "deltachat-jsonrpc"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 description = "DeltaChat JSON-RPC API"
 edition = "2024"
 license = "MPL-2.0"
@@ -546,18 +546,6 @@ impl CommandApi {
        ctx.add_transport_from_qr(&qr).await
    }

-    /// Adds an initial transport on the chatmail relay that answers fastest
-    /// and lets the profile add further ones in the background.
-    ///
-    /// A `DCACCOUNT:` or `DCLOGIN:` `qr` code adds a single transport
-    /// while securejoin codes add the inviter's relays to the candidates.
-    ///
-    /// Does nothing if the profile already has a transport.
-    async fn init_transports(&self, account_id: u32, qr: Option<String>) -> Result<()> {
-        let ctx = self.get_context(account_id).await?;
-        ctx.init_transports(qr.as_deref()).await
-    }
-
    /// Returns the list of all email accounts that are used as a transport in the current profile.
    /// Use [Self::add_or_update_transport()] to add or change a transport
    /// and [Self::delete_transport()] to remove a transport.
@@ -13,6 +13,7 @@ pub enum Account {
    Configured {
        id: u32,
        display_name: Option<String>,
+        addr: Option<String>,
        // size: u32,
        profile_image: Option<String>,
        color: String,
@@ -28,6 +29,7 @@ impl Account {
    pub async fn from_context(ctx: &deltachat::context::Context, id: u32) -> Result<Self> {
        if ctx.is_configured().await? {
            let display_name = ctx.get_config(Config::Displayname).await?;
+            let addr = ctx.get_config(Config::Addr).await?;
            let profile_image = ctx.get_config(Config::Selfavatar).await?;
            let color = color_int_to_hex_string(
                Contact::get_by_id(ctx, ContactId::SELF)
@@ -39,6 +41,7 @@ impl Account {
            Ok(Account::Configured {
                id,
                display_name,
+                addr,
                profile_image,
                color,
                private_tag,
@@ -9,8 +9,6 @@ use deltachat::context::Context;
 use serde::{Deserialize, Serialize};
 use typescript_type_def::TypeDef;

-use crate::api::types::contact::ContactFreshness;
-
 use super::color_int_to_hex_string;

 #[derive(Serialize, TypeDef, schemars::JsonSchema)]
@@ -71,7 +69,7 @@ pub struct FullChat {
    is_muted: bool,
    ephemeral_timer: u32,
    can_send: bool,
-    freshness: ContactFreshness,
+    was_seen_recently: bool,
    mailing_list_address: Option<String>,
 }

@@ -94,17 +92,16 @@ impl FullChat {

        let can_send = chat.can_send(context).await?;

-        let freshness = if chat.get_type() == Chattype::Single {
+        let was_seen_recently = if chat.get_type() == Chattype::Single {
            match contact_ids.first() {
                Some(contact) => Contact::get_by_id(context, *contact)
                    .await
-                    .context("failed to load contact for get_freshness")?
-                    .get_freshness()
-                    .into(),
-                None => ContactFreshness::Normal,
+                    .context("failed to load contact for was_seen_recently")?
+                    .was_seen_recently(),
+                None => false,
            }
        } else {
-            ContactFreshness::Normal
+            false
        };

        let mailing_list_address = chat.get_mailinglist_addr().map(|s| s.to_string());
@@ -129,7 +126,7 @@ impl FullChat {
            is_muted: chat.is_muted(),
            ephemeral_timer,
            can_send,
-            freshness,
+            was_seen_recently,
            mailing_list_address,
        })
    }
@@ -140,7 +137,7 @@ impl FullChat {
 /// - fresh_message_counter
 /// - ephemeral_timer
 /// - self_in_group
-/// - freshness
+/// - was_seen_recently
 /// - can_send
 ///
 /// used when you only need the basic metadata of a chat like type, name, profile picture
@@ -11,8 +11,6 @@ use num_traits::cast::ToPrimitive;
 use serde::Serialize;
 use typescript_type_def::TypeDef;

-use crate::api::types::contact::ContactFreshness;
-
 use super::chat::JsonrpcChatType;
 use super::color_int_to_hex_string;
 use super::message::MessageViewtype;
@@ -70,7 +68,7 @@ pub enum ChatListItemFetchResult {
        is_contact_request: bool,
        /// contact id if this is a dm chat (for view profile entry in context menu)
        dm_chat_contact: Option<u32>,
-        freshness: ContactFreshness,
+        was_seen_recently: bool,
        last_message_type: Option<MessageViewtype>,
        last_message_id: Option<u32>,
    },
@@ -129,20 +127,22 @@ pub(crate) async fn get_chat_list_item_by_id(
        None => (None, None),
    };

-    let (dm_chat_contact, freshness) = if chat.get_type() == Chattype::Single {
+    let (dm_chat_contact, was_seen_recently) = if chat.get_type() == Chattype::Single {
        let chat_contacts = get_chat_contacts(ctx, chat_id).await?;
        let contact = chat_contacts.first();
-        let freshness = match contact {
+        let was_seen_recently = match contact {
            Some(contact) => Contact::get_by_id(ctx, *contact)
                .await
                .context("contact")?
-                .get_freshness()
-                .into(),
-            None => ContactFreshness::Normal,
+                .was_seen_recently(),
+            None => false,
        };
-        (contact.map(|contact_id| contact_id.to_u32()), freshness)
+        (
+            contact.map(|contact_id| contact_id.to_u32()),
+            was_seen_recently,
+        )
    } else {
-        (None, ContactFreshness::Normal)
+        (None, false)
    };

    let color = color_int_to_hex_string(chat.get_color(ctx).await?);
@@ -170,7 +170,7 @@ pub(crate) async fn get_chat_list_item_by_id(
        is_muted: chat.is_muted(),
        is_contact_request: chat.is_contact_request(),
        dm_chat_contact,
-        freshness,
+        was_seen_recently,
        last_message_type: message_type,
        last_message_id: last_msgid.map(|id| id.to_u32()),
    })
@@ -1,5 +1,4 @@
 use anyhow::Result;
-use deltachat::contact;
 use deltachat::context::Context;
 use deltachat::key::{DcKey, SignedPublicKey};
 use serde::Serialize;
@@ -7,27 +6,6 @@ use typescript_type_def::TypeDef;

 use super::color_int_to_hex_string;

-/// Freshness of a contact, based on when it was last seen.
-#[derive(Serialize, TypeDef, schemars::JsonSchema)]
-pub enum ContactFreshness {
-    /// Contact shall not be highlighted.
-    Normal,
-    /// Contact was seen recently.
-    RecentlySeen,
-    /// Contact was not seen for a long time.
-    Old,
-}
-
-impl From<contact::Freshness> for ContactFreshness {
-    fn from(freshness: contact::Freshness) -> Self {
-        match freshness {
-            contact::Freshness::Normal => ContactFreshness::Normal,
-            contact::Freshness::RecentlySeen => ContactFreshness::RecentlySeen,
-            contact::Freshness::Old => ContactFreshness::Old,
-        }
-    }
-}
-
 #[derive(Serialize, TypeDef, schemars::JsonSchema)]
 #[serde(rename = "Contact", rename_all = "camelCase")]
 pub struct ContactObject {
@@ -54,7 +32,7 @@ pub struct ContactObject {

    /// the contact's last seen timestamp
    last_seen: i64,
-    freshness: ContactFreshness,
+    was_seen_recently: bool,

    /// If the contact is a bot.
    is_bot: bool,
@@ -82,7 +60,7 @@ impl ContactObject {
            is_key_contact: contact.is_key_contact(),
            e2ee_avail: contact.e2ee_avail(context).await?,
            last_seen: contact.last_seen(),
-            freshness: contact.get_freshness().into(),
+            was_seen_recently: contact.was_seen_recently(),
            is_bot: contact.is_bot(),
        })
    }
@@ -44,6 +44,9 @@ pub enum EventType {
    /// Emitted when an IMAP message has been marked as deleted
    ImapMessageDeleted { msg: String },

+    /// Emitted when an IMAP message has been moved
+    ImapMessageMoved { msg: String },
+
    /// Emitted before going into IDLE on the Inbox folder.
    ImapInboxIdle,

@@ -258,15 +261,6 @@ pub enum EventType {
        chat_id: u32,
    },

-    /// The list of pinned messages for the chat has changed.
-    ///
-    /// Some message got pinned, or pinned message is unpinned or deleted.
-    #[serde(rename_all = "camelCase")]
-    PinnedMessagesChanged {
-        /// ID of the chat where the list of pinned messages changed.
-        chat_id: u32,
-    },
-
    /// Contact(s) created, renamed, blocked or deleted.
    #[serde(rename_all = "camelCase")]
    ContactsChanged {
@@ -502,6 +496,7 @@ impl From<CoreEventType> for EventType {
            CoreEventType::ImapConnected(msg) => ImapConnected { msg },
            CoreEventType::SmtpMessageSent(msg) => SmtpMessageSent { msg },
            CoreEventType::ImapMessageDeleted(msg) => ImapMessageDeleted { msg },
+            CoreEventType::ImapMessageMoved(msg) => ImapMessageMoved { msg },
            CoreEventType::ImapInboxIdle => ImapInboxIdle,
            CoreEventType::NewBlobFile(file) => NewBlobFile { file },
            CoreEventType::DeletedBlobFile(file) => DeletedBlobFile { file },
@@ -521,9 +516,6 @@ impl From<CoreEventType> for EventType {
                msg_id: msg_id.to_u32(),
                contact_id: contact_id.to_u32(),
            },
-            CoreEventType::PinnedMessagesChanged { chat_id } => PinnedMessagesChanged {
-                chat_id: chat_id.to_u32(),
-            },
            CoreEventType::IncomingReaction {
                chat_id,
                contact_id,
@@ -68,6 +68,16 @@ pub enum QrObject {
        /// Contact ID.
        contact_id: u32,
    },
+    /// Scanned fingerprint does not match the last seen fingerprint.
+    FprMismatch {
+        /// Contact ID.
+        contact_id: Option<u32>,
+    },
+    /// The scanned QR code contains a fingerprint but no e-mail address.
+    FprWithoutAddr {
+        /// Key fingerprint.
+        fingerprint: String,
+    },
    /// Ask the user if they want to create an account on the given domain.
    Account {
        /// Server domain name.
@@ -286,6 +296,11 @@ impl From<Qr> for QrObject {
                let contact_id = contact_id.to_u32();
                QrObject::FprOk { contact_id }
            }
+            Qr::FprMismatch { contact_id } => {
+                let contact_id = contact_id.map(|contact_id| contact_id.to_u32());
+                QrObject::FprMismatch { contact_id }
+            }
+            Qr::FprWithoutAddr { fingerprint } => QrObject::FprWithoutAddr { fingerprint },
            Qr::Account { domain } => QrObject::Account { domain },
            Qr::Backup2 {
                ref node_addr,
@@ -12,7 +12,7 @@ pub struct JsonrpcReaction {
    emoji: String,

    /// Emoji frequency.
-    count: u32,
+    count: usize,

    /// True if we reacted with this emoji.
    is_from_self: bool,
@@ -1,6 +1,6 @@
 [package]
 name = "deltachat-repl"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 license = "MPL-2.0"
 edition = "2024"
 repository = "https://github.com/chatmail/core"
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"

 [project]
 name = "deltachat-rpc-client"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 license = "MPL-2.0"
 description = "Python client for Delta Chat core JSON-RPC interface"
 classifiers = [
@@ -139,18 +139,6 @@ class Account:
        """Add a new transport using a QR code."""
        yield self._rpc.add_transport_from_qr.future(self.id, qr)

-    @futuremethod
-    def init_transports(self, qr: Optional[str] = None):
-        """Add an initial transport on the chatmail relay that answers fastest.
-
-        The profile then adds further ones in the background.
-        A ``DCACCOUNT:`` or ``DCLOGIN:`` ``qr`` code adds a single transport
-        while securejoin codes add the inviter's relays to the candidates.
-
-        Does nothing if the profile already has a transport.
-        """
-        yield self._rpc.init_transports.future(self.id, qr)
-
    def delete_transport(self, addr: str):
        """Delete a transport."""
        self._rpc.delete_transport(self.id, addr)
@@ -38,6 +38,7 @@ class EventType(str, Enum):
    IMAP_CONNECTED = "ImapConnected"
    SMTP_MESSAGE_SENT = "SmtpMessageSent"
    IMAP_MESSAGE_DELETED = "ImapMessageDeleted"
+    IMAP_MESSAGE_MOVED = "ImapMessageMoved"
    IMAP_INBOX_IDLE = "ImapInboxIdle"
    NEW_BLOB_FILE = "NewBlobFile"
    DELETED_BLOB_FILE = "DeletedBlobFile"
@@ -24,16 +24,8 @@ class DirectImap:

    def __init__(self, account: Account, addr=None, password=None) -> None:
        self.account = account
-        if addr is None or password is None:
-            transport = account.list_transports()[-1]
-        if addr is None:
-            self.addr = transport["addr"]
-        else:
-            self.addr = addr
-        if password is None:
-            self.password = transport["password"]
-        else:
-            self.password = password
+        self.addr = addr or account.get_config("addr")
+        self.password = password or account.get_config("mail_pw")
        self.logid = account.get_config("displayname") or id(account)
        self._idling = False
        self.connect()
@@ -24,12 +24,6 @@ def wait_for_imap_message(imap):
        time.sleep(1)


-def test_init_transports(acf):
-    account = acf.get_unconfigured_account()
-    account.init_transports(acf.get_account_qr())
-    assert len(account.list_transports()) == 1
-
-
 def test_add_second_address(acf) -> None:
    account = acf.new_configured_account()
    assert len(account.list_transports()) == 1
@@ -27,7 +27,7 @@ def test_qr_setup_contact(acf) -> None:

 def test_qr_setup_contact_svg(acf) -> None:
    alice = acf.new_configured_account()
-    _, _, domain = alice.list_transports()[0]["addr"].rpartition("@")
+    _, _, domain = alice.get_config("addr").rpartition("@")

    _qr_code, svg = alice.get_qr_code_svg()

@@ -43,7 +43,6 @@ def test_qr_setup_contact_svg(acf) -> None:
 def test_qr_securejoin(acf):
    alice, bob, fiona = acf.get_online_accounts(3)

-    alice.set_config("displayname", "Alice")
    # Setup second device for Alice
    # to test observing securejoin protocol.
    alice2 = alice.clone()
@@ -68,7 +67,7 @@ def test_qr_securejoin(acf):
    assert alice_contact_bob_snapshot.e2ee_avail

    snapshot = bob.wait_for_incoming_msg().get_snapshot()
-    assert snapshot.text == "You were added by Alice."
+    assert snapshot.text == "You were added by {}.".format(alice.get_config("addr"))

    bob_contact_alice = bob.create_contact(alice)
    bob_contact_alice_snapshot = bob_contact_alice.get_snapshot()
@@ -147,13 +146,17 @@ def test_qr_securejoin_broadcast(acf, all_devices_online):
            assert "invited you to join this channel" in first_msg.text
            assert first_msg.is_info

-        if not inviter_side:
+        if inviter_side:
+            member_added_msg = chat_msgs.pop(0).get_snapshot()
+            assert member_added_msg.text == f"Member {contact_snapshot.display_name} added."
+            assert member_added_msg.info_contact_id == contact_snapshot.id
+        else:
            if chat_msgs[0].get_snapshot().text == "You joined the channel.":
                member_added_msg = chat_msgs.pop(0).get_snapshot()
            else:
                member_added_msg = chat_msgs.pop(1).get_snapshot()
                assert member_added_msg.text == "You joined the channel."
-            assert member_added_msg.is_info
+        assert member_added_msg.is_info

        hello_msg = chat_msgs.pop(0).get_snapshot()
        assert hello_msg.text == "Hello everyone!"
@@ -218,7 +221,7 @@ def test_qr_securejoin_broadcast(acf, all_devices_online):
    snapshot = fiona.wait_for_incoming_msg().get_snapshot()
    assert snapshot.text == "You joined the channel."

-    get_broadcast(alice2).get_messages()[1].resend()
+    get_broadcast(alice2).get_messages()[2].resend()
    snapshot = fiona.wait_for_incoming_msg().get_snapshot()
    assert snapshot.text == "Hello everyone!"

@@ -500,9 +503,11 @@ def test_aeap_flow(acf):
    assert msg_in_1.text == msg_out.text

    logging.info("changing email account")
-    old_addr = ac1.list_transports()[0]["addr"]
-    ac1.add_transport_from_qr(acf.get_account_qr())
-    ac1.delete_transport(old_addr)
+    ac1.set_config("addr", addr)
+    ac1.set_config("mail_pw", password)
+    ac1.stop_io()
+    ac1.configure()
+    ac1.start_io()

    logging.info("sending second message")
    msg_out = chat.send_text("changed address").get_snapshot()
@@ -524,7 +529,6 @@ def test_securejoin_after_contact_resetup(acf) -> None:
    but different key fingerprint while a securejoin with that contact is still pending.
    """
    ac1, ac2, ac3 = acf.get_online_accounts(3)
-    ac3.set_config("displayname", "ac3")

    # ac3 creates a group with ac1.
    ac3_chat = ac3.create_group("Group")
@@ -536,7 +540,7 @@ def test_securejoin_after_contact_resetup(acf) -> None:

    # ac1 waits for member added message and creates a QR code.
    snapshot = ac1.wait_for_incoming_msg().get_snapshot()
-    assert snapshot.text == "You were added by ac3."
+    assert snapshot.text == "You were added by {}.".format(ac3.get_config("addr"))
    ac1_qr_code = snapshot.chat.get_qr_code()

    # ac2 sets up contact with ac1
@@ -576,8 +580,6 @@ def test_securejoin_after_contact_resetup(acf) -> None:

 def test_withdraw_securejoin_qr(acf):
    alice, bob = acf.get_online_accounts(2)
-    alice.set_config("displayname", "Alice")
-    bob.set_config("displayname", "Bob")

    logging.info("Alice creates a group")
    alice_chat = alice.create_group("Group")
@@ -590,11 +592,11 @@ def test_withdraw_securejoin_qr(acf):
    alice.clear_all_events()

    snapshot = bob.wait_for_incoming_msg().get_snapshot()
-    assert snapshot.text == "You were added by Alice."
+    assert snapshot.text == "You were added by {}.".format(alice.get_config("addr"))
    bob_chat.leave()

    snapshot = alice.get_message_by_id(alice.wait_for_msgs_changed_event().msg_id).get_snapshot()
-    assert snapshot.text == "Group left by Bob."
+    assert snapshot.text == "Group left by {}.".format(bob.get_config("addr"))

    logging.info("Alice withdraws QR code.")
    qr = alice.check_qr(qr_code)
@@ -155,7 +155,7 @@ def test_list_transports(acf) -> None:
 def test_account(acf) -> None:
    alice, bob = acf.get_online_accounts(2)

-    bob_addr = bob.get_config("configured_addr")
+    bob_addr = bob.get_config("addr")
    alice_contact_bob = alice.create_contact(bob, "Bob")
    alice_chat_bob = alice_contact_bob.create_chat()
    alice_chat_bob.send_text("Hello!")
@@ -318,7 +318,7 @@ def test_chat(acf) -> None:
 def test_contact(acf) -> None:
    alice, bob = acf.get_online_accounts(2)

-    bob_addr = bob.get_config("configured_addr")
+    bob_addr = bob.get_config("addr")
    alice_contact_bob = alice.create_contact(bob, "Bob")

    assert alice_contact_bob == alice.get_contact_by_id(alice_contact_bob.id)
@@ -604,6 +604,7 @@ def test_import_export_online_all(acf, tmp_path, rpcdata, log) -> None:
    (ac1, some1) = acf.get_online_accounts(2)

    log.section("create some chat content")
+    some1_addr = some1.get_config("addr")
    chat1 = ac1.create_contact(some1).create_chat()
    chat1.send_text("msg1")
    assert len(ac1.get_contacts()) == 1
@@ -621,6 +622,7 @@ def test_import_export_online_all(acf, tmp_path, rpcdata, log) -> None:
        contacts = ac.get_contacts()
        assert len(contacts) == 1
        contact2 = contacts[0]
+        assert contact2.get_snapshot().address == some1_addr
        chat2 = contact2.create_chat()
        messages = chat2.get_messages()
        assert len(messages) == 3 + E2EE_INFO_MSGS
@@ -1185,6 +1187,7 @@ def test_leave_broadcast(acf, all_devices_online):

    def check_account(ac, contact, inviter_side, please_wait_info_msg=False):
        chat = get_broadcast(ac)
+        contact_snapshot = contact.get_snapshot()
        chat_msgs = chat.get_messages()

        encrypted_msg = chat_msgs.pop(0).get_snapshot()
@@ -1196,11 +1199,14 @@ def test_leave_broadcast(acf, all_devices_online):
            assert "invited you to join this channel" in first_msg.text
            assert first_msg.is_info

-        if not inviter_side:
-            member_added_msg = chat_msgs.pop(0).get_snapshot()
+        member_added_msg = chat_msgs.pop(0).get_snapshot()
+        if inviter_side:
+            assert member_added_msg.text == f"Member {contact_snapshot.display_name} added."
+        else:
            assert member_added_msg.text == "You joined the channel."
-            assert member_added_msg.is_info
+        assert member_added_msg.is_info

+        if not inviter_side:
            leave_msg = chat_msgs.pop(0).get_snapshot()
            assert leave_msg.text == "You left the channel."

@@ -1,6 +1,6 @@
 [package]
 name = "deltachat-rpc-server"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 description = "DeltaChat JSON-RPC server"
 edition = "2024"
 license = "MPL-2.0"
@@ -15,5 +15,5 @@
  },
  "type": "module",
  "types": "index.d.ts",
-  "version": "2.63.0-dev"
+  "version": "2.61.0-dev"
 }
@@ -69,11 +69,8 @@ skip = [
     { name = "derive_more-impl", version = "1.0.0" },
     { name = "derive_more", version = "1.0.0" },
     { name = "event-listener", version = "2.5.3" },
-     { name = "foldhash", version = "0.1.5" },
     { name = "getrandom", version = "0.2.12" },
     { name = "getrandom", version = "0.3.3" },
-     { name = "hashbrown", version = "0.15.4" },
-     { name = "hashbrown", version = "0.16.1" },
     { name = "heck", version = "0.4.1" },
     { name = "http", version = "0.2.12" },
     { name = "hybrid-array", version = "0.2.3" },
@@ -630,12 +630,9 @@ CREATE TABLE broadcast_secrets(


 -- Candidate chatmail relays for automatic relay management.
-- Holds the hosts a QR code contributed and the default relays already tried;
-- the default list itself lives in `autorelay.rs` and is not stored here.
 CREATE TABLE relay_candidates(
    host TEXT PRIMARY KEY NOT NULL,
-    -- Timestamp of the last connection attempt, 0 if the host was never tried.
-    last_tried INTEGER NOT NULL DEFAULT 0
+    last_tried INTEGER NOT NULL DEFAULT 0 -- Timestamp of the last connection attempt.
 ) STRICT;

 CREATE TABLE transports (
@@ -683,11 +680,7 @@ CREATE TABLE imap (
    transport_id INTEGER NOT NULL, -- ID of the transport in the `transports` table.
    rfc724_mid TEXT NOT NULL, -- Message-ID header
    folder TEXT NOT NULL, -- IMAP folder
-
-    -- Destination folder. Empty string means that the message shall be deleted.
-    -- Since we don't move messages between IMAP folders anymore,
-    -- this is always either empty or equal to `folder`.
-    target TEXT NOT NULL,
+    target TEXT NOT NULL, -- Destination folder. Empty string means that the message shall be deleted.
    uid INTEGER NOT NULL, -- UID
    uidvalidity INTEGER NOT NULL,
    UNIQUE (transport_id, folder, uid, uidvalidity)
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"

 [project]
 name = "deltachat"
-version = "2.63.0-dev"
+version = "2.61.0-dev"
 license = "MPL-2.0"
 description = "Python bindings for the Delta Chat Core library using CFFI against the Rust-implemented libdeltachat"
 readme = "README.rst"
@@ -1 +1 @@
-2026-09-22
+2026-09-11
@@ -169,7 +169,9 @@ impl Accounts {
            .with_push_subscriber(self.push_subscriber.clone())
            .build()
            .await?;
-        ctx.open().await?;
+        // Try to open without a passphrase,
+        // but do not return an error if account is passphare-protected.
+        ctx.open("".to_string()).await?;

        self.accounts.insert(account_config.id, ctx);
        self.emit_event(EventType::AccountsChanged);
@@ -819,7 +821,9 @@ impl Config {
                .build()
                .await
                .with_context(|| format!("failed to create context from file {dbfile:?}"))?;
-            ctx.open().await?;
+            // Try to open without a passphrase,
+            // but do not return an error if account is passphare-protected.
+            ctx.open("".to_string()).await?;

            accounts.insert(account_config.id, ctx);
        }
@@ -1268,6 +1272,52 @@ mod tests {

        Ok(())
    }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn test_encrypted_account() -> Result<()> {
+        let dir = tempfile::tempdir().context("failed to create tempdir")?;
+        let p: PathBuf = dir.path().join("accounts");
+
+        let writable = true;
+        let mut accounts = Accounts::new(p.clone(), writable)
+            .await
+            .context("failed to create accounts manager")?;
+
+        assert_eq!(accounts.accounts.len(), 0);
+        let account_id = accounts
+            .add_closed_account()
+            .await
+            .context("failed to add closed account")?;
+        let account = accounts
+            .get_selected_account()
+            .context("failed to get account")?;
+        assert_eq!(account.id, account_id);
+        let passphrase_set_success = account
+            .open("foobar".to_string())
+            .await
+            .context("failed to set passphrase")?;
+        assert!(passphrase_set_success);
+        drop(accounts);
+
+        let writable = false;
+        let accounts = Accounts::new(p.clone(), writable)
+            .await
+            .context("failed to create second accounts manager")?;
+        let account = accounts
+            .get_selected_account()
+            .context("failed to get account")?;
+        assert_eq!(account.is_open().await, false);
+
+        // Try wrong passphrase.
+        assert_eq!(account.open("barfoo".to_string()).await?, false);
+        assert_eq!(account.open("".to_string()).await?, false);
+
+        assert_eq!(account.open("foobar".to_string()).await?, true);
+        assert_eq!(account.is_open().await, true);
+
+        Ok(())
+    }
+
    /// Tests that accounts share stock string translations.
    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
    async fn test_accounts_share_translations() -> Result<()> {
@@ -1,24 +1,29 @@
-//! # Automatic multi-relay onboarding
+//! # Automatic relay handling (experimental, still in development)
 //!
-//! Support for automatically onboarding a profile on transport
-//! candidates without the user choosing a relay.
+//! Chatmail relays create an account on first login,
+//! so a profile can add further transports on its own without user interaction.
+//! Candidate hosts come from the `relay_candidates` table,
+//! which migrations seed with a list of known chatmail relays.
+//!
+//! Status of implementation:
+//! Additions are attempted right before going into IMAP IDLE,
+//! i.e. only while connected and with nothing more important to do,
+//! and only if a UI opted in via [`Config::Autorelay`].
+//! Once a profile has reached `NUM_TRANSPORTS_TARGET` transports,
+//! [`Config::AutorelayFinished`] is set and nothing is ever added again,
+//! so deleting a transport later does not pull in a replacement.

-use std::collections::BTreeMap;
 use std::pin::Pin;

-use anyhow::{Result, format_err};
+use anyhow::Result;
 use deltachat_contact_tools::addr_normalize;
 use rand::distr::{Alphanumeric, SampleString};
-use rand::seq::{IndexedRandom, SliceRandom};
-use rusqlite::Transaction;
-use tokio::task::JoinSet;
+use rand::seq::IndexedRandom;

 use crate::config::{self, Config};
-use crate::configure::{EnteredLoginParam, SILENT_PROGRESS, configure};
 use crate::log::{LogExt, warn};
 use crate::login_param::{EnteredCertificateChecks, EnteredImapLoginParam};
-use crate::net::{connect_tcp, proxy::ProxyConfig};
-use crate::{context::Context, tools::time};
+use crate::{configure::EnteredLoginParam, context::Context, tools::time};

 /// The target number of transports.
 const NUM_TRANSPORTS_TARGET: usize = 3;
@@ -27,87 +32,6 @@ const AUTOMATIC_ADDITION_DEBOUNCE_SECONDS: i64 = 60 * 60; // one hour
 /// How long we ignore a relay candidate after failing to connect to it:
 const BACKOFF_PERIOD_FOR_NOT_WORKING_RELAY: i64 = 60 * 60 * 24 * 7; // one week

-/// Sorted relay list a profile can attempt to onboard on without the user choosing one.
-const DEFAULT_RELAY_CANDIDATES: &[&str] = &[
-    "chat.adminforge.de", // iroh relay 404s
-    "chat.me.ke",
-    "chat.nuvon.app",
-    "chat.tinydispatch.org",
-    "chat.vim.wtf",
-    "chatmail.uk",
-    "chtml.ca",
-    "deltachat.me",
-    "e2e.sus.fr",
-    "e2ee.wang",
-    "mailchat.pl",
-    "nchrcht.la10cy.net",
-    "nine.testrun.org",
-    "sweetfern.net",
-    "tarpit.fun",
-];
-
-/// Records the hosts of `addrs` as relay candidates.
-pub(crate) async fn add_relay_candidates(context: &Context, addrs: &[String]) -> Result<()> {
-    context
-        .sql
-        .transaction(|tx| hosts_of(addrs).try_for_each(|host| save_relay_candidate(tx, host, 0)))
-        .await
-}
-
-/// Adds a first transport on the relay candidate that answers fastest.
-///
-/// All candidates are probed at once with a TCP connection to their HTTPS port
-/// and configured in the order in which the connections complete,
-/// stopping at the first success. Candidates that fail the probe are skipped.
-/// Answering TCP fastest is used as a network proximity measure,
-/// which keeps latency low for initial onboarding,
-/// and it avoids relays that are down or black-holing traffic.
-pub(crate) async fn add_transport_from_candidates(
-    context: &Context,
-    skip_network: bool,
-) -> Result<()> {
-    let mut candidates = triable_relay_candidates(context, time()).await?;
-    candidates.shuffle(&mut rand::rng());
-    let mut probes = JoinSet::new();
-    let proxy_config = ProxyConfig::load(context).await?;
-    let load_cache = false;
-    for host in candidates {
-        let ctx = context.clone();
-        let proxy_config = proxy_config.clone();
-        probes.spawn(async move {
-            let res = match proxy_config {
-                _ if skip_network => Ok(()),
-                Some(proxy) => proxy.connect(&ctx, &host, 443, load_cache).await.map(drop),
-                None => connect_tcp(&ctx, &host, 443, load_cache).await.map(drop),
-            };
-            (host, res)
-        });
-    }
-
-    let mut last_err = format_err!("No relay candidates");
-    let mark_as_autorelay = true;
-    while let Some(res) = probes.join_next().await {
-        let (host, res) = res?;
-        if let Err(err) = res {
-            warn!(context, "Failed to connect to relay {host}: {err:#}.");
-            last_err = err;
-            continue;
-        }
-        let param = login_param_from_host(&host, mark_as_autorelay);
-        match configure(context, &param, skip_network).await {
-            Ok(()) => {
-                info!(context, "Added a transport on relay {host}.");
-                return Ok(());
-            }
-            Err(err) => {
-                warn!(context, "Failed to add relay {host}: {err:#}.");
-                last_err = err;
-            }
-        }
-    }
-    Err(last_err)
-}
-
 pub(crate) fn maybe_add_additional_relays(
    context: Context,
 ) -> Pin<Box<dyn Future<Output = ()> + Send>> {
@@ -169,7 +93,10 @@ async fn maybe_add_additional_relays_inner(context: &Context, skip_network: bool
            return Ok(relay_added);
        }

-        let candidates = triable_relay_candidates(context, now).await?;
+        // First, query all candidates that were not tried since `BACKOFF_PERIOD_FOR_NOT_WORKING_RELAY` seconds.
+        // Hosts that are already used are excluded.
+        let candidates = load_relay_candidates(context, now).await?;
+
        let Some(host) = candidates.choose(&mut rand::rng()) else {
            info!(
                context,
@@ -186,13 +113,14 @@ async fn maybe_add_additional_relays_inner(context: &Context, skip_network: bool

        context
            .sql
-            .transaction(|tx| save_relay_candidate(tx, host, now))
+            .execute(
+                "UPDATE relay_candidates SET last_tried=? WHERE host=?",
+                (now, host),
+            )
            .await?;
        let mark_as_autorelay = true;
        let param = login_param_from_host(host, mark_as_autorelay);
-        let res = SILENT_PROGRESS
-            .scope((), configure(context, &param, skip_network))
-            .await;
+        let res = crate::configure::configure(context, &param, skip_network).await;
        if let Err(e) = res {
            warn!(
                context,
@@ -207,49 +135,30 @@ async fn maybe_add_additional_relays_inner(context: &Context, skip_network: bool
    Ok(relay_added)
 }

-async fn triable_relay_candidates(context: &Context, now: i64) -> Result<Vec<String>> {
+async fn load_relay_candidates(context: &Context, now: i64) -> Result<Vec<String>, anyhow::Error> {
    let cutoff_timestamp = now.saturating_sub(BACKOFF_PERIOD_FOR_NOT_WORKING_RELAY);
-    let mut last_tried: BTreeMap<String, i64> = context
+    let candidates: Vec<String> = context
        .sql
-        .query_map_collect("SELECT host, last_tried FROM relay_candidates", (), |row| {
-            Ok((row.get(0)?, row.get(1)?))
-        })
+        .query_map_vec(
+            // This also selects candidates which have last_tried in the future,
+            // essentially treating them as never tried,
+            // so if some timestamp far in the future is accidentally stored,
+            // we are not stuck never trying the candidate.
+            // After trying the candidate, last_tried will be corrected to the current time.
+            "SELECT host FROM relay_candidates WHERE (last_tried<? OR last_tried>?)
+                AND NOT EXISTS (
+                    SELECT 1
+                    FROM transports
+                    WHERE substr(addr, instr(addr, '@') + 1) = host
+                )",
+            (cutoff_timestamp, now),
+            |row| Ok(row.get::<_, String>(0)?),
+        )
        .await?;
-    for host in DEFAULT_RELAY_CANDIDATES {
-        last_tried.entry(host.to_string()).or_insert(0);
-    }
-    let self_addrs = context.get_self_addrs().await?;
-    let used_hosts: Vec<&str> = hosts_of(&self_addrs).collect();
-
-    // We also try candidates which have `last_tried` in the future,
-    // which on next failure get `last_tried` reset to the current time.
-    let candidates = last_tried
-        .into_iter()
-        .filter(|(host, last_tried)| {
-            (*last_tried < cutoff_timestamp || *last_tried > now)
-                && !used_hosts.contains(&host.as_str())
-        })
-        .map(|(host, _)| host)
-        .collect();

    Ok(candidates)
 }

-/// Returns the host of each address in `addrs`.
-fn hosts_of(addrs: &[String]) -> impl Iterator<Item = &str> {
-    addrs.iter().filter_map(|a| Some(a.rsplit_once('@')?.1))
-}
-
-/// Records `host` as a relay candidate, overwriting a stored `last_tried`.
-fn save_relay_candidate(tx: &Transaction, host: &str, last_tried: i64) -> Result<()> {
-    tx.execute(
-        "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)
-        ON CONFLICT(host) DO UPDATE SET last_tried=excluded.last_tried",
-        (host, last_tried),
-    )?;
-    Ok(())
-}
-
 pub(crate) fn login_param_from_host(host: &str, mark_as_autorelay: bool) -> EnteredLoginParam {
    let rng = &mut rand::rng();
    let username = Alphanumeric.sample_string(rng, 9);
@@ -1,150 +1,42 @@
 use std::time::Duration;

 use super::*;
-use crate::EventType;
-use crate::test_utils::{TestContext, TestContextManager};
+use crate::test_utils::TestContext;
 use crate::tools::SystemTime;

-/// Tests that the default relays are candidates without a row in the table.
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_triable_relay_candidates_defaults() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let t = &tcm.unconfigured().await;
-    let now = time();
-
-    assert!(DEFAULT_RELAY_CANDIDATES.is_sorted());
-    let mut candidates = triable_relay_candidates(t, now).await?;
-    candidates.sort();
-    assert_eq!(candidates, DEFAULT_RELAY_CANDIDATES);
-
-    let tried = DEFAULT_RELAY_CANDIDATES[0];
-    save_relay_candidates(t, &[tried], now).await?;
-    let candidates = triable_relay_candidates(t, now).await?;
-    assert_eq!(candidates.len(), DEFAULT_RELAY_CANDIDATES.len() - 1);
-    assert!(!candidates.contains(&tried.to_string()));
-
-    Ok(())
-}
-
-/// Tests that a transport is added on a candidate from the given addresses.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_add_transport_from_candidates() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let t = &tcm.unconfigured().await;
-    mark_defaults_tried(t, time()).await?;
-    let addrs_from_qr = [
-        "alice@example.org".to_string(),
-        "bob@example.org".to_string(),
-    ];
-    let skip_network = true;
-    add_relay_candidates(t, &addrs_from_qr).await?;
-    add_transport_from_candidates(t, skip_network).await?;
-
-    let transports = t.list_transports().await?;
-    assert_eq!(transports.len(), 1);
-    assert!(transports[0].addr.ends_with("@example.org"));
-    let untried = untried_relay_candidates(t).await?;
-    assert_eq!(untried, ["example.org"]);
-    assert!(configure_progress_emitted(t).await);
-
-    Ok(())
-}
-
-/// Tests correct add_transport_from_candidates error handling.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_add_transport_from_candidates_failure() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let t = &tcm.unconfigured().await;
-    mark_defaults_tried(t, time()).await?;
-    save_relay_candidates(t, &["bad host", "worse host"], 0).await?;
-
-    let skip_network = true;
-    let err = add_transport_from_candidates(t, skip_network)
-        .await
-        .unwrap_err();
-    assert!(format!("{err:#}").contains("Bad email-address"));
-    assert!(!t.is_configured().await?);
-    let untried = untried_relay_candidates(t).await?;
-    assert_eq!(untried, ["bad host", "worse host"]);
-    t.assert_warns_or_errors(&[
-        "Failed to add relay bad host",
-        "Failed to add relay worse host",
-    ])
-    .await;
-
-    Ok(())
-}
-
-async fn untried_relay_candidates(t: &TestContext) -> Result<Vec<String>> {
-    t.sql
-        .query_map_vec(
-            "SELECT host FROM relay_candidates WHERE last_tried=0 ORDER BY host",
-            (),
-            |row| Ok(row.get(0)?),
-        )
-        .await
-}
-
-async fn save_relay_candidates(t: &TestContext, hosts: &[&str], last_tried: i64) -> Result<()> {
-    t.sql
-        .transaction(|tx| {
-            for host in hosts {
-                save_relay_candidate(tx, host, last_tried)?;
-            }
-            Ok(())
-        })
-        .await
-}
-
-/// Keeps the default relays out of `triable_relay_candidates()`.
-async fn mark_defaults_tried(t: &TestContext, now: i64) -> Result<()> {
-    save_relay_candidates(t, DEFAULT_RELAY_CANDIDATES, now).await
-}
-
-/// Consumes emitted events, telling whether a configure progress is among them.
-async fn configure_progress_emitted(t: &TestContext) -> bool {
-    t.evtracker
-        .get_matching_opt(t, |evt| matches!(evt, EventType::ConfigureProgress { .. }))
-        .await
-        .is_some()
-}
-
-/// Tests that saving a candidate overwrites its stored timestamp.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_save_relay_candidate() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let t = &tcm.unconfigured().await;
-    let now = time();
-
-    for last_tried in [0, now, 0] {
-        t.sql
-            .transaction(|tx| save_relay_candidate(tx, "relay.example", last_tried))
-            .await?;
-        let stored: Option<i64> = t
-            .sql
-            .query_get_value(
-                "SELECT last_tried FROM relay_candidates WHERE host=?",
-                ("relay.example",),
-            )
-            .await?;
-        assert_eq!(stored, Some(last_tried));
-    }
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_triable_relay_candidates_single() -> Result<()> {
+async fn test_load_relay_candidates_single() -> Result<()> {
    let t = &TestContext::new_alice().await;
    enable_config(t).await;
    let now = time();

-    mark_defaults_tried(t, now).await?;
+    t.sql.execute("DELETE FROM relay_candidates", ()).await?;

-    save_relay_candidates(t, &["never_tried.example", "example.org"], 0).await?;
-    save_relay_candidates(t, &["recent.example"], now).await?;
+    // This host should be returned by load_relay_candidates():
+    t.sql
+        .execute(
+            "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+            ("never_tried.example", 0),
+        )
+        .await?;

-    let candidates = triable_relay_candidates(t, now).await?;
+    // This host was recently tried and should not be returned:
+    t.sql
+        .execute(
+            "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+            ("recent.example", now),
+        )
+        .await?;
+
+    // This host is already in use (alice@example.org) and should not be returned:
+    t.sql
+        .execute(
+            "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+            ("example.org", 0),
+        )
+        .await?;
+
+    let candidates = load_relay_candidates(t, now).await?;

    assert_eq!(candidates, vec!["never_tried.example".to_string()]);

@@ -152,15 +44,22 @@ async fn test_triable_relay_candidates_single() -> Result<()> {
 }

 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_triable_relay_candidates_multiple() -> Result<()> {
+async fn test_load_relay_candidates_multiple() -> Result<()> {
    let t = &TestContext::new().await;
    enable_config(t).await;
    let now = time();

-    mark_defaults_tried(t, now).await?;
-    save_relay_candidates(t, &["a.example", "b.example", "c.example"], 0).await?;
+    t.sql.execute("DELETE FROM relay_candidates", ()).await?;
+    for host in ["a.example", "b.example", "c.example"] {
+        t.sql
+            .execute(
+                "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+                (host, 0),
+            )
+            .await?;
+    }

-    let mut candidates = triable_relay_candidates(t, now).await?;
+    let mut candidates = load_relay_candidates(t, now).await?;
    candidates.sort();

    assert_eq!(
@@ -261,8 +160,13 @@ async fn test_maybe_add_additional_relays_add_one() -> Result<()> {
    enable_config(t).await;
    let now = time();

-    mark_defaults_tried(t, now).await?;
-    save_relay_candidates(t, &["relay.example"], 0).await?;
+    t.sql.execute("DELETE FROM relay_candidates", ()).await?;
+    t.sql
+        .execute(
+            "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+            ("relay.example", 0),
+        )
+        .await?;

    let transports_before = t.count_transports().await?;

@@ -275,7 +179,6 @@ async fn test_maybe_add_additional_relays_add_one() -> Result<()> {

    let transports_after = t.count_transports().await?;
    assert_eq!(transports_after, transports_before + 1);
-    assert!(!configure_progress_emitted(t).await);

    Ok(())
 }
@@ -286,8 +189,15 @@ async fn test_maybe_add_additional_relays_add_multiple() -> Result<()> {
    enable_config(t).await;
    let now = time();

-    mark_defaults_tried(t, now).await?;
-    save_relay_candidates(t, &["a.example", "b.example", "c.example", "d.example"], 0).await?;
+    t.sql.execute("DELETE FROM relay_candidates", ()).await?;
+    for host in ["a.example", "b.example", "c.example", "d.example"] {
+        t.sql
+            .execute(
+                "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+                (host, 0),
+            )
+            .await?;
+    }

    let skip_network = true;
    let relay_added = maybe_add_additional_relays_inner(t, skip_network).await?;
@@ -308,9 +218,14 @@ async fn test_maybe_add_additional_relays_failure() -> Result<()> {
    enable_config(t).await;
    let now = time();

-    mark_defaults_tried(t, now).await?;
+    t.sql.execute("DELETE FROM relay_candidates", ()).await?;
    for i in 1..10 {
-        save_relay_candidates(t, &[format!("{i}.invalid.example").as_str()], 0).await?;
+        t.sql
+            .execute(
+                "INSERT INTO relay_candidates (host, last_tried) VALUES (?, ?)",
+                (format!("{i}.invalid.example"), 0),
+            )
+            .await?;
    }

    let transports_before = t.count_transports().await?;
@@ -339,7 +254,7 @@ async fn test_maybe_add_additional_relays_failure() -> Result<()> {

    // ...but not all, because there might be many relay candidates
    // and we don't want to try all of them in a single call:
-    assert_eq!(triable_relay_candidates(t, now).await?.is_empty(), false);
+    assert_eq!(load_relay_candidates(t, now).await?.is_empty(), false);

    t.assert_warns_or_errors(&[
        "DNS lookup with memory cache failure",
@@ -2895,11 +2895,11 @@ async fn create_send_msg_jobs(context: &Context, msg: &mut Message) -> Result<Ve
    let (queued_msg, side_effects) = queued_msg_pair;

    if needs_encryption && !is_encrypted {
-        let addr = context.get_config(Config::ConfiguredAddr).await?;
+        // FIXME: remove this message? We don't know yet which provider we are going to send the message through.
+        let addr = context.get_primary_self_addr().await?;
        let text = stock_str::unencrypted_email(
            context,
-            addr.unwrap_or_default()
-                .split('@')
+            addr.split('@')
                .nth(1)
                .unwrap_or_default(),
        )
@@ -3918,7 +3918,15 @@ pub(crate) async fn add_contact_to_chat_ext(
        msg.viewtype = Viewtype::Text;

        let contact_addr = contact.get_addr().to_lowercase();
-        let added_by = ContactId::SELF;
+        let added_by = if from_handshake && chat.typ == Chattype::OutBroadcast {
+            // The contact was added via a QR code rather than explicit user action,
+            // so it could be confusing to say 'You added member Alice'.
+            // And in a broadcast, SELF is the only one who can add members,
+            // so, no information is lost by just writing 'Member Alice added' instead.
+            ContactId::UNDEFINED
+        } else {
+            ContactId::SELF
+        };
        msg.text = stock_str::msg_add_member_local(context, contact.id, added_by).await;
        msg.param.set_cmd(SystemMessage::MemberAddedToGroup);
        msg.param.set(Param::Arg, contact_addr);
@@ -3932,11 +3940,6 @@ pub(crate) async fn add_contact_to_chat_ext(
                .await?
                .context("Failed to find broadcast shared secret")?;
            msg.param.set(PARAM_BROADCAST_SECRET, secret);
-
-            // We don't show "member added" info-messages in channels,
-            // because there can be a lot members added,
-            // and these messages would clutter the timeline.
-            msg.hidden = true;
        }
        send_msg(context, chat_id, &mut msg).await?;

@@ -3985,7 +3988,7 @@ ORDER BY timestamp DESC, id DESC -- final ORDER BY is needed as UNION does not g
            (
                chat_id,
                Viewtype::Webxdc,
-                constants::N_MSGS_TO_NEW_BROADCAST_MEMBER as u32,
+                constants::N_MSGS_TO_NEW_BROADCAST_MEMBER,
                ContactId::INFO,
            ),
            |row: &rusqlite::Row| Ok(row.get::<_, MsgId>(0)?),
@@ -5104,7 +5107,7 @@ async fn set_contacts_by_fingerprints(
    if contacts == contacts_old {
        return Ok(());
    }
-    context
+    let broadcast_contacts_added = context
        .sql
        .transaction(move |transaction| {
            // For broadcast channels, we only add members,
@@ -5121,12 +5124,31 @@ async fn set_contacts_by_fingerprints(
            let mut statement = transaction.prepare(
                "INSERT OR IGNORE INTO chats_contacts (chat_id, contact_id) VALUES (?, ?)",
            )?;
+            let mut broadcast_contacts_added = Vec::new();
            for contact_id in &contacts {
-                statement.execute((id, contact_id))?;
+                if statement.execute((id, contact_id))? > 0 && chat.typ == Chattype::OutBroadcast {
+                    broadcast_contacts_added.push(*contact_id);
+                }
            }
-            Ok(())
+            Ok(broadcast_contacts_added)
        })
        .await?;
+    let timestamp = time();
+    for added_id in broadcast_contacts_added {
+        let msg = stock_str::msg_add_member_local(context, added_id, ContactId::UNDEFINED).await;
+        add_info_msg_with_cmd(
+            context,
+            id,
+            &msg,
+            SystemMessage::MemberAddedToGroup,
+            Some(timestamp),
+            timestamp,
+            None,
+            Some(ContactId::SELF),
+            Some(added_id),
+        )
+        .await?;
+    }
    context.emit_event(EventType::ChatModified(id));
    Ok(())
 }
@@ -3003,13 +3003,13 @@ async fn test_broadcast_change_name() -> Result<()> {

        tcm.section("Bob receives the name-change system message");
        let msg = bob.recv_msg(&sent).await;
-        assert_eq!(msg.subject, "My great broadcast");
+        assert_eq!(msg.subject, "Re: My great broadcast");
        let bob_chat = Chat::load_from_db(bob, msg.chat_id).await?;
        assert_eq!(bob_chat.name, "My great broadcast");

        tcm.section("Fiona receives the name-change system message");
        let msg = fiona.recv_msg(&sent).await;
-        assert_eq!(msg.subject, "My great broadcast");
+        assert_eq!(msg.subject, "Re: My great broadcast");
        let fiona_chat = Chat::load_from_db(fiona, msg.chat_id).await?;
        assert_eq!(fiona_chat.name, "My great broadcast");
    }
@@ -3343,27 +3343,41 @@ async fn test_broadcast_recipients_sync1() -> Result<()> {
    alice2.assert_warn("unknown grpid").await;

    let member_added = alice1.pop_sent_msg().await;
-    alice2.recv_msg_trash(&member_added).await;
+    let a2_charlie_added = alice2.recv_msg(&member_added).await;
    let _c_member_added = charlie.recv_msg(&member_added).await;
+    let a2_chatlist = Chatlist::try_load(alice2, 0, Some("Channel"), None).await?;
+    assert_eq!(a2_chatlist.get_msg_id(0)?.unwrap(), a2_charlie_added.id);

    // Alice1 will now sync the full member list to Alice2:
    sync(alice1, alice2).await;
    let a2_bob_contact = alice2.add_or_lookup_contact_id(bob).await;
    let a2_charlie_contact = alice2.add_or_lookup_contact_id(charlie).await;
    let a2_chatlist = Chatlist::try_load(alice2, 0, Some("Channel"), None).await?;
-    let a2_chat_id = a2_chatlist.get_chat_id(0).unwrap();
+    let msg_id = a2_chatlist.get_msg_id(0)?.unwrap();
+    let a2_bob_added = Message::load_from_db(alice2, msg_id).await?;
+    assert_ne!(a2_bob_added.id, a2_charlie_added.id);
+    assert_eq!(
+        a2_bob_added.text,
+        stock_str::msg_add_member_local(alice2, a2_bob_contact, ContactId::UNDEFINED).await
+    );
+    assert_eq!(a2_bob_added.from_id, ContactId::SELF);
+    assert_eq!(
+        a2_bob_added.param.get_cmd(),
+        SystemMessage::MemberAddedToGroup
+    );
+    assert_eq!(
+        ContactId::new(
+            a2_bob_added
+                .param
+                .get_int(Param::ContactAddedRemoved)
+                .unwrap()
+                .try_into()
+                .unwrap()
+        ),
+        a2_bob_contact
+    );

-    // Also for Alice2, no info message should be shown;
-    // she should see only the "Messages are end-to-end encrypted" message.
-    let a2_chat_msgs = get_chat_msgs(alice2, a2_chat_id).await?;
-    assert_eq!(a2_chat_msgs.len(), 1);
-    let ChatItem::Message { msg_id } = a2_chat_msgs[0] else {
-        unreachable!()
-    };
-    let a2_msg = Message::load_from_db(alice2, msg_id).await?;
-    assert_eq!(a2_msg.get_info_type(), SystemMessage::ChatE2ee);
-
-    let a2_chat_members = get_chat_contacts(alice2, a2_chat_id).await?;
+    let a2_chat_members = get_chat_contacts(alice2, a2_charlie_added.chat_id).await?;
    assert!(a2_chat_members.contains(&a2_bob_contact));
    assert!(a2_chat_members.contains(&a2_charlie_contact));
    assert_eq!(a2_chat_members.len(), 2);
@@ -526,6 +526,14 @@ impl Context {

    /// Get a config key value if set, or a default value. Returns `None` if no value exists.
    pub async fn get_config(&self, key: Config) -> Result<Option<String>> {
+        if key == Config::ConfiguredAddr {
+            let addr: Option<String> = self
+                .sql
+                .query_get_value("SELECT addr FROM transports", ())
+                .await?;
+            return Ok(addr);
+        }
+
        let value = self.get_config_opt(key).await?;
        if value.is_some() {
            return Ok(value);
@@ -884,7 +892,7 @@ impl Context {
            .await
    }

-    /// Returns the address of the transport used for sending.
+    /// Returns address of some transport.
    /// Returns an error if no self addr is configured.
    pub async fn get_primary_self_addr(&self) -> Result<String> {
        self.get_config(Config::ConfiguredAddr)
@@ -31,39 +31,36 @@ use crate::login_param::EnteredCertificateChecks;
 pub use crate::login_param::EnteredLoginParam;
 use crate::net::proxy::ProxyConfig;
 use crate::provider::{self, Protocol, Socket};
-use crate::qr::{Qr, check_qr, login_param_from_account_qr, login_param_from_login_qr};
+use crate::qr::{login_param_from_account_qr, login_param_from_login_qr};
 use crate::smtp::Smtp;
 use crate::sync::Sync::Nosync;
 use crate::tools::time;
 use crate::transport::{
    ConfiguredCertificateChecks, ConfiguredLoginParam, ConfiguredServerLoginParam,
-    ConnectionCandidate, delete_transport_row, maybe_update_sending_transport,
-    purge_transport_caches, send_sync_transports, transport_addrs,
+    ConnectionCandidate, delete_transport_row, purge_transport_caches, send_sync_transports,
+    transport_addrs,
 };
-use crate::{EventType, autorelay, stock_str};
+use crate::{EventType, stock_str};

 /// Maximum number of relays.
 ///
 /// See <https://github.com/chatmail/core/issues/7608>.
 pub(crate) const MAX_RELAYS: usize = 5;

-tokio::task_local! {
-    pub(crate) static SILENT_PROGRESS: ();
-}
-
-#[track_caller]
-fn emit_progress(ctx: &Context, progress: u16) {
-    assert!(
-        progress <= 1000,
-        "value in range 0..1000 expected with: 0=error, 1..999=progress, 1000=success"
-    );
-    if SILENT_PROGRESS.try_with(|_| ()).is_ok() {
-        return;
-    }
-    ctx.emit_event(EventType::ConfigureProgress {
-        progress,
-        comment: None,
-    });
+macro_rules! progress {
+    ($context:tt, $progress:expr, $comment:expr) => {
+        assert!(
+            $progress <= 1000,
+            "value in range 0..1000 expected with: 0=error, 1..999=progress, 1000=success"
+        );
+        $context.emit_event($crate::events::EventType::ConfigureProgress {
+            progress: $progress,
+            comment: $comment,
+        });
+    };
+    ($context:tt, $progress:expr) => {
+        progress!($context, $progress, None);
+    };
 }

 impl Context {
@@ -127,17 +124,14 @@ impl Context {
    pub(crate) async fn add_transport_inner(&self, param: &mut EnteredLoginParam) -> Result<()> {
        match self.add_transport_unreported(param).await {
            Ok(()) => {
-                emit_progress(self, 1000);
+                progress!(self, 1000);
                Ok(())
            }
            Err(err) => {
                // We are using Anyhow's .context() and to show the
                // inner error, too, we need the {:#}:
                let error_msg = stock_str::configuration_failed(self, &format!("{err:#}"));
-                self.emit_event(EventType::ConfigureProgress {
-                    progress: 0,
-                    comment: Some(error_msg.clone()),
-                });
+                progress!(self, 0, Some(error_msg.clone()));
                bail!(error_msg);
            }
        }
@@ -162,7 +156,9 @@ impl Context {
            .await;

        self.free_ongoing().await;
-        res
+        res?;
+
+        param.save_legacy(self).await
    }

    /// Adds a new email account as a transport
@@ -194,62 +190,6 @@ impl Context {
        Ok(())
    }

-    /// Adds an initial transport on the chatmail relay that answers fastest
-    /// and lets the profile add further ones in the background.
-    ///
-    /// A `DCACCOUNT:` or `DCLOGIN:` `qr` code adds a single transport
-    /// while securejoin codes add the inviter's relays to the candidates.
-    ///
-    /// Does nothing if the profile already has a transport.
-    pub async fn init_transports(&self, qr: Option<&str>) -> Result<()> {
-        if self.is_configured().await? {
-            return Ok(());
-        }
-        if let Some(qr) = qr {
-            match check_qr(self, qr).await? {
-                Qr::Account { .. } | Qr::Login { .. } => {
-                    return self.add_transport_from_qr(qr).await;
-                }
-                Qr::AskVerifyContact { addrs, .. }
-                | Qr::AskVerifyGroup { addrs, .. }
-                | Qr::AskJoinBroadcast { addrs, .. } => {
-                    autorelay::add_relay_candidates(self, &addrs).await?
-                }
-                _ => bail!("QR code does not contain a relay"),
-            }
-        }
-
-        let cancel_channel = self.alloc_ongoing().await?;
-        let skip_network = false;
-        let res = autorelay::add_transport_from_candidates(self, skip_network)
-            .race(cancel_channel.recv().map(|_| Err(format_err!("Canceled"))))
-            .await;
-        self.free_ongoing().await;
-
-        let configured = self.is_configured().await?;
-        match res {
-            Ok(()) => {}
-            Err(err) if configured => {
-                warn!(
-                    self,
-                    "Onboarding interrupted after adding a transport: {err:#}."
-                );
-            }
-            Err(err) => {
-                let error_msg = stock_str::configuration_failed(self, &format!("{err:#}"));
-                self.emit_event(EventType::ConfigureProgress {
-                    progress: 0,
-                    comment: Some(error_msg.clone()),
-                });
-                bail!(error_msg);
-            }
-        }
-        self.set_config_bool(Config::Autorelay, true).await?;
-        emit_progress(self, 1000);
-        self.start_io().await;
-        Ok(())
-    }
-
    /// Returns the list of all email accounts that are used as a transport in the current profile.
    /// Use [Self::add_or_update_transport()] to add or change a transport
    /// and [Self::delete_transport()] to delete a transport.
@@ -275,7 +215,7 @@ impl Context {
    /// another one is chosen automatically.
    pub async fn delete_transport(&self, addr: &str) -> Result<()> {
        let now = time();
-        let (removed_transport_id, reelected) = self
+        let removed_transport_id = self
            .sql
            .transaction(|transaction| {
                if transport_addrs(transaction)?.len() <= 1 {
@@ -294,14 +234,9 @@ impl Context {
                let remove_timestamp = std::cmp::max(now, add_timestamp);
                let transport_id = delete_transport_row(transaction, addr, remove_timestamp)?
                    .context("Transport disappeared")?;
-                let reelected = maybe_update_sending_transport(transaction)?;
-                Ok((transport_id, reelected))
+                Ok(transport_id)
            })
            .await?;
-        if let Some(new_addr) = reelected {
-            info!(self, "Using transport {new_addr:?} for sending now.");
-            self.sql.uncache_raw_config("configured_addr").await;
-        }
        send_sync_transports(self).await?;
        purge_transport_caches(self, removed_transport_id).await;
        // Restarting all IO also stops the removed transport's IMAP loop.
@@ -381,7 +316,7 @@ async fn get_configured_param(
    let parsed = EmailAddress::new(&param.addr).context("Bad email-address")?;
    let param_domain = parsed.domain;

-    emit_progress(ctx, 200);
+    progress!(ctx, 200);

    let param_autoconfig = if param.imap.server.is_empty()
        && param.imap.port == 0
@@ -403,7 +338,7 @@ async fn get_configured_param(
        None
    };

-    emit_progress(ctx, 500);
+    progress!(ctx, 500);

    let mut servers = param_autoconfig.unwrap_or_default();
    if !servers
@@ -497,13 +432,13 @@ pub(crate) async fn configure(
    param: &EnteredLoginParam,
    skip_network: bool,
 ) -> Result<()> {
-    emit_progress(ctx, 1);
+    progress!(ctx, 1);

    let configured_param = get_configured_param(ctx, param, skip_network).await?;
    let proxy_config = ProxyConfig::load(ctx).await?;
    let strict_tls = configured_param.strict_tls(proxy_config.is_some())?;

-    emit_progress(ctx, 550);
+    progress!(ctx, 550);

    if !skip_network {
        // Spawn SMTP configuration task
@@ -529,7 +464,7 @@ pub(crate) async fn configure(
            Ok::<(), anyhow::Error>(())
        });

-        emit_progress(ctx, 600);
+        progress!(ctx, 600);

        // Configure IMAP

@@ -543,12 +478,12 @@ pub(crate) async fn configure(
            }
        };

-        emit_progress(ctx, 850);
+        progress!(ctx, 850);

        // Wait for SMTP configuration
        smtp_config_task.await??;

-        emit_progress(ctx, 900);
+        progress!(ctx, 900);

        // Drop the imap connection explicitly
        // to make sure that it's not forgotten in a future refactoring
@@ -556,7 +491,7 @@ pub(crate) async fn configure(
        drop(imap);
    }

-    emit_progress(ctx, 910);
+    progress!(ctx, 910);

    configured_param
        .clone()
@@ -567,11 +502,11 @@ pub(crate) async fn configure(
    ctx.set_config_internal(Config::ConfiguredTimestamp, Some(&time().to_string()))
        .await?;

-    emit_progress(ctx, 920);
+    progress!(ctx, 920);

    ctx.scheduler.interrupt_inbox().await;

-    emit_progress(ctx, 940);
+    progress!(ctx, 940);
    ctx.update_device_chats()
        .await
        .context("Failed to update device chats")?;
@@ -615,7 +550,7 @@ async fn get_autoconfig(
    {
        return Some(res);
    }
-    emit_progress(ctx, 300);
+    progress!(ctx, 300);

    // `?emailaddress=` query string is excluded on purpose.
    // It is not part of the URL according to <https://datatracker.ietf.org/doc/draft-ietf-mailmaint-autoconfig/06/>.
@@ -630,7 +565,7 @@ async fn get_autoconfig(
    {
        return Some(res);
    }
-    emit_progress(ctx, 310);
+    progress!(ctx, 310);

    // Outlook uses always SSL but different domains (this comment describes the next two steps)
    if let Ok(res) = outlk_autodiscover(
@@ -642,7 +577,7 @@ async fn get_autoconfig(
    {
        return Some(res);
    }
-    emit_progress(ctx, 320);
+    progress!(ctx, 320);

    if let Ok(res) = outlk_autodiscover(
        ctx,
@@ -653,7 +588,7 @@ async fn get_autoconfig(
    {
        return Some(res);
    }
-    emit_progress(ctx, 330);
+    progress!(ctx, 330);

    // always SSL for Thunderbird's database
    if let Ok(res) = moz_autoconfigure(
@@ -750,28 +685,6 @@ mod tests {
        Ok(())
    }

-    /// Tests that init_transports() fails on a bad code
-    /// and does nothing on a profile that already has a transport.
-    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-    async fn test_init_transports() -> Result<()> {
-        let mut tcm = TestContextManager::new();
-        let t = &tcm.unconfigured().await;
-        assert!(t.init_transports(Some("not a qr code")).await.is_err());
-        assert!(!t.is_configured().await?);
-
-        let alice = &tcm.alice().await;
-        let invite = "openpgp4fpr:79252762C34C5096AF57958F4FC3D21A81B0F0A7#a=cli%40invite.example&i=TbnwJ6lSvD5&s=0ejvbdFSQxB";
-        alice.init_transports(Some(invite)).await?;
-        let candidates = alice
-            .sql
-            .count("SELECT COUNT(*) FROM relay_candidates", ())
-            .await?;
-        assert_eq!(candidates, 0);
-        assert_eq!(alice.count_transports().await?, 1);
-
-        Ok(())
-    }
-
    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
    async fn test_get_configured_param() -> Result<()> {
        let t = &TestContext::new().await;
@@ -40,33 +40,9 @@ use crate::sync::{self, Sync::*};
 use crate::tools::{SystemTime, duration_to_str, get_abs_path, normalize_text, time, to_lowercase};
 use crate::{chat, chatlist_events, ensure_and_debug_assert, stock_str};

-/// If the contact's "last seen" is newer, the contact freshness is set to "recently seen".
+/// Time during which a contact is considered as seen recently.
 const SEEN_RECENTLY_SECONDS: i64 = 600;

-/// If the contact's "last seen" is older, the contact freshness is set to "old".
-const CONTACT_OLD_SECONDS: i64 = 60 * 24 * 60 * 60;
-
-/// Freshness of a contact, based on when it was last seen.
-///
-/// Used by the UI to highlight contacts:
-/// recently seen contacts get a little green dot on the avatar,
-/// contacts not seen for a long time get a string below the name (e.g. "Seen 2 months ago").
-#[derive(Debug, PartialEq, Eq)]
-pub enum Freshness {
-    /// Contact shall not be highlighted.
-    Normal = 0,
-    /// Contact was seen recently.
-    RecentlySeen = 1,
-    /// Contact was not seen for a long time.
-    Old = 2,
-}
-
-impl From<Freshness> for u32 {
-    fn from(freshness: Freshness) -> Self {
-        freshness as u32
-    }
-}
-
 /// Contact ID, including reserved IDs.
 ///
 /// Some contact IDs are reserved to identify special contacts.  This
@@ -718,9 +694,9 @@ impl Contact {
                    .await?
                    .unwrap_or_default();
                contact.addr = context
-                    .get_config(Config::ConfiguredAddr)
-                    .await?
-                    .unwrap_or_default();
+                    .get_primary_self_addr()
+                    .await
+                    .context("Cannot get address for self-contact")?;
                if let Some(self_fp) = self_fingerprint_opt(context).await? {
                    contact.fingerprint = Some(self_fp.to_string());
                }
@@ -749,23 +725,10 @@ impl Contact {
        self.last_seen
    }

-    /// Returns freshness of the contact.
-    pub fn get_freshness(&self) -> Freshness {
-        if self.id.is_special() || !self.is_key_contact() || self.is_blocked() {
-            return Freshness::Normal;
-        }
-
-        let is_old = time().saturating_sub(self.last_seen) > CONTACT_OLD_SECONDS;
-        if is_old || self.last_seen <= 0 {
-            return Freshness::Old;
-        }
-
-        let seen_recently = time().saturating_sub(self.last_seen) <= SEEN_RECENTLY_SECONDS;
-        if seen_recently {
-            return Freshness::RecentlySeen;
-        }
-
-        Freshness::Normal
+    /// Returns `true` if this contact was seen recently.
+    #[expect(clippy::arithmetic_side_effects)]
+    pub fn was_seen_recently(&self) -> bool {
+        time() - self.last_seen <= SEEN_RECENTLY_SECONDS
    }

    /// Check if a contact is blocked.
@@ -1421,10 +1384,6 @@ WHERE addr=?
        );

        let contact = Contact::get_by_id(context, contact_id).await?;
-        let addr = context
-            .get_config(Config::ConfiguredAddr)
-            .await?
-            .unwrap_or_default();

        let Some(fingerprint_other) = contact.fingerprint() else {
            return Ok(stock_str::encr_none(context));
@@ -1444,30 +1403,26 @@ WHERE addr=?
            .await?
            .dc_fingerprint()
            .human_readable();
-        if addr < contact.addr {
+        if fingerprint_self < fingerprint_other {
            cat_fingerprint(
                &mut ret,
                &stock_str::self_msg(context),
-                &addr,
                &fingerprint_self,
            );
            cat_fingerprint(
                &mut ret,
                contact.get_display_name(),
-                &contact.addr,
                &fingerprint_other,
            );
        } else {
            cat_fingerprint(
                &mut ret,
                contact.get_display_name(),
-                &contact.addr,
                &fingerprint_other,
            );
            cat_fingerprint(
                &mut ret,
                &stock_str::self_msg(context),
-                &addr,
                &fingerprint_self,
            );
        }
@@ -1968,8 +1923,8 @@ pub(crate) async fn update_last_seen(
    Ok(())
 }

-fn cat_fingerprint(ret: &mut String, name: &str, addr: &str, fingerprint: &str) {
-    *ret += &format!("\n\n{name} ({addr}):\n{fingerprint}");
+fn cat_fingerprint(ret: &mut String, name: &str, fingerprint: &str) {
+    *ret += &format!("\n\n{name}:\n{fingerprint}");
 }

 fn split_address_book(book: &str) -> Vec<(&str, &str)> {
@@ -887,11 +887,11 @@ async fn test_contact_get_encrinfo() -> Result<()> {
        "Messages are end-to-end encrypted.
 Fingerprints:

-Me (alice@example.org):
+Me:
 2E6F A2CB 23B5 32D7 2863
 4B58 64B0 8F61 A9ED 9443

-bob@example.net (bob@example.net):
+bob@example.net:
 CCCB 5AA9 F6E1 141C 9431
 65F1 DB18 B18C BCF7 0487

@@ -908,11 +908,11 @@ bob@example.net"
        "No encryption.
 Fingerprints:

-Me (alice@example.org):
+Me:
 2E6F A2CB 23B5 32D7 2863
 4B58 64B0 8F61 A9ED 9443

-bob@example.net (bob@example.net):
+bob@example.net:
 CCCB 5AA9 F6E1 141C 9431
 65F1 DB18 B18C BCF7 0487"
    );
@@ -1048,7 +1048,7 @@ async fn test_last_seen() -> Result<()> {
 }

 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_contact_freshness() -> Result<()> {
+async fn test_was_seen_recently() -> Result<()> {
    let _n = TimeShiftFalsePositiveNote;

    let mut tcm = TestContextManager::new();
@@ -1061,57 +1061,15 @@ async fn test_contact_freshness() -> Result<()> {
    let chat = bob.create_chat(&alice).await;
    let contacts = chat::get_chat_contacts(&bob, chat.id).await?;
    let contact = Contact::get_by_id(&bob, *contacts.first().unwrap()).await?;
-    assert_eq!(contact.get_freshness(), Freshness::Old);
+    assert!(!contact.was_seen_recently());

    bob.recv_msg(&sent_msg).await;
    let contact = Contact::get_by_id(&bob, *contacts.first().unwrap()).await?;

-    assert_eq!(contact.get_freshness(), Freshness::RecentlySeen);
+    assert!(contact.was_seen_recently());

    let self_contact = Contact::get_by_id(&bob, ContactId::SELF).await?;
-    assert_eq!(self_contact.get_freshness(), Freshness::Normal);
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_contact_freshness_blocked() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = tcm.alice().await;
-    let bob = tcm.bob().await;
-
-    // Alice sends message to Bob. Bob receives message, contact's freshness is "recently seen"
-    let msg = tcm.send_recv(&alice, &bob, "moin").await;
-
-    let contact = Contact::get_by_id(&bob, msg.from_id).await?;
-    assert_eq!(contact.get_freshness(), Freshness::RecentlySeen);
-
-    // Bob blocks Alice, contact's freshness is "normal" now
-    Contact::block(&bob, msg.from_id).await?;
-    let contact = Contact::get_by_id(&bob, msg.from_id).await?;
-    assert!(contact.is_blocked());
-    assert_eq!(contact.get_freshness(), Freshness::Normal);
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_contact_freshness_address_contact() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = tcm.alice().await;
-    alice.allow_unencrypted().await?;
-    let bob = tcm.bob().await;
-    bob.allow_unencrypted().await?;
-
-    // Alice sends a message to Bob
-    let alice_chat = alice.create_email_chat(&bob).await;
-    let sent_msg = alice.send_text(alice_chat.id, "moin").await;
-
-    // Bob receives message, contact's freshness is "normal", even though the messages was just received
-    let msg = bob.recv_msg(&sent_msg).await;
-    let contact = Contact::get_by_id(&bob, msg.from_id).await?;
-    assert!(!contact.is_key_contact());
-    assert_eq!(contact.get_freshness(), Freshness::Normal);
+    assert!(!self_contact.was_seen_recently());

    Ok(())
 }
@@ -1129,11 +1087,11 @@ async fn test_was_seen_recently_event() -> Result<()> {
        let chat = alice.create_chat(&bob).await;
        let sent_msg = alice.send_text(chat.id, "moin").await;
        let contact = Contact::get_by_id(&bob, *contacts.first().unwrap()).await?;
-        assert_ne!(contact.get_freshness(), Freshness::RecentlySeen);
+        assert!(!contact.was_seen_recently());
        bob.evtracker.clear_events();
        bob.recv_msg(&sent_msg).await;
        let contact = Contact::get_by_id(&bob, *contacts.first().unwrap()).await?;
-        assert_eq!(contact.get_freshness(), Freshness::RecentlySeen);
+        assert!(contact.was_seen_recently());
        bob.evtracker
            .get_matching(|evt| matches!(evt, EventType::ContactsChanged { .. }))
            .await;
@@ -1141,12 +1099,12 @@ async fn test_was_seen_recently_event() -> Result<()> {
            .interrupt(contact.id, contact.last_seen)
            .await;

-        // Wait for "seen recently" to turn off.
+        // Wait for `was_seen_recently()` to turn off.
        bob.evtracker.clear_events();
        SystemTime::shift(Duration::from_secs(SEEN_RECENTLY_SECONDS as u64 * 2));
        recently_seen_loop.interrupt(ContactId::UNDEFINED, 0).await;
        let contact = Contact::get_by_id(&bob, *contacts.first().unwrap()).await?;
-        assert_eq!(contact.get_freshness(), Freshness::Normal);
+        assert!(!contact.was_seen_recently());
        bob.evtracker
            .get_matching(|evt| matches!(evt, EventType::ContactsChanged { .. }))
            .await;
@@ -67,6 +67,7 @@ pub struct ContextBuilder {
    id: u32,
    events: Events,
    stock_strings: StockStrings,
+    password: Option<String>,

    push_subscriber: Option<PushSubscriber>,
 }
@@ -83,6 +84,7 @@ impl ContextBuilder {
            id: rand::random(),
            events: Events::new(),
            stock_strings: StockStrings::new(),
+            password: None,
            push_subscriber: None,
        }
    }
@@ -129,6 +131,19 @@ impl ContextBuilder {
        self
    }

+    /// Sets the password to unlock the database.
+    /// Deprecated 2025-11:
+    /// - Db encryption does nothing with blobs, so fs/disk encryption is recommended.
+    /// - Isolation from other apps is needed anyway.
+    ///
+    /// If an encrypted database is used it must be opened with a password.  Setting a
+    /// password on a new database will enable encryption.
+    #[deprecated(since = "TBD")]
+    pub fn with_password(mut self, password: String) -> Self {
+        self.password = Some(password);
+        self
+    }
+
    /// Sets push subscriber.
    pub(crate) fn with_push_subscriber(mut self, push_subscriber: PushSubscriber) -> Self {
        self.push_subscriber = Some(push_subscriber);
@@ -153,10 +168,11 @@ impl ContextBuilder {
    ///
    /// Returns error if context cannot be opened.
    pub async fn open(self) -> Result<Context> {
+        let password = self.password.clone().unwrap_or_default();
        let context = self.build().await?;
-        match context.open().await? {
+        match context.open(password).await? {
            true => Ok(context),
-            false => bail!("FIXME database could not be decrypted, incorrect or missing password"),
+            false => bail!("database could not be decrypted, incorrect or missing password"),
        }
    }
 }
@@ -370,7 +386,10 @@ impl Context {
        let context =
            Self::new_closed(dbfile, id, events, stock_strings, Default::default()).await?;

-        context.sql.open(&context).await?;
+        // Open the database if is not encrypted.
+        if context.check_passphrase("".to_string()).await? {
+            context.sql.open(&context, "".to_string()).await?;
+        }
        Ok(context)
    }

@@ -414,9 +433,20 @@ impl Context {
    /// Returns true if passphrase is correct, false is passphrase is not correct. Fails on other
    /// errors.
    #[deprecated(since = "TBD")]
-    pub async fn open(&self) -> Result<bool> {
-        self.sql.open(self).await?;
-        Ok(true)
+    pub async fn open(&self, passphrase: String) -> Result<bool> {
+        if self.sql.check_passphrase(passphrase.clone()).await? {
+            self.sql.open(self, passphrase).await?;
+            Ok(true)
+        } else {
+            Ok(false)
+        }
+    }
+
+    /// Changes encrypted database passphrase.
+    /// Deprecated 2025-11, see [`ContextBuilder::with_password()`] for reasoning.
+    pub async fn change_passphrase(&self, passphrase: String) -> Result<()> {
+        self.sql.change_passphrase(passphrase).await?;
+        Ok(())
    }

    /// Returns true if database is open.
@@ -424,6 +454,15 @@ impl Context {
        self.sql.is_open().await
    }

+    /// Tests the database passphrase.
+    ///
+    /// Returns true if passphrase is correct.
+    ///
+    /// Fails if database is already open.
+    pub(crate) async fn check_passphrase(&self, passphrase: String) -> Result<bool> {
+        self.sql.check_passphrase(passphrase).await
+    }
+
    pub(crate) fn with_blobdir(
        dbfile: PathBuf,
        blobdir: PathBuf,
@@ -811,6 +850,13 @@ impl Context {
        res.insert("number_of_contacts", contacts.to_string());
        res.insert("database_dir", self.get_dbfile().display().to_string());
        res.insert("database_version", dbversion.to_string());
+        res.insert(
+            "database_encrypted",
+            self.sql
+                .is_encrypted()
+                .await
+                .map_or_else(|| "closed".to_string(), |b| b.to_string()),
+        );
        res.insert("journal_mode", journal_mode);
        res.insert("blobdir", self.get_blobdir().display().to_string());
        res.insert(
@@ -1,4 +1,6 @@
+use anyhow::Context as _;
 use strum::IntoEnumIterator;
+use tempfile::tempdir;

 use super::*;
 use crate::chat::{Chat, MuteDuration, get_chat_contacts, get_chat_msgs, send_msg, set_muted};
@@ -484,6 +486,63 @@ async fn test_limit_search_msgs() -> Result<()> {
    Ok(())
 }

+#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+async fn test_check_passphrase() -> Result<()> {
+    let dir = tempdir()?;
+    let dbfile = dir.path().join("db.sqlite");
+
+    let context = ContextBuilder::new(dbfile.clone())
+        .with_id(1)
+        .build()
+        .await
+        .context("failed to create context")?;
+    assert_eq!(context.open("foo".to_string()).await?, true);
+    assert_eq!(context.is_open().await, true);
+    drop(context);
+
+    let context = ContextBuilder::new(dbfile)
+        .with_id(2)
+        .build()
+        .await
+        .context("failed to create context")?;
+    assert_eq!(context.is_open().await, false);
+    assert_eq!(context.check_passphrase("bar".to_string()).await?, false);
+    assert_eq!(context.open("false".to_string()).await?, false);
+    assert_eq!(context.open("foo".to_string()).await?, true);
+
+    Ok(())
+}
+
+#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+async fn test_context_change_passphrase() -> Result<()> {
+    let dir = tempdir()?;
+    let dbfile = dir.path().join("db.sqlite");
+
+    let context = ContextBuilder::new(dbfile)
+        .with_id(1)
+        .build()
+        .await
+        .context("failed to create context")?;
+    assert_eq!(context.open("foo".to_string()).await?, true);
+    assert_eq!(context.is_open().await, true);
+
+    context
+        .set_config(Config::Addr, Some("alice@example.org"))
+        .await?;
+
+    context
+        .change_passphrase("bar".to_string())
+        .await
+        .context("Failed to change passphrase")?;
+
+    assert_eq!(
+        context.get_config(Config::Addr).await?.unwrap(),
+        "alice@example.org"
+    );
+
+    Ok(())
+}
+
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_ongoing() -> Result<()> {
    let context = TestContext::new().await;
@@ -363,7 +363,7 @@ pub(crate) async fn start_chat_ephemeral_timers(context: &Context, chat_id: Chat
 /// Selects messages which are expired according to
 /// `delete_device_after` setting or `ephemeral_timestamp` column.
 ///
-/// For each message a row ID, chat id, viewtype, whether the message is pinned and location ID is returned.
+/// For each message a row ID, chat id, viewtype and location ID is returned.
 ///
 /// Unknown viewtypes are returned as `Viewtype::Unknown`
 /// and not as errors bubbled up, easily resulting in infinite loop or leaving messages undeleted.
@@ -371,12 +371,12 @@ pub(crate) async fn start_chat_ephemeral_timers(context: &Context, chat_id: Chat
 async fn select_expired_messages(
    context: &Context,
    now: i64,
-) -> Result<Vec<(MsgId, ChatId, Viewtype, bool, u32)>> {
+) -> Result<Vec<(MsgId, ChatId, Viewtype, u32)>> {
    let mut rows = context
        .sql
        .query_map_vec(
            r#"
-SELECT id, chat_id, type, pinned, location_id
+SELECT id, chat_id, type, location_id
 FROM msgs
 WHERE
  ephemeral_timestamp != 0
@@ -392,9 +392,8 @@ WHERE
                    .context("Using default viewtype for ephemeral handling.")
                    .log_err(context)
                    .unwrap_or_default();
-                let pinned: bool = row.get("pinned")?;
                let location_id: u32 = row.get("location_id")?;
-                Ok((id, chat_id, viewtype, pinned, location_id))
+                Ok((id, chat_id, viewtype, location_id))
            },
        )
        .await?;
@@ -415,7 +414,7 @@ WHERE
            .sql
            .query_map_vec(
                r#"
-SELECT id, chat_id, type, pinned, location_id
+SELECT id, chat_id, type, location_id
 FROM msgs
 WHERE
  timestamp < ?1
@@ -438,9 +437,8 @@ WHERE
                        .context("Using default viewtype for delete-old handling.")
                        .log_err(context)
                        .unwrap_or_default();
-                    let pinned: bool = row.get("pinned")?;
                    let location_id: u32 = row.get("location_id")?;
-                    Ok((id, chat_id, viewtype, pinned, location_id))
+                    Ok((id, chat_id, viewtype, location_id))
                },
            )
            .await?;
@@ -465,15 +463,11 @@ pub(crate) async fn delete_expired_messages(context: &Context, now: i64) -> Resu
    if !rows.is_empty() {
        info!(context, "Attempting to delete {} messages.", rows.len());

-        let (msgs_changed, webxdc_deleted, pinned_chat_ids) = context
+        let (msgs_changed, webxdc_deleted) = context
            .sql
            .transaction(|transaction| {
                let mut msgs_changed = Vec::with_capacity(rows.len());
                let mut webxdc_deleted = Vec::new();
-
-                // IDs of the chats in which pinned messages were deleted.
-                let mut pinned_chat_ids = BTreeSet::new();
-
                // If you change which information is preserved here, also change `MsgId::trash()`
                // and other places it references.
                let mut del_msg_stmt = transaction.prepare(
@@ -484,7 +478,7 @@ SELECT ?1, rfc724_mid, pre_rfc724_mid, timestamp, ? FROM msgs WHERE id=?1
                )?;
                let mut del_location_stmt =
                    transaction.prepare("DELETE FROM locations WHERE independent=1 AND id=?")?;
-                for (msg_id, chat_id, viewtype, is_pinned, location_id) in rows {
+                for (msg_id, chat_id, viewtype, location_id) in rows {
                    del_msg_stmt.execute((msg_id, ChatId::TRASH))?;
                    if location_id > 0 {
                        del_location_stmt.execute((location_id,))?;
@@ -494,12 +488,8 @@ SELECT ?1, rfc724_mid, pre_rfc724_mid, timestamp, ? FROM msgs WHERE id=?1
                    if viewtype == Viewtype::Webxdc {
                        webxdc_deleted.push(msg_id)
                    }
-
-                    if is_pinned {
-                        pinned_chat_ids.insert(chat_id);
-                    }
                }
-                Ok((msgs_changed, webxdc_deleted, pinned_chat_ids))
+                Ok((msgs_changed, webxdc_deleted))
            })
            .await?;

@@ -514,10 +504,6 @@ SELECT ?1, rfc724_mid, pre_rfc724_mid, timestamp, ? FROM msgs WHERE id=?1
            context.emit_msgs_changed_without_msg_id(modified_chat_id);
        }

-        for chat_id in pinned_chat_ids {
-            context.emit_event(EventType::PinnedMessagesChanged { chat_id });
-        }
-
        for msg_id in webxdc_deleted {
            context.emit_event(EventType::WebxdcInstanceDeleted { msg_id });
        }
@@ -33,6 +33,9 @@ pub enum EventType {
    /// Emitted when an IMAP message has been marked as deleted
    ImapMessageDeleted(String),

+    /// Emitted when an IMAP message has been moved
+    ImapMessageMoved(String),
+
    /// Emitted before going into IDLE on the Inbox folder.
    ImapInboxIdle,

@@ -93,14 +96,6 @@ pub enum EventType {
        contact_id: ContactId,
    },

-    /// The list of pinned messages for the chat has changed.
-    ///
-    /// Some message got pinned, or pinned message is unpinned or deleted.
-    PinnedMessagesChanged {
-        /// ID of the chat where the list of pinned messages changed.
-        chat_id: ChatId,
-    },
-
    /// A reaction to one's own sent message received.
    /// Typically, the UI will show a notification for that.
    ///
@@ -301,8 +301,7 @@ impl Imap {
        self.conn_backoff_ms = max(BACKOFF_MIN_MS, self.conn_backoff_ms);

        let login_params = prioritize_server_login_params(&context.sql, &self.lp, "imap").await?;
-        let mut first_connection_error = None;
-        let mut first_login_error = None;
+        let mut first_error = None;
        'candidate: for lp in login_params {
            info!(context, "IMAP trying to connect to {}.", lp.connection);
            let connection_candidate = lp.connection.clone();
@@ -318,7 +317,7 @@ impl Imap {
                Ok(client) => client,
                Err(err) => {
                    warn!(context, "{err:#}.");
-                    first_connection_error.get_or_insert(err);
+                    first_error.get_or_insert(err);
                    continue 'candidate;
                }
            };
@@ -397,14 +396,12 @@ impl Imap {

                Err(err) => {
                    warn!(context, "{err:#}.");
-                    first_login_error.get_or_insert(err);
+                    first_error.get_or_insert(err);
                }
            }
        }

-        Err(first_login_error
-            .or(first_connection_error)
-            .unwrap_or_else(|| format_err!("No IMAP connection candidates provided")))
+        Err(first_error.unwrap_or_else(|| format_err!("No IMAP connection candidates provided")))
    }

    /// Prepare a new IMAP session.
@@ -423,13 +420,13 @@ impl Imap {
        Ok(session)
    }

-    /// FETCH-and-DELETE iteration.
+    /// FETCH-MOVE-DELETE iteration.
    ///
-    /// Prefetches headers and downloads new message from the folder
-    /// and deletes messages in the folder.
+    /// Prefetches headers and downloads new message from the folder, moves messages away from the
+    /// folder and deletes messages in the folder.
    ///
    /// Returns true if at least one message was fetched.
-    pub async fn fetch_delete(
+    pub async fn fetch_move_delete(
        &mut self,
        context: &Context,
        session: &mut Session,
@@ -460,9 +457,9 @@ impl Imap {
            .context("delete_expired_imap_messages")?;

        session
-            .delete_messages(context, watch_folder)
+            .move_delete_messages(context, watch_folder)
            .await
-            .context("delete_messages")?;
+            .context("move_delete_messages")?;

        Ok(msgs_fetched)
    }
@@ -573,6 +570,16 @@ impl Imap {
                .size
                .context("imap fetch response does not contain size")?;

+            // Determine the target folder where the message should be moved to.
+            //
+            // We only move the messages from the INBOX and Spam folders.
+            // This is required to avoid infinite MOVE loop on IMAP servers
+            // that alias `DeltaChat` folder to other names.
+            // For example, some Dovecot servers alias `DeltaChat` folder to `INBOX.DeltaChat`.
+            // In this case moving from `INBOX.DeltaChat` to `DeltaChat`
+            // results in the messages getting a new UID,
+            // so the messages will be detected as new
+            // in the `INBOX.DeltaChat` folder again.
            let delete = if let Some(message_id) = &message_id {
                message::rfc724_mid_exists_ext(context, message_id, "deleted=1")
                    .await?
@@ -610,7 +617,13 @@ impl Imap {
                )
                .await?;

-            if !delete
+            // Download only the messages which have reached their target folder if there are
+            // multiple devices. This prevents race conditions in multidevice case, where one
+            // device tries to download the message while another device moves the message at the
+            // same time. Even in single device case it is possible to fail downloading the first
+            // message, move it to the movebox and then download the second message before
+            // downloading the first one, if downloading from inbox before moving is allowed.
+            if folder == target
                && prefetch_should_download(context, &headers, &message_id, fetch_response.flags())
                    .await
                    .context("prefetch_should_download")?
@@ -847,10 +860,75 @@ impl Session {
        Ok(())
    }

-    /// Deletes messages as planned in the `imap` table.
+    /// Moves batch of messages identified by their UID from the currently
+    /// selected folder to the target folder.
+    async fn move_message_batch(
+        &mut self,
+        context: &Context,
+        set: &str,
+        row_ids: Vec<i64>,
+        target: &str,
+    ) -> Result<()> {
+        if self.can_move() {
+            match self.uid_mv(set, &target).await {
+                Ok(()) => {
+                    // Messages are moved or don't exist, IMAP returns OK response in both cases.
+                    context
+                        .sql
+                        .transaction(|transaction| {
+                            let mut stmt = transaction.prepare("DELETE FROM imap WHERE id = ?")?;
+                            for row_id in row_ids {
+                                stmt.execute((row_id,))?;
+                            }
+                            Ok(())
+                        })
+                        .await
+                        .context("Cannot delete moved messages from imap table")?;
+                    context.emit_event(EventType::ImapMessageMoved(format!(
+                        "IMAP messages {set} moved to {target}"
+                    )));
+                    return Ok(());
+                }
+                Err(err) => {
+                    warn!(
+                        context,
+                        "Cannot move messages, fallback to COPY/DELETE {} to {}: {}",
+                        set,
+                        target,
+                        err
+                    );
+                }
+            }
+        }
+
+        // Server does not support MOVE or MOVE failed.
+        // Copy messages to the destination folder if needed and mark records for deletion.
+        info!(
+            context,
+            "Server does not support MOVE, fallback to COPY/DELETE {} to {}", set, target
+        );
+        self.uid_copy(&set, &target).await?;
+        context
+            .sql
+            .transaction(|transaction| {
+                let mut stmt = transaction.prepare("UPDATE imap SET target='' WHERE id = ?")?;
+                for row_id in row_ids {
+                    stmt.execute((row_id,))?;
+                }
+                Ok(())
+            })
+            .await
+            .context("Cannot plan deletion of messages")?;
+        context.emit_event(EventType::ImapMessageMoved(format!(
+            "IMAP messages {set} copied to {target}"
+        )));
+        Ok(())
+    }
+
+    /// Moves and deletes messages as planned in the `imap` table.
    ///
-    /// This is the only place where messages are deleted on the IMAP server.
-    async fn delete_messages(&mut self, context: &Context, folder: &str) -> Result<()> {
+    /// This is the only place where messages are moved or deleted on the IMAP server.
+    async fn move_delete_messages(&mut self, context: &Context, folder: &str) -> Result<()> {
        let transport_id = self.transport_id();
        let rows = context
            .sql
@@ -872,21 +950,23 @@ impl Session {

        for (target, rowid_set, uid_set) in UidGrouper::from(rows) {
            // Select folder inside the loop to avoid selecting it if there are no pending
-            // DELETE operations. This does not result in multiple SELECT commands
+            // MOVE/DELETE operations. This does not result in multiple SELECT commands
            // being sent because `select_folder()` does nothing if the folder is already
            // selected.
            let folder_exists = self.select_with_uidvalidity(context, folder).await?;
            ensure!(folder_exists, "No folder {folder}");

            // Empty target folder name means messages should be deleted.
-            // Since we don't move messages between IMAP folders anymore,
-            // `target` is always either empty or equal to `folder`.
-            debug_assert!(target.is_empty() || folder == target);
-
            if target.is_empty() {
                self.delete_message_batch(context, &uid_set, rowid_set)
                    .await
                    .with_context(|| format!("cannot delete batch of messages {uid_set:?}"))?;
+            } else {
+                self.move_message_batch(context, &uid_set, rowid_set, &target)
+                    .await
+                    .with_context(|| {
+                        format!("cannot move batch of messages {uid_set:?} to folder {target:?}",)
+                    })?;
            }
        }

@@ -9,6 +9,10 @@ pub(crate) struct Capabilities {
    /// <https://tools.ietf.org/html/rfc2177>
    pub can_idle: bool,

+    /// True if the server has MOVE capability as defined in
+    /// <https://tools.ietf.org/html/rfc6851>
+    pub can_move: bool,
+
    /// True if the server has QUOTA capability as defined in
    /// <https://tools.ietf.org/html/rfc2087>
    pub can_check_quota: bool,
@@ -78,6 +78,7 @@ pub(crate) async fn identify_server(
    };
    let capabilities = Capabilities {
        can_idle: caps.has_str("IDLE"),
+        can_move: caps.has_str("MOVE"),
        can_check_quota: caps.has_str("QUOTA"),
        can_metadata: caps.has_str("METADATA"),
        can_compress: caps.has_str("COMPRESS=DEFLATE"),
@@ -99,6 +99,10 @@ impl Session {
        self.capabilities.can_idle
    }

+    pub fn can_move(&self) -> bool {
+        self.capabilities.can_move
+    }
+
    pub fn can_check_quota(&self) -> bool {
        self.capabilities.can_check_quota
    }
@@ -200,9 +200,6 @@ async fn import_backup(
    backup_to_import: &Path,
    passphrase: String,
 ) -> Result<()> {
-    if !passphrase.is_empty() {
-        bail!("Encrypted passphrase is not supported");
-    }
    let backup_file = File::open(backup_to_import).await?;
    let file_size = backup_file.metadata().await?.len();
    info!(
@@ -213,7 +210,7 @@ async fn import_backup(
        context.get_dbfile().display()
    );

-    import_backup_stream(context, backup_file, file_size).await?;
+    import_backup_stream(context, backup_file, file_size, passphrase).await?;
    Ok(())
 }

@@ -234,6 +231,7 @@ pub(crate) async fn import_backup_stream<R: tokio::io::AsyncRead + Unpin>(
    context: &Context,
    backup_file: R,
    file_size: u64,
+    passphrase: String,
 ) -> Result<()> {
    ensure!(
        !context.is_configured().await?,
@@ -244,7 +242,7 @@ pub(crate) async fn import_backup_stream<R: tokio::io::AsyncRead + Unpin>(
        "Cannot import backup, IO is running"
    );

-    import_backup_stream_inner(context, backup_file, file_size)
+    import_backup_stream_inner(context, backup_file, file_size, passphrase)
        .await
        .0
 }
@@ -317,6 +315,7 @@ async fn import_backup_stream_inner<R: tokio::io::AsyncRead + Unpin>(
    context: &Context,
    backup_file: R,
    file_size: u64,
+    passphrase: String,
 ) -> (Result<()>,) {
    let backup_file = ProgressReader::new(backup_file, context.clone(), file_size);
    let mut archive = Archive::new(backup_file);
@@ -363,7 +362,7 @@ async fn import_backup_stream_inner<R: tokio::io::AsyncRead + Unpin>(
    if res.is_ok() {
        res = context
            .sql
-            .import(&unpacked_database)
+            .import(&unpacked_database, passphrase.clone())
            .await
            .context("cannot import unpacked database");
    }
@@ -391,7 +390,7 @@ async fn import_backup_stream_inner<R: tokio::io::AsyncRead + Unpin>(
        }
        context
            .sql
-            .open(context)
+            .open(context, "".to_string())
            .await
            .log_err(context)
            .ok();
@@ -736,7 +735,7 @@ where
 /// overwritten.
 ///
 /// This also verifies that IO is not running during the export.
-async fn export_database(context: &Context, dest: &Path, _passphrase: String) -> Result<()> {
+async fn export_database(context: &Context, dest: &Path, passphrase: String) -> Result<()> {
    ensure!(
        !context.scheduler.is_running().await,
        "cannot export backup, IO is running"
@@ -746,7 +745,6 @@ async fn export_database(context: &Context, dest: &Path, _passphrase: String) ->
    let dest = dest
        .to_str()
        .with_context(|| format!("path {} is not valid unicode", dest.display()))?;
-    let mut dest_conn = rusqlite::Connection::open(dest)?;

    context.set_config(Config::BccSelf, Some("1")).await?;
    context
@@ -757,12 +755,22 @@ async fn export_database(context: &Context, dest: &Path, _passphrase: String) ->
    context
        .sql
        .call_write(|conn| {
-            if let Err(err) = conn.execute("VACUUM", ()) {
-                warn!(context, "Vacuum failed, exporting anyway: {err:#}.");
-            }
-
-            let backup = rusqlite::backup::Backup::new(conn, &mut dest_conn)?;
-            backup.run_to_completion(5, std::time::Duration::ZERO, None)?;
+            conn.execute("VACUUM;", ())
+                .map_err(|err| warn!(context, "Vacuum failed, exporting anyway {err}"))
+                .ok();
+            conn.execute("ATTACH DATABASE ? AS backup KEY ?", (dest, passphrase))
+                .context("failed to attach backup database")?;
+            let res = conn
+                .query_row("SELECT sqlcipher_export('backup')", [], |_row| Ok(()))
+                .context("failed to export to attached backup database");
+            conn.execute(
+                "UPDATE backup.config SET value='0' WHERE keyname='verified_one_on_one_chats';",
+                [],
+            )
+            .ok(); // Deprecated 2025-07. If verified_one_on_one_chats was not set, this errors, which we ignore
+            conn.execute("DETACH DATABASE backup", [])
+                .context("failed to detach backup database")?;
+            res?;
            Ok(())
        })
        .await
@@ -1032,7 +1040,7 @@ mod tests {
            ar.unpack(&unpack_dir).await?;

            let sql = sql::Sql::new(unpack_dir.path().join(DBFILE_BACKUP_NAME));
-            sql.open(&context2).await?;
+            sql.open(&context2, "".to_string()).await?;
            assert_eq!(
                sql.get_raw_config_int("backup_version").await?.unwrap(),
                DCBACKUP_VERSION
@@ -324,6 +324,7 @@ pub async fn get_backup2(
    info!(context, "Sending backup authentication token.");
    send_stream.write_all(auth_token.as_bytes()).await?;

+    let passphrase = String::new();
    info!(context, "Starting to read backup from the stream.");

    let mut file_size_buf = [0u8; 8];
@@ -333,7 +334,7 @@ pub async fn get_backup2(
    // Emit a nonzero progress so that UIs can display smth like "Transferring...".
    context.emit_event(EventType::ImexProgress(1));

-    import_backup_stream(context, recv_stream, file_size)
+    import_backup_stream(context, recv_stream, file_size, passphrase)
        .await
        .context("Failed to import backup from QUIC stream")?;
    info!(context, "Finished importing backup from the stream.");
@@ -52,7 +52,7 @@ const KEYUPDATE_CHUNK_CONTACTS: usize = 200;
 const KEYUPDATE_MAX_SILENCE: i64 = 3 * 365 * 24 * 3600;

 /// Upper bound on the contacts informed after a relay list change, keeping the freshest.
-const KEYUPDATE_MAX_RECIPIENTS: u32 = 5000;
+const KEYUPDATE_MAX_RECIPIENTS: usize = 5000;

 /// A contact to inform: the relays to reach them at, and the key to encrypt to.
 struct KeyupdateRecipient {
@@ -63,7 +63,7 @@ struct KeyupdateRecipient {
 /// Returns at most `max_recipients` key-contacts to inform.
 async fn keyupdate_recipients(
    context: &Context,
-    max_recipients: u32,
+    max_recipients: usize,
 ) -> Result<Vec<KeyupdateRecipient>> {
    // Single chat contacts only become keyupdate recipient candidates
    // if we have a record of a sent message or `last_seen` is not 0.
@@ -9,12 +9,14 @@
 use std::fmt;

 use anyhow::{Context as _, Result};
+use num_traits::ToPrimitive as _;
 use serde::{Deserialize, Serialize};

 use crate::config::Config;
 use crate::context::Context;
 pub use crate::net::proxy::ProxyConfig;
 pub use crate::provider::Socket;
+use crate::tools::ToOption;

 /// User-entered setting for certificate checks.
 ///
@@ -230,6 +232,62 @@ impl EnteredLoginParam {
            oauth2: false,
        })
    }
+
+    /// Saves entered account settings,
+    /// so that they can be prefilled if the user wants to configure the server again.
+    ///
+    /// This is needed in case a UI is not yet updated, and still uses `get_config("mail_pw")` etc.
+    /// in order to prefill the entered account settings.
+    pub(crate) async fn save_legacy(&self, context: &Context) -> Result<()> {
+        context.set_config(Config::Addr, Some(&self.addr)).await?;
+
+        context
+            .set_config(Config::MailServer, self.imap.server.to_option())
+            .await?;
+        context
+            .set_config(Config::MailPort, self.imap.port.to_option().as_deref())
+            .await?;
+        context
+            .set_config(
+                Config::MailSecurity,
+                self.imap.security.to_i32().to_option().as_deref(),
+            )
+            .await?;
+        context
+            .set_config(Config::MailUser, self.imap.user.to_option())
+            .await?;
+        context
+            .set_config(Config::MailPw, self.imap.password.to_option())
+            .await?;
+
+        context
+            .set_config(Config::SendServer, self.smtp.server.to_option())
+            .await?;
+        context
+            .set_config(Config::SendPort, self.smtp.port.to_option().as_deref())
+            .await?;
+        context
+            .set_config(
+                Config::SendSecurity,
+                self.smtp.security.to_i32().to_option().as_deref(),
+            )
+            .await?;
+        context
+            .set_config(Config::SendUser, self.smtp.user.to_option())
+            .await?;
+        context
+            .set_config(Config::SendPw, self.smtp.password.to_option())
+            .await?;
+
+        context
+            .set_config(
+                Config::ImapCertificateChecks,
+                self.certificate_checks.to_i32().to_option().as_deref(),
+            )
+            .await?;
+
+        Ok(())
+    }
 }

 impl fmt::Display for EnteredLoginParam {
@@ -311,4 +369,41 @@ mod tests {

        Ok(())
    }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn test_save_entered_login_param() -> Result<()> {
+        let t = TestContext::new().await;
+        let param = EnteredLoginParam {
+            addr: "alice@example.org".to_string(),
+            imap: EnteredImapLoginParam {
+                server: "".to_string(),
+                port: 0,
+                folder: "".to_string(),
+                security: Socket::Starttls,
+                user: "".to_string(),
+                password: "foobar".to_string(),
+            },
+            smtp: EnteredSmtpLoginParam {
+                server: "".to_string(),
+                port: 2947,
+                security: Socket::default(),
+                user: "".to_string(),
+                password: "".to_string(),
+            },
+            certificate_checks: Default::default(),
+            oauth2: false,
+        };
+        param.save_legacy(&t).await?;
+        assert_eq!(
+            t.get_config(Config::Addr).await?.unwrap(),
+            "alice@example.org"
+        );
+        assert_eq!(t.get_config(Config::MailPw).await?.unwrap(), "foobar");
+        assert_eq!(t.get_config(Config::SendPw).await?, None);
+        assert_eq!(t.get_config_int(Config::SendPort).await?, 2947);
+
+        assert_eq!(EnteredLoginParam::load_legacy(&t).await?, param);
+
+        Ok(())
+    }
 }
@@ -1445,10 +1445,13 @@ impl std::fmt::Display for MessageState {
 }

 impl MessageState {
-    /// Returns true if the message can be marked as failed in the current state.
+    /// Returns true if the message can transition to `OutFailed` state from the current state.
    pub fn can_fail(self) -> bool {
        use MessageState::*;
-        matches!(self, OutPending | OutDelivered | OutFailed)
+        matches!(
+            self,
+            OutPending | OutDelivered | OutMdnRcvd // OutMdnRcvd can still fail because it could be a group message and only some recipients failed.
+        )
    }

    /// Returns true for any outgoing message states.
@@ -1641,15 +1644,11 @@ pub(crate) async fn delete_msgs_locally_done(
    context: &Context,
    msg_ids: &[MsgId],
    modified_chat_ids: BTreeSet<ChatId>,
-    pinned_messages_changed_chat_ids: BTreeSet<ChatId>,
 ) -> Result<()> {
    for modified_chat_id in modified_chat_ids {
        context.emit_msgs_changed_without_msg_id(modified_chat_id);
        chatlist_events::emit_chatlist_item_changed(context, modified_chat_id);
    }
-    for chat_id in pinned_messages_changed_chat_ids {
-        context.emit_event(EventType::PinnedMessagesChanged { chat_id });
-    }
    if !msg_ids.is_empty() {
        context.emit_msgs_changed_without_ids();
        chatlist_events::emit_chatlist_changed(context);
@@ -1675,7 +1674,6 @@ pub async fn delete_msgs_ext(
    delete_for_all: bool,
 ) -> Result<()> {
    let mut modified_chat_ids = BTreeSet::new();
-    let mut pinned_messages_changed_chat_ids = BTreeSet::new();
    let mut deleted_rfc724_mid = Vec::new();
    let mut res = Ok(());

@@ -1691,9 +1689,6 @@ pub async fn delete_msgs_ext(
        );

        modified_chat_ids.insert(msg.chat_id);
-        if msg.is_pinned() {
-            pinned_messages_changed_chat_ids.insert(msg.chat_id);
-        }
        deleted_rfc724_mid.push(msg.rfc724_mid.clone());

        let update_db = |trans: &mut rusqlite::Transaction| {
@@ -1751,13 +1746,7 @@ pub async fn delete_msgs_ext(
        let msg = Message::load_from_db(context, msg_id).await?;
        delete_msg_locally(context, &msg).await?;
    }
-    delete_msgs_locally_done(
-        context,
-        msg_ids,
-        modified_chat_ids,
-        pinned_messages_changed_chat_ids,
-    )
-    .await?;
+    delete_msgs_locally_done(context, msg_ids, modified_chat_ids).await?;

    // Interrupt Inbox loop to start message deletion, run housekeeping and call send_sync_msg().
    context.scheduler.interrupt_inbox().await;
@@ -1986,15 +1975,15 @@ pub(crate) async fn set_msg_failed(
    msg: &mut Message,
    error: &str,
 ) -> Result<()> {
-    if !msg.state.can_fail() {
-        info!(
+    if msg.state.can_fail() {
+        msg.state = MessageState::OutFailed;
+        warn!(context, "{} failed: {}", msg.id, error);
+    } else {
+        warn!(
            context,
-            "Ignoring failed {} in state {}: {}", msg.id, msg.state, error
-        );
-        return Ok(());
+            "{} seems to have failed ({}), but state is {}", msg.id, error, msg.state
+        )
    }
-    msg.state = MessageState::OutFailed;
-    warn!(context, "{} failed: {}", msg.id, error);
    msg.error = Some(error.to_string());

    let exists = context
@@ -454,28 +454,6 @@ async fn test_get_state() -> Result<()> {
    Ok(())
 }

-/// Tests that a failure reported after a read receipt leaves the message untouched.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_set_msg_failed_after_mdn() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let bob = &tcm.bob().await;
-    let alice_chat = alice.create_chat(bob).await;
-    let sent = alice.send_text(alice_chat.id, "hi").await;
-    let bob_msg = bob.recv_msg(&sent).await;
-    alice.recv_mdn(bob, &bob_msg).await?;
-    let mut msg = sent.load_from_db().await;
-    assert_eq!(msg.state, MessageState::OutMdnRcvd);
-
-    set_msg_failed(alice, &mut msg, "relay bounced").await?;
-    let msg = sent.load_from_db().await;
-    assert_eq!(msg.state, MessageState::OutMdnRcvd);
-    assert_eq!(msg.error(), None);
-    let chats = Chatlist::try_load(alice, 0, None, None).await?;
-    assert_eq!(chats.get_msg_id(0)?, Some(msg.id));
-    Ok(())
-}
-
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_is_bot() -> Result<()> {
    let mut tcm = TestContextManager::new();
@@ -782,23 +760,3 @@ async fn test_get_existing_msg_ids() -> Result<()> {

    Ok(())
 }
-
-#[test]
-fn test_can_fail() -> Result<()> {
-    use MessageState::*;
-
-    // states that are not allowed to transition to OutFailed
-    assert!(!Undefined.can_fail());
-    assert!(!InFresh.can_fail());
-    assert!(!InNoticed.can_fail());
-    assert!(!InSeen.can_fail());
-    assert!(!OutDraft.can_fail());
-    assert!(!OutMdnRcvd.can_fail());
-
-    // states that are allowed to transition to OutFailed
-    assert!(OutPending.can_fail());
-    assert!(OutDelivered.can_fail());
-    assert!(OutFailed.can_fail());
-
-    Ok(())
-}
@@ -22,7 +22,7 @@ use crate::key::{load_self_secret_key, secret_key_to_public_key};
 use crate::message;
 use crate::mimeparser::MimeMessage;
 use crate::receive_imf::receive_imf;
-use crate::test_utils::{self, SentMessage};
+use crate::test_utils;
 use crate::test_utils::{TestContext, TestContextManager, get_chat_msg};
 use crate::tools::SystemTime;

@@ -1022,7 +1022,7 @@ END:VCARD";
 }

 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_render_outer_headers_of_encrypted_msg() -> Result<()> {
+async fn test_render_outer_headers() -> Result<()> {
    let mut tcm = TestContextManager::new();
    let alice = &tcm.alice().await;
    let bob = &tcm.bob().await;
@@ -1030,9 +1030,26 @@ async fn test_render_outer_headers_of_encrypted_msg() -> Result<()> {
    let chat_id = alice.create_chat_id(bob).await;
    let sent = alice.send_text(chat_id, "Hello!").await;

-    let payload = normalized_payload(sent).await;
+    let (unencrypted, _encrypted) = sent
+        .payload()
+        .split_once("-----BEGIN PGP MESSAGE-----")
+        .unwrap();

-    let (unencrypted, _encrypted) = payload.split_once("-----BEGIN PGP MESSAGE-----").unwrap();
+    // Normalize the parts of the message that vary between runs
+    // (MIME boundary, Date, Message-ID)
+    let boundary = unencrypted
+        .split_once("boundary=\"")
+        .and_then(|(_, rest)| rest.split_once('"'))
+        .map(|(b, _)| b)
+        .unwrap_or_default();
+    let unencrypted = unencrypted.replace(boundary, "BOUNDARY");
+
+    let rfc724_mid = sent.load_from_db().await.rfc724_mid;
+    let unencrypted = unencrypted.replace(&rfc724_mid, "MESSAGE_ID@localhost");
+
+    let unencrypted = regex!(r"Date:[^\r\n]*")
+        .replace(&unencrypted, "Date: DATE")
+        .to_string();

    let expected = r#"From: <alice@example.org>
 Date: DATE
@@ -1068,140 +1085,3 @@ expected (debug print): {expected:?}"

    Ok(())
 }
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_render_unencrypted_msg_basic() -> Result<()> {
-    let alice = &TestContext::new_alice().await;
-    alice.allow_unencrypted().await?;
-
-    let chat = alice
-        .create_chat_with_contact("Bob", "bob@example.net")
-        .await;
-    let sent = alice.send_text(chat.id, "Hello!").await;
-    let unencrypted = normalized_payload(sent).await;
-
-    let expected = r#"From: <alice@example.org>
-Message-ID: <MESSAGE_ID@localhost>
-MIME-Version: 1.0
-Autocrypt: addr=alice@example.org; prefer-encrypt=mutual; keydata=mDMEXlh13RYJKwYBBAHaRw8BAQdAzfVIAleCXMJrq8VeLlEVof6ITCviMktKjmcBKAu4m5
-	 DCtAQfFggAZgUCXlh13RYhBC5vossjtTLXKGNLWGSwj2Gp7ZRDAhsDAh4JBAsJCAcFFQgJCgsDFgIB
-	 AycJAgIZASwUgAAAAAASABFyZWxheXNAY2hhdG1haWwuYXRhbGljZUBleGFtcGxlLm9yZwAAb1QA/0
-	 HbvPN3/Vn02Gk1dcQMEcyGyETld9dSsRo8uwHAyW35AQCrFJjAQFLTud7XK61uYt9BC/QHipCfIGbq
-	 X1FjMbTUC80TPGFsaWNlQGV4YW1wbGUub3JnPsKRBBMWCAA5BQJeWHXdFiEELm+iyyO1MtcoY0tYZL
-	 CPYantlEMCGwMCHgkECwkIBwUVCAkKCwMWAgEDJwkCAhkBAAoJEGSwj2Gp7ZRD1m4A/iOifEzIOiP8
-	 wW0O8I/sg69gQtG8Czn4MsVV6Ea1EyIqAP4uByHaUJdy8MSQPfv/Usr09KsidNgy2Jh37yg82fKUBr
-	 g4BF5Ydd0SCisGAQQBl1UBBQEBB0AG7cjWy2SFAU8KnltlubVW67rFiyfp01JrRe6Xqy22HQMBCAeI
-	 eAQYFggAIBYhBC5vossjtTLXKGNLWGSwj2Gp7ZRDBQJeWHXdAhsMAAoJEGSwj2Gp7ZRDLo8BAObE8G
-	 nsGVwKzNqCvHeWgJsqhjS3C6gvSlV3tEm9XmF6AQDXucIyVfoBwoyMh2h6cSn/ATn5QJb35pgo+ivp
-	 3jsMAg==
-Content-Type: text/plain; charset="utf-8"
-Date: DATE
-To: <bob@example.net>
-Subject: Message from alice@example.org
-References: <MESSAGE_ID@localhost>
-Chat-Version: 1.0
-Chat-Disposition-Notification-To: alice@example.org
-Content-Transfer-Encoding: 7bit
-
-Hello!"#
-    .replace("\n", "\r\n");
-    assert_eq!(
-        unencrypted, expected,
-        "---------------- Actual: ----------------
-{unencrypted}
-----------------------------------------
-actual (debug print): {unencrypted:?}
-expected (debug print): {expected:?}"
-    );
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_render_unencrypted_msg_with_attachment() -> Result<()> {
-    let alice = &TestContext::new_alice().await;
-    alice.allow_unencrypted().await?;
-
-    let chat = alice
-        .create_chat_with_contact("Bob", "bob@example.net")
-        .await;
-    let mut msg = Message::new(Viewtype::File);
-    msg.set_text("Hello!".to_string());
-    msg.set_file_from_bytes(alice, "foo.bar", "content".as_bytes(), None)?;
-    let sent = alice.send_msg(chat.id, &mut msg).await;
-    let unencrypted = normalized_payload(sent).await;
-
-    let expected = r#"From: <alice@example.org>
-Message-ID: <MESSAGE_ID@localhost>
-MIME-Version: 1.0
-Autocrypt: addr=alice@example.org; prefer-encrypt=mutual; keydata=mDMEXlh13RYJKwYBBAHaRw8BAQdAzfVIAleCXMJrq8VeLlEVof6ITCviMktKjmcBKAu4m5
-	 DCtAQfFggAZgUCXlh13RYhBC5vossjtTLXKGNLWGSwj2Gp7ZRDAhsDAh4JBAsJCAcFFQgJCgsDFgIB
-	 AycJAgIZASwUgAAAAAASABFyZWxheXNAY2hhdG1haWwuYXRhbGljZUBleGFtcGxlLm9yZwAAb1QA/0
-	 HbvPN3/Vn02Gk1dcQMEcyGyETld9dSsRo8uwHAyW35AQCrFJjAQFLTud7XK61uYt9BC/QHipCfIGbq
-	 X1FjMbTUC80TPGFsaWNlQGV4YW1wbGUub3JnPsKRBBMWCAA5BQJeWHXdFiEELm+iyyO1MtcoY0tYZL
-	 CPYantlEMCGwMCHgkECwkIBwUVCAkKCwMWAgEDJwkCAhkBAAoJEGSwj2Gp7ZRD1m4A/iOifEzIOiP8
-	 wW0O8I/sg69gQtG8Czn4MsVV6Ea1EyIqAP4uByHaUJdy8MSQPfv/Usr09KsidNgy2Jh37yg82fKUBr
-	 g4BF5Ydd0SCisGAQQBl1UBBQEBB0AG7cjWy2SFAU8KnltlubVW67rFiyfp01JrRe6Xqy22HQMBCAeI
-	 eAQYFggAIBYhBC5vossjtTLXKGNLWGSwj2Gp7ZRDBQJeWHXdAhsMAAoJEGSwj2Gp7ZRDLo8BAObE8G
-	 nsGVwKzNqCvHeWgJsqhjS3C6gvSlV3tEm9XmF6AQDXucIyVfoBwoyMh2h6cSn/ATn5QJb35pgo+ivp
-	 3jsMAg==
-Content-Type: multipart/mixed; 
-	boundary="BOUNDARY"
-Date: DATE
-To: <bob@example.net>
-Subject: Message from alice@example.org
-References: <MESSAGE_ID@localhost>
-Chat-Version: 1.0
-Chat-Disposition-Notification-To: alice@example.org
-
-
--BOUNDARY
-Content-Type: text/plain; charset="utf-8"
-Content-Transfer-Encoding: 7bit
-
-Hello!
--BOUNDARY
-Content-Type: application/octet-stream
-Content-Disposition: attachment; filename="foo.bar"
-Content-Transfer-Encoding: base64
-
-Y29udGVudA==
-
--BOUNDARY--
-"#
-    .replace("\n", "\r\n");
-    assert_eq!(
-        unencrypted, expected,
-        "---------------- Actual: ----------------
-{unencrypted}
-----------------------------------------
-actual (debug print): {unencrypted:?}
-expected (debug print): {expected:?}"
-    );
-
-    Ok(())
-}
-
-/// Normalize the parts of the message that vary between runs
-/// (MIME boundary, Date, Message-ID)
-async fn normalized_payload(sent: SentMessage<'_>) -> String {
-    let rfc724_mid = sent.load_from_db().await.rfc724_mid;
-
-    let mut payload = sent.payload;
-
-    if let Some(boundary) = payload
-        .split_once("boundary=\"")
-        .and_then(|(_, rest)| rest.split_once('"'))
-        .map(|(b, _)| b)
-    {
-        payload = payload.replace(boundary, "BOUNDARY");
-    }
-
-    payload = payload.replace(&rfc724_mid, "MESSAGE_ID@localhost");
-
-    payload = regex!(r"Date:[^\r\n]*")
-        .replace(&payload, "Date: DATE")
-        .to_string();
-
-    payload
-}
@@ -2540,18 +2540,19 @@ async fn handle_ndn(
    for msg_id in msg_ids {
        let mut message = Message::load_from_db(context, msg_id).await?;
        let chat = Chat::load_from_db(context, message.chat_id).await?;
-        if chat.typ == constants::Chattype::Single {
-            let aggregated_error = message
-                .error
-                .as_ref()
-                .map(|err| format!("{err}\n\n{err_msg}"));
-            set_msg_failed(
-                context,
-                &mut message,
-                aggregated_error.as_ref().unwrap_or(err_msg),
-            )
-            .await?;
+        if chat.typ == constants::Chattype::OutBroadcast {
+            continue;
        }
+        let aggregated_error = message
+            .error
+            .as_ref()
+            .map(|err| format!("{err}\n\n{err_msg}"));
+        set_msg_failed(
+            context,
+            &mut message,
+            aggregated_error.as_ref().unwrap_or(err_msg),
+        )
+        .await?;
    }

    Ok(())
@@ -33,7 +33,7 @@ use tls::wrap_tls;
 pub(crate) const TIMEOUT: Duration = Duration::from_secs(60);

 /// TTL for caches in seconds.
-pub(crate) const CACHE_TTL: u32 = 30 * 24 * 60 * 60;
+pub(crate) const CACHE_TTL: u64 = 30 * 24 * 60 * 60;

 /// Removes connection history entries after `CACHE_TTL`.
 pub(crate) async fn prune_connection_history(context: &Context) -> Result<()> {
@@ -13,7 +13,6 @@ use anyhow::{Result, ensure};
 use crate::chat::{ChatId, send_msg};
 use crate::contact::ContactId;
 use crate::context::Context;
-use crate::events::EventType;
 use crate::log::warn;
 use crate::message::{Message, MessageState, MsgId, Viewtype};
 use crate::mimeparser::SystemMessage;
@@ -79,11 +78,7 @@ async fn update_pinned_state_in_db(
            (new_pinned_state, msg.id),
        )
        .await?;
-
    context.emit_msgs_changed(msg.chat_id, msg.id);
-    context.emit_event(EventType::PinnedMessagesChanged {
-        chat_id: msg.chat_id,
-    });

    Ok(())
 }
@@ -145,4 +140,226 @@ pub(crate) async fn handle_pinned_state_from_wire(
 }

 #[cfg(test)]
-mod pinned_messages_tests;
+mod tests {
+    use super::*;
+    use crate::chat::{ChatItem, add_info_msg, create_broadcast, get_chat_msgs};
+    use crate::config::Config;
+    use crate::securejoin::get_securejoin_qr;
+    use crate::test_utils::{TestContextManager, sync};
+    use std::time::Duration;
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn test_pinned_messages() -> Result<()> {
+        let mut tcm = TestContextManager::new();
+        let alice = &tcm.alice().await;
+        let alice2 = &tcm.alice().await; // Alice's second device
+        let bob = &tcm.bob().await;
+
+        alice.set_config_bool(Config::SyncMsgs, true).await?;
+        alice2.set_config_bool(Config::SyncMsgs, true).await?;
+
+        // Alice creates all chat types upfront, with Bob as member if possible
+        let single_chat_id = alice.create_chat(bob).await.id;
+        let group_chat_id = alice.create_group_with_members("Group", &[bob]).await;
+        let broadcast_chat_id = create_broadcast(alice, "Channel".to_string()).await?;
+        let qr = get_securejoin_qr(alice, Some(broadcast_chat_id)).await?;
+        tcm.exec_securejoin_qr(bob, alice, &qr).await;
+        let self_chat_id = alice.get_self_chat().await.id;
+        sync(alice, alice2).await;
+
+        for alice_chat_id in [
+            single_chat_id,
+            group_chat_id,
+            broadcast_chat_id,
+            self_chat_id,
+        ] {
+            let pinned = get_pinned_messages(alice, alice_chat_id).await?;
+            assert!(pinned.is_empty());
+
+            // Alice sends message "Foo" and pins it
+            let sent1 = alice.send_text(alice_chat_id, "Foo").await;
+            let msg1 = sent1.load_from_db().await;
+            assert!(!msg1.is_pinned());
+
+            set_pinned_state(alice, msg1.id, true).await?;
+            let sent2 = alice.pop_sent_msg().await;
+            assert!(sent1.load_from_db().await.is_pinned());
+
+            let info_msg = sent2.load_from_db().await;
+            assert!(info_msg.is_info());
+            assert!(!info_msg.hidden);
+            assert_eq!(info_msg.get_info_type(), SystemMessage::MessagePinned);
+            assert!(info_msg.get_info_contact_id(alice).await?.is_none()); // contact not needed, tapping shall jump to message
+
+            let pinned = get_pinned_messages(alice, alice_chat_id).await?;
+            assert_eq!(pinned.len(), 1);
+            assert_eq!(pinned[0], msg1.id);
+
+            // Pinning an info message does not work
+            assert!(set_pinned_state(alice, info_msg.id, true).await.is_err());
+
+            // Unpin the initially pinned message.
+            // Before, send another message "Bar". To test, no visible info message is added this time,
+            let sent3 = alice.send_text(alice_chat_id, "Bar").await;
+
+            set_pinned_state(alice, msg1.id, false).await?;
+            let sent4 = alice.pop_sent_msg().await;
+            assert!(!sent1.load_from_db().await.is_pinned());
+
+            let pinned = get_pinned_messages(alice, alice_chat_id).await?;
+            assert!(pinned.is_empty());
+
+            let msg3 = sent3.load_from_db().await;
+            assert!(!msg3.is_info());
+            assert!(!msg3.is_pinned());
+            assert_eq!(alice.get_last_msg_id_in(msg3.chat_id).await, msg3.id); // last message is still "Bar", not an info message
+
+            if alice_chat_id != self_chat_id {
+                // Bob receives message "Foo"
+                let msg1 = bob.recv_msg(&sent1).await;
+                assert!(!msg1.is_pinned());
+                let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
+                assert!(pinned.is_empty());
+
+                // Bob receives info message to pin "Foo"
+                bob.recv_msg(&sent2).await;
+                assert!(Message::load_from_db(bob, msg1.id).await?.is_pinned());
+
+                let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
+                assert_eq!(pinned.len(), 1);
+                assert_eq!(pinned[0], msg1.id);
+
+                let info_msg =
+                    Message::load_from_db(bob, bob.get_last_msg_id_in(msg1.chat_id).await).await?;
+                assert!(info_msg.is_info());
+                assert!(!info_msg.hidden);
+                assert_eq!(info_msg.get_info_type(), SystemMessage::MessagePinned);
+                assert!(info_msg.get_info_contact_id(bob).await?.is_none());
+
+                // Bob receives message "Bar" and hidden message to unpin message "Foo"
+                bob.recv_msg(&sent3).await;
+                bob.recv_msg_trash(&sent4).await;
+                assert!(!Message::load_from_db(bob, msg1.id).await?.is_pinned());
+
+                let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
+                assert!(pinned.is_empty());
+
+                let no_info_msg =
+                    Message::load_from_db(bob, bob.get_last_msg_id_in(msg1.chat_id).await).await?;
+                assert!(!no_info_msg.is_info());
+                assert_eq!(no_info_msg.text, "Bar");
+            }
+
+            // Alice's second device receives all four messages and ends up in the same state
+            let msg1 = alice2.recv_msg(&sent1).await;
+            alice2.recv_msg(&sent2).await;
+            assert!(Message::load_from_db(alice2, msg1.id).await?.is_pinned());
+
+            alice2.recv_msg(&sent3).await;
+            alice2.recv_msg_trash(&sent4).await;
+            assert!(!Message::load_from_db(alice2, msg1.id).await?.is_pinned());
+
+            let no_info_msg =
+                Message::load_from_db(alice2, alice2.get_last_msg_id_in(msg1.chat_id).await)
+                    .await?;
+            assert!(!no_info_msg.is_info());
+            assert_eq!(no_info_msg.text, "Bar");
+        }
+
+        Ok(())
+    }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn test_get_pinned_messages_order() -> Result<()> {
+        let mut tcm = TestContextManager::new();
+        let alice = &tcm.alice().await;
+        let chat_id = alice.get_self_chat().await.id;
+        let boilerplate_msg_count = get_chat_msgs(alice, chat_id).await?.len();
+
+        // create three messages, sent1 and sent2 have different timestamp, sent2 and sent3 may differ by ID only
+        let sent1 = alice.send_text(chat_id, "1").await;
+        tokio::time::sleep(Duration::from_millis(1100)).await;
+        let sent2 = alice.send_text(chat_id, "2").await;
+        let sent3 = alice.send_text(chat_id, "3").await;
+
+        // get_chat_msgs() start with the oldest message
+        let chat_msgs = get_chat_msgs(alice, chat_id).await?;
+        let msg_ids: Vec<_> = chat_msgs
+            .into_iter()
+            .filter_map(|item| match item {
+                ChatItem::Message { msg_id } => Some(msg_id),
+                ChatItem::DayMarker { .. } => None,
+            })
+            .collect();
+        assert_eq!(
+            &msg_ids[boilerplate_msg_count..],
+            &[
+                sent1.sender_msg_id,
+                sent2.sender_msg_id,
+                sent3.sender_msg_id
+            ]
+        );
+
+        // get_pinned_messages() has the same order, also starting with the oldest message
+        set_pinned_state(alice, sent1.sender_msg_id, true).await?;
+        set_pinned_state(alice, sent2.sender_msg_id, true).await?;
+        set_pinned_state(alice, sent3.sender_msg_id, true).await?;
+        let pinned = get_pinned_messages(alice, chat_id).await?;
+        assert_eq!(pinned.len(), 3);
+        assert_eq!(pinned[0], sent1.sender_msg_id);
+        assert_eq!(pinned[1], sent2.sender_msg_id);
+        assert_eq!(pinned[2], sent3.sender_msg_id);
+
+        // order of pinning does not affect the order of pinned messages.
+        // this is to keep scrolling direction of chat bubbles and pinned banner scrollbar in sync,
+        // and not jumping wildly around.
+        // this is also what most other messengers are doing.
+        set_pinned_state(alice, sent1.sender_msg_id, false).await?;
+        set_pinned_state(alice, sent2.sender_msg_id, false).await?;
+        set_pinned_state(alice, sent3.sender_msg_id, false).await?;
+        let pinned = get_pinned_messages(alice, chat_id).await?;
+        assert_eq!(pinned.len(), 0);
+
+        set_pinned_state(alice, sent3.sender_msg_id, true).await?;
+        set_pinned_state(alice, sent2.sender_msg_id, true).await?;
+        set_pinned_state(alice, sent1.sender_msg_id, true).await?;
+        let pinned = get_pinned_messages(alice, chat_id).await?;
+        assert_eq!(pinned.len(), 3);
+        assert_eq!(pinned[0], sent1.sender_msg_id);
+        assert_eq!(pinned[1], sent2.sender_msg_id);
+        assert_eq!(pinned[2], sent3.sender_msg_id);
+
+        Ok(())
+    }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn test_handle_pinned_state_from_wire() -> Result<()> {
+        let mut tcm = TestContextManager::new();
+        let alice = &tcm.alice().await;
+        let chat_id = alice.get_self_chat().await.id;
+
+        let sent1 = alice.send_text(chat_id, "pinnable").await;
+        let msg1 = sent1.load_from_db().await;
+        assert!(is_pinnable(&msg1));
+        assert!(
+            handle_pinned_state_from_wire(alice, &msg1, true)
+                .await
+                .is_ok()
+        );
+
+        // For not-pinnable messages, handle_pinned_state_from_wire() logs a warning and returns "ok".
+        // otherwise if there is an incompatibility in which messages are treated as "pinnable",
+        // this error will bubble up and user will get a device message saying "please report a bug".
+        let msg2_id = add_info_msg(alice, chat_id, "not pinnable").await?;
+        let msg2 = Message::load_from_db(alice, msg2_id).await?;
+        assert!(!is_pinnable(&msg2));
+        assert!(
+            handle_pinned_state_from_wire(alice, &msg2, true)
+                .await
+                .is_ok()
+        );
+        alice.assert_warn("Message is not pinnable").await;
+
+        Ok(())
+    }
+}
@@ -1,309 +0,0 @@
-use super::*;
-use crate::chat::{ChatItem, add_info_msg, create_broadcast, get_chat_msgs};
-use crate::config::Config;
-use crate::ephemeral;
-use crate::message;
-use crate::securejoin::get_securejoin_qr;
-use crate::test_utils::{TestContext, TestContextManager, sync};
-use crate::tools::{SystemTime, time};
-use std::time::Duration;
-
-/// Waits for a PinnedMessagesChanged for a given `chat_id`.
-///
-/// Panics if event arrives for the wrong `chat_id`.
-async fn expect_pinned_message_event(context: &TestContext, chat_id: ChatId) {
-    let EventType::PinnedMessagesChanged {
-        chat_id: event_chat_id,
-    } = context
-        .evtracker
-        .get_matching(|evt| matches!(evt, EventType::PinnedMessagesChanged { .. }))
-        .await
-    else {
-        unreachable!();
-    };
-    assert_eq!(event_chat_id, chat_id);
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_pinned_messages() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let alice2 = &tcm.alice().await; // Alice's second device
-    let bob = &tcm.bob().await;
-
-    alice.set_config_bool(Config::SyncMsgs, true).await?;
-    alice2.set_config_bool(Config::SyncMsgs, true).await?;
-
-    // Alice creates all chat types upfront, with Bob as member if possible
-    let single_chat_id = alice.create_chat(bob).await.id;
-    let group_chat_id = alice.create_group_with_members("Group", &[bob]).await;
-    let broadcast_chat_id = create_broadcast(alice, "Channel".to_string()).await?;
-    let qr = get_securejoin_qr(alice, Some(broadcast_chat_id)).await?;
-    tcm.exec_securejoin_qr(bob, alice, &qr).await;
-    let self_chat_id = alice.get_self_chat().await.id;
-    sync(alice, alice2).await;
-
-    for alice_chat_id in [
-        single_chat_id,
-        group_chat_id,
-        broadcast_chat_id,
-        self_chat_id,
-    ] {
-        let pinned = get_pinned_messages(alice, alice_chat_id).await?;
-        assert!(pinned.is_empty());
-
-        // Alice sends message "Foo" and pins it
-        let sent1 = alice.send_text(alice_chat_id, "Foo").await;
-        let msg1 = sent1.load_from_db().await;
-        assert!(!msg1.is_pinned());
-
-        set_pinned_state(alice, msg1.id, true).await?;
-        let sent2 = alice.pop_sent_msg().await;
-        expect_pinned_message_event(alice, msg1.chat_id).await;
-        assert!(sent1.load_from_db().await.is_pinned());
-
-        let info_msg = sent2.load_from_db().await;
-        assert!(info_msg.is_info());
-        assert!(!info_msg.hidden);
-        assert_eq!(info_msg.get_info_type(), SystemMessage::MessagePinned);
-        assert!(info_msg.get_info_contact_id(alice).await?.is_none()); // contact not needed, tapping shall jump to message
-
-        let pinned = get_pinned_messages(alice, alice_chat_id).await?;
-        assert_eq!(pinned.len(), 1);
-        assert_eq!(pinned[0], msg1.id);
-
-        // Pinning an info message does not work
-        assert!(set_pinned_state(alice, info_msg.id, true).await.is_err());
-
-        // Unpin the initially pinned message.
-        // Before, send another message "Bar". To test, no visible info message is added this time,
-        let sent3 = alice.send_text(alice_chat_id, "Bar").await;
-
-        set_pinned_state(alice, msg1.id, false).await?;
-        let sent4 = alice.pop_sent_msg().await;
-        assert!(!sent1.load_from_db().await.is_pinned());
-        expect_pinned_message_event(alice, msg1.chat_id).await;
-
-        let pinned = get_pinned_messages(alice, alice_chat_id).await?;
-        assert!(pinned.is_empty());
-
-        let msg3 = sent3.load_from_db().await;
-        assert!(!msg3.is_info());
-        assert!(!msg3.is_pinned());
-        assert_eq!(alice.get_last_msg_id_in(msg3.chat_id).await, msg3.id); // last message is still "Bar", not an info message
-
-        if alice_chat_id != self_chat_id {
-            // Bob receives message "Foo"
-            let msg1 = bob.recv_msg(&sent1).await;
-            assert!(!msg1.is_pinned());
-            let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
-            assert!(pinned.is_empty());
-
-            // Bob receives info message to pin "Foo"
-            bob.recv_msg(&sent2).await;
-            expect_pinned_message_event(bob, msg1.chat_id).await;
-            assert!(Message::load_from_db(bob, msg1.id).await?.is_pinned());
-
-            let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
-            assert_eq!(pinned.len(), 1);
-            assert_eq!(pinned[0], msg1.id);
-
-            let info_msg =
-                Message::load_from_db(bob, bob.get_last_msg_id_in(msg1.chat_id).await).await?;
-            assert!(info_msg.is_info());
-            assert!(!info_msg.hidden);
-            assert_eq!(info_msg.get_info_type(), SystemMessage::MessagePinned);
-            assert!(info_msg.get_info_contact_id(bob).await?.is_none());
-
-            // Bob receives message "Bar" and hidden message to unpin message "Foo"
-            bob.recv_msg(&sent3).await;
-            bob.recv_msg_trash(&sent4).await;
-            expect_pinned_message_event(bob, msg1.chat_id).await;
-            assert!(!Message::load_from_db(bob, msg1.id).await?.is_pinned());
-
-            let pinned = get_pinned_messages(bob, msg1.chat_id).await?;
-            assert!(pinned.is_empty());
-
-            let no_info_msg =
-                Message::load_from_db(bob, bob.get_last_msg_id_in(msg1.chat_id).await).await?;
-            assert!(!no_info_msg.is_info());
-            assert_eq!(no_info_msg.text, "Bar");
-        }
-
-        // Alice's second device receives all four messages and ends up in the same state
-        let msg1 = alice2.recv_msg(&sent1).await;
-        alice2.recv_msg(&sent2).await;
-        expect_pinned_message_event(alice2, msg1.chat_id).await;
-        assert!(Message::load_from_db(alice2, msg1.id).await?.is_pinned());
-
-        alice2.recv_msg(&sent3).await;
-        alice2.recv_msg_trash(&sent4).await;
-        expect_pinned_message_event(alice2, msg1.chat_id).await;
-        assert!(!Message::load_from_db(alice2, msg1.id).await?.is_pinned());
-
-        let no_info_msg =
-            Message::load_from_db(alice2, alice2.get_last_msg_id_in(msg1.chat_id).await).await?;
-        assert!(!no_info_msg.is_info());
-        assert_eq!(no_info_msg.text, "Bar");
-    }
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_get_pinned_messages_order() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let chat_id = alice.get_self_chat().await.id;
-    let boilerplate_msg_count = get_chat_msgs(alice, chat_id).await?.len();
-
-    // create three messages, sent1 and sent2 have different timestamp, sent2 and sent3 may differ by ID only
-    let sent1 = alice.send_text(chat_id, "1").await;
-    tokio::time::sleep(Duration::from_millis(1100)).await;
-    let sent2 = alice.send_text(chat_id, "2").await;
-    let sent3 = alice.send_text(chat_id, "3").await;
-
-    // get_chat_msgs() start with the oldest message
-    let chat_msgs = get_chat_msgs(alice, chat_id).await?;
-    let msg_ids: Vec<_> = chat_msgs
-        .into_iter()
-        .filter_map(|item| match item {
-            ChatItem::Message { msg_id } => Some(msg_id),
-            ChatItem::DayMarker { .. } => None,
-        })
-        .collect();
-    assert_eq!(
-        &msg_ids[boilerplate_msg_count..],
-        &[
-            sent1.sender_msg_id,
-            sent2.sender_msg_id,
-            sent3.sender_msg_id
-        ]
-    );
-
-    // get_pinned_messages() has the same order, also starting with the oldest message
-    set_pinned_state(alice, sent1.sender_msg_id, true).await?;
-    set_pinned_state(alice, sent2.sender_msg_id, true).await?;
-    set_pinned_state(alice, sent3.sender_msg_id, true).await?;
-    let pinned = get_pinned_messages(alice, chat_id).await?;
-    assert_eq!(pinned.len(), 3);
-    assert_eq!(pinned[0], sent1.sender_msg_id);
-    assert_eq!(pinned[1], sent2.sender_msg_id);
-    assert_eq!(pinned[2], sent3.sender_msg_id);
-
-    // order of pinning does not affect the order of pinned messages.
-    // this is to keep scrolling direction of chat bubbles and pinned banner scrollbar in sync,
-    // and not jumping wildly around.
-    // this is also what most other messengers are doing.
-    set_pinned_state(alice, sent1.sender_msg_id, false).await?;
-    set_pinned_state(alice, sent2.sender_msg_id, false).await?;
-    set_pinned_state(alice, sent3.sender_msg_id, false).await?;
-    let pinned = get_pinned_messages(alice, chat_id).await?;
-    assert_eq!(pinned.len(), 0);
-
-    set_pinned_state(alice, sent3.sender_msg_id, true).await?;
-    set_pinned_state(alice, sent2.sender_msg_id, true).await?;
-    set_pinned_state(alice, sent1.sender_msg_id, true).await?;
-    let pinned = get_pinned_messages(alice, chat_id).await?;
-    assert_eq!(pinned.len(), 3);
-    assert_eq!(pinned[0], sent1.sender_msg_id);
-    assert_eq!(pinned[1], sent2.sender_msg_id);
-    assert_eq!(pinned[2], sent3.sender_msg_id);
-
-    Ok(())
-}
-
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_handle_pinned_state_from_wire() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let chat_id = alice.get_self_chat().await.id;
-
-    let sent1 = alice.send_text(chat_id, "pinnable").await;
-    let msg1 = sent1.load_from_db().await;
-    assert!(is_pinnable(&msg1));
-    assert!(
-        handle_pinned_state_from_wire(alice, &msg1, true)
-            .await
-            .is_ok()
-    );
-
-    // For not-pinnable messages, handle_pinned_state_from_wire() logs a warning and returns "ok".
-    // otherwise if there is an incompatibility in which messages are treated as "pinnable",
-    // this error will bubble up and user will get a device message saying "please report a bug".
-    let msg2_id = add_info_msg(alice, chat_id, "not pinnable").await?;
-    let msg2 = Message::load_from_db(alice, msg2_id).await?;
-    assert!(!is_pinnable(&msg2));
-    assert!(
-        handle_pinned_state_from_wire(alice, &msg2, true)
-            .await
-            .is_ok()
-    );
-    alice.assert_warn("Message is not pinnable").await;
-
-    Ok(())
-}
-
-/// Tests that disappearing pinned message expires and emits `PinnedMessagesChanged` event.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_ephemeral_pinned_message() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let bob = &tcm.bob().await;
-
-    let alice_chat_id = alice.create_chat_id(bob).await;
-
-    // Alice sends ephemeral timer in single chat with Bob.
-    alice_chat_id
-        .set_ephemeral_timer(alice, ephemeral::Timer::from_u32(60))
-        .await?;
-    let sent = alice.pop_sent_msg().await;
-    bob.recv_msg(&sent).await;
-
-    // Alice sends "Hello!" message to Bob.
-    let bob_msg = tcm.send_recv_accept(alice, bob, "Hello!").await;
-    let bob_chat_id = bob_msg.chat_id;
-
-    // Bob reads the message, so the timer starts.
-    message::markseen_msgs(bob, vec![bob_msg.id]).await?;
-
-    // Bob pins "Hello!" message received from Alice.
-    set_pinned_state(bob, bob_msg.id, true).await?;
-    expect_pinned_message_event(bob, bob_chat_id).await;
-    let pinned = get_pinned_messages(bob, bob_chat_id).await?;
-    assert_eq!(pinned.len(), 1);
-
-    // Wait until the message expires.
-    SystemTime::shift(Duration::from_secs(100));
-    ephemeral::delete_expired_messages(bob, time()).await?;
-
-    expect_pinned_message_event(bob, bob_chat_id).await;
-    let pinned = get_pinned_messages(bob, bob_chat_id).await?;
-    assert!(pinned.is_empty());
-
-    Ok(())
-}
-
-/// Tests that `PinnedMessagesChanged` event is emitted when pinned message is deleted.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_delete_pinned_message() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let bob = &tcm.bob().await;
-
-    let bob_msg = tcm.send_recv_accept(alice, bob, "Hello!").await;
-    let bob_chat_id = bob_msg.chat_id;
-
-    // Bob pins "Hello!" message received from Alice.
-    set_pinned_state(bob, bob_msg.id, true).await?;
-    expect_pinned_message_event(bob, bob_chat_id).await;
-    let pinned = get_pinned_messages(bob, bob_chat_id).await?;
-    assert_eq!(pinned.len(), 1);
-
-    message::delete_msgs(bob, &[bob_msg.id]).await?;
-    expect_pinned_message_event(bob, bob_chat_id).await;
-    let pinned = get_pinned_messages(bob, bob_chat_id).await?;
-    assert!(pinned.is_empty());
-
-    Ok(())
-}
@@ -13,7 +13,6 @@ use serde::Deserialize;

 use crate::autorelay::login_param_from_host;
 use crate::config::Config;
-use crate::configure::MAX_RELAYS;
 use crate::contact::{Contact, ContactId, Origin};
 use crate::context::Context;
 use crate::key::Fingerprint;
@@ -134,6 +133,18 @@ pub enum Qr {
        contact_id: ContactId,
    },

+    /// Scanned fingerprint does not match the last seen fingerprint.
+    FprMismatch {
+        /// Contact ID.
+        contact_id: Option<ContactId>,
+    },
+
+    /// The scanned QR code contains a fingerprint but no e-mail address.
+    FprWithoutAddr {
+        /// Key fingerprint.
+        fingerprint: String,
+    },
+
    /// Ask the user if they want to create an account on the given domain.
    Account {
        /// Server domain name.
@@ -489,8 +500,7 @@ async fn decode_openpgp(context: &Context, qr: &str) -> Result<Qr> {
            addrs.push(normalize_address(primary_addr)?);
        };
        if let Some(secondary_addrs_raw) = param.get("r") {
-            let max_secondary = MAX_RELAYS.saturating_sub(addrs.len());
-            for secondary_address in secondary_addrs_raw.split(',').take(max_secondary) {
+            for secondary_address in secondary_addrs_raw.split(',') {
                addrs.push(normalize_address(secondary_address)?)
            }
        }
@@ -641,21 +651,24 @@ async fn decode_openpgp(context: &Context, qr: &str) -> Result<Qr> {
                is_v3,
            })
        }
-    } else {
+    } else if let Some(addr) = addrs.first() {
        let fingerprint = fingerprint.hex();
-        let contact_id: Option<ContactId> = context
-            .sql
-            .query_get_value(
-                "SELECT id FROM contacts WHERE fingerprint=?",
-                (fingerprint,),
-            )
-            .await?;
+        let (contact_id, _) =
+            Contact::add_or_lookup_ext(context, "", addr, &fingerprint, Origin::UnhandledQrScan)
+                .await?;
+        let contact = Contact::get_by_id(context, contact_id).await?;

-        let Some(contact_id) = contact_id else {
-            bail!("Contact matching the fingerprint is not found");
-        };
-
-        Ok(Qr::FprOk { contact_id })
+        if contact.public_key(context).await?.is_some() {
+            Ok(Qr::FprOk { contact_id })
+        } else {
+            Ok(Qr::FprMismatch {
+                contact_id: Some(contact_id),
+            })
+        }
+    } else {
+        Ok(Qr::FprWithoutAddr {
+            fingerprint: fingerprint.human_readable(),
+        })
    }
 }

@@ -305,10 +305,12 @@ async fn test_decode_openpgp_invalid_token() -> Result<()> {
    let ctx = TestContext::new_alice().await;

    // Token cannot contain "/"
-    assert!(check_qr(
+    let qr = check_qr(
        &ctx.ctx,
        "OPENPGP4FPR:79252762C34C5096AF57958F4FC3D21A81B0F0A7#a=cli%40deltachat.de&g=test%20%3F+test%20%21&x=h-0oKQf2CDK&i=9JEXlxAqGM0&s=0V7LzL/cxRL"
-    ).await.is_err());
+    ).await?;
+
+    assert!(matches!(qr, Qr::FprMismatch { .. }));

    Ok(())
 }
@@ -359,23 +361,6 @@ async fn test_decode_openpgp_secure_join() -> Result<()> {
        bail!("Wrong QR code type");
    }

-    // A bad invite code must not be able to steer us onto arbitrarily many relays.
-    let relays: Vec<String> = (0..20).map(|i| format!("cli%40r{i}.example.org")).collect();
-    let qr = check_qr(
-        &ctx.ctx,
-        &format!(
-            "openpgp4fpr:79252762C34C5096AF57958F4FC3D21A81B0F0A7#a=cli%40deltachat.de&r={}&i=TbnwJ6lSvD5&s=0ejvbdFSQxB",
-            relays.join(",")
-        ),
-    )
-    .await?;
-
-    if let Qr::AskVerifyContact { addrs, .. } = qr {
-        assert_eq!(addrs.len(), MAX_RELAYS);
-    } else {
-        bail!("Wrong QR code type");
-    }
-
    Ok(())
 }

@@ -388,17 +373,16 @@ async fn test_decode_openpgp_fingerprint() -> Result<()> {
    let alice_contact = bob.add_or_lookup_contact(alice).await;
    let alice_contact_id = alice_contact.id;

-    // OPENPGP4FPR may have an address,
-    // but it is not used anymore since key contacts are introduced.
-    // We lookup the contact only by fingerprint and ignore the address.
-    assert!(
-        check_qr(
-            bob,
-            "OPENPGP4FPR:1234567890123456789012345678901234567890#a=alice@example.org",
-        )
-        .await
-        .is_err()
-    );
+    let qr = check_qr(
+        bob,
+        "OPENPGP4FPR:1234567890123456789012345678901234567890#a=alice@example.org",
+    )
+    .await?;
+    if let Qr::FprMismatch { contact_id, .. } = qr {
+        assert_ne!(contact_id.unwrap(), alice_contact_id);
+    } else {
+        bail!("Wrong QR code type");
+    }

    let qr = check_qr(
        bob,
@@ -414,44 +398,46 @@ async fn test_decode_openpgp_fingerprint() -> Result<()> {
        bail!("Wrong QR code type");
    }

-    assert!(
+    assert!(matches!(
        check_qr(
            bob,
            "OPENPGP4FPR:1234567890123456789012345678901234567890#a=bob@example.org",
        )
-        .await
-        .is_err()
-    );
+        .await?,
+        Qr::FprMismatch { .. }
+    ));

    Ok(())
 }

-/// Tests OPENPGP4FPR QR codes without an email address.
-///
-/// Email address in OPENPGP4FPR QR codes was an extension
-/// used before switch to identifying contacts by fingerprint.
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_decode_openpgp_without_addr() -> Result<()> {
    let ctx = TestContext::new().await;

-    assert!(
-        check_qr(
-            &ctx.ctx,
-            "OPENPGP4FPR:1234567890123456789012345678901234567890",
-        )
-        .await
-        .is_err()
+    let qr = check_qr(
+        &ctx.ctx,
+        "OPENPGP4FPR:1234567890123456789012345678901234567890",
+    )
+    .await?;
+    assert_eq!(
+        qr,
+        Qr::FprWithoutAddr {
+            fingerprint: "1234 5678 9012 3456 7890\n1234 5678 9012 3456 7890".to_string()
+        }
    );

    // Test it again with lowercased "openpgp4fpr:" uri scheme

-    assert!(
-        check_qr(
-            &ctx.ctx,
-            "openpgp4fpr:1234567890123456789012345678901234567890",
-        )
-        .await
-        .is_err()
+    let qr = check_qr(
+        &ctx.ctx,
+        "openpgp4fpr:1234567890123456789012345678901234567890",
+    )
+    .await?;
+    assert_eq!(
+        qr,
+        Qr::FprWithoutAddr {
+            fingerprint: "1234 5678 9012 3456 7890\n1234 5678 9012 3456 7890".to_string()
+        }
    );

    let res = check_qr(&ctx.ctx, "OPENPGP4FPR:12345678901234567890").await;
@@ -84,7 +84,7 @@ pub struct ReactionFrequency {
    pub reaction: Reaction,

    /// Number of contacts that reacted with this emoji.
-    pub count: u32,
+    pub count: usize,

    /// True if `ContactId::SELF` is among the contacts that reacted with this emoji.
    pub is_from_self: bool,
@@ -420,7 +420,7 @@ pub(crate) async fn apply_pending_reactions(
 /// sorted in descending order of frequency.
 fn calc_frequencies(by_contact: &BTreeMap<ContactId, Reaction>) -> Vec<ReactionFrequency> {
    let mut self_reaction = Reaction::new("");
-    let mut counts: BTreeMap<&str, u32> = BTreeMap::new();
+    let mut counts: BTreeMap<&str, usize> = BTreeMap::new();
    for (contact_id, reaction) in by_contact {
        let count = counts.entry(reaction.as_str()).or_insert(0);
        *count = count.saturating_add(1);
@@ -42,7 +42,7 @@ struct WireMessage {
 #[derive(Debug, Serialize, Deserialize)]
 struct WireEntry {
    emoji: String,
-    count: u32,
+    count: usize,
 }

 /// Renders one or more message's states as a JSON string, ready to be sent in `Chat-Broadcast-States:` header.
@@ -235,10 +235,10 @@ pub(crate) async fn load_broadcast_reactions(
            (msg_id,),
            |row| {
                let reaction: String = row.get(0)?;
-                let count: u32 = row.get(1)?;
+                let count: i64 = row.get(1)?;
                Ok(ReactionFrequency {
                    reaction: Reaction::new(&reaction),
-                    count,
+                    count: count as usize,
                    is_from_self: false,
                })
            },
@@ -405,7 +405,7 @@ mod tests {
    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
    async fn test_modify_frequencies() {
        // Helper to create a ReactionFrequency entry
-        let freq = |emoji: &str, count: u32, is_from_self: bool| -> ReactionFrequency {
+        let freq = |emoji: &str, count: usize, is_from_self: bool| -> ReactionFrequency {
            ReactionFrequency {
                reaction: Reaction::new(emoji),
                count,
@@ -2107,8 +2107,7 @@ async fn add_parts(
        let hidden = part.is_reaction;
        if part.is_reaction {
            let reaction_str = simplify::remove_footers(part.msg.as_str());
-            let is_incoming_fresh =
-                mime_parser.incoming && !seen && chat_id_blocked == Blocked::Not;
+            let is_incoming_fresh = mime_parser.incoming && !seen;
            set_msg_reaction(
                context,
                mime_in_reply_to,
@@ -2392,7 +2391,6 @@ async fn handle_edit_delete(
        }

        let mut modified_chat_ids = BTreeSet::new();
-        let mut pinned_messages_changed_chat_ids = BTreeSet::new();
        let mut msg_ids = Vec::new();

        let rfc724_mid_vec: Vec<&str> = rfc724_mid_list.split_whitespace().collect();
@@ -2417,17 +2415,8 @@ async fn handle_edit_delete(
            message::delete_msg_locally(context, &msg).await?;
            msg_ids.push(msg.id);
            modified_chat_ids.insert(msg.chat_id);
-            if msg.is_pinned() {
-                pinned_messages_changed_chat_ids.insert(msg.chat_id);
-            }
        }
-        message::delete_msgs_locally_done(
-            context,
-            &msg_ids,
-            modified_chat_ids,
-            pinned_messages_changed_chat_ids,
-        )
-        .await?;
+        message::delete_msgs_locally_done(context, &msg_ids, modified_chat_ids).await?;
    }
    Ok(())
 }
@@ -2716,12 +2705,6 @@ async fn lookup_or_create_adhoc_group(
        for &id in &contact_ids {
            stmt.execute((id,)).context("INSERT INTO temp.contacts")?;
        }
-
-        // Contact IDs are 32-bit internally,
-        // so this conversion of contact ID set size
-        // to u32 should never fail.
-        let contact_ids_len = u32::try_from(contact_ids.len())?;
-
        let val = t
            .query_row(
                "SELECT c.id, c.blocked
@@ -2735,7 +2718,7 @@ async fn lookup_or_create_adhoc_group(
                     AND contact_id NOT IN (SELECT id FROM temp.contacts)
                     AND add_timestamp >= remove_timestamp)=0
                ORDER BY m.timestamp DESC",
-                (&grpname, contact_ids_len),
+                (&grpname, contact_ids.len()),
                |row| {
                    let id: ChatId = row.get(0)?;
                    let blocked: Blocked = row.get(1)?;
@@ -3749,9 +3732,10 @@ async fn apply_out_broadcast_changes(
        if from_id == ContactId::SELF {
            let added_id = lookup_key_contact_by_fingerprint(context, added_fpr).await?;
            if let Some(added_id) = added_id {
-                info!(context, "Broadcast addition (TRASH)");
-                better_msg.get_or_insert("".to_string());
-                if !chat::is_contact_in_chat(context, chat.id, added_id).await? {
+                if chat::is_contact_in_chat(context, chat.id, added_id).await? {
+                    info!(context, "No-op broadcast addition (TRASH)");
+                    better_msg.get_or_insert("".to_string());
+                } else {
                    chat::add_to_chat_contacts_table(
                        context,
                        mime_parser.timestamp_sent,
@@ -3759,6 +3743,11 @@ async fn apply_out_broadcast_changes(
                        &[added_id],
                    )
                    .await?;
+                    let msg =
+                        stock_str::msg_add_member_local(context, added_id, ContactId::UNDEFINED)
+                            .await;
+                    better_msg.get_or_insert(msg);
+                    added_removed_id = Some(added_id);
                    send_event_chat_modified = true;
                }
            } else {
@@ -726,7 +726,6 @@ async fn test_resend_after_ndn() -> Result<()> {
    Ok(())
 }

-// an NDN in a group does not make the whole message as failed
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_parse_ndn_group_msg() -> Result<()> {
    let t = TestContext::new().await;
@@ -759,7 +758,7 @@ async fn test_parse_ndn_group_msg() -> Result<()> {

    let msg = Message::load_from_db(&t, msg_id).await?;

-    assert_eq!(msg.state, MessageState::OutDelivered);
+    assert_eq!(msg.state, MessageState::OutFailed);

    let msgs = chat::get_chat_msgs(&t, msg.chat_id).await?;
    assert!(matches!(
@@ -767,6 +766,9 @@ async fn test_parse_ndn_group_msg() -> Result<()> {
        ChatItem::Message { msg_id } if msg_id == msg.id
    ));

+    t.assert_warn("Delivery Status Notification (Failure)")
+        .await;
+
    Ok(())
 }

@@ -2723,7 +2725,20 @@ async fn test_read_receipts_dont_create_chats() -> Result<()> {
    let chats = Chatlist::try_load(&alice, 0, None, None).await?;
    assert_eq!(chats.len(), 0);

-    alice.recv_mdn(&bob, &received_msg).await?;
+    // Bob sends a read receipt.
+    let mdn_mimefactory = crate::mimefactory::MimeFactory::from_mdn(
+        &bob,
+        received_msg.from_id,
+        received_msg.rfc724_mid,
+        vec![],
+    )
+    .await?;
+    let bob_addr = bob.get_primary_self_addr().await?;
+    let rendered_mdn = mdn_mimefactory.render(&bob, &bob_addr).await?;
+    let mdn_body = rendered_mdn.message;
+
+    // Alice receives the read receipt.
+    receive_imf(&alice, mdn_body.as_bytes(), false).await?;

    // Chat should not pop up in the chatlist.
    let chats = Chatlist::try_load(&alice, 0, None, None).await?;
@@ -2746,7 +2761,20 @@ async fn test_read_receipts_dont_unmark_bots() -> Result<()> {
        .await;
    let received_msg = bob.get_last_msg().await;

-    alice.recv_mdn(bob, &received_msg).await?;
+    // Bob sends a read receipt.
+    let mdn_mimefactory = crate::mimefactory::MimeFactory::from_mdn(
+        bob,
+        received_msg.from_id,
+        received_msg.rfc724_mid,
+        vec![],
+    )
+    .await?;
+    let bob_addr = bob.get_primary_self_addr().await?;
+    let rendered_mdn = mdn_mimefactory.render(bob, &bob_addr).await?;
+    let mdn_body = rendered_mdn.message;
+
+    // Alice receives the read receipt.
+    receive_imf(alice, mdn_body.as_bytes(), false).await?;
    let msg = alice.get_last_msg_in(alice_chat.id).await;
    assert_eq!(msg.state, MessageState::OutMdnRcvd);
    let ab_contact = alice.add_or_lookup_contact(bob).await;
@@ -3338,35 +3366,6 @@ async fn test_blocked_contact_creates_group() -> Result<()> {
    Ok(())
 }

-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_blocked_contact_sends_reaction() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let bob = &tcm.bob().await;
-
-    let bob_msg_id = tcm.send_recv_accept(alice, bob, "Hi!").await.id;
-
-    let chat = alice.get_chat(bob).await;
-    chat.id.block(alice).await?;
-
-    crate::reaction::send_reaction(bob, bob_msg_id, "👍").await?;
-    let sent = bob.pop_sent_msg().await;
-    alice.recv_msg_hidden(&sent).await;
-    alice.emit_event(EventType::Test);
-
-    while let Some(ev) = alice.evtracker.recv().await {
-        match ev.typ {
-            EventType::IncomingReaction { .. } => {
-                panic!("Alice is not supposed to receive a notification, since she blocked Bob")
-            }
-            EventType::Test => break,
-            _ => {}
-        }
-    }
-
-    Ok(())
-}
-
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_outgoing_undecryptable() -> Result<()> {
    let alice = &TestContext::new().await;
@@ -341,7 +341,7 @@ async fn background_fetch_from_transport(

    let folder = connection.folder.clone();
    connection
-        .fetch_delete(context, &mut session, &folder)
+        .fetch_move_delete(context, &mut session, &folder)
        .await
 }

@@ -556,9 +556,9 @@ async fn fetch_idle(ctx: &Context, connection: &mut Imap, mut session: Session)

    // Fetch the watched folder.
    connection
-        .fetch_delete(ctx, &mut session, &watch_folder)
+        .fetch_move_delete(ctx, &mut session, &watch_folder)
        .await
-        .context("fetch_delete")?;
+        .context("fetch_move_delete")?;

    download_known_post_messages_without_pre_message(ctx, &mut session).await?;
    download_msgs(ctx, &mut session)
@@ -48,7 +48,7 @@ async fn test_setup_contact_ext(case: SetupContactCase) -> (TestContext, TestCon

    let mut tcm = TestContextManager::new();
    let alice = tcm.alice().await;
-    let alice_addr = &alice
+    let alice_addr = alice
        .get_config(Config::ConfiguredAddr)
        .await
        .unwrap()
@@ -116,7 +116,7 @@ async fn test_setup_contact_ext(case: SetupContactCase) -> (TestContext, TestCon
    let contact_alice_id = bob.add_or_lookup_contact_no_key(&alice).await.id;
    let sent = bob.pop_sent_msg().await;
    assert!(!sent.payload.contains("Bob Examplenet"));
-    assert_eq!(sent.recipient(), EmailAddress::new(alice_addr).unwrap());
+    assert_eq!(sent.recipients, *alice_addr);
    let msg = alice.parse_msg(&sent).await;
    assert!(msg.signature.is_none());
    assert_eq!(
@@ -56,6 +56,10 @@ pub struct Sql {
    /// SQL connection pool.
    pool: RwLock<Option<Pool>>,

+    /// None if the database is not open, true if it is open with passphrase and false if it is
+    /// open without a passphrase.
+    is_encrypted: RwLock<Option<bool>>,
+
    /// Cache of `config` table.
    pub(crate) config_cache: RwLock<HashMap<String, Option<String>>>,
 }
@@ -66,15 +70,52 @@ impl Sql {
        Self {
            dbfile,
            pool: Default::default(),
+            is_encrypted: Default::default(),
            config_cache: Default::default(),
        }
    }

+    /// Tests SQLCipher passphrase.
+    ///
+    /// Returns true if passphrase is correct, i.e. the database is new or can be unlocked with
+    /// this passphrase, and false if the database is already encrypted with another passphrase or
+    /// corrupted.
+    ///
+    /// Fails if database is already open.
+    pub async fn check_passphrase(&self, passphrase: String) -> Result<bool> {
+        if self.is_open().await {
+            bail!("Database is already opened.");
+        }
+
+        // Hold the lock to prevent other thread from opening the database.
+        let _lock = self.pool.write().await;
+
+        // Test that the key is correct using a single connection.
+        let connection = Connection::open(&self.dbfile)?;
+        if !passphrase.is_empty() {
+            connection
+                .pragma_update(None, "key", &passphrase)
+                .context("Failed to set PRAGMA key")?;
+        }
+        let key_is_correct = connection
+            .query_row("SELECT count(*) FROM sqlite_master", [], |_row| Ok(()))
+            .is_ok();
+
+        Ok(key_is_correct)
+    }
+
    /// Checks if there is currently a connection to the underlying Sqlite database.
    pub async fn is_open(&self) -> bool {
        self.pool.read().await.is_some()
    }

+    /// Returns true if the database is encrypted.
+    ///
+    /// If database is not open, returns `None`.
+    pub(crate) async fn is_encrypted(&self) -> Option<bool> {
+        *self.is_encrypted.read().await
+    }
+
    /// Closes all underlying Sqlite connections.
    pub(crate) async fn close(&self) {
        let _ = self.pool.write().await.take();
@@ -82,22 +123,52 @@ impl Sql {
    }

    /// Imports the database from a separate file with the given passphrase.
-    pub(crate) async fn import(&self, path: &Path) -> Result<()> {
+    pub(crate) async fn import(&self, path: &Path, passphrase: String) -> Result<()> {
+        let path_str = path
+            .to_str()
+            .with_context(|| format!("path {path:?} is not valid unicode"))?
+            .to_string();
+
        // Keep `config_cache` locked all the time the db is imported so that nobody can use invalid
        // values from there. And clear it immediately so as not to forget in case of errors.
        let mut config_cache = self.config_cache.write().await;
        config_cache.clear();

-        let src_conn =
-            rusqlite::Connection::open(path).context("Failed to open source database")?;
        let query_only = false;
        self.call(query_only, move |conn| {
-            let backup = rusqlite::backup::Backup::new(&src_conn, &mut *conn)?;
-            backup.run_to_completion(5, std::time::Duration::ZERO, None)?;
-            drop(backup);
+            // Check that backup passphrase is correct before resetting our database.
+            conn.execute("ATTACH DATABASE ? AS backup KEY ?", (path_str, passphrase))
+                .context("failed to attach backup database")?;
+            let res = conn
+                .query_row("SELECT count(*) FROM sqlite_master", [], |_row| Ok(()))
+                .context("backup passphrase is not correct");

-            conn.execute("VACUUM", [])
-                .context("failed to vacuum the database")?;
+            // Reset the database without reopening it. We don't want to reopen the database because we
+            // don't have main database passphrase at this point.
+            // See <https://sqlite.org/c3ref/c_dbconfig_enable_fkey.html> for documentation.
+            // Without resetting import may fail due to existing tables.
+            res.and_then(|_| {
+                conn.set_db_config(DbConfig::SQLITE_DBCONFIG_RESET_DATABASE, true)
+                    .context("failed to set SQLITE_DBCONFIG_RESET_DATABASE")
+            })
+            .and_then(|_| {
+                conn.execute("VACUUM", [])
+                    .context("failed to vacuum the database")
+            })
+            .and(
+                conn.set_db_config(DbConfig::SQLITE_DBCONFIG_RESET_DATABASE, false)
+                    .context("failed to unset SQLITE_DBCONFIG_RESET_DATABASE"),
+            )
+            .and_then(|_| {
+                conn.query_row("SELECT sqlcipher_export('main', 'backup')", [], |_row| {
+                    Ok(())
+                })
+                .context("failed to import from attached backup database")
+            })
+            .and(
+                conn.execute("DETACH DATABASE backup", [])
+                    .context("failed to detach backup database"),
+            )?;
            Ok(())
        })
        .await
@@ -106,10 +177,10 @@ impl Sql {
    const N_DB_CONNECTIONS: usize = 3;

    /// Creates a new connection pool.
-    fn new_pool(dbfile: &Path) -> Result<Pool> {
+    fn new_pool(dbfile: &Path, passphrase: String) -> Result<Pool> {
        let mut connections = Vec::with_capacity(Self::N_DB_CONNECTIONS);
        for _ in 0..Self::N_DB_CONNECTIONS {
-            let connection = new_connection(dbfile)?;
+            let connection = new_connection(dbfile, &passphrase)?;
            connections.push(connection);
        }

@@ -117,8 +188,8 @@ impl Sql {
        Ok(pool)
    }

-    async fn try_open(&self, context: &Context, dbfile: &Path) -> Result<()> {
-        *self.pool.write().await = Some(Self::new_pool(dbfile)?);
+    async fn try_open(&self, context: &Context, dbfile: &Path, passphrase: String) -> Result<()> {
+        *self.pool.write().await = Some(Self::new_pool(dbfile, passphrase.to_string())?);

        if let Err(e) = self.run_migrations(context).await {
            error!(context, "Running migrations failed: {e:#}");
@@ -176,7 +247,7 @@ impl Sql {

    /// Opens the provided database and runs any necessary migrations.
    /// If a database is already open, this will return an error.
-    pub async fn open(&self, context: &Context) -> Result<()> {
+    pub async fn open(&self, context: &Context, passphrase: String) -> Result<()> {
        if self.is_open().await {
            error!(
                context,
@@ -185,8 +256,10 @@ impl Sql {
            bail!("SQL database is already opened.");
        }

-        self.try_open(context, &self.dbfile).await?;
+        let passphrase_nonempty = !passphrase.is_empty();
+        self.try_open(context, &self.dbfile, passphrase).await?;
        info!(context, "Opened database {:?}.", self.dbfile);
+        *self.is_encrypted.write().await = Some(passphrase_nonempty);

        // setup debug logging if there is an entry containing its id
        if let Some(xdc_id) = self
@@ -198,6 +271,28 @@ impl Sql {
        Ok(())
    }

+    /// Changes the passphrase of encrypted database.
+    ///
+    /// The database must already be encrypted and the passphrase cannot be empty.
+    /// It is impossible to turn encrypted database into unencrypted
+    /// and vice versa this way, use import/export for this.
+    pub async fn change_passphrase(&self, passphrase: String) -> Result<()> {
+        let mut lock = self.pool.write().await;
+
+        let pool = lock.take().context("SQL connection pool is not open")?;
+        let query_only = false;
+        let conn = pool.get(query_only).await?;
+        if !passphrase.is_empty() {
+            conn.pragma_update(None, "rekey", passphrase.clone())
+                .context("Failed to set PRAGMA rekey")?;
+        }
+        drop(pool);
+
+        *lock = Some(Self::new_pool(&self.dbfile, passphrase.to_string())?);
+
+        Ok(())
+    }
+
    /// Allocates a connection and calls `function` with the connection.
    ///
    /// If `query_only` is true, allocates read-only connection,
@@ -595,7 +690,7 @@ impl Sql {
 ///
 /// `passphrase` is the SQLCipher database passphrase.
 /// Empty string if database is not encrypted.
-fn new_connection(path: &Path) -> Result<Connection> {
+fn new_connection(path: &Path, passphrase: &str) -> Result<Connection> {
    let flags = OpenFlags::SQLITE_OPEN_NO_MUTEX
        | OpenFlags::SQLITE_OPEN_READ_WRITE
        | OpenFlags::SQLITE_OPEN_CREATE;
@@ -631,6 +726,9 @@ fn new_connection(path: &Path) -> Result<Connection> {
        conn.busy_timeout(Duration::ZERO)?;
    }

+    if !passphrase.is_empty() {
+        conn.pragma_update(None, "key", passphrase)?;
+    }
    // Try to enable auto_vacuum. This will only be
    // applied if the database is new or after successful
    // VACUUM, which usually happens before backup export.
@@ -657,7 +657,7 @@ pub(crate) async fn msgs_to_key_contacts(context: &Context) -> Result<()> {
        return Ok(());
    }
    let trans_fn = |t: &mut rusqlite::Transaction| {
-        let mut first_key_contacts_msg_id: u32 = t
+        let mut first_key_contacts_msg_id: u64 = t
            .query_one(
                "SELECT CAST(value AS INTEGER) FROM config WHERE keyname='first_key_contacts_msg_id'",
                (),
@@ -681,10 +681,10 @@ pub(crate) async fn msgs_to_key_contacts(context: &Context) -> Result<()> {
            )
            .context("Prepare stmt")?;
        let msgs_to_migrate = 1000;
-        let mut msgs_migrated: u32 = 0;
+        let mut msgs_migrated: u64 = 0;
        while first_key_contacts_msg_id > 0 && msgs_migrated < msgs_to_migrate {
            let start_msg_id = first_key_contacts_msg_id.saturating_sub(msgs_to_migrate);
-            let cnt: u32 = stmt
+            let cnt: u64 = stmt
                .execute((start_msg_id, first_key_contacts_msg_id))
                .context("UPDATE msgs")?
                .try_into()?;
@@ -2673,13 +2673,6 @@ CREATE TABLE smtp2 (
        .await?;
    }

-    inc_and_check(&mut migration_version, 167)?;
-    if dbversion < migration_version {
-        // The default relay candidates are no longer seeded into the table.
-        sql.execute_migration("DELETE FROM relay_candidates", migration_version)
-            .await?;
-    }
-
    let new_version = sql
        .get_raw_config_int(VERSION_CFG)
        .await?
@@ -83,7 +83,7 @@ async fn test_housekeeping_db_closed() {

    t.sql.close().await;
    housekeeping(&t).await.unwrap(); // housekeeping should emit warnings but not fail
-    t.sql.open(&t).await.unwrap();
+    t.sql.open(&t, "".to_string()).await.unwrap();

    let a = t.get_config(Config::Selfavatar).await.unwrap().unwrap();
    assert_eq!(avatar_bytes, &tokio::fs::read(&a).await.unwrap()[..]);
@@ -155,11 +155,11 @@ async fn test_db_reopen() -> Result<()> {
    let sql = Sql::new(dbfile);

    // Create database with all the tables.
-    sql.open(&t).await.unwrap();
+    sql.open(&t, "".to_string()).await.unwrap();
    sql.close().await;

    // Reopen the database
-    sql.open(&t).await?;
+    sql.open(&t, "".to_string()).await?;
    sql.execute(
        "INSERT INTO config (keyname, value) VALUES (?, ?);",
        ("foo", "bar"),
@@ -209,6 +209,99 @@ async fn test_migration_flags() -> Result<()> {
    Ok(())
 }

+#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+async fn test_check_passphrase() -> Result<()> {
+    use tempfile::tempdir;
+
+    // The context is used only for logging.
+    let t = TestContext::new().await;
+
+    // Create a separate empty database for testing.
+    let dir = tempdir()?;
+    let dbfile = dir.path().join("testdb.sqlite");
+    let sql = Sql::new(dbfile.clone());
+
+    sql.check_passphrase("foo".to_string()).await?;
+    sql.open(&t, "foo".to_string())
+        .await
+        .context("failed to open the database first time")?;
+    sql.close().await;
+
+    // Reopen the database
+    let sql = Sql::new(dbfile);
+
+    // Test that we can't open encrypted database without a passphrase.
+    assert!(sql.open(&t, "".to_string()).await.is_err());
+
+    // Now open the database with passpharse, it should succeed.
+    sql.check_passphrase("foo".to_string()).await?;
+    sql.open(&t, "foo".to_string())
+        .await
+        .context("failed to open the database second time")?;
+
+    Ok(())
+}
+
+#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+async fn test_sql_change_passphrase() -> Result<()> {
+    use tempfile::tempdir;
+
+    // The context is used only for logging.
+    let t = TestContext::new().await;
+
+    // Create a separate empty database for testing.
+    let dir = tempdir()?;
+    let dbfile = dir.path().join("testdb.sqlite");
+    let sql = Sql::new(dbfile.clone());
+
+    sql.open(&t, "foo".to_string())
+        .await
+        .context("failed to open the database first time")?;
+    sql.close().await;
+
+    // Change the passphrase from "foo" to "bar".
+    let sql = Sql::new(dbfile.clone());
+    sql.open(&t, "foo".to_string())
+        .await
+        .context("failed to open the database second time")?;
+    sql.change_passphrase("bar".to_string())
+        .await
+        .context("failed to change passphrase")?;
+
+    // Test that at least two connections are still working.
+    // This ensures that not only the connection which changed the password is working,
+    // but other connections as well.
+    {
+        let lock = sql.pool.read().await;
+        let pool = lock.as_ref().unwrap();
+        let query_only = true;
+        let conn1 = pool.get(query_only).await?;
+        let conn2 = pool.get(query_only).await?;
+        conn1
+            .query_row("SELECT count(*) FROM sqlite_master", [], |_row| Ok(()))
+            .unwrap();
+        conn2
+            .query_row("SELECT count(*) FROM sqlite_master", [], |_row| Ok(()))
+            .unwrap();
+    }
+
+    sql.close().await;
+
+    let sql = Sql::new(dbfile);
+
+    // Test that old passphrase is not working.
+    assert!(sql.open(&t, "foo".to_string()).await.is_err());
+
+    // Open the database with the new passphrase.
+    sql.check_passphrase("bar".to_string()).await?;
+    sql.open(&t, "bar".to_string())
+        .await
+        .context("failed to open the database third time")?;
+    sql.close().await;
+
+    Ok(())
+}
+
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_query_only() -> Result<()> {
    let t = TestContext::new().await;
@@ -69,7 +69,7 @@ struct ContactStat {
    #[serde(skip_serializing_if = "is_false", rename = "direct_chat")]
    single_chat: bool,

-    last_seen: i64,
+    last_seen: u64,

    /// Whether the contact was established after stats-sending was enabled
    #[serde(skip_serializing_if = "is_false")]
@@ -312,7 +312,7 @@ async fn ensure_last_old_contact_id(context: &Context) -> Result<()> {
        return Ok(());
    }

-    let last_contact_id: u32 = context
+    let last_contact_id: u64 = context
        .sql
        .query_get_value("SELECT MAX(id) FROM contacts", ())
        .await?
@@ -436,7 +436,7 @@ async fn get_contact_stats(context: &Context, last_old_contact: u32) -> Result<V
            |row| {
                let id = row.get(0)?;
                let encrypted: bool = row.get(1)?;
-                let last_seen: i64 = row.get(2)?;
+                let last_seen: u64 = row.get(2)?;
                let bot: bool = row.get(3)?;

                Ok(ContactStat {
@@ -56,18 +56,16 @@ pub async fn get_storage_usage(ctx: &Context) -> Result<StorageUsage> {
    let blobdir_size =
        tokio::task::spawn_blocking(move || get_blobdir_storage_usage(&context_clone));

-    let page_size: i64 = ctx
+    let page_size: u64 = ctx
        .sql
        .query_get_value("PRAGMA page_size", ())
        .await?
        .unwrap_or_default();
-    let page_size = u64::try_from(page_size)?;
-    let page_count: i64 = ctx
+    let page_count: u64 = ctx
        .sql
        .query_get_value("PRAGMA page_count", ())
        .await?
        .unwrap_or_default();
-    let page_count = u64::try_from(page_count)?;

    let mut largest_tables = ctx
        .sql
@@ -80,8 +78,7 @@ pub async fn get_storage_usage(ctx: &Context) -> Result<StorageUsage> {
            (),
            |row| {
                let name: String = row.get(0)?;
-                let size: i64 = row.get(1)?;
-                let size: u64 = u64::try_from(size)?;
+                let size: u64 = row.get(1)?;
                Ok((name, size, None))
            },
        )
@@ -89,13 +86,12 @@ pub async fn get_storage_usage(ctx: &Context) -> Result<StorageUsage> {

    for row in &mut largest_tables {
        let name = &row.0;
-        let row_count: Option<i64> = ctx
+        let row_count: Result<Option<u64>> = ctx
            .sql
            // SECURITY: the table name comes from the db, not from the user
            .query_get_value(&format!("SELECT COUNT(*) FROM {name}"), ())
-            .await
-            .unwrap_or_default();
-        row.2 = row_count.map(|count| u64::try_from(count).unwrap_or_default());
+            .await;
+        row.2 = row_count.unwrap_or_default();
    }

    let largest_webxdc_data = ctx
@@ -107,12 +103,8 @@ pub async fn get_storage_usage(ctx: &Context) -> Result<StorageUsage> {
            (),
            |row| {
                let msg_id: MsgId = row.get(0)?;
-                let size: i64 = row.get(1)?;
-                let count: i64 = row.get(2)?;
-
-                // This should never fail as the count cannot be negative.
-                let size: u64 = u64::try_from(size)?;
-                let count: u64 = u64::try_from(count)?;
+                let size: u64 = row.get(1)?;
+                let count: u64 = row.get(2)?;

                Ok((msg_id, size, count))
            },
@@ -384,7 +384,6 @@ impl Context {

    async fn sync_message_deletion(&self, msgs: &[String]) -> Result<()> {
        let mut modified_chat_ids = BTreeSet::new();
-        let mut pinned_messages_changed_chat_ids = BTreeSet::new();
        let mut msg_ids = Vec::new();
        for rfc724_mid in msgs {
            if let Some(msg_id) = message::rfc724_mid_exists(self, rfc724_mid).await? {
@@ -392,9 +391,6 @@ impl Context {
                    message::delete_msg_locally(self, &msg).await?;
                    msg_ids.push(msg.id);
                    modified_chat_ids.insert(msg.chat_id);
-                    if msg.is_pinned() {
-                        pinned_messages_changed_chat_ids.insert(msg.chat_id);
-                    }
                } else {
                    warn!(self, "Sync message delete: Database entry does not exist.");
                }
@@ -402,13 +398,7 @@ impl Context {
                warn!(self, "Sync message delete: {rfc724_mid:?} not found.");
            }
        }
-        message::delete_msgs_locally_done(
-            self,
-            &msg_ids,
-            modified_chat_ids,
-            pinned_messages_changed_chat_ids,
-        )
-        .await?;
+        message::delete_msgs_locally_done(self, &msg_ids, modified_chat_ids).await?;
        Ok(())
    }
 }
@@ -35,7 +35,7 @@ use crate::context::Context;
 use crate::events::{Event, EventEmitter, EventType, Events};
 use crate::key::{self, DcKey, self_fingerprint};
 use crate::message::{Message, MessageState, MsgId};
-use crate::mimefactory::{self, MimeFactory};
+use crate::mimefactory;
 use crate::mimeparser::{MimeMessage, SystemMessage};
 use crate::pgp::SeipdVersion;
 use crate::receive_imf::{ReceivedMsg, receive_imf};
@@ -193,21 +193,11 @@ impl TestContextManager {
        to.recv_msg(&sent).await
    }

+    // TODO: this just adds a transport
    pub async fn change_addr(&self, test_context: &TestContext, new_addr: &str) {
-        self.section(&format!(
-            "{} changes her self address and reconfigures",
-            test_context.name()
-        ));
-
        test_context.add_transport(new_addr).await;
-        test_context.set_primary_self_addr(new_addr).await.unwrap();
        // ensure_secret_key_exists() is called during configure
        key::ensure_secret_key_exists(test_context).await.unwrap();
-
-        assert_eq!(
-            test_context.get_primary_self_addr().await.unwrap(),
-            new_addr
-        );
    }

    /// Executes SecureJoin protocol between `scanner` and `scanned`.
@@ -850,17 +840,6 @@ ORDER BY id"
        assert_eq!(received.chat_id, ChatId::TRASH);
    }

-    /// Receives a read receipt from `reader`, who received `msg`.
-    pub async fn recv_mdn(&self, reader: &TestContext, msg: &Message) -> Result<()> {
-        let mdn = MimeFactory::from_mdn(reader, msg.from_id, msg.rfc724_mid.clone(), vec![])
-            .await?
-            .render(reader, &reader.get_primary_self_addr().await?)
-            .await?
-            .message;
-        receive_imf(self, mdn.as_bytes(), false).await?;
-        Ok(())
-    }
-
    /// Gets the most recent message ID of a chat.
    ///
    /// Panics on errors or if the most recent message is a marker.
@@ -520,6 +520,32 @@ where
    }
 }

+pub(crate) trait ToOption<T> {
+    fn to_option(self) -> Option<T>;
+}
+impl<'a> ToOption<&'a str> for &'a String {
+    fn to_option(self) -> Option<&'a str> {
+        if self.is_empty() { None } else { Some(self) }
+    }
+}
+impl ToOption<String> for u16 {
+    fn to_option(self) -> Option<String> {
+        if self == 0 {
+            None
+        } else {
+            Some(self.to_string())
+        }
+    }
+}
+impl ToOption<String> for Option<i32> {
+    fn to_option(self) -> Option<String> {
+        match self {
+            None | Some(0) => None,
+            Some(v) => Some(v.to_string()),
+        }
+    }
+}
+
 #[expect(clippy::arithmetic_side_effects)]
 pub(crate) fn remove_subject_prefix(last_subject: &str) -> String {
    let subject_start = if last_subject.starts_with("Chat:") {
@@ -276,14 +276,14 @@ impl ConfiguredLoginParam {
            .await
    }

-    /// Loads legacy configured param. Only used for tests and the migration.
+    /// Loads legacy configured param. Only used for tests and migration 131.
    pub(crate) async fn load_legacy(context: &Context) -> Result<Option<Self>> {
        if !context.get_config_bool(Config::Configured).await? {
            return Ok(None);
        }

        let addr = context
-            .get_config(Config::ConfiguredAddr)
+            .get_config_opt(Config::ConfiguredAddr)
            .await?
            .unwrap_or_default()
            .trim()
@@ -625,7 +625,7 @@ pub(crate) async fn sync_transports(
        )
        .collect();

-    let (deleted_ids, reelected) = context
+    let deleted_ids = context
        .sql
        .transaction(|transaction| {
            let mut deleted_ids = Vec::new();
@@ -638,8 +638,7 @@ pub(crate) async fn sync_transports(
            }
            modified |= !deleted_ids.is_empty();

-            let reelected = maybe_update_sending_transport(transaction)?;
-            Ok((deleted_ids, reelected))
+            Ok(deleted_ids)
        })
        .await?;

@@ -647,12 +646,6 @@ pub(crate) async fn sync_transports(
        purge_transport_caches(context, *transport_id).await;
    }

-    if let Some(new_addr) = reelected {
-        info!(context, "Re-elected sending transport {new_addr:?}.");
-        context.sql.uncache_raw_config("configured_addr").await;
-        modified = true;
-    }
-
    if modified {
        context.self_public_key.lock().await.take();
        context
@@ -711,31 +704,6 @@ pub(crate) async fn purge_transport_caches(context: &Context, transport_id: u32)
    context.metadata.write().await.remove(&transport_id);
 }

-/// Elects another transport for sending if the current one vanished.
-/// Any remaining transport works and selection is anyway moving
-/// to the authority of the SMTP loop, see <https://github.com/chatmail/core/pull/8619>
-pub(crate) fn maybe_update_sending_transport(
-    transaction: &mut rusqlite::Transaction,
-) -> Result<Option<String>> {
-    let configured_addr: String = transaction.query_row(
-        "SELECT value FROM config WHERE keyname='configured_addr'",
-        (),
-        |row| row.get(0),
-    )?;
-    let addrs = transport_addrs(transaction)?;
-    if addrs.contains(&configured_addr) {
-        return Ok(None);
-    }
-    let Some(new_addr) = addrs.into_iter().next() else {
-        return Ok(None);
-    };
-    transaction.execute(
-        "UPDATE config SET value=? WHERE keyname='configured_addr'",
-        (&new_addr,),
-    )?;
-    Ok(Some(new_addr))
-}
-
 /// Adds transport entry to the `transports` table with empty configuration.
 pub async fn add_pseudo_transport(context: &Context, addr: &str) -> Result<()> {
    context.sql
@@ -226,50 +226,6 @@ async fn test_delete_transport() -> Result<()> {
    Ok(())
 }

-/// Tests that selecting sending transport by setting "configured_addr" does not
-/// send the sync message, is not synchronized between devices even if sync message is forced,
-/// and does not bump sending transport `add_timestamp`.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_no_configured_addr_synchronization() -> Result<()> {
-    let mut tcm = TestContextManager::new();
-    let alice = &tcm.alice().await;
-    let alice2 = &tcm.alice().await;
-    for a in [alice, alice2] {
-        a.set_config_bool(Config::SyncMsgs, true).await?;
-        a.set_config_bool(Config::BccSelf, true).await?;
-    }
-
-    let addr = "alice@otherprovider.com";
-    add_dummy_transport(alice, addr).await?;
-    send_sync_transports(alice).await?;
-    sync_and_check_recipients(alice, alice2, &format!("{addr} alice@example.org")).await;
-
-    // Selects `addr` on `alice` as the sending transport
-    // and syncs the transport update to `alice2`,
-    // whose own sending transport must stay unchanged.
-    let old_timestamp = add_timestamp(alice2, addr).await;
-    let alice2_primary = alice2.get_config(Config::ConfiguredAddr).await?;
-    alice.set_config(Config::ConfiguredAddr, Some(addr)).await?;
-    assert_eq!(add_timestamp(alice, addr).await, old_timestamp);
-
-    send_sync_transports(alice).await?;
-    alice.send_sync_msg().await?.unwrap();
-    let sync_msg = alice.pop_sent_msg().await;
-    assert_eq!(sync_msg.recipients, format!("alice@example.org {addr}"));
-    // The sync message comes from the new sending address,
-    // which must not make `alice2` adopt it as its own sending address.
-    assert!(sync_msg.payload.contains(&format!("From: <{addr}>")));
-    alice2.recv_msg_trash(&sync_msg).await;
-
-    // add_timestamp must not change.
-    assert_eq!(add_timestamp(alice2, addr).await, old_timestamp);
-    assert_eq!(
-        alice2.get_config(Config::ConfiguredAddr).await?,
-        alice2_primary
-    );
-    Ok(())
-}
-
 /// Tests that `sync_transports()` requests an IO restart
 /// if and only if it modified anything.
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
@@ -288,14 +244,6 @@ async fn test_sync_transports_requests_io_restart() -> Result<()> {
    Ok(())
 }

-async fn add_timestamp(t: &TestContext, addr: &str) -> i64 {
-    t.sql
-        .query_get_value("SELECT add_timestamp FROM transports WHERE addr=?", (addr,))
-        .await
-        .unwrap()
-        .unwrap()
-}
-
 /// Tests that removing the last transport keeps it.
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_removing_last_transport() -> Result<()> {
@@ -326,33 +274,6 @@ async fn test_removing_last_transport() -> Result<()> {
    Ok(())
 }

-/// Tests which transport is elected for sending.
-#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
-async fn test_maybe_update_sending_transport() -> Result<()> {
-    let t = &TestContext::new_alice().await;
-
-    add_dummy_transport(t, "alice@one.com").await?;
-    assert_eq!(
-        t.sql.transaction(maybe_update_sending_transport).await?,
-        None
-    );
-
-    t.sql
-        .execute(
-            "DELETE FROM transports WHERE addr=?",
-            ("alice@example.org",),
-        )
-        .await?;
-    assert_eq!(
-        t.sql
-            .transaction(maybe_update_sending_transport)
-            .await?
-            .as_deref(),
-        Some("alice@one.com")
-    );
-    Ok(())
-}
-
 /// Tests that a transport an older core unpublished is removed.
 #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
 async fn test_sync_unpublished_transport_removes_it() -> Result<()> {
@@ -2,4 +2,5 @@ OutBroadcast#Chat#1001: My Channel [1 member(s)]🔇 Icon: e9b6c7a78aa2e4f415644
 --------------------------------------------------------------------------------
 Msg#1001: info (Contact#Contact#Info): Messages are end-to-end encrypted. [NOTICED][INFO]
 Msg#1002🔒: Me (Contact#Contact#Self): Channel image changed. [INFO] √
+Msg#1005🔒: Me (Contact#Contact#Self): Member bob@example.net added. [INFO] √
 --------------------------------------------------------------------------------
@@ -1,6 +1,7 @@
 OutBroadcast#Chat#1001: Channel [0 member(s)]🔇
 --------------------------------------------------------------------------------
 Msg#1001: info (Contact#Contact#Info): Messages are end-to-end encrypted. [NOTICED][INFO]
+Msg#1006🔒: Me (Contact#Contact#Self): Member bob@example.net added. [INFO] √
 Msg#1009🔒: Me (Contact#Contact#Self): hi  √
 Msg#1010🔒: Me (Contact#Contact#Self): You removed member bob@example.net. [INFO] √
 --------------------------------------------------------------------------------
@@ -1,6 +1,7 @@
 OutBroadcast#Chat#1001: Channel [0 member(s)]🔇
 --------------------------------------------------------------------------------
 Msg#1002: info (Contact#Contact#Info): Messages are end-to-end encrypted. [NOTICED][INFO]
+Msg#1006🔒: Me (Contact#Contact#Self): Member bob@example.net added. [INFO] √
 Msg#1009🔒: Me (Contact#Contact#Self): hi  √
 Msg#1010🔒: Me (Contact#Contact#Self): You removed member bob@example.net. [INFO] √
 --------------------------------------------------------------------------------
@@ -1 +1 @@
 -09-22
 -09-11