Skip to content

Commit ecb6dce

Browse files
codabrinkcodabrink
committed
remove events
1 parent df88739 commit ecb6dce

File tree

31 files changed

+8
-1145
lines changed

31 files changed

+8
-1145
lines changed

‎bindings_ffi/benches/create_client.rs‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ fn create_ffi_client(c: &mut Criterion) {
7474
None,
7575
None,
7676
None,
77-
None,
7877
)
7978
.instrument(span)
8079
.await

‎bindings_ffi/src/mls.rs‎

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ use xmtp_mls::mls_common::group::GroupMetadataOptions;
7575
use xmtp_mls::mls_common::group_metadata::GroupMetadata;
7676
use xmtp_mls::mls_common::group_mutable_metadata::MessageDisappearingSettings;
7777
use xmtp_mls::mls_common::group_mutable_metadata::MetadataField;
78-
use xmtp_mls::utils::events::upload_debug_archive;
7978
use xmtp_mls::verified_key_package_v2::{VerifiedKeyPackageV2, VerifiedLifetime};
8079
use xmtp_mls::{
8180
client::Client as MlsClient,
@@ -285,7 +284,6 @@ pub async fn create_client(
285284
device_sync_server_url: Option<String>,
286285
device_sync_mode: Option<FfiSyncWorkerMode>,
287286
allow_offline: Option<bool>,
288-
disable_events: Option<bool>,
289287
fork_recovery_opts: Option<FfiForkRecoveryOpts>,
290288
) -> Result<Arc<FfiXmtpClient>, GenericError> {
291289
let ident = account_identifier.clone();
@@ -338,7 +336,6 @@ pub async fn create_client(
338336
.enable_api_debug_wrapper()?
339337
.with_remote_verifier()?
340338
.with_allow_offline(allow_offline)
341-
.with_disable_events(disable_events)
342339
.store(store);
343340

344341
if let Some(sync_worker_mode) = device_sync_mode {
@@ -966,12 +963,6 @@ impl FfiXmtpClient {
966963
.map_err(DeviceSyncError::Archive)?;
967964
Ok(importer.metadata.into())
968965
}
969-
970-
/// Export an encrypted debug archive to a device sync server to inspect telemetry for debugging purposes.
971-
pub async fn upload_debug_archive(&self, server_url: String) -> Result<String, GenericError> {
972-
let db = self.inner_client.context.db();
973-
Ok(upload_debug_archive(db, Some(server_url)).await?)
974-
}
975966
}
976967

977968
fn check_key(mut key: Vec<u8>) -> Result<Vec<u8>, GenericError> {

‎bindings_ffi/src/mls/test_utils.rs‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,6 @@ where
196196
Some(builder.sync_mode.into()),
197197
None,
198198
None,
199-
None,
200199
)
201200
.await
202201
.unwrap();

‎bindings_ffi/src/mls/tests/client.rs‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ async fn test_create_client_with_storage() {
2424
None,
2525
None,
2626
None,
27-
None,
2827
)
2928
.await
3029
.unwrap();
@@ -46,7 +45,6 @@ async fn test_create_client_with_storage() {
4645
None,
4746
None,
4847
None,
49-
None,
5048
)
5149
.await
5250
.unwrap();
@@ -84,7 +82,6 @@ async fn test_create_client_with_key() {
8482
None,
8583
None,
8684
None,
87-
None,
8885
)
8986
.await
9087
.unwrap();
@@ -107,7 +104,6 @@ async fn test_create_client_with_key() {
107104
None,
108105
None,
109106
None,
110-
None,
111107
)
112108
.await
113109
.is_err();
@@ -140,7 +136,6 @@ async fn test_can_message() {
140136
None,
141137
None,
142138
None,
143-
None,
144139
)
145140
.await
146141
.unwrap();
@@ -183,7 +178,6 @@ async fn test_can_message() {
183178
None,
184179
None,
185180
None,
186-
None,
187181
)
188182
.await
189183
.unwrap();

‎bindings_ffi/src/mls/tests/identity.rs‎

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,6 @@ async fn test_can_add_wallet_to_inbox() {
3838
None,
3939
None,
4040
None,
41-
None,
4241
)
4342
.await
4443
.unwrap();
@@ -136,7 +135,6 @@ async fn test_can_revoke_wallet() {
136135
None,
137136
None,
138137
None,
139-
None,
140138
)
141139
.await
142140
.unwrap();
@@ -231,7 +229,6 @@ async fn test_invalid_external_signature() {
231229
None,
232230
None,
233231
None,
234-
None,
235232
)
236233
.await
237234
.unwrap();
@@ -422,7 +419,6 @@ async fn test_can_not_create_new_inbox_id_with_already_associated_wallet() {
422419
None,
423420
None,
424421
None,
425-
None,
426422
)
427423
.await
428424
.unwrap();
@@ -464,7 +460,6 @@ async fn test_can_not_create_new_inbox_id_with_already_associated_wallet() {
464460
None,
465461
None,
466462
None,
467-
None,
468463
)
469464
.await
470465
.unwrap();
@@ -550,7 +545,6 @@ async fn test_can_not_create_new_inbox_id_with_already_associated_wallet() {
550545
None,
551546
None,
552547
None,
553-
None,
554548
)
555549
.await;
556550

@@ -587,7 +581,6 @@ async fn test_wallet_b_cannot_create_new_client_for_inbox_b_after_association()
587581
None,
588582
None,
589583
None,
590-
None,
591584
)
592585
.await
593586
.unwrap();
@@ -612,7 +605,6 @@ async fn test_wallet_b_cannot_create_new_client_for_inbox_b_after_association()
612605
None,
613606
None,
614607
None,
615-
None,
616608
)
617609
.await
618610
.unwrap();
@@ -634,7 +626,6 @@ async fn test_wallet_b_cannot_create_new_client_for_inbox_b_after_association()
634626
None,
635627
None,
636628
None,
637-
None,
638629
)
639630
.await
640631
.unwrap();
@@ -667,7 +658,6 @@ async fn test_wallet_b_cannot_create_new_client_for_inbox_b_after_association()
667658
None,
668659
None,
669660
None,
670-
None,
671661
)
672662
.await;
673663

