style: format everything
Guess we haven't run cargo fmt over the whole thing ina while!
249 unmodified linesExpand all250251252253254254255256257258259260539 unmodified linesExpand all249 unmodified linesExpand all let cfg = tranquil_config::get();
let mut state = match cfg.storage.repo_backend() { tranquil_config::RepoBackend::TranquilStore => { tracing::info!("tranquil-store repo backend active. Thank you so much for believing in us!"); tracing::info!( "tranquil-store repo backend active. Thank you so much for believing in us!" ); Self::from_store(shutdown).await } tranquil_config::RepoBackend::Postgres => { let database_url = &cfg.database.url;539 unmodified linesExpand all1212345678638 unmodified linesExpand alluse base64::{Engine as _, engine::general_purpose::URL_SAFE_NO_PAD};use chrono::Utc;use crate::common::{base_url, client, create_account_and_login, pds_endpoint};use crate::helpers::verify_new_account;use base64::{Engine as _, engine::general_purpose::URL_SAFE_NO_PAD};use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};use sha2::{Digest, Sha256};use wiremock::matchers::{method, path};638 unmodified linesExpand all1123456401 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};
async fn create_verified_account(401 unmodified linesExpand all12334567774 unmodified linesExpand alluse crate::common::*;use base64::Engine;use base64::engine::general_purpose::URL_SAFE_NO_PAD;use crate::common::*;use k256::ecdsa::{SigningKey, signature::Signer};use reqwest::StatusCode;use serde_json::{Value, json};use wiremock::matchers::{method, path};774 unmodified linesExpand all12334567176 unmodified linesExpand alluse crate::common::*;use base64::Engine;use base64::engine::general_purpose::URL_SAFE_NO_PAD;use crate::common::*;use reqwest::StatusCode;use serde_json::{Value, json};use std::sync::{Arc, Mutex};use wiremock::matchers::{method, path};176 unmodified linesExpand all112345678413 unmodified linesExpand alluse cid::Cid;use crate::common::*;use crate::firehose::FirehoseConsumer;use crate::helpers::build_car_with_signature;use cid::Cid;use iroh_car::CarReader;use k256::ecdsa::SigningKey;use multihash::Multihash;use reqwest::StatusCode;413 unmodified linesExpand all1123456973 unmodified linesExpand alluse cid::Cid;use crate::common::*;use cid::Cid;use futures::{SinkExt, stream::StreamExt};use iroh_car::CarReader;use reqwest::StatusCode;use serde::{Deserialize, Serialize};973 unmodified linesExpand all11234567235 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use crate::helpers::*;use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};use tranquil_types::{Did, Nsid, Rkey};
235 unmodified linesExpand all1123456168 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};
fn run_compaction(168 unmodified linesExpand all11234567929 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use crate::helpers::*;use chrono::Utc;use reqwest::{StatusCode, header};use serde_json::{Value, json};use std::time::Duration;
929 unmodified linesExpand all11234567760 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use crate::helpers::*;use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};
#[tokio::test]760 unmodified linesExpand all11234567258 unmodified linesExpand alluse chrono::Utc;use crate::common::*;use crate::helpers::*;use chrono::Utc;use reqwest::StatusCode;use serde_json::{Value, json};
#[tokio::test]258 unmodified linesExpand all2 unmodified lines3456787891011121314458 unmodified linesExpand all2 unmodified linesuse std::str::FromStr;use std::sync::Arc;use std::time::Duration;
use bytes::Bytes;use cid::Cid;use crate::common::*;use crate::firehose::{FirehoseConsumer, ParsedCommitFrame};use bytes::Bytes;use cid::Cid;use iroh_car::CarReader;use jacquard_common::smol_str::SmolStr;use jacquard_repo::commit::Commit;use jacquard_repo::mst::{Mst, VerifiedWriteOp};458 unmodified linesExpand all123455678910111112131415684 unmodified linesExpand alluse std::collections::BTreeMap;use std::str::FromStr;use std::sync::Arc;
use cid::Cid;use crate::common::*;use crate::mst_verify::{extract_event_blocks, inline_to_store};use cid::Cid;use jacquard_common::smol_str::SmolStr;use jacquard_repo::commit::Commit;use jacquard_repo::mst::{Mst, VerifiedWriteOp};use jacquard_repo::storage::{BlockStore, MemoryBlockStore};use crate::mst_verify::{extract_event_blocks, inline_to_store};use reqwest::StatusCode;use serde_json::{Value, json};use tranquil_db_traits::{RepoEventType, SequenceNumber, SequencedEvent};use tranquil_types::Did;684 unmodified linesExpand all