1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197
// Wire
// Copyright (C) 2022 Wire Swiss GmbH
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program. If not, see http://www.gnu.org/licenses/.
//! Core Crypto is a wrapper on top of OpenMLS aimed to provide an ergonomic API for usage in web
//! through Web Assembly and in mobile devices through FFI.
//!
//! The goal is provide a easier and less verbose API to create, manage and interact with MLS
//! groups.
#![doc = include_str!("../../README.md")]
#![deny(missing_docs)]
#![allow(clippy::single_component_path_imports)]
use async_lock::Mutex;
#[cfg(test)]
pub use core_crypto_attributes::{dispotent, durable, idempotent};
use std::sync::Arc;
pub use self::error::*;
#[cfg(test)]
#[macro_use]
pub mod test_utils;
// both imports above have to be defined at the beginning of the crate for rstest to work
mod error;
/// MLS Abstraction
pub mod mls;
/// re-export [rusty-jwt-tools](https://github.com/wireapp/rusty-jwt-tools) API
pub mod e2e_identity;
#[cfg(feature = "proteus")]
/// Proteus Abstraction
pub mod proteus;
pub mod context;
mod group_store;
mod obfuscate;
mod build_metadata;
pub use build_metadata::{BuildMetadata, BUILD_METADATA};
/// Common imports that should be useful for most uses of the crate
pub mod prelude {
pub use openmls::{
group::{MlsGroup, MlsGroupConfig},
prelude::{
group_info::VerifiableGroupInfo, Ciphersuite as CiphersuiteName, Credential, GroupEpoch, KeyPackage,
KeyPackageIn, KeyPackageRef, MlsMessageIn, Node,
},
};
pub use mls_crypto_provider::{EntropySeed, MlsCryptoProvider, RawEntropySeed};
pub use crate::{
e2e_identity::{
conversation_state::E2eiConversationState,
device_status::DeviceStatus,
error::{E2eIdentityError, E2eIdentityResult},
identity::{WireIdentity, X509Identity},
rotate::MlsRotateBundle,
types::{E2eiAcmeChallenge, E2eiAcmeDirectory, E2eiNewAcmeAuthz, E2eiNewAcmeOrder},
E2eiEnrollment,
},
error::{CryptoError, CryptoResult, CryptoboxMigrationError, MlsError, ProteusError},
mls::{
ciphersuite::MlsCiphersuite,
client::id::ClientId,
client::identifier::ClientIdentifier,
client::key_package::INITIAL_KEYING_MATERIAL_COUNT,
client::*,
config::MlsCentralConfiguration,
conversation::{
commit::{MlsCommitBundle, MlsConversationCreationMessage},
config::{MlsConversationConfiguration, MlsCustomConfiguration, MlsWirePolicy},
decrypt::{self, MlsBufferedConversationDecryptMessage, MlsConversationDecryptMessage},
group_info::{GroupInfoPayload, MlsGroupInfoBundle, MlsGroupInfoEncryptionType, MlsRatchetTreeType},
proposal::MlsProposalBundle,
welcome::WelcomeBundle,
ConversationId, MlsConversation,
},
credential::{typ::MlsCredentialType, x509::CertificateBundle},
external_commit::MlsConversationInitBundle,
proposal::{MlsProposal, MlsProposalRef},
MlsCentral,
},
CoreCrypto, CoreCryptoCallbacks,
};
}
/// Client callbacks in order to Core Crypto to verify user authorization
///
/// This trait is used to provide callback mechanisms for the MlsCentral struct, for example for
/// operations like adding or removing memebers that can be authorized through a caller provided
/// authorization method.
#[cfg_attr(target_family = "wasm", async_trait::async_trait(?Send))]
#[cfg_attr(not(target_family = "wasm"), async_trait::async_trait)]
pub trait CoreCryptoCallbacks: std::fmt::Debug + Send + Sync {
/// Function responsible for authorizing an operation.
/// Returns `true` if the operation is authorized.
///
/// # Arguments
/// * `conversation_id` - id of the group/conversation
/// * `client_id` - id of the client to authorize
async fn authorize(&self, conversation_id: prelude::ConversationId, client_id: prelude::ClientId) -> bool;
/// Function responsible for authorizing an operation for a given user.
/// Use `external_client_id` & `existing_clients` to get all the 'client_id' belonging to the same user
/// as `external_client_id`. Then, given those client ids, verify that at least one has the right role
/// (is authorized) exactly like it's done in [Self::authorize]
/// Returns `true` if the operation is authorized.
///
/// # Arguments
/// * `conversation_id` - id of the group/conversation
/// * `external_client_id` - id a client external to the MLS group
/// * `existing_clients` - all the clients in the MLS group
async fn user_authorize(
&self,
conversation_id: prelude::ConversationId,
external_client_id: prelude::ClientId,
existing_clients: Vec<prelude::ClientId>,
) -> bool;
/// Validates if the given `client_id` belongs to one of the provided `existing_clients`
/// This basically allows to defer the client ID parsing logic to the caller - because CoreCrypto is oblivious to such things
///
/// # Arguments
/// * `conversation_id` - ID of the conversation
/// * `client_id` - client ID of the client referenced within the sent proposal
/// * `existing_clients` - all the clients in the MLS group
async fn client_is_existing_group_user(
&self,
conversation_id: prelude::ConversationId,
client_id: prelude::ClientId,
existing_clients: Vec<prelude::ClientId>,
parent_conversation_clients: Option<Vec<prelude::ClientId>>,
) -> bool;
}
#[derive(Debug)]
/// Wrapper superstruct for both [mls::MlsCentral] and [proteus::ProteusCentral]
///
/// As [std::ops::Deref] is implemented, this struct is automatically dereferred to [mls::MlsCentral] apart from `proteus_*` calls
pub struct CoreCrypto {
mls: mls::MlsCentral,
#[cfg(feature = "proteus")]
proteus: Arc<Mutex<Option<proteus::ProteusCentral>>>,
#[cfg(not(feature = "proteus"))]
#[allow(dead_code)]
proteus: (),
}
impl From<mls::MlsCentral> for CoreCrypto {
fn from(mls: mls::MlsCentral) -> Self {
Self {
mls,
proteus: Default::default(),
}
}
}
impl std::ops::Deref for CoreCrypto {
type Target = mls::MlsCentral;
fn deref(&self) -> &Self::Target {
&self.mls
}
}
impl std::ops::DerefMut for CoreCrypto {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.mls
}
}
impl CoreCrypto {
/// Allows to extract the MLS Client from the wrapper superstruct
#[inline]
pub fn take(self) -> mls::MlsCentral {
self.mls
}
}
#[cfg(feature = "uniffi")]
uniffi::setup_scaffolding!("core_crypto");