@@ -784,7 +774,6 @@ async fn test_sorts_members_by_created_at_using_ffi_identifiers() {
784774
None,
785775
None,
786776
None,
787-
None,
788777
)
789778
.await
790779
.unwrap();

‎bindings_ffi/src/mls/tests/mod.rs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -310,7 +310,6 @@ pub(crate) async fn new_test_client_with_wallet_and_history_sync_url(
310310
sync_worker_mode,
311311
None,
312312
None,
313-
None,
314313
)
315314
.await
316315
.unwrap();
@@ -345,7 +344,6 @@ pub(crate) async fn new_test_client_no_panic(
345344
None,
346345
None,
347346
None,
348-
None,
349347
)
350348
.await?;
351349

‎bindings_ffi/src/mls/tests/networking.rs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ async fn create_client_does_not_hit_network() {
8282
None,
8383
None,
8484
None,
85-
None,
8685
)
8786
.await
8887
.unwrap();
@@ -124,7 +123,6 @@ async fn create_client_does_not_hit_network() {
124123
None,
125124
Some(true),
126125
None,
127-
None,
128126
)
129127
.await
130128
.unwrap();

‎bindings_node/src/client.rs‎

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ use xmtp_mls::builder::SyncWorkerMode as XmtpSyncWorkerMode;
1717
use xmtp_mls::cursor_store::SqliteCursorStore;
1818
use xmtp_mls::groups::MlsGroup;
1919
use xmtp_mls::identity::IdentityStrategy;
20-
use xmtp_mls::utils::events::upload_debug_archive;
2120
use xmtp_proto::api_client::AggregateStats;
2221

2322
mod gateway_auth;
@@ -174,7 +173,6 @@ pub async fn create_client(
174173
device_sync_worker_mode: Option<SyncWorkerMode>,
175174
log_options: Option<LogOptions>,
176175
allow_offline: Option<bool>,
177-
disable_events: Option<bool>,
178176
app_version: Option<String>,
179177
nonce: Option<BigInt>,
180178
auth_callback: Option<&gateway_auth::FfiAuthCallback>,
@@ -250,7 +248,6 @@ pub async fn create_client(
250248
.with_remote_verifier()
251249
.map_err(ErrorWrapper::from)?
252250
.with_allow_offline(allow_offline)
253-
.with_disable_events(disable_events)
254251
.store(store);
255252

256253
if let Some(u) = device_sync_server_url {
@@ -432,16 +429,6 @@ impl Client {
432429
self.inner_client.clear_stats()
433430
}
434431

435-
#[napi]
436-
pub async fn upload_debug_archive(&self, server_url: String) -> Result<String> {
437-
let db = self.inner_client().context.db();
438-
Ok(
439-
upload_debug_archive(db, Some(server_url))
440-
.await
441-
.map_err(ErrorWrapper::from)?,
442-
)
443-
}
444-
445432
#[napi]
446433
pub fn delete_message(&self, message_id: Uint8Array) -> Result<u32> {
447434
let deleted_count = self

‎bindings_node/src/test_utils.rs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ pub async fn create_local_toxic_client(
2727
device_sync_worker_mode: Option<SyncWorkerMode>,
2828
log_options: Option<LogOptions>,
2929
allow_offline: Option<bool>,
30-
disable_events: Option<bool>,
3130
) -> Result<TestClient, napi::Error> {
3231
let api_addr = GrpcUrlsToxic::NODE.to_string();
3332
let proxy = ToxicNodeGoClient::proxies().await;
@@ -44,7 +43,6 @@ pub async fn create_local_toxic_client(
4443
device_sync_worker_mode,
4544
log_options,
4645
allow_offline,
47-
disable_events,
4846
None,
4947
None,
5048
None,

‎xmtp_archive/src/export_stream/event_save.rs‎

Lines changed: 0 additions & 39 deletions
This file was deleted.

0 commit comments

Comments
 (0)