use super::protocol::build_protocol_subscription_filters;
use super::*;
const TEST_PROTOCOL_ENGINE_STATE_KEY: &str = "appcore/protocol-engine-state-v1";
const TEST_DEVICE_APPROVAL_REQUEST_SECRET: &str = "AQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQE";
fn seed_protocol_storage_for_test(
storage: &dyn StorageAdapter,
seed_session_manager: SessionManagerSnapshot,
seed_group_manager: GroupManagerSnapshot,
) -> anyhow::Result<()> {
let verified_app_keys_owners = seed_session_manager
.verified_peer_app_keys_events
.iter()
.map(|event| ndr_owner_pubkey(event.pubkey))
.collect::<std::collections::BTreeSet<_>>();
let state = serde_json::json!({
"version": 1,
"session_manager": seed_session_manager,
"group_manager": seed_group_manager,
"verified_app_keys_owners": verified_app_keys_owners,
"app_keys_provenance_version": 1,
"invite_owner_app_keys_evidence": {},
"pending_outbound": [],
"pending_inbound": [],
"pending_group_fanouts": [],
"pending_group_pairwise_payloads": [],
"pending_group_sender_key_messages": [],
"pending_group_sender_key_repairs": [],
"pending_decrypted_deliveries": [],
"subscription_generation": 0,
});
storage.put(TEST_PROTOCOL_ENGINE_STATE_KEY, state.to_string())?;
Ok(())
}
fn seed_protocol_storage_if_missing_for_test(
storage: &dyn StorageAdapter,
seed_session_manager: SessionManagerSnapshot,
seed_group_manager: GroupManagerSnapshot,
) -> anyhow::Result<()> {
if storage.get(TEST_PROTOCOL_ENGINE_STATE_KEY)?.is_none() {
seed_protocol_storage_for_test(storage, seed_session_manager, seed_group_manager)?;
}
Ok(())
}
fn protocol_publish_events(effects: &[ProtocolEffect]) -> Vec<&Event> {
effects
.iter()
.map(|effect| match effect {
ProtocolEffect::Publish(publish) => &publish.event,
})
.collect()
}
fn protocol_publish_events_with_kind(effects: &[ProtocolEffect], kind: u32) -> Vec<Event> {
effects
.iter()
.filter_map(|effect| match effect {
ProtocolEffect::Publish(publish) if publish.event.kind.as_u16() as u32 == kind => {
Some(publish.event.clone())
}
_ => None,
})
.collect()
}
fn protocol_publish_events_for_target(
effects: &[ProtocolEffect],
_owner_pubkey_hex: &str,
_device_id: &str,
) -> Vec<Event> {
effects
.iter()
.filter_map(|effect| match effect {
ProtocolEffect::Publish(publish)
if publish.event.kind.as_u16() as u32 == MESSAGE_EVENT_KIND =>
{
Some(publish.event.clone())
}
_ => None,
})
.collect()
}
fn protocol_has_publish_target(
effects: &[ProtocolEffect],
_owner_pubkey_hex: &str,
_device_id: &str,
) -> bool {
effects.iter().any(|effect| {
matches!(
effect,
ProtocolEffect::Publish(publish)
if publish.event.kind.as_u16() as u32 == MESSAGE_EVENT_KIND
)
})
}
fn protocol_targeted_payload_count(effects: &[ProtocolEffect], _owner_pubkey_hex: &str) -> usize {
effects
.iter()
.filter(|effect| {
matches!(
effect,
ProtocolEffect::Publish(publish)
if publish.event.kind.as_u16() as u32 == MESSAGE_EVENT_KIND
)
})
.count()
}
include!("tests/protocol_runtime.rs");
include!("tests/forwarding.rs");
include!("tests/protocol_runtime_direct_queue.rs");
include!("tests/send_display.rs");
include!("tests/attachment_completion.rs");
include!("tests/receipt_batch_latency.rs");
include!("tests/registration_recovery.rs");
include!("tests/device_roster_fetch.rs");
include!("tests/device_connections.rs");
include!("tests/protocol_startup_guards.rs");
include!("tests/profile_metadata_restart.rs");
include!("tests/protocol_runtime_replay.rs");
include!("tests/protocol_idle_replay.rs");
include!("tests/pending_publish_replay.rs");
include!("tests/metadata_privacy.rs");
include!("tests/retry_publish_ordering.rs");
include!("tests/nearby_publish_burst.rs");
include!("tests/publish_drain_progress.rs");
include!("tests/protocol_filters_push.rs");
include!("tests/protocol_discovery_demand.rs");
include!("tests/invite_notifications.rs");
include!("tests/device_approval.rs");
include!("tests/app_keys_roster.rs");
include!("tests/app_keys_device_labels.rs");
include!("tests/app_keys_publishing.rs");
include!("tests/app_keys_invites_requests.rs");
include!("tests/direct_message_request_acceptance.rs");
include!("tests/explicit_direct_invite_acceptance.rs");
include!("tests/pending_device_link.rs");
include!("tests/signer_login.rs");
include!("tests/signer_login_lookup.rs");
include!("tests/remote_signer_fixture.rs");
include!("tests/remote_signer.rs");
include!("tests/device_link_signer.rs");
include!("tests/private_invite_owner_verification.rs");
include!("tests/private_invite_owner_crash.rs");
include!("tests/handshake_owner_proof.rs");
include!("tests/first_contact_receiver.rs");
include!("tests/direct_messages_group_requests.rs");
include!("tests/direct_messages_blocking.rs");
include!("tests/block_preserves_history.rs");
include!("tests/private_block_sync.rs");
include!("tests/private_block_ingress.rs");
include!("tests/private_block_outbox.rs");
include!("tests/private_block_carriers.rs");
include!("tests/private_block_push_atomic.rs");
include!("tests/private_block_controls.rs");
include!("tests/direct_chat_capability.rs");
include!("tests/direct_messages_typing.rs");
include!("tests/chat_page_order.rs");
include!("tests/open_chat_finalize.rs");
include!("tests/direct_messages_runtime_regressions.rs");
include!("tests/direct_group_sender_key_ack.rs");
include!("tests/groups_sender_key.rs");
include!("tests/groups_sender_key_continuation.rs");
include!("tests/group_reactions.rs");
include!("tests/groups_mutation_delivery.rs");
include!("tests/group_message_ids.rs");
include!("tests/groups_sender_key_retry.rs");
include!("tests/protocol_ready_retry.rs");
include!("tests/groups_scale.rs");
include!("tests/private_group_wake.rs");
include!("tests/groups_message_expiration.rs");
include!("tests/groups_persistence_helpers.rs");
include!("tests/groups_persistence_more.rs");
include!("tests/message_expiry.rs");
include!("tests/group_removal.rs");
include!("tests/device_sync_helpers.rs");
include!("tests/device_sync.rs");
include!("tests/device_sync_authorization.rs");
include!("tests/device_sync_history.rs");
include!("tests/device_sync_history_restart.rs");
include!("tests/device_sync_records.rs");
include!("tests/device_sync_mutation_privacy.rs");
include!("tests/chat_read_sync.rs");
include!("tests/chat_read_negentropy.rs");
include!("tests/recipient_receipt_sync.rs");
include!("tests/mobile_push_read_sync.rs");
include!("tests/mobile_push_controls.rs");
include!("tests/chat_read_receipts.rs");
include!("tests/chat_deletion_sync.rs");
include!("tests/local_message_deletion.rs");
include!("tests/mesh_chat.rs");
include!("tests/mesh_group_replay.rs");
include!("tests/image_proxy_preferences.rs");
include!("tests/calls.rs");
include!("tests/call_wake_v2.rs");
include!("tests/call_quality.rs");
include!("tests/call_history_multi_device.rs");
include!("tests/direct_files.rs");
include!("tests/contact_details.rs");
include!("tests/private_contacts.rs");
include!("tests/private_contact_migration.rs");
include!("tests/private_control_interop.rs");
include!("tests/timed_mute.rs");
include!("tests/contact_identity.rs");
include!("tests/public_follow.rs");
include!("tests/synthetic_history_scale.rs");
include!("tests/synthetic_vm_profile.rs");
include!("tests/populated_discovery_idle.rs");
include!("tests/foreground_discovery.rs");
include!("tests/synthetic_protocol_checkpoint.rs");
include!("tests/populated_retry_idle.rs");
include!("tests/message_mutations.rs");
include!("tests/message_mutation_live_privacy.rs");
include!("tests/message_mutation_cleanup.rs");
include!("tests/private_settings.rs");
include!("tests/request_acceptance_sync.rs");
include!("tests/mentions.rs");
include!("tests/nhash_previews.rs");
include!("tests/issued_invites.rs");
include!("tests/full_invites.rs");
include!("tests/fips_provider_privacy.rs");
include!("tests/startup_restore.rs